X-Git-Url: http://www.aleph1.co.uk/gitweb/?p=yaffs2.git;a=blobdiff_plain;f=yaffs_guts.c;h=2443c78b00df2051328573ed77baca0a48a660be;hp=9f6b40964b5e85d154294fef73af38b544634cd8;hb=refs%2Fheads%2Fclean-up;hpb=a78bce6f4a7042fa153ab32d2bb263ecf7d27b66 diff --git a/yaffs_guts.c b/yaffs_guts.c index 9f6b409..2443c78 100644 --- a/yaffs_guts.c +++ b/yaffs_guts.c @@ -34,12 +34,14 @@ #define YAFFS_GC_GOOD_ENOUGH 2 #define YAFFS_GC_PASSIVE_THRESHOLD 4 +#define YAFFS_MAX_CACHE_USAGE 100000000 + #include "yaffs_ecc.h" /* Forward declarations */ static int yaffs_wr_data_obj(struct yaffs_obj *in, int inode_chunk, - const u8 *buffer, int n_bytes, int use_reserve); + const u8 *buffer, u32 n_bytes, int use_reserve); static void yaffs_fix_null_name(struct yaffs_obj *obj, YCHAR *name, int buffer_size); @@ -47,9 +49,9 @@ static void yaffs_fix_null_name(struct yaffs_obj *obj, YCHAR *name, /* Function to calculate chunk and offset */ void yaffs_addr_to_chunk(struct yaffs_dev *dev, loff_t addr, - int *chunk_out, u32 *offset_out) + u32 *chunk_out, u32 *offset_out) { - int chunk; + u32 chunk; u32 offset; chunk = (u32) (addr >> dev->chunk_shift); @@ -78,7 +80,7 @@ void yaffs_addr_to_chunk(struct yaffs_dev *dev, loff_t addr, * be hellishly efficient. */ -static inline u32 calc_shifts_ceiling(u32 x) +static inline u32 yaffs_calc_shifts_ceiling(u32 x) { int extra_bits; int shifts; @@ -211,11 +213,18 @@ static void yaffs_handle_chunk_update(struct yaffs_dev *dev, int nand_chunk, } void yaffs_handle_chunk_error(struct yaffs_dev *dev, - struct yaffs_block_info *bi) + struct yaffs_block_info *bi, + enum yaffs_ecc_result err_type) { - if (!bi->gc_prioritise) { - bi->gc_prioritise = 1; - dev->has_pending_prioritised_gc = 1; + if (bi->gc_prioritise) + return; + + /* We need to refresh this data by gc'ing the block soon. */ + bi->gc_prioritise = 1; + dev->has_pending_prioritised_gc = 1; + + /* If it was more than just refresh request then consider retirement. */ + if (err_type > YAFFS_ECC_RESULT_REFRESH) { bi->chunk_error_strikes++; if (bi->chunk_error_strikes > 3) { @@ -227,13 +236,13 @@ void yaffs_handle_chunk_error(struct yaffs_dev *dev, } } -static void yaffs_handle_chunk_wr_error(struct yaffs_dev *dev, int nand_chunk, +static void yaffs_handle_chunk_wr_error(struct yaffs_dev *dev, u32 nand_chunk, int erased_ok) { - int flash_block = nand_chunk / dev->param.chunks_per_block; + u32 flash_block = nand_chunk / dev->param.chunks_per_block; struct yaffs_block_info *bi = yaffs_get_block_info(dev, flash_block); - yaffs_handle_chunk_error(dev, bi); + yaffs_handle_chunk_error(dev, bi, YAFFS_ECC_RESULT_FIXED); if (erased_ok) { /* Was an actual write failure, @@ -298,9 +307,8 @@ static int yaffs_check_chunk_erased(struct yaffs_dev *dev, int nand_chunk) int retval = YAFFS_OK; u8 *data = yaffs_get_temp_buffer(dev); struct yaffs_ext_tags tags; - int result; - result = yaffs_rd_chunk_tags_nand(dev, nand_chunk, data, &tags); + yaffs_rd_chunk_tags_nand(dev, nand_chunk, data, &tags); if (tags.ecc_result > YAFFS_ECC_RESULT_NO_ERROR) retval = YAFFS_FAIL; @@ -326,9 +334,8 @@ static int yaffs_verify_chunk_written(struct yaffs_dev *dev, int retval = YAFFS_OK; struct yaffs_ext_tags temp_tags; u8 *buffer = yaffs_get_temp_buffer(dev); - int result; - result = yaffs_rd_chunk_tags_nand(dev, nand_chunk, buffer, &temp_tags); + yaffs_rd_chunk_tags_nand(dev, nand_chunk, buffer, &temp_tags); if (memcmp(buffer, data, dev->data_bytes_per_chunk) || temp_tags.obj_id != tags->obj_id || temp_tags.chunk_id != tags->chunk_id || @@ -357,7 +364,7 @@ int yaffs_check_alloc_available(struct yaffs_dev *dev, int n_chunks) static int yaffs_find_alloc_block(struct yaffs_dev *dev) { - int i; + u32 i; struct yaffs_block_info *bi; if (dev->n_erased_blocks < 1) { @@ -418,7 +425,7 @@ static int yaffs_alloc_chunk(struct yaffs_dev *dev, int use_reserver, return -1; } - if (dev->n_erased_blocks < dev->param.n_reserved_blocks + if (dev->n_erased_blocks < (int)dev->param.n_reserved_blocks && dev->alloc_page == 0) yaffs_trace(YAFFS_TRACE_ALLOCATE, "Allocating reserve"); @@ -436,7 +443,7 @@ static int yaffs_alloc_chunk(struct yaffs_dev *dev, int use_reserver, dev->n_free_chunks--; /* If the block is full set the state to full */ - if (dev->alloc_page >= dev->param.chunks_per_block) { + if (dev->alloc_page >= (int)dev->param.chunks_per_block) { bi->block_state = YAFFS_BLOCK_STATE_FULL; dev->alloc_block = -1; } @@ -631,6 +638,78 @@ static void yaffs_retire_block(struct yaffs_dev *dev, int flash_block) /*---------------- Name handling functions ------------*/ +static void yaffs_load_name_from_oh(struct yaffs_dev *dev, YCHAR *name, + const YCHAR *oh_name, int buff_size) +{ +#ifdef CONFIG_YAFFS_AUTO_UNICODE + if (dev->param.auto_unicode) { + if (*oh_name) { + /* It is an ASCII name, do an ASCII to + * unicode conversion */ + const char *ascii_oh_name = (const char *)oh_name; + int n = buff_size - 1; + while (n > 0 && *ascii_oh_name) { + *name = *ascii_oh_name; + name++; + ascii_oh_name++; + n--; + } + } else { + strncpy(name, oh_name + 1, buff_size - 1); + } + } else { +#else + (void) dev; + { +#endif + strncpy(name, oh_name, buff_size - 1); + } +} + +static void yaffs_load_oh_from_name(struct yaffs_dev *dev, YCHAR *oh_name, + const YCHAR *name) +{ +#ifdef CONFIG_YAFFS_AUTO_UNICODE + + int is_ascii; + const YCHAR *w; + + if (dev->param.auto_unicode) { + + is_ascii = 1; + w = name; + + /* Figure out if the name will fit in ascii character set */ + while (is_ascii && *w) { + if ((*w) & 0xff00) + is_ascii = 0; + w++; + } + + if (is_ascii) { + /* It is an ASCII name, so convert unicode to ascii */ + char *ascii_oh_name = (char *)oh_name; + int n = YAFFS_MAX_NAME_LENGTH - 1; + while (n > 0 && *name) { + *ascii_oh_name = (char)*name; + name++; + ascii_oh_name++; + n--; + } + } else { + /* Unicode name, so save starting at the second YCHAR */ + *oh_name = 0; + strncpy(oh_name + 1, name, YAFFS_MAX_NAME_LENGTH - 2); + } + } else { +#else + dev = dev; + { +#endif + strncpy(oh_name, name, YAFFS_MAX_NAME_LENGTH - 1); + } +} + static u16 yaffs_calc_name_sum(const YCHAR *name) { u16 sum = 0; @@ -792,7 +871,7 @@ u32 yaffs_get_group_base(struct yaffs_dev *dev, struct yaffs_tnode *tn, * in the tree. 0 means only the level 0 tnode is in the tree. */ -/* FindLevel0Tnode finds the level 0 tnode, if one exists. */ +/* yaffs_find_tnode_0 finds the level 0 tnode, if one exists. */ struct yaffs_tnode *yaffs_find_tnode_0(struct yaffs_dev *dev, struct yaffs_file_var *file_struct, u32 chunk_id) @@ -943,8 +1022,8 @@ struct yaffs_tnode *yaffs_add_find_tnode_0(struct yaffs_dev *dev, return tn; } -static int yaffs_tags_match(const struct yaffs_ext_tags *tags, int obj_id, - int chunk_obj) +static int yaffs_tags_match(const struct yaffs_ext_tags *tags, u32 obj_id, + u32 chunk_obj) { return (tags->chunk_id == chunk_obj && tags->obj_id == obj_id && @@ -952,11 +1031,11 @@ static int yaffs_tags_match(const struct yaffs_ext_tags *tags, int obj_id, } -static int yaffs_find_chunk_in_group(struct yaffs_dev *dev, int the_chunk, - struct yaffs_ext_tags *tags, int obj_id, - int inode_chunk) +static int yaffs_find_chunk_in_group(struct yaffs_dev *dev, u32 the_chunk, + struct yaffs_ext_tags *tags, u32 obj_id, + u32 inode_chunk) { - int j; + u32 j; for (j = 0; the_chunk && j < dev->chunk_grp_size; j++) { if (yaffs_check_chunk_bit @@ -980,7 +1059,7 @@ static int yaffs_find_chunk_in_group(struct yaffs_dev *dev, int the_chunk, return -1; } -static int yaffs_find_chunk_in_file(struct yaffs_obj *in, int inode_chunk, +int yaffs_find_chunk_in_file(struct yaffs_obj *in, int inode_chunk, struct yaffs_ext_tags *tags) { /*Get the Tnode, then get the level 0 offset chunk offset */ @@ -1377,56 +1456,49 @@ static int yaffs_obj_cache_dirty(struct yaffs_obj *obj) return 0; } -static void yaffs_flush_file_cache(struct yaffs_obj *obj) +static void yaffs_flush_single_cache(struct yaffs_cache *cache, int discard) +{ + + if (!cache || cache->locked) + return; + + /* Write it out and free it up if need be.*/ + if (cache->dirty) { + yaffs_wr_data_obj(cache->object, + cache->chunk_id, + cache->data, + cache->n_bytes, + 1); + + cache->dirty = 0; + } + + if (discard) + cache->object = NULL; +} + +static void yaffs_flush_file_cache(struct yaffs_obj *obj, int discard) { struct yaffs_dev *dev = obj->my_dev; - int lowest = -99; /* Stop compiler whining. */ int i; struct yaffs_cache *cache; - int chunk_written = 0; int n_caches = obj->my_dev->param.n_caches; if (n_caches < 1) return; - do { - cache = NULL; - - /* Find the lowest dirty chunk for this object */ - for (i = 0; i < n_caches; i++) { - if (dev->cache[i].object == obj && - dev->cache[i].dirty) { - if (!cache || - dev->cache[i].chunk_id < lowest) { - cache = &dev->cache[i]; - lowest = cache->chunk_id; - } - } - } - if (cache && !cache->locked) { - /* Write it out and free it up */ - chunk_written = - yaffs_wr_data_obj(cache->object, - cache->chunk_id, - cache->data, - cache->n_bytes, 1); - cache->dirty = 0; - cache->object = NULL; - } - } while (cache && chunk_written > 0); - if (cache) - /* Hoosterman, disk full while writing cache out. */ - yaffs_trace(YAFFS_TRACE_ERROR, - "yaffs tragedy: no space during cache write"); + /* Find the chunks for this object and flush them. */ + for (i = 0; i < n_caches; i++) { + cache = &dev->cache[i]; + if (cache->object == obj) + yaffs_flush_single_cache(cache, discard); + } + } -/*yaffs_flush_whole_cache(dev) - * - * - */ -void yaffs_flush_whole_cache(struct yaffs_dev *dev) +void yaffs_flush_whole_cache(struct yaffs_dev *dev, int discard) { struct yaffs_obj *obj; int n_caches = dev->param.n_caches; @@ -1442,19 +1514,19 @@ void yaffs_flush_whole_cache(struct yaffs_dev *dev) obj = dev->cache[i].object; } if (obj) - yaffs_flush_file_cache(obj); + yaffs_flush_file_cache(obj, discard); } while (obj); } -/* Grab us a cache chunk for use. +/* Grab us an unused cache chunk for use. * First look for an empty one. * Then look for the least recently used non-dirty one. * Then look for the least recently used dirty one...., flush and look again. */ static struct yaffs_cache *yaffs_grab_chunk_worker(struct yaffs_dev *dev) { - int i; + u32 i; if (dev->param.n_caches > 0) { for (i = 0; i < dev->param.n_caches; i++) { @@ -1462,56 +1534,50 @@ static struct yaffs_cache *yaffs_grab_chunk_worker(struct yaffs_dev *dev) return &dev->cache[i]; } } + return NULL; } static struct yaffs_cache *yaffs_grab_chunk_cache(struct yaffs_dev *dev) { struct yaffs_cache *cache; - struct yaffs_obj *the_obj; - int usage; - int i; - int pushout; + u32 usage; + u32 i; if (dev->param.n_caches < 1) return NULL; - /* Try find a non-dirty one... */ + /* First look for an unused cache */ cache = yaffs_grab_chunk_worker(dev); - if (!cache) { - /* They were all dirty, find the LRU object and flush - * its cache, then find again. - * NB what's here is not very accurate, - * we actually flush the object with the LRU chunk. - */ + if (cache) + return cache; - /* With locking we can't assume we can use entry zero, - * Set the_obj to a valid pointer for Coverity. */ - the_obj = dev->cache[0].object; - usage = -1; - cache = NULL; - pushout = -1; + /* + * Thery were all in use. + * Find the LRU cache and flush it if it is dirty. + */ - for (i = 0; i < dev->param.n_caches; i++) { - if (dev->cache[i].object && - !dev->cache[i].locked && - (dev->cache[i].last_use < usage || - !cache)) { + usage = YAFFS_MAX_CACHE_USAGE + 100; /* Silly high number */ + cache = NULL; + + for (i = 0; i < dev->param.n_caches; i++) { + if (dev->cache[i].object && + !dev->cache[i].locked && + (dev->cache[i].last_use < usage || !cache)) { usage = dev->cache[i].last_use; - the_obj = dev->cache[i].object; cache = &dev->cache[i]; - pushout = i; - } - } - - if (!cache || cache->dirty) { - /* Flush and try again */ - yaffs_flush_file_cache(the_obj); - cache = yaffs_grab_chunk_worker(dev); } } + +#if 1 + yaffs_flush_single_cache(cache, 1); +#else + yaffs_flush_file_cache(cache->object, 1); + cache = yaffs_grab_chunk_worker(dev); +#endif + return cache; } @@ -1520,7 +1586,7 @@ static struct yaffs_cache *yaffs_find_chunk_cache(const struct yaffs_obj *obj, int chunk_id) { struct yaffs_dev *dev = obj->my_dev; - int i; + u32 i; if (dev->param.n_caches < 1) return NULL; @@ -1540,13 +1606,12 @@ static struct yaffs_cache *yaffs_find_chunk_cache(const struct yaffs_obj *obj, static void yaffs_use_cache(struct yaffs_dev *dev, struct yaffs_cache *cache, int is_write) { - int i; - if (dev->param.n_caches < 1) return; - if (dev->cache_last_use < 0 || - dev->cache_last_use > 100000000) { + if (dev->cache_last_use > YAFFS_MAX_CACHE_USAGE) { + u32 i; + /* Reset the cache usages */ for (i = 1; i < dev->param.n_caches; i++) dev->cache[i].last_use = 0; @@ -1581,7 +1646,7 @@ static void yaffs_invalidate_chunk_cache(struct yaffs_obj *object, int chunk_id) */ static void yaffs_invalidate_whole_cache(struct yaffs_obj *in) { - int i; + u32 i; struct yaffs_dev *dev = in->my_dev; if (dev->param.n_caches > 0) { @@ -2302,12 +2367,11 @@ alloc_error: return YAFFS_FAIL; } - -void yaffs_block_became_dirty(struct yaffs_dev *dev, int block_no) +void yaffs_block_became_dirty(struct yaffs_dev *dev, u32 block_no) { struct yaffs_block_info *bi = yaffs_get_block_info(dev, block_no); int erased_ok = 0; - int i; + u32 i; /* If the block is still healthy erase it and mark as clean. * If the block has had a data failure, then retire it. @@ -2530,7 +2594,7 @@ static int yaffs_gc_block(struct yaffs_dev *dev, int block, int whole_block) { int old_chunk; int ret_val = YAFFS_OK; - int i; + u32 i; int is_checkpt_block; int max_copies; int chunks_before = yaffs_get_erased_chunks(dev); @@ -2635,13 +2699,13 @@ static int yaffs_gc_block(struct yaffs_dev *dev, int block, int whole_block) static unsigned yaffs_find_gc_block(struct yaffs_dev *dev, int aggressive, int background) { - int i; - int iterations; + u32 i; + u32 iterations; unsigned selected = 0; int prioritised = 0; int prioritised_exist = 0; struct yaffs_block_info *bi; - int threshold; + u32 threshold; /* First let's see if we need to grab a prioritised block */ if (dev->has_pending_prioritised_gc && !aggressive) { @@ -2682,14 +2746,14 @@ static unsigned yaffs_find_gc_block(struct yaffs_dev *dev, */ if (!selected) { - int pages_used; - int n_blocks = + u32 pages_used; + u32 n_blocks = dev->internal_end_block - dev->internal_start_block + 1; if (aggressive) { threshold = dev->param.chunks_per_block; iterations = n_blocks; } else { - int max_threshold; + u32 max_threshold; if (background) max_threshold = dev->param.chunks_per_block / 2; @@ -2745,7 +2809,7 @@ static unsigned yaffs_find_gc_block(struct yaffs_dev *dev, */ if (!selected && dev->param.is_yaffs2 && - dev->gc_not_done >= (background ? 10 : 20)) { + dev->gc_not_done >= (unsigned)(background ? 10 : 20)) { yaffs2_find_oldest_dirty_seq(dev); if (dev->oldest_dirty_block > 0) { selected = dev->oldest_dirty_block; @@ -2875,14 +2939,14 @@ static int yaffs_check_gc(struct yaffs_dev *dev, int background) gc_ok = yaffs_gc_block(dev, dev->gc_block, aggressive); } - if (dev->n_erased_blocks < (dev->param.n_reserved_blocks) && + if (dev->n_erased_blocks < (int)dev->param.n_reserved_blocks && dev->gc_block > 0) { yaffs_trace(YAFFS_TRACE_GC, "yaffs: GC !!!no reclaim!!! n_erased_blocks %d after try %d block %d", dev->n_erased_blocks, max_tries, dev->gc_block); } - } while ((dev->n_erased_blocks < dev->param.n_reserved_blocks) && + } while ((dev->n_erased_blocks < (int)dev->param.n_reserved_blocks) && (dev->gc_block > 0) && (max_tries < 2)); return aggressive ? gc_ok : YAFFS_OK; @@ -2982,7 +3046,7 @@ void yaffs_chunk_del(struct yaffs_dev *dev, int chunk_id, int mark_flash, } static int yaffs_wr_data_obj(struct yaffs_obj *in, int inode_chunk, - const u8 *buffer, int n_bytes, int use_reserve) + const u8 *buffer, u32 n_bytes, int use_reserve) { /* Find old chunk Need to do this to get serial number * Write new one and patch into tree. @@ -3017,7 +3081,7 @@ static int yaffs_wr_data_obj(struct yaffs_obj *in, int inode_chunk, if (n_bytes < 1 || n_bytes > dev->param.total_bytes_per_chunk) { yaffs_trace(YAFFS_TRACE_ERROR, - "Writing %d bytes to chunk!!!!!!!!!", + "Writing %u bytes to chunk!!!!!!!!!", n_bytes); BUG(); } @@ -3163,8 +3227,6 @@ static void yaffs_check_obj_details_loaded(struct yaffs_obj *in) struct yaffs_obj_hdr *oh; struct yaffs_dev *dev; struct yaffs_ext_tags tags; - int result; - int alloc_failed = 0; if (!in || !in->lazy_loaded || in->hdr_chunk < 1) return; @@ -3173,7 +3235,7 @@ static void yaffs_check_obj_details_loaded(struct yaffs_obj *in) in->lazy_loaded = 0; buf = yaffs_get_temp_buffer(dev); - result = yaffs_rd_chunk_tags_nand(dev, in->hdr_chunk, buf, &tags); + yaffs_rd_chunk_tags_nand(dev, in->hdr_chunk, buf, &tags); oh = (struct yaffs_obj_hdr *)buf; in->yst_mode = oh->yst_mode; @@ -3183,84 +3245,10 @@ static void yaffs_check_obj_details_loaded(struct yaffs_obj *in) if (in->variant_type == YAFFS_OBJECT_TYPE_SYMLINK) { in->variant.symlink_variant.alias = yaffs_clone_str(oh->alias); - if (!in->variant.symlink_variant.alias) - alloc_failed = 1; /* Not returned */ } yaffs_release_temp_buffer(dev, buf); } -static void yaffs_load_name_from_oh(struct yaffs_dev *dev, YCHAR *name, - const YCHAR *oh_name, int buff_size) -{ -#ifdef CONFIG_YAFFS_AUTO_UNICODE - if (dev->param.auto_unicode) { - if (*oh_name) { - /* It is an ASCII name, do an ASCII to - * unicode conversion */ - const char *ascii_oh_name = (const char *)oh_name; - int n = buff_size - 1; - while (n > 0 && *ascii_oh_name) { - *name = *ascii_oh_name; - name++; - ascii_oh_name++; - n--; - } - } else { - strncpy(name, oh_name + 1, buff_size - 1); - } - } else { -#else - (void) dev; - { -#endif - strncpy(name, oh_name, buff_size - 1); - } -} - -static void yaffs_load_oh_from_name(struct yaffs_dev *dev, YCHAR *oh_name, - const YCHAR *name) -{ -#ifdef CONFIG_YAFFS_AUTO_UNICODE - - int is_ascii; - YCHAR *w; - - if (dev->param.auto_unicode) { - - is_ascii = 1; - w = name; - - /* Figure out if the name will fit in ascii character set */ - while (is_ascii && *w) { - if ((*w) & 0xff00) - is_ascii = 0; - w++; - } - - if (is_ascii) { - /* It is an ASCII name, so convert unicode to ascii */ - char *ascii_oh_name = (char *)oh_name; - int n = YAFFS_MAX_NAME_LENGTH - 1; - while (n > 0 && *name) { - *ascii_oh_name = *name; - name++; - ascii_oh_name++; - n--; - } - } else { - /* Unicode name, so save starting at the second YCHAR */ - *oh_name = 0; - strncpy(oh_name + 1, name, YAFFS_MAX_NAME_LENGTH - 2); - } - } else { -#else - dev = dev; - { -#endif - strncpy(oh_name, name, YAFFS_MAX_NAME_LENGTH - 1); - } -} - /* UpdateObjectHeader updates the header on NAND for an object. * If name is not NULL, then that new name is used. */ @@ -3272,7 +3260,6 @@ int yaffs_update_oh(struct yaffs_obj *in, const YCHAR *name, int force, struct yaffs_dev *dev = in->my_dev; int prev_chunk_id; int ret_val = 0; - int result = 0; int new_chunk_id; struct yaffs_ext_tags new_tags; struct yaffs_ext_tags old_tags; @@ -3296,7 +3283,7 @@ int yaffs_update_oh(struct yaffs_obj *in, const YCHAR *name, int force, prev_chunk_id = in->hdr_chunk; if (prev_chunk_id > 0) { - result = yaffs_rd_chunk_tags_nand(dev, prev_chunk_id, + yaffs_rd_chunk_tags_nand(dev, prev_chunk_id, buffer, &old_tags); yaffs_verify_oh(in, oh, &old_tags, 0); @@ -3419,13 +3406,13 @@ int yaffs_update_oh(struct yaffs_obj *in, const YCHAR *name, int force, * Curve-balls: the first chunk might also be the last chunk. */ -int yaffs_file_rd(struct yaffs_obj *in, u8 * buffer, loff_t offset, int n_bytes) +int yaffs_file_rd(struct yaffs_obj *in, u8 * buffer, loff_t offset, u32 n_bytes) { - int chunk; + u32 chunk; u32 start; - int n_copy; - int n = n_bytes; - int n_done = 0; + u32 n_copy; + u32 n = n_bytes; + u32 n_done = 0; struct yaffs_cache *cache; struct yaffs_dev *dev; @@ -3495,19 +3482,19 @@ int yaffs_file_rd(struct yaffs_obj *in, u8 * buffer, loff_t offset, int n_bytes) buffer += n_copy; n_done += n_copy; } - return n_done; + return (int)n_done; } int yaffs_do_file_wr(struct yaffs_obj *in, const u8 *buffer, loff_t offset, - int n_bytes, int write_through) + u32 n_bytes, int write_through) { - int chunk; + u32 chunk; u32 start; - int n_copy; - int n = n_bytes; - int n_done = 0; - int n_writeback; + u32 n_copy; + u32 n = n_bytes; + u32 n_done = 0; + u32 n_writeback; loff_t start_write = offset; int chunk_written = 0; u32 n_bytes_read; @@ -3523,8 +3510,8 @@ int yaffs_do_file_wr(struct yaffs_obj *in, const u8 *buffer, loff_t offset, dev->data_bytes_per_chunk + start != offset || start >= dev->data_bytes_per_chunk) { yaffs_trace(YAFFS_TRACE_ERROR, - "AddrToChunk of offset %lld gives chunk %d start %d", - offset, chunk, start); + "addr_to_chunk() of offset %lld gives chunk %u start %u", + (long long int)offset, chunk, start); } chunk++; /* File pos to chunk in file offset */ @@ -3555,11 +3542,10 @@ int yaffs_do_file_wr(struct yaffs_obj *in, const u8 *buffer, loff_t offset, n_bytes_read = dev->data_bytes_per_chunk; n_writeback = - (n_bytes_read > - (start + n)) ? n_bytes_read : (start + n); + (n_bytes_read > (start + n)) ? + n_bytes_read : (start + n); - if (n_writeback < 0 || - n_writeback > dev->data_bytes_per_chunk) + if (n_writeback > dev->data_bytes_per_chunk) BUG(); } else { @@ -3664,7 +3650,7 @@ int yaffs_do_file_wr(struct yaffs_obj *in, const u8 *buffer, loff_t offset, /* Update file object */ - if ((start_write + n_done) > in->variant.file_variant.file_size) + if ((start_write + n_done) > (u32)in->variant.file_variant.file_size) in->variant.file_variant.file_size = (start_write + n_done); in->dirty = 1; @@ -3672,7 +3658,7 @@ int yaffs_do_file_wr(struct yaffs_obj *in, const u8 *buffer, loff_t offset, } int yaffs_wr_file(struct yaffs_obj *in, const u8 *buffer, loff_t offset, - int n_bytes, int write_through) + u32 n_bytes, int write_through) { yaffs2_handle_hole(in, offset); return yaffs_do_file_wr(in, buffer, offset, n_bytes, write_through); @@ -3685,11 +3671,11 @@ static void yaffs_prune_chunks(struct yaffs_obj *in, loff_t new_size) struct yaffs_dev *dev = in->my_dev; loff_t old_size = in->variant.file_variant.file_size; - int i; + u32 i; int chunk_id; u32 dummy; - int last_del; - int start_del; + u32 last_del; + u32 start_del; if (old_size > 0) yaffs_addr_to_chunk(dev, old_size - 1, &last_del, &dummy); @@ -3715,9 +3701,9 @@ static void yaffs_prune_chunks(struct yaffs_obj *in, loff_t new_size) if (chunk_id < 1) continue; - if (chunk_id < + if ((u32)chunk_id < (dev->internal_start_block * dev->param.chunks_per_block) || - chunk_id >= + (u32)chunk_id >= ((dev->internal_end_block + 1) * dev->param.chunks_per_block)) { yaffs_trace(YAFFS_TRACE_ALWAYS, @@ -3732,7 +3718,7 @@ static void yaffs_prune_chunks(struct yaffs_obj *in, loff_t new_size) void yaffs_resize_file_down(struct yaffs_obj *obj, loff_t new_size) { - int new_full; + u32 new_full; u32 new_partial; struct yaffs_dev *dev = obj->my_dev; @@ -3765,7 +3751,7 @@ int yaffs_resize_file(struct yaffs_obj *in, loff_t new_size) struct yaffs_dev *dev = in->my_dev; loff_t old_size = in->variant.file_variant.file_size; - yaffs_flush_file_cache(in); + yaffs_flush_file_cache(in, 1); yaffs_invalidate_whole_cache(in); yaffs_check_gc(dev, 0); @@ -3798,12 +3784,15 @@ int yaffs_resize_file(struct yaffs_obj *in, loff_t new_size) return YAFFS_OK; } -int yaffs_flush_file(struct yaffs_obj *in, int update_time, int data_sync) +int yaffs_flush_file(struct yaffs_obj *in, + int update_time, + int data_sync, + int discard_cache) { if (!in->dirty) return YAFFS_OK; - yaffs_flush_file_cache(in); + yaffs_flush_file_cache(in, discard_cache); if (data_sync) return YAFFS_OK; @@ -3950,6 +3939,70 @@ int yaffs_del_obj(struct yaffs_obj *obj) return ret_val; } + +static void yaffs_empty_dir_to_dir(struct yaffs_obj *from_dir, + struct yaffs_obj *to_dir) +{ + struct yaffs_obj *obj; + struct list_head *lh; + struct list_head *n; + + list_for_each_safe(lh, n, &from_dir->variant.dir_variant.children) { + obj = list_entry(lh, struct yaffs_obj, siblings); + yaffs_add_obj_to_dir(to_dir, obj); + } +} + +struct yaffs_obj *yaffs_retype_obj(struct yaffs_obj *obj, + enum yaffs_obj_type type) +{ + /* Tear down the old variant */ + switch (obj->variant_type) { + case YAFFS_OBJECT_TYPE_FILE: + /* Nuke file data */ + yaffs_resize_file(obj, 0); + yaffs_free_tnode(obj->my_dev, obj->variant.file_variant.top); + obj->variant.file_variant.top = NULL; + break; + case YAFFS_OBJECT_TYPE_DIRECTORY: + /* Put the children in lost and found. */ + yaffs_empty_dir_to_dir(obj, obj->my_dev->lost_n_found); + if (!list_empty(&obj->variant.dir_variant.dirty)) + list_del_init(&obj->variant.dir_variant.dirty); + break; + case YAFFS_OBJECT_TYPE_SYMLINK: + /* Nuke symplink data */ + kfree(obj->variant.symlink_variant.alias); + obj->variant.symlink_variant.alias = NULL; + break; + case YAFFS_OBJECT_TYPE_HARDLINK: + list_del_init(&obj->hard_links); + break; + default: + break; + } + + memset(&obj->variant, 0, sizeof(obj->variant)); + + /*Set up new variant if the memset is not enough. */ + switch (type) { + case YAFFS_OBJECT_TYPE_DIRECTORY: + INIT_LIST_HEAD(&obj->variant.dir_variant.children); + INIT_LIST_HEAD(&obj->variant.dir_variant.dirty); + break; + case YAFFS_OBJECT_TYPE_FILE: + case YAFFS_OBJECT_TYPE_SYMLINK: + case YAFFS_OBJECT_TYPE_HARDLINK: + default: + break; + } + + obj->variant_type = type; + + return obj; + +} + static int yaffs_unlink_worker(struct yaffs_obj *obj) { int del_now = 0; @@ -4125,7 +4178,7 @@ int yaffs_rename_obj(struct yaffs_obj *old_dir, const YCHAR *old_name, /*----------------------- Initialisation Scanning ---------------------- */ -void yaffs_handle_shadowed_obj(struct yaffs_dev *dev, int obj_id, +void yaffs_handle_shadowed_obj(struct yaffs_dev *dev, u32 obj_id, int backward_scanning) { struct yaffs_obj *obj; @@ -4433,18 +4486,17 @@ int yaffs_get_obj_name(struct yaffs_obj *obj, YCHAR *name, int buffer_size) } else if (obj->short_name[0]) { strcpy(name, obj->short_name); } else if (obj->hdr_chunk > 0) { - int result; u8 *buffer = yaffs_get_temp_buffer(obj->my_dev); struct yaffs_obj_hdr *oh = (struct yaffs_obj_hdr *)buffer; memset(buffer, 0, obj->my_dev->data_bytes_per_chunk); - if (obj->hdr_chunk > 0) { - result = yaffs_rd_chunk_tags_nand(obj->my_dev, + if (obj->hdr_chunk > 0) + yaffs_rd_chunk_tags_nand(obj->my_dev, obj->hdr_chunk, buffer, NULL); - } + yaffs_load_name_from_oh(obj->my_dev, name, oh->name, buffer_size); @@ -4593,15 +4645,16 @@ static int yaffs_create_initial_dir(struct yaffs_dev *dev) return YAFFS_FAIL; } -int yaffs_guts_initialise(struct yaffs_dev *dev) +/* Low level init. + * Typically only used by yaffs_guts_initialise, but also used by the + * Low level yaffs driver tests. + */ + +int yaffs_guts_ll_init(struct yaffs_dev *dev) { - int init_failed = 0; - unsigned x; - int bits; - yaffs_trace(YAFFS_TRACE_TRACING, "yaffs: yaffs_guts_initialise()"); - /* Check stuff that must be set */ + yaffs_trace(YAFFS_TRACE_TRACING, "yaffs: yaffs_ll_init()"); if (!dev) { yaffs_trace(YAFFS_TRACE_ALWAYS, @@ -4610,10 +4663,8 @@ int yaffs_guts_initialise(struct yaffs_dev *dev) return YAFFS_FAIL; } - if (dev->is_mounted) { - yaffs_trace(YAFFS_TRACE_ALWAYS, "device already mounted"); - return YAFFS_FAIL; - } + if (dev->ll_init) + return YAFFS_OK; dev->internal_start_block = dev->param.start_block; dev->internal_end_block = dev->param.end_block; @@ -4653,11 +4704,6 @@ int yaffs_guts_initialise(struct yaffs_dev *dev) return YAFFS_FAIL; } - if (yaffs_init_nand(dev) != YAFFS_OK) { - yaffs_trace(YAFFS_TRACE_ALWAYS, "InitialiseNAND failed"); - return YAFFS_FAIL; - } - /* Sort out space for inband tags, if required */ if (dev->param.inband_tags) dev->data_bytes_per_chunk = @@ -4675,7 +4721,50 @@ int yaffs_guts_initialise(struct yaffs_dev *dev) return YAFFS_FAIL; } - /* Finished with most checks. Further checks happen later on too. */ + if (yaffs_init_nand(dev) != YAFFS_OK) { + yaffs_trace(YAFFS_TRACE_ALWAYS, "InitialiseNAND failed"); + return YAFFS_FAIL; + } + + return YAFFS_OK; +} + + +int yaffs_guts_format_dev(struct yaffs_dev *dev) +{ + u32 i; + enum yaffs_block_state state; + u32 dummy; + + if(yaffs_guts_ll_init(dev) != YAFFS_OK) + return YAFFS_FAIL; + + if(dev->is_mounted) + return YAFFS_FAIL; + + for (i = dev->internal_start_block; i <= dev->internal_end_block; i++) { + yaffs_query_init_block_state(dev, i, &state, &dummy); + if (state != YAFFS_BLOCK_STATE_DEAD) + yaffs_erase_block(dev, i); + } + + return YAFFS_OK; +} + + +int yaffs_guts_initialise(struct yaffs_dev *dev) +{ + int init_failed = 0; + unsigned x; + unsigned bits; + + if(yaffs_guts_ll_init(dev) != YAFFS_OK) + return YAFFS_FAIL; + + if (dev->is_mounted) { + yaffs_trace(YAFFS_TRACE_ALWAYS, "device already mounted"); + return YAFFS_FAIL; + } dev->is_mounted = 1; @@ -4699,7 +4788,7 @@ int yaffs_guts_initialise(struct yaffs_dev *dev) x = dev->param.chunks_per_block * (dev->internal_end_block + 1); - bits = calc_shifts_ceiling(x); + bits = yaffs_calc_shifts_ceiling(x); /* Set up tnode width if wide tnodes are enabled. */ if (!dev->param.wide_tnodes_disabled) { @@ -4777,7 +4866,7 @@ int yaffs_guts_initialise(struct yaffs_dev *dev) dev->gc_cleanup_list = NULL; if (!init_failed && dev->param.n_caches > 0) { - int i; + u32 i; void *buf; int cache_bytes = dev->param.n_caches * sizeof(struct yaffs_cache); @@ -4912,7 +5001,7 @@ int yaffs_guts_initialise(struct yaffs_dev *dev) void yaffs_deinitialise(struct yaffs_dev *dev) { if (dev->is_mounted) { - int i; + u32 i; yaffs_deinit_blocks(dev); yaffs_deinit_tnodes_and_objs(dev); @@ -4942,8 +5031,8 @@ void yaffs_deinitialise(struct yaffs_dev *dev) int yaffs_count_free_chunks(struct yaffs_dev *dev) { - int n_free = 0; - int b; + u32 n_free = 0; + u32 b; struct yaffs_block_info *blk; blk = dev->block_info; @@ -4962,7 +5051,7 @@ int yaffs_count_free_chunks(struct yaffs_dev *dev) } blk++; } - return n_free; + return (int)n_free; } int yaffs_get_n_free_chunks(struct yaffs_dev *dev) @@ -4971,7 +5060,7 @@ int yaffs_get_n_free_chunks(struct yaffs_dev *dev) int n_free; int n_dirty_caches; int blocks_for_checkpt; - int i; + u32 i; n_free = dev->n_free_chunks; n_free += dev->n_deleted_files; @@ -5000,40 +5089,6 @@ int yaffs_get_n_free_chunks(struct yaffs_dev *dev) } -int yaffs_format_dev(struct yaffs_dev *dev) -{ - int i; - enum yaffs_block_state state; - u32 dummy; - - if(dev->is_mounted) - return YAFFS_FAIL; - - /* - * The runtime variables might not have been set up, - * so set up what we need. - */ - dev->internal_start_block = dev->param.start_block; - dev->internal_end_block = dev->param.end_block; - dev->block_offset = 0; - dev->chunk_offset = 0; - - if (dev->param.start_block == 0) { - dev->internal_start_block = dev->param.start_block + 1; - dev->internal_end_block = dev->param.end_block + 1; - dev->block_offset = 1; - dev->chunk_offset = dev->param.chunks_per_block; - } - - for (i = dev->internal_start_block; i <= dev->internal_end_block; i++) { - yaffs_query_init_block_state(dev, i, &state, &dummy); - if (state != YAFFS_BLOCK_STATE_DEAD) - yaffs_erase_block(dev, i); - } - - return YAFFS_OK; -} - /* * Marshalling functions to get loff_t file sizes into and out of @@ -5041,19 +5096,45 @@ int yaffs_format_dev(struct yaffs_dev *dev) */ void yaffs_oh_size_load(struct yaffs_obj_hdr *oh, loff_t fsize) { + int shift = 32; + oh->file_size_low = (fsize & 0xFFFFFFFF); - oh->file_size_high = ((fsize >> 32) & 0xFFFFFFFF); + if (sizeof(loff_t) >= 8) + oh->file_size_high = ((fsize >> shift) & 0xFFFFFFFF); + else + oh->file_size_high = 0; } loff_t yaffs_oh_to_size(struct yaffs_obj_hdr *oh) { + int shift = 32; loff_t retval; if (sizeof(loff_t) >= 8 && ~(oh->file_size_high)) - retval = (((loff_t) oh->file_size_high) << 32) | + retval = (((loff_t) oh->file_size_high) << shift) | (((loff_t) oh->file_size_low) & 0xFFFFFFFF); else retval = (loff_t) oh->file_size_low; return retval; } + + +void yaffs_count_blocks_by_state(struct yaffs_dev *dev, int bs[10]) +{ + u32 i; + struct yaffs_block_info *bi; + int s; + + for(i = 0; i < 10; i++) + bs[i] = 0; + + for(i = dev->internal_start_block; i <= dev->internal_end_block; i++) { + bi = yaffs_get_block_info(dev, i); + s = bi->block_state; + if(s > YAFFS_BLOCK_STATE_DEAD || s < YAFFS_BLOCK_STATE_UNKNOWN) + bs[0]++; + else + bs[s]++; + } +}