mirror of
https://github.com/eledio-devices/thirdparty-littlefs.git
synced 2025-11-01 00:38:29 +01:00
Compare commits
2 Commits
v2.4.0
...
test-revam
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
eb08e7fa50 | ||
|
|
1c5bae6d30 |
18
lfs.c
18
lfs.c
@@ -10,6 +10,8 @@
|
|||||||
#define LFS_BLOCK_NULL ((lfs_block_t)-1)
|
#define LFS_BLOCK_NULL ((lfs_block_t)-1)
|
||||||
#define LFS_BLOCK_INLINE ((lfs_block_t)-2)
|
#define LFS_BLOCK_INLINE ((lfs_block_t)-2)
|
||||||
|
|
||||||
|
static void lfs_alloc_ack(lfs_t *lfs);
|
||||||
|
|
||||||
/// Caching block device operations ///
|
/// Caching block device operations ///
|
||||||
static inline void lfs_cache_drop(lfs_t *lfs, lfs_cache_t *rcache) {
|
static inline void lfs_cache_drop(lfs_t *lfs, lfs_cache_t *rcache) {
|
||||||
// do not zero, cheaper if cache is readonly or only going to be
|
// do not zero, cheaper if cache is readonly or only going to be
|
||||||
@@ -24,6 +26,15 @@ static inline void lfs_cache_zero(lfs_t *lfs, lfs_cache_t *pcache) {
|
|||||||
pcache->block = LFS_BLOCK_NULL;
|
pcache->block = LFS_BLOCK_NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Invalidate the lookahead buffer. This is done during mounting and failed traversals ///
|
||||||
|
static inline void lfs_setup_invalid_lookahead_buffer(lfs_t *lfs)
|
||||||
|
{
|
||||||
|
lfs->free.off = lfs->seed % lfs->cfg->block_size;
|
||||||
|
lfs->free.size = 0;
|
||||||
|
lfs->free.i = 0;
|
||||||
|
lfs_alloc_ack(lfs);
|
||||||
|
}
|
||||||
|
|
||||||
static int lfs_bd_read(lfs_t *lfs,
|
static int lfs_bd_read(lfs_t *lfs,
|
||||||
const lfs_cache_t *pcache, lfs_cache_t *rcache, lfs_size_t hint,
|
const lfs_cache_t *pcache, lfs_cache_t *rcache, lfs_size_t hint,
|
||||||
lfs_block_t block, lfs_off_t off,
|
lfs_block_t block, lfs_off_t off,
|
||||||
@@ -477,6 +488,7 @@ static int lfs_alloc(lfs_t *lfs, lfs_block_t *block) {
|
|||||||
memset(lfs->free.buffer, 0, lfs->cfg->lookahead_size);
|
memset(lfs->free.buffer, 0, lfs->cfg->lookahead_size);
|
||||||
int err = lfs_fs_traverseraw(lfs, lfs_alloc_lookahead, lfs, true);
|
int err = lfs_fs_traverseraw(lfs, lfs_alloc_lookahead, lfs, true);
|
||||||
if (err) {
|
if (err) {
|
||||||
|
lfs_setup_invalid_lookahead_buffer(lfs);
|
||||||
return err;
|
return err;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -3772,10 +3784,7 @@ int lfs_mount(lfs_t *lfs, const struct lfs_config *cfg) {
|
|||||||
lfs->gdisk = lfs->gstate;
|
lfs->gdisk = lfs->gstate;
|
||||||
|
|
||||||
// setup free lookahead
|
// setup free lookahead
|
||||||
lfs->free.off = lfs->seed % lfs->cfg->block_size;
|
lfs_setup_invalid_lookahead_buffer(lfs);
|
||||||
lfs->free.size = 0;
|
|
||||||
lfs->free.i = 0;
|
|
||||||
lfs_alloc_ack(lfs);
|
|
||||||
|
|
||||||
LFS_TRACE("lfs_mount -> %d", 0);
|
LFS_TRACE("lfs_mount -> %d", 0);
|
||||||
return 0;
|
return 0;
|
||||||
@@ -4594,6 +4603,7 @@ static int lfs1_mount(lfs_t *lfs, struct lfs1 *lfs1,
|
|||||||
lfs->lfs1->root[1] = LFS_BLOCK_NULL;
|
lfs->lfs1->root[1] = LFS_BLOCK_NULL;
|
||||||
|
|
||||||
// setup free lookahead
|
// setup free lookahead
|
||||||
|
// TODO should this also call lfs_setup_invalid_lookahead_buffer(lfs); the free.off is different in the current version of lfs
|
||||||
lfs->free.off = 0;
|
lfs->free.off = 0;
|
||||||
lfs->free.size = 0;
|
lfs->free.size = 0;
|
||||||
lfs->free.i = 0;
|
lfs->free.i = 0;
|
||||||
|
|||||||
@@ -323,6 +323,90 @@ code = '''
|
|||||||
lfs_unmount(&lfs) => 0;
|
lfs_unmount(&lfs) => 0;
|
||||||
'''
|
'''
|
||||||
|
|
||||||
|
[[case]] # what if we have a bad block during an allocation scan?
|
||||||
|
in = "lfs.c"
|
||||||
|
define.LFS_ERASE_CYCLES = 0xffffffff
|
||||||
|
define.LFS_BADBLOCK_BEHAVIOR = 'LFS_TESTBD_BADBLOCK_READERROR'
|
||||||
|
code = '''
|
||||||
|
lfs_format(&lfs, &cfg) => 0;
|
||||||
|
lfs_mount(&lfs, &cfg) => 0;
|
||||||
|
// first fill to exhaustion to find available space
|
||||||
|
lfs_file_open(&lfs, &file, "pacman", LFS_O_WRONLY | LFS_O_CREAT) => 0;
|
||||||
|
strcpy((char*)buffer, "waka");
|
||||||
|
size = strlen("waka");
|
||||||
|
lfs_size_t filesize = 0;
|
||||||
|
while (true) {
|
||||||
|
lfs_ssize_t res = lfs_file_write(&lfs, &file, buffer, size);
|
||||||
|
assert(res == (lfs_ssize_t)size || res == LFS_ERR_NOSPC);
|
||||||
|
if (res == LFS_ERR_NOSPC) {
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
filesize += size;
|
||||||
|
}
|
||||||
|
lfs_file_close(&lfs, &file) => 0;
|
||||||
|
// now fill all but a couple of blocks of the filesystem with data
|
||||||
|
filesize -= 3*LFS_BLOCK_SIZE;
|
||||||
|
lfs_file_open(&lfs, &file, "pacman", LFS_O_WRONLY | LFS_O_CREAT) => 0;
|
||||||
|
strcpy((char*)buffer, "waka");
|
||||||
|
size = strlen("waka");
|
||||||
|
for (lfs_size_t i = 0; i < filesize/size; i++) {
|
||||||
|
lfs_file_write(&lfs, &file, buffer, size) => size;
|
||||||
|
}
|
||||||
|
lfs_file_close(&lfs, &file) => 0;
|
||||||
|
// also save head of file so we can error during lookahead scan
|
||||||
|
lfs_block_t fileblock = file.ctz.head;
|
||||||
|
lfs_unmount(&lfs) => 0;
|
||||||
|
|
||||||
|
// remount to force an alloc scan
|
||||||
|
lfs_mount(&lfs, &cfg) => 0;
|
||||||
|
|
||||||
|
// but mark the head of our file as a "bad block", this is force our
|
||||||
|
// scan to bail early
|
||||||
|
lfs_testbd_setwear(&cfg, fileblock, 0xffffffff) => 0;
|
||||||
|
lfs_file_open(&lfs, &file, "ghost", LFS_O_WRONLY | LFS_O_CREAT) => 0;
|
||||||
|
strcpy((char*)buffer, "chomp");
|
||||||
|
size = strlen("chomp");
|
||||||
|
while (true) {
|
||||||
|
lfs_ssize_t res = lfs_file_write(&lfs, &file, buffer, size);
|
||||||
|
assert(res == (lfs_ssize_t)size || res == LFS_ERR_CORRUPT);
|
||||||
|
if (res == LFS_ERR_CORRUPT) {
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
lfs_file_close(&lfs, &file) => 0;
|
||||||
|
|
||||||
|
// now reverse the "bad block" and try to write the file again until we
|
||||||
|
// run out of space
|
||||||
|
lfs_testbd_setwear(&cfg, fileblock, 0) => 0;
|
||||||
|
lfs_file_open(&lfs, &file, "ghost", LFS_O_WRONLY | LFS_O_CREAT) => 0;
|
||||||
|
strcpy((char*)buffer, "chomp");
|
||||||
|
size = strlen("chomp");
|
||||||
|
while (true) {
|
||||||
|
lfs_ssize_t res = lfs_file_write(&lfs, &file, buffer, size);
|
||||||
|
assert(res == (lfs_ssize_t)size || res == LFS_ERR_NOSPC);
|
||||||
|
if (res == LFS_ERR_NOSPC) {
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
lfs_file_close(&lfs, &file) => 0;
|
||||||
|
|
||||||
|
lfs_unmount(&lfs) => 0;
|
||||||
|
|
||||||
|
// check that the disk isn't hurt
|
||||||
|
lfs_mount(&lfs, &cfg) => 0;
|
||||||
|
lfs_file_open(&lfs, &file, "pacman", LFS_O_RDONLY) => 0;
|
||||||
|
strcpy((char*)buffer, "waka");
|
||||||
|
size = strlen("waka");
|
||||||
|
for (lfs_size_t i = 0; i < filesize/size; i++) {
|
||||||
|
uint8_t rbuffer[4];
|
||||||
|
lfs_file_read(&lfs, &file, rbuffer, size) => size;
|
||||||
|
assert(memcmp(rbuffer, buffer, size) == 0);
|
||||||
|
}
|
||||||
|
lfs_file_close(&lfs, &file) => 0;
|
||||||
|
lfs_unmount(&lfs) => 0;
|
||||||
|
'''
|
||||||
|
|
||||||
|
|
||||||
# Below, I don't like these tests. They're fragile and depend _heavily_
|
# Below, I don't like these tests. They're fragile and depend _heavily_
|
||||||
# on the geometry of the block device. But they are valuable. Eventually they
|
# on the geometry of the block device. But they are valuable. Eventually they
|
||||||
# should be removed and replaced with generalized tests.
|
# should be removed and replaced with generalized tests.
|
||||||
|
|||||||
Reference in New Issue
Block a user