/* * lookup_table.c * * Lookup table, implemented as a hash table, that maps SHA1 message digests to * data streams; plus code to read and write the corresponding on-disk data. */ /* * Copyright (C) 2012, 2013 Eric Biggers * * This file is part of wimlib, a library for working with WIM files. * * wimlib is free software; you can redistribute it and/or modify it under the * terms of the GNU General Public License as published by the Free * Software Foundation; either version 3 of the License, or (at your option) * any later version. * * wimlib is distributed in the hope that it will be useful, but WITHOUT ANY * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR * A PARTICULAR PURPOSE. See the GNU General Public License for more * details. * * You should have received a copy of the GNU General Public License * along with wimlib; if not, see http://www.gnu.org/licenses/. */ #ifdef HAVE_CONFIG_H # include "config.h" #endif #include "wimlib/endianness.h" #include "wimlib/error.h" #include "wimlib/file_io.h" #include "wimlib/lookup_table.h" #include "wimlib/metadata.h" #include "wimlib/paths.h" #include "wimlib/resource.h" #include "wimlib/util.h" #include "wimlib/write.h" #include #include #ifdef WITH_FUSE # include /* for unlink() */ #endif struct wim_lookup_table * new_lookup_table(size_t capacity) { struct wim_lookup_table *table; struct hlist_head *array; table = CALLOC(1, sizeof(struct wim_lookup_table)); if (table) { array = CALLOC(capacity, sizeof(array[0])); if (array) { table->num_entries = 0; table->capacity = capacity; table->array = array; } else { FREE(table); table = NULL; ERROR("Failed to allocate memory for lookup table " "with capacity %zu", capacity); } } return table; } struct wim_lookup_table_entry * new_lookup_table_entry(void) { struct wim_lookup_table_entry *lte; lte = CALLOC(1, sizeof(struct wim_lookup_table_entry)); if (lte) { lte->part_number = 1; lte->refcnt = 1; } else { ERROR("Out of memory (tried to allocate %zu bytes for " "lookup table entry)", sizeof(struct wim_lookup_table_entry)); } return lte; } struct wim_lookup_table_entry * clone_lookup_table_entry(const struct wim_lookup_table_entry *old) { struct wim_lookup_table_entry *new; new = memdup(old, sizeof(struct wim_lookup_table_entry)); if (!new) return NULL; new->extracted_file = NULL; switch (new->resource_location) { case RESOURCE_IN_FILE_ON_DISK: #ifdef __WIN32__ case RESOURCE_WIN32_ENCRYPTED: #endif #ifdef WITH_FUSE case RESOURCE_IN_STAGING_FILE: BUILD_BUG_ON((void*)&old->file_on_disk != (void*)&old->staging_file_name); #endif new->file_on_disk = TSTRDUP(old->file_on_disk); if (!new->file_on_disk) goto out_free; break; case RESOURCE_IN_ATTACHED_BUFFER: new->attached_buffer = memdup(old->attached_buffer, wim_resource_size(old)); if (!new->attached_buffer) goto out_free; break; #ifdef WITH_NTFS_3G case RESOURCE_IN_NTFS_VOLUME: if (old->ntfs_loc) { struct ntfs_location *loc; loc = memdup(old->ntfs_loc, sizeof(struct ntfs_location)); if (!loc) goto out_free; loc->path = NULL; loc->stream_name = NULL; new->ntfs_loc = loc; loc->path = STRDUP(old->ntfs_loc->path); if (!loc->path) goto out_free; if (loc->stream_name_nchars) { loc->stream_name = memdup(old->ntfs_loc->stream_name, loc->stream_name_nchars * 2); if (!loc->stream_name) goto out_free; } } break; #endif default: break; } return new; out_free: free_lookup_table_entry(new); return NULL; } void free_lookup_table_entry(struct wim_lookup_table_entry *lte) { if (lte) { switch (lte->resource_location) { case RESOURCE_IN_FILE_ON_DISK: #ifdef __WIN32__ case RESOURCE_WIN32_ENCRYPTED: #endif #ifdef WITH_FUSE case RESOURCE_IN_STAGING_FILE: BUILD_BUG_ON((void*)<e->file_on_disk != (void*)<e->staging_file_name); #endif case RESOURCE_IN_ATTACHED_BUFFER: BUILD_BUG_ON((void*)<e->file_on_disk != (void*)<e->attached_buffer); FREE(lte->file_on_disk); break; #ifdef WITH_NTFS_3G case RESOURCE_IN_NTFS_VOLUME: if (lte->ntfs_loc) { FREE(lte->ntfs_loc->path); FREE(lte->ntfs_loc->stream_name); FREE(lte->ntfs_loc); } break; #endif default: break; } FREE(lte); } } static int do_free_lookup_table_entry(struct wim_lookup_table_entry *entry, void *ignore) { free_lookup_table_entry(entry); return 0; } void free_lookup_table(struct wim_lookup_table *table) { DEBUG2("Freeing lookup table"); if (table) { if (table->array) { for_lookup_table_entry(table, do_free_lookup_table_entry, NULL); FREE(table->array); } FREE(table); } } /* * Inserts an entry into the lookup table. * * @table: A pointer to the lookup table. * @lte: A pointer to the entry to insert. */ void lookup_table_insert(struct wim_lookup_table *table, struct wim_lookup_table_entry *lte) { size_t i = lte->hash_short % table->capacity; hlist_add_head(<e->hash_list, &table->array[i]); /* XXX Make the table grow when too many entries have been inserted. */ table->num_entries++; } static void finalize_lte(struct wim_lookup_table_entry *lte) { #ifdef WITH_FUSE if (lte->resource_location == RESOURCE_IN_STAGING_FILE) { unlink(lte->staging_file_name); list_del(<e->unhashed_list); } #endif free_lookup_table_entry(lte); } /* Decrements the reference count for the lookup table entry @lte. If its * reference count reaches 0, it is unlinked from the lookup table. If, * furthermore, the entry has no opened file descriptors associated with it, the * entry is freed. */ void lte_decrement_refcnt(struct wim_lookup_table_entry *lte, struct wim_lookup_table *table) { wimlib_assert(lte != NULL); wimlib_assert(lte->refcnt != 0); if (--lte->refcnt == 0) { if (lte->unhashed) list_del(<e->unhashed_list); else lookup_table_unlink(table, lte); #ifdef WITH_FUSE if (lte->num_opened_fds == 0) #endif finalize_lte(lte); } } #ifdef WITH_FUSE void lte_decrement_num_opened_fds(struct wim_lookup_table_entry *lte) { if (lte->num_opened_fds != 0) if (--lte->num_opened_fds == 0 && lte->refcnt == 0) finalize_lte(lte); } #endif /* Calls a function on all the entries in the WIM lookup table. Stop early and * return nonzero if any call to the function returns nonzero. */ int for_lookup_table_entry(struct wim_lookup_table *table, int (*visitor)(struct wim_lookup_table_entry *, void *), void *arg) { struct wim_lookup_table_entry *lte; struct hlist_node *pos, *tmp; int ret; for (size_t i = 0; i < table->capacity; i++) { hlist_for_each_entry_safe(lte, pos, tmp, &table->array[i], hash_list) { wimlib_assert2(!(lte->resource_entry.flags & WIM_RESHDR_FLAG_METADATA)); ret = visitor(lte, arg); if (ret) return ret; } } return 0; } int cmp_streams_by_wim_position(const void *p1, const void *p2) { const struct wim_lookup_table_entry *lte1, *lte2; lte1 = *(const struct wim_lookup_table_entry**)p1; lte2 = *(const struct wim_lookup_table_entry**)p2; if (lte1->resource_entry.offset < lte2->resource_entry.offset) return -1; else if (lte1->resource_entry.offset > lte2->resource_entry.offset) return 1; else return 0; } static int add_lte_to_array(struct wim_lookup_table_entry *lte, void *_pp) { struct wim_lookup_table_entry ***pp = _pp; *(*pp)++ = lte; return 0; } /* Iterate through the lookup table entries, but first sort them by stream * offset in the WIM. Caution: this is intended to be used when the stream * offset field has actually been set. */ int for_lookup_table_entry_pos_sorted(struct wim_lookup_table *table, int (*visitor)(struct wim_lookup_table_entry *, void *), void *arg) { struct wim_lookup_table_entry **lte_array, **p; size_t num_streams = table->num_entries; int ret; lte_array = MALLOC(num_streams * sizeof(lte_array[0])); if (!lte_array) return WIMLIB_ERR_NOMEM; p = lte_array; for_lookup_table_entry(table, add_lte_to_array, &p); wimlib_assert(p == lte_array + num_streams); qsort(lte_array, num_streams, sizeof(lte_array[0]), cmp_streams_by_wim_position); ret = 0; for (size_t i = 0; i < num_streams; i++) { ret = visitor(lte_array[i], arg); if (ret) break; } FREE(lte_array); return ret; } /* On-disk format of a WIM lookup table entry (stream entry). */ struct wim_lookup_table_entry_disk { /* Location, offset, compression status, and metadata status of the * stream. */ struct resource_entry_disk resource_entry; /* Which part of the split WIM this stream is in; indexed from 1. */ le16 part_number; /* Reference count of this stream over all WIM images. */ le32 refcnt; /* SHA1 message digest of the uncompressed data of this stream, or * optionally all zeroes if this stream is of zero length. */ u8 hash[SHA1_HASH_SIZE]; } _packed_attribute; #define WIM_LOOKUP_TABLE_ENTRY_DISK_SIZE 50 void lte_init_wim(struct wim_lookup_table_entry *lte, WIMStruct *wim) { lte->resource_location = RESOURCE_IN_WIM; lte->wim = wim; if (lte->resource_entry.flags & WIM_RESHDR_FLAG_COMPRESSED) lte->compression_type = wim->compression_type; else lte->compression_type = WIMLIB_COMPRESSION_TYPE_NONE; if (wim_is_pipable(wim)) lte->is_pipable = 1; } /* * Reads the lookup table from a WIM file. * * Saves lookup table entries for non-metadata streams in a hash table, and * saves the metadata entry for each image in a special per-image location (the * image_metadata array). * * Return values: * WIMLIB_ERR_SUCCESS (0) * WIMLIB_ERR_INVALID_LOOKUP_TABLE_ENTRY * WIMLIB_ERR_RESOURCE_NOT_FOUND */ int read_wim_lookup_table(WIMStruct *wim) { int ret; size_t i; size_t num_entries; struct wim_lookup_table *table; struct wim_lookup_table_entry *cur_entry, *duplicate_entry; struct wim_lookup_table_entry_disk *buf; BUILD_BUG_ON(sizeof(struct wim_lookup_table_entry_disk) != WIM_LOOKUP_TABLE_ENTRY_DISK_SIZE); DEBUG("Reading lookup table: offset %"PRIu64", size %"PRIu64"", wim->hdr.lookup_table_res_entry.offset, wim->hdr.lookup_table_res_entry.size); /* Calculate number of entries in the lookup table. */ num_entries = wim->hdr.lookup_table_res_entry.size / sizeof(struct wim_lookup_table_entry_disk); /* Read the lookup table into a buffer. */ ret = res_entry_to_data(&wim->hdr.lookup_table_res_entry, wim, (void**)&buf); if (ret) goto out; /* Allocate hash table. */ table = new_lookup_table(num_entries * 2 + 1); if (!table) { ERROR("Not enough memory to read lookup table."); ret = WIMLIB_ERR_NOMEM; goto out_free_buf; } /* Allocate and initalize `struct wim_lookup_table_entry's from the * on-disk lookup table. */ wim->current_image = 0; for (i = 0; i < num_entries; i++) { const struct wim_lookup_table_entry_disk *disk_entry = &buf[i]; cur_entry = new_lookup_table_entry(); if (!cur_entry) { ERROR("Not enough memory to read lookup table."); ret = WIMLIB_ERR_NOMEM; goto out_free_lookup_table; } cur_entry->wim = wim; cur_entry->resource_location = RESOURCE_IN_WIM; get_resource_entry(&disk_entry->resource_entry, &cur_entry->resource_entry); cur_entry->part_number = le16_to_cpu(disk_entry->part_number); cur_entry->refcnt = le32_to_cpu(disk_entry->refcnt); copy_hash(cur_entry->hash, disk_entry->hash); lte_init_wim(cur_entry, wim); if (cur_entry->part_number != wim->hdr.part_number) { WARNING("A lookup table entry in part %hu of the WIM " "points to part %hu (ignoring it)", wim->hdr.part_number, cur_entry->part_number); free_lookup_table_entry(cur_entry); continue; } if (is_zero_hash(cur_entry->hash)) { WARNING("The WIM lookup table contains an entry with a " "SHA1 message digest of all 0's (ignoring it)"); free_lookup_table_entry(cur_entry); continue; } if (!(cur_entry->resource_entry.flags & WIM_RESHDR_FLAG_COMPRESSED) && (cur_entry->resource_entry.size != cur_entry->resource_entry.original_size)) { if (wimlib_print_errors) { WARNING("Found uncompressed resource with " "original size (%"PRIu64") not the same " "as compressed size (%"PRIu64")", cur_entry->resource_entry.original_size, cur_entry->resource_entry.size); if (cur_entry->resource_entry.original_size) { WARNING("Overriding compressed size with original size."); cur_entry->resource_entry.size = cur_entry->resource_entry.original_size; } else { WARNING("Overriding original size with compressed size"); cur_entry->resource_entry.original_size = cur_entry->resource_entry.size; } } } if (cur_entry->resource_entry.flags & WIM_RESHDR_FLAG_METADATA) { /* Lookup table entry for a metadata resource */ if (cur_entry->refcnt != 1) { if (wimlib_print_errors) { ERROR("Found metadata resource with refcnt != 1:"); print_lookup_table_entry(cur_entry, stderr); } ret = WIMLIB_ERR_INVALID_LOOKUP_TABLE_ENTRY; goto out_free_cur_entry; } if (wim->hdr.part_number != 1) { WARNING("Ignoring metadata resource found in a " "non-first part of the split WIM"); free_lookup_table_entry(cur_entry); continue; } if (wim->current_image == wim->hdr.image_count) { WARNING("The WIM header says there are %u images " "in the WIM, but we found more metadata " "resources than this (ignoring the extra)", wim->hdr.image_count); free_lookup_table_entry(cur_entry); continue; } /* Notice very carefully: We are assigning the metadata * resources in the exact order mirrored by their lookup * table entries on disk, which is the behavior of * Microsoft's software. In particular, this overrides * the actual locations of the metadata resources * themselves in the WIM file as well as any information * written in the XML data. */ DEBUG("Found metadata resource for image %u at " "offset %"PRIu64".", wim->current_image + 1, cur_entry->resource_entry.offset); wim->image_metadata[ wim->current_image++]->metadata_lte = cur_entry; } else { /* Lookup table entry for a stream that is not a * metadata resource */ duplicate_entry = __lookup_resource(table, cur_entry->hash); if (duplicate_entry) { if (wimlib_print_errors) { WARNING("The WIM lookup table contains two entries with the " "same SHA1 message digest!"); WARNING("The first entry is:"); print_lookup_table_entry(duplicate_entry, stderr); WARNING("The second entry is:"); print_lookup_table_entry(cur_entry, stderr); } free_lookup_table_entry(cur_entry); continue; } else { lookup_table_insert(table, cur_entry); } } } if (wim->hdr.part_number == 1 && wim->current_image != wim->hdr.image_count) { WARNING("The header of \"%"TS"\" says there are %u images in\n" " the WIM, but we only found %d metadata resources! Acting as if\n" " the header specified only %d images instead.", wim->filename, wim->hdr.image_count, wim->current_image, wim->current_image); for (int i = wim->current_image; i < wim->hdr.image_count; i++) put_image_metadata(wim->image_metadata[i], NULL); wim->hdr.image_count = wim->current_image; } DEBUG("Done reading lookup table."); wim->lookup_table = table; ret = 0; goto out_free_buf; out_free_cur_entry: FREE(cur_entry); out_free_lookup_table: free_lookup_table(table); out_free_buf: FREE(buf); out: wim->current_image = 0; return ret; } static void write_wim_lookup_table_entry(const struct wim_lookup_table_entry *lte, struct wim_lookup_table_entry_disk *disk_entry) { put_resource_entry(<e->output_resource_entry, &disk_entry->resource_entry); disk_entry->part_number = cpu_to_le16(lte->part_number); disk_entry->refcnt = cpu_to_le32(lte->out_refcnt); copy_hash(disk_entry->hash, lte->hash); } static int write_wim_lookup_table_from_stream_list(struct list_head *stream_list, struct filedes *out_fd, struct resource_entry *out_res_entry, int write_resource_flags) { size_t table_size; struct wim_lookup_table_entry *lte; struct wim_lookup_table_entry_disk *table_buf; struct wim_lookup_table_entry_disk *table_buf_ptr; int ret; table_size = 0; list_for_each_entry(lte, stream_list, lookup_table_list) table_size += sizeof(struct wim_lookup_table_entry_disk); DEBUG("Writing WIM lookup table (size=%zu, offset=%"PRIu64")", table_size, out_fd->offset); table_buf = MALLOC(table_size); if (!table_buf) { ERROR("Failed to allocate %zu bytes for temporary lookup table", table_size); return WIMLIB_ERR_NOMEM; } table_buf_ptr = table_buf; list_for_each_entry(lte, stream_list, lookup_table_list) write_wim_lookup_table_entry(lte, table_buf_ptr++); /* Write the lookup table uncompressed. Although wimlib can handle a * compressed lookup table, MS software cannot. */ ret = write_wim_resource_from_buffer(table_buf, table_size, WIM_RESHDR_FLAG_METADATA, out_fd, WIMLIB_COMPRESSION_TYPE_NONE, out_res_entry, NULL, write_resource_flags); FREE(table_buf); return ret; } static int append_lookup_table_entry(struct wim_lookup_table_entry *lte, void *_list) { if (lte->out_refcnt != 0) list_add_tail(<e->lookup_table_list, (struct list_head*)_list); return 0; } int write_wim_lookup_table(WIMStruct *wim, int image, int write_flags, struct resource_entry *out_res_entry, struct list_head *stream_list_override) { int write_resource_flags; struct list_head _stream_list; struct list_head *stream_list; if (stream_list_override) { stream_list = stream_list_override; } else { stream_list = &_stream_list; INIT_LIST_HEAD(stream_list); } if (!(write_flags & WIMLIB_WRITE_FLAG_NO_METADATA)) { int start_image; int end_image; if (image == WIMLIB_ALL_IMAGES) { start_image = 1; end_image = wim->hdr.image_count; } else { start_image = image; end_image = image; } /* Push metadata resource lookup table entries onto the front of * the list in reverse order, so that they're written in order. */ for (int i = end_image; i >= start_image; i--) { struct wim_lookup_table_entry *metadata_lte; metadata_lte = wim->image_metadata[i - 1]->metadata_lte; metadata_lte->out_refcnt = 1; metadata_lte->part_number = wim->hdr.part_number; metadata_lte->output_resource_entry.flags |= WIM_RESHDR_FLAG_METADATA; list_add(&metadata_lte->lookup_table_list, stream_list); } } /* Append additional lookup table entries that have out_refcnt != 0. */ if (!stream_list_override) { for_lookup_table_entry(wim->lookup_table, append_lookup_table_entry, stream_list); } write_resource_flags = 0; if (write_flags & WIMLIB_WRITE_FLAG_PIPABLE) write_resource_flags |= WIMLIB_WRITE_RESOURCE_FLAG_PIPABLE; return write_wim_lookup_table_from_stream_list(stream_list, &wim->out_fd, out_res_entry, write_resource_flags); } int lte_zero_real_refcnt(struct wim_lookup_table_entry *lte, void *_ignore) { lte->real_refcnt = 0; return 0; } int lte_zero_out_refcnt(struct wim_lookup_table_entry *lte, void *_ignore) { lte->out_refcnt = 0; return 0; } int lte_free_extracted_file(struct wim_lookup_table_entry *lte, void *_ignore) { if (lte->extracted_file != NULL) { FREE(lte->extracted_file); lte->extracted_file = NULL; } return 0; } void print_lookup_table_entry(const struct wim_lookup_table_entry *lte, FILE *out) { if (!lte) { tputc(T('\n'), out); return; } tfprintf(out, T("Offset = %"PRIu64" bytes\n"), lte->resource_entry.offset); tfprintf(out, T("Size = %"PRIu64" bytes\n"), (u64)lte->resource_entry.size); tfprintf(out, T("Original size = %"PRIu64" bytes\n"), lte->resource_entry.original_size); tfprintf(out, T("Part Number = %hu\n"), lte->part_number); tfprintf(out, T("Reference Count = %u\n"), lte->refcnt); if (lte->unhashed) { tfprintf(out, T("(Unhashed: inode %p, stream_id = %u)\n"), lte->back_inode, lte->back_stream_id); } else { tfprintf(out, T("Hash = 0x")); print_hash(lte->hash, out); tputc(T('\n'), out); } tfprintf(out, T("Flags = ")); u8 flags = lte->resource_entry.flags; if (flags & WIM_RESHDR_FLAG_COMPRESSED) tfputs(T("WIM_RESHDR_FLAG_COMPRESSED, "), out); if (flags & WIM_RESHDR_FLAG_FREE) tfputs(T("WIM_RESHDR_FLAG_FREE, "), out); if (flags & WIM_RESHDR_FLAG_METADATA) tfputs(T("WIM_RESHDR_FLAG_METADATA, "), out); if (flags & WIM_RESHDR_FLAG_SPANNED) tfputs(T("WIM_RESHDR_FLAG_SPANNED, "), out); tputc(T('\n'), out); switch (lte->resource_location) { case RESOURCE_IN_WIM: if (lte->wim->filename) { tfprintf(out, T("WIM file = `%"TS"'\n"), lte->wim->filename); } break; #ifdef __WIN32__ case RESOURCE_WIN32_ENCRYPTED: #endif case RESOURCE_IN_FILE_ON_DISK: tfprintf(out, T("File on Disk = `%"TS"'\n"), lte->file_on_disk); break; #ifdef WITH_FUSE case RESOURCE_IN_STAGING_FILE: tfprintf(out, T("Staging File = `%"TS"'\n"), lte->staging_file_name); break; #endif default: break; } tputc(T('\n'), out); } void lte_to_wimlib_resource_entry(const struct wim_lookup_table_entry *lte, struct wimlib_resource_entry *wentry) { wentry->uncompressed_size = lte->resource_entry.original_size; wentry->compressed_size = lte->resource_entry.size; wentry->offset = lte->resource_entry.offset; copy_hash(wentry->sha1_hash, lte->hash); wentry->part_number = lte->part_number; wentry->reference_count = lte->refcnt; wentry->is_compressed = (lte->resource_entry.flags & WIM_RESHDR_FLAG_COMPRESSED) != 0; wentry->is_metadata = (lte->resource_entry.flags & WIM_RESHDR_FLAG_METADATA) != 0; wentry->is_free = (lte->resource_entry.flags & WIM_RESHDR_FLAG_FREE) != 0; wentry->is_spanned = (lte->resource_entry.flags & WIM_RESHDR_FLAG_SPANNED) != 0; } struct iterate_lte_context { wimlib_iterate_lookup_table_callback_t cb; void *user_ctx; }; static int do_iterate_lte(struct wim_lookup_table_entry *lte, void *_ctx) { struct iterate_lte_context *ctx = _ctx; struct wimlib_resource_entry entry; lte_to_wimlib_resource_entry(lte, &entry); return (*ctx->cb)(&entry, ctx->user_ctx); } /* API function documented in wimlib.h */ WIMLIBAPI int wimlib_iterate_lookup_table(WIMStruct *wim, int flags, wimlib_iterate_lookup_table_callback_t cb, void *user_ctx) { struct iterate_lte_context ctx = { .cb = cb, .user_ctx = user_ctx, }; if (wim->hdr.part_number == 1) { int ret; for (int i = 0; i < wim->hdr.image_count; i++) { ret = do_iterate_lte(wim->image_metadata[i]->metadata_lte, &ctx); if (ret) return ret; } } return for_lookup_table_entry(wim->lookup_table, do_iterate_lte, &ctx); } static int do_print_lookup_table_entry(struct wim_lookup_table_entry *lte, void *fp) { print_lookup_table_entry(lte, (FILE*)fp); return 0; } /* API function documented in wimlib.h */ WIMLIBAPI void wimlib_print_lookup_table(WIMStruct *wim) { for (int i = 0; i < wim->hdr.image_count; i++) print_lookup_table_entry(wim->image_metadata[i]->metadata_lte, stdout); for_lookup_table_entry(wim->lookup_table, do_print_lookup_table_entry, stdout); } /* Given a SHA1 message digest, return the corresponding entry in the WIM's * lookup table, or NULL if there is none. */ struct wim_lookup_table_entry * __lookup_resource(const struct wim_lookup_table *table, const u8 hash[]) { size_t i; struct wim_lookup_table_entry *lte; struct hlist_node *pos; wimlib_assert(table != NULL); wimlib_assert(hash != NULL); i = *(size_t*)hash % table->capacity; hlist_for_each_entry(lte, pos, &table->array[i], hash_list) if (hashes_equal(hash, lte->hash)) return lte; return NULL; } #ifdef WITH_FUSE /* * Finds the dentry, lookup table entry, and stream index for a WIM file stream, * given a path name. * * This is only for pre-resolved inodes. */ int lookup_resource(WIMStruct *wim, const tchar *path, int lookup_flags, struct wim_dentry **dentry_ret, struct wim_lookup_table_entry **lte_ret, u16 *stream_idx_ret) { struct wim_dentry *dentry; struct wim_lookup_table_entry *lte; u16 stream_idx; const tchar *stream_name = NULL; struct wim_inode *inode; tchar *p = NULL; if (lookup_flags & LOOKUP_FLAG_ADS_OK) { stream_name = path_stream_name(path); if (stream_name) { p = (tchar*)stream_name - 1; *p = T('\0'); } } dentry = get_dentry(wim, path); if (p) *p = T(':'); if (!dentry) return -errno; inode = dentry->d_inode; if (!inode->i_resolved) if (inode_resolve_ltes(inode, wim->lookup_table, false)) return -EIO; if (!(lookup_flags & LOOKUP_FLAG_DIRECTORY_OK) && inode_is_directory(inode)) return -EISDIR; if (stream_name) { struct wim_ads_entry *ads_entry; u16 ads_idx; ads_entry = inode_get_ads_entry(inode, stream_name, &ads_idx); if (ads_entry) { stream_idx = ads_idx + 1; lte = ads_entry->lte; goto out; } else { return -ENOENT; } } else { lte = inode->i_lte; stream_idx = 0; } out: if (dentry_ret) *dentry_ret = dentry; if (lte_ret) *lte_ret = lte; if (stream_idx_ret) *stream_idx_ret = stream_idx; return 0; } #endif /* * Resolve an inode's lookup table entries. * * This replaces the SHA1 hash fields (which are used to lookup an entry in the * lookup table) with pointers directly to the lookup table entries. * * If @force is %false: * If any needed SHA1 message digests are not found in the lookup table, * WIMLIB_ERR_RESOURCE_NOT_FOUND is returned and the inode is left * unmodified. * If @force is %true: * If any needed SHA1 message digests are not found in the lookup table, * new entries are allocated and inserted into the lookup table. */ int inode_resolve_ltes(struct wim_inode *inode, struct wim_lookup_table *table, bool force) { const u8 *hash; if (!inode->i_resolved) { struct wim_lookup_table_entry *lte, *ads_lte; /* Resolve the default file stream */ lte = NULL; hash = inode->i_hash; if (!is_zero_hash(hash)) { lte = __lookup_resource(table, hash); if (!lte) { if (force) { lte = new_lookup_table_entry(); if (!lte) return WIMLIB_ERR_NOMEM; copy_hash(lte->hash, hash); lookup_table_insert(table, lte); } else { goto resource_not_found; } } } /* Resolve the alternate data streams */ struct wim_lookup_table_entry *ads_ltes[inode->i_num_ads]; for (u16 i = 0; i < inode->i_num_ads; i++) { struct wim_ads_entry *cur_entry; ads_lte = NULL; cur_entry = &inode->i_ads_entries[i]; hash = cur_entry->hash; if (!is_zero_hash(hash)) { ads_lte = __lookup_resource(table, hash); if (!ads_lte) { if (force) { ads_lte = new_lookup_table_entry(); if (!ads_lte) return WIMLIB_ERR_NOMEM; copy_hash(ads_lte->hash, hash); lookup_table_insert(table, ads_lte); } else { goto resource_not_found; } } } ads_ltes[i] = ads_lte; } inode->i_lte = lte; for (u16 i = 0; i < inode->i_num_ads; i++) inode->i_ads_entries[i].lte = ads_ltes[i]; inode->i_resolved = 1; } return 0; resource_not_found: if (wimlib_print_errors) { ERROR("\"%"TS"\": resource not found", inode_first_full_path(inode)); tfprintf(stderr, T(" SHA-1 message digest of missing resource:\n ")); print_hash(hash, stderr); tputc(T('\n'), stderr); } return WIMLIB_ERR_RESOURCE_NOT_FOUND; } void inode_unresolve_ltes(struct wim_inode *inode) { if (inode->i_resolved) { if (inode->i_lte) copy_hash(inode->i_hash, inode->i_lte->hash); else zero_out_hash(inode->i_hash); for (u16 i = 0; i < inode->i_num_ads; i++) { if (inode->i_ads_entries[i].lte) copy_hash(inode->i_ads_entries[i].hash, inode->i_ads_entries[i].lte->hash); else zero_out_hash(inode->i_ads_entries[i].hash); } inode->i_resolved = 0; } } /* * Returns the lookup table entry for stream @stream_idx of the inode, where * stream_idx = 0 means the default un-named file stream, and stream_idx >= 1 * corresponds to an alternate data stream. * * This works for both resolved and un-resolved inodes. */ struct wim_lookup_table_entry * inode_stream_lte(const struct wim_inode *inode, unsigned stream_idx, const struct wim_lookup_table *table) { if (inode->i_resolved) return inode_stream_lte_resolved(inode, stream_idx); else return inode_stream_lte_unresolved(inode, stream_idx, table); } struct wim_lookup_table_entry * inode_unnamed_lte_resolved(const struct wim_inode *inode) { wimlib_assert(inode->i_resolved); for (unsigned i = 0; i <= inode->i_num_ads; i++) { if (inode_stream_name_nbytes(inode, i) == 0 && !is_zero_hash(inode_stream_hash_resolved(inode, i))) { return inode_stream_lte_resolved(inode, i); } } return NULL; } struct wim_lookup_table_entry * inode_unnamed_lte_unresolved(const struct wim_inode *inode, const struct wim_lookup_table *table) { wimlib_assert(!inode->i_resolved); for (unsigned i = 0; i <= inode->i_num_ads; i++) { if (inode_stream_name_nbytes(inode, i) == 0 && !is_zero_hash(inode_stream_hash_unresolved(inode, i))) { return inode_stream_lte_unresolved(inode, i, table); } } return NULL; } /* Return the lookup table entry for the unnamed data stream of an inode, or * NULL if there is none. * * You'd think this would be easier than it actually is, since the unnamed data * stream should be the one referenced from the inode itself. Alas, if there * are named data streams, Microsoft's "imagex.exe" program will put the unnamed * data stream in one of the alternate data streams instead of inside the WIM * dentry itself. So we need to check the alternate data streams too. * * Also, note that a dentry may appear to have more than one unnamed stream, but * if the SHA1 message digest is all 0's then the corresponding stream does not * really "count" (this is the case for the inode's own file stream when the * file stream that should be there is actually in one of the alternate stream * entries.). This is despite the fact that we may need to extract such a * missing entry as an empty file or empty named data stream. */ struct wim_lookup_table_entry * inode_unnamed_lte(const struct wim_inode *inode, const struct wim_lookup_table *table) { if (inode->i_resolved) return inode_unnamed_lte_resolved(inode); else return inode_unnamed_lte_unresolved(inode, table); } static int lte_add_stream_size(struct wim_lookup_table_entry *lte, void *total_bytes_p) { *(u64*)total_bytes_p += lte->resource_entry.size; return 0; } u64 lookup_table_total_stream_size(struct wim_lookup_table *table) { u64 total_size = 0; for_lookup_table_entry(table, lte_add_stream_size, &total_size); return total_size; } struct wim_lookup_table_entry ** retrieve_lte_pointer(struct wim_lookup_table_entry *lte) { wimlib_assert(lte->unhashed); struct wim_inode *inode = lte->back_inode; u32 stream_id = lte->back_stream_id; if (stream_id == 0) return &inode->i_lte; else for (u16 i = 0; i < inode->i_num_ads; i++) if (inode->i_ads_entries[i].stream_id == stream_id) return &inode->i_ads_entries[i].lte; wimlib_assert(0); return NULL; } /* Calculate the SHA1 message digest of a stream and move it from the list of * unhashed streams to the stream lookup table, possibly joining it with an * existing lookup table entry for an identical stream. * * @lte: An unhashed lookup table entry. * @lookup_table: Lookup table for the WIM. * @lte_ret: On success, write a pointer to the resulting lookup table * entry to this location. This will be the same as @lte * if it was inserted into the lookup table, or different if * a duplicate stream was found. * * Returns 0 on success; nonzero if there is an error reading the stream. */ int hash_unhashed_stream(struct wim_lookup_table_entry *lte, struct wim_lookup_table *lookup_table, struct wim_lookup_table_entry **lte_ret) { int ret; struct wim_lookup_table_entry *duplicate_lte; struct wim_lookup_table_entry **back_ptr; wimlib_assert(lte->unhashed); /* back_ptr must be saved because @back_inode and @back_stream_id are in * union with the SHA1 message digest and will no longer be valid once * the SHA1 has been calculated. */ back_ptr = retrieve_lte_pointer(lte); ret = sha1_resource(lte); if (ret) return ret; /* Look for a duplicate stream */ duplicate_lte = __lookup_resource(lookup_table, lte->hash); list_del(<e->unhashed_list); if (duplicate_lte) { /* We have a duplicate stream. Transfer the reference counts * from this stream to the duplicate, update the reference to * this stream (in an inode or ads_entry) to point to the * duplicate, then free this stream. */ wimlib_assert(!(duplicate_lte->unhashed)); duplicate_lte->refcnt += lte->refcnt; duplicate_lte->out_refcnt += lte->refcnt; *back_ptr = duplicate_lte; free_lookup_table_entry(lte); lte = duplicate_lte; } else { /* No duplicate stream, so we need to insert * this stream into the lookup table and treat * it as a hashed stream. */ lookup_table_insert(lookup_table, lte); lte->unhashed = 0; } if (lte_ret) *lte_ret = lte; return 0; }