mirror of
https://github.com/eledio-devices/thirdparty-littlefs.git
synced 2025-11-01 08:48:31 +01:00
Compare commits
41 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
ce2c01f098 | ||
|
|
0197b18100 | ||
|
|
1f11e6b78a | ||
|
|
9a7a3f637a | ||
|
|
8188019cbf | ||
|
|
d6dc728c87 | ||
|
|
aeff2a28cf | ||
|
|
aae22c8256 | ||
|
|
60e67ae080 | ||
|
|
64dedee2d1 | ||
|
|
5925db48da | ||
|
|
ab56dc5a8b | ||
|
|
6b65737715 | ||
|
|
4ebe6030c5 | ||
|
|
7ae8d778f1 | ||
|
|
4d068a154d | ||
|
|
ba088aa213 | ||
|
|
955b296bcc | ||
|
|
241dbc6f86 | ||
|
|
8cca58f1a6 | ||
|
|
97f86af4e9 | ||
|
|
d40302c5e3 | ||
|
|
0b5a78e2cd | ||
|
|
27b6cc829b | ||
|
|
fd204ac2fb | ||
|
|
bd99402d9a | ||
|
|
bce442a86b | ||
|
|
f26e970a0e | ||
|
|
965d29b887 | ||
|
|
f7fd7d966a | ||
|
|
d5aba27d60 | ||
|
|
0c77123eee | ||
|
|
494dd6673d | ||
|
|
fce2569005 | ||
|
|
9d1f1211a9 | ||
|
|
151104c790 | ||
|
|
303ffb2da4 | ||
|
|
5bf71fa43e | ||
|
|
55fb1416c7 | ||
|
|
dc031ce1d9 | ||
|
|
f85ff1d2f8 |
27
.travis.yml
27
.travis.yml
@@ -20,6 +20,7 @@ script:
|
||||
# run tests with a few different configurations
|
||||
- make test QUIET=1 CFLAGS+="-DLFS_READ_SIZE=1 -DLFS_CACHE_SIZE=4"
|
||||
- make test QUIET=1 CFLAGS+="-DLFS_READ_SIZE=512 -DLFS_CACHE_SIZE=512 -DLFS_BLOCK_CYCLES=16"
|
||||
- make test QUIET=1 CFLAGS+="-DLFS_READ_SIZE=8 -DLFS_CACHE_SIZE=16 -DLFS_BLOCK_CYCLES=2"
|
||||
- make test QUIET=1 CFLAGS+="-DLFS_BLOCK_COUNT=1023 -DLFS_LOOKAHEAD_SIZE=256"
|
||||
|
||||
- make clean test QUIET=1 CFLAGS+="-DLFS_INLINE_MAX=0"
|
||||
@@ -248,34 +249,30 @@ jobs:
|
||||
-m "Generated v$LFS_VERSION_MAJOR prefixes")
|
||||
git reset --hard
|
||||
# Update major version branches (vN and vN-prefix)
|
||||
git push https://$GEKY_BOT_RELEASES@github.com/$TRAVIS_REPO_SLUG.git \
|
||||
git push --atomic https://$GEKY_BOT_RELEASES@github.com/$TRAVIS_REPO_SLUG.git \
|
||||
v$LFS_VERSION_MAJOR \
|
||||
v$LFS_VERSION_MAJOR-prefix
|
||||
# Create patch version tag (vN.N.N)
|
||||
curl -f -u "$GEKY_BOT_RELEASES" -X POST \
|
||||
https://api.github.com/repos/$TRAVIS_REPO_SLUG/git/refs \
|
||||
-d "{
|
||||
\"ref\": \"refs/tags/$LFS_VERSION\",
|
||||
\"sha\": \"$TRAVIS_COMMIT\"
|
||||
}"
|
||||
# Create minor release?
|
||||
[[ "$LFS_VERSION" == *.0 ]] || exit 0
|
||||
# Build release notes
|
||||
PREV=$(git tag --sort=-v:refname -l "v*.0" | head -1)
|
||||
PREV=$(git tag --sort=-v:refname -l "v*" | head -1)
|
||||
if [ ! -z "$PREV" ]
|
||||
then
|
||||
echo "PREV $PREV"
|
||||
CHANGES=$'### Changes\n\n'$( \
|
||||
git log --oneline $PREV.. --grep='^Merge' --invert-grep)
|
||||
CHANGES=$(git log --oneline $PREV.. --grep='^Merge' --invert-grep)
|
||||
printf "CHANGES\n%s\n\n" "$CHANGES"
|
||||
fi
|
||||
# Create the release
|
||||
case ${GEKY_BOT_DRAFT:-minor} in
|
||||
true) DRAFT=true ;;
|
||||
minor) DRAFT=$(jq -R 'endswith(".0")' <<< "$LFS_VERSION") ;;
|
||||
false) DRAFT=false ;;
|
||||
esac
|
||||
# Create the release and patch version tag (vN.N.N)
|
||||
curl -f -u "$GEKY_BOT_RELEASES" -X POST \
|
||||
https://api.github.com/repos/$TRAVIS_REPO_SLUG/releases \
|
||||
-d "{
|
||||
\"tag_name\": \"$LFS_VERSION\",
|
||||
\"name\": \"${LFS_VERSION%.0}\",
|
||||
\"draft\": true,
|
||||
\"target_commitish\": \"$TRAVIS_COMMIT\",
|
||||
\"draft\": $DRAFT,
|
||||
\"body\": $(jq -sR '.' <<< "$CHANGES")
|
||||
}" #"
|
||||
SCRIPT
|
||||
|
||||
54
DESIGN.md
54
DESIGN.md
@@ -254,7 +254,7 @@ have weaknesses that limit their usefulness. But if we merge the two they can
|
||||
mutually solve each other's limitations.
|
||||
|
||||
This is the idea behind littlefs. At the sub-block level, littlefs is built
|
||||
out of small, two blocks logs that provide atomic updates to metadata anywhere
|
||||
out of small, two block logs that provide atomic updates to metadata anywhere
|
||||
on the filesystem. At the super-block level, littlefs is a CObW tree of blocks
|
||||
that can be evicted on demand.
|
||||
|
||||
@@ -676,7 +676,7 @@ block, this cost is fairly reasonable.
|
||||
---
|
||||
|
||||
This is a new data structure, so we still have several questions. What is the
|
||||
storage overage? Can the number of pointers exceed the size of a block? How do
|
||||
storage overhead? Can the number of pointers exceed the size of a block? How do
|
||||
we store a CTZ skip-list in our metadata pairs?
|
||||
|
||||
To find the storage overhead, we can look at the data structure as multiple
|
||||
@@ -742,8 +742,8 @@ where:
|
||||
2. popcount(![x]) = the number of bits that are 1 in ![x]
|
||||
|
||||
Initial tests of this surprising property seem to hold. As ![n] approaches
|
||||
infinity, we end up with an average overhead of 2 pointers, which matches what
|
||||
our assumption from earlier. During iteration, the popcount function seems to
|
||||
infinity, we end up with an average overhead of 2 pointers, which matches our
|
||||
assumption from earlier. During iteration, the popcount function seems to
|
||||
handle deviations from this average. Of course, just to make sure I wrote a
|
||||
quick script that verified this property for all 32-bit integers.
|
||||
|
||||
@@ -767,7 +767,7 @@ overflow, but we can avoid this by rearranging the equation a bit:
|
||||
|
||||
![off = N - (B-2w/8)n - (w/8)popcount(n)][ctz-formula7]
|
||||
|
||||
Our solution requires quite a bit of math, but computer are very good at math.
|
||||
Our solution requires quite a bit of math, but computers are very good at math.
|
||||
Now we can find both our block index and offset from a size in _O(1)_, letting
|
||||
us store CTZ skip-lists with only a pointer and size.
|
||||
|
||||
@@ -850,7 +850,7 @@ nearly every write to the filesystem.
|
||||
|
||||
Normally, block allocation involves some sort of free list or bitmap stored on
|
||||
the filesystem that is updated with free blocks. However, with power
|
||||
resilience, keeping these structure consistent becomes difficult. It doesn't
|
||||
resilience, keeping these structures consistent becomes difficult. It doesn't
|
||||
help that any mistake in updating these structures can result in lost blocks
|
||||
that are impossible to recover.
|
||||
|
||||
@@ -894,9 +894,9 @@ high-risk error conditions.
|
||||
---
|
||||
|
||||
Our block allocator needs to find free blocks efficiently. You could traverse
|
||||
through every block on storage and check each one against our filesystem tree,
|
||||
however the runtime would be abhorrent. We need to somehow collect multiple
|
||||
blocks each traversal.
|
||||
through every block on storage and check each one against our filesystem tree;
|
||||
however, the runtime would be abhorrent. We need to somehow collect multiple
|
||||
blocks per traversal.
|
||||
|
||||
Looking at existing designs, some larger filesystems that use a similar "drop
|
||||
it on the floor" strategy store a bitmap of the entire storage in [RAM]. This
|
||||
@@ -920,8 +920,8 @@ a brute force traversal. Instead of a bitmap the size of storage, we keep track
|
||||
of a small, fixed-size bitmap called the lookahead buffer. During block
|
||||
allocation, we take blocks from the lookahead buffer. If the lookahead buffer
|
||||
is empty, we scan the filesystem for more free blocks, populating our lookahead
|
||||
buffer. Each scan we use an increasing offset, circling the storage as blocks
|
||||
are allocated.
|
||||
buffer. In each scan we use an increasing offset, circling the storage as
|
||||
blocks are allocated.
|
||||
|
||||
Here's what it might look like to allocate 4 blocks on a decently busy
|
||||
filesystem with a 32 bit lookahead and a total of 128 blocks (512 KiB
|
||||
@@ -950,7 +950,7 @@ alloc = 112 lookahead: ffff8000
|
||||
```
|
||||
|
||||
This lookahead approach has a runtime complexity of _O(n²)_ to completely
|
||||
scan storage, however, bitmaps are surprisingly compact, and in practice only
|
||||
scan storage; however, bitmaps are surprisingly compact, and in practice only
|
||||
one or two passes are usually needed to find free blocks. Additionally, the
|
||||
performance of the allocator can be optimized by adjusting the block size or
|
||||
size of the lookahead buffer, trading either write granularity or RAM for
|
||||
@@ -1173,9 +1173,9 @@ We may find that the new block is also bad, but hopefully after repeating this
|
||||
cycle we'll eventually find a new block where a write succeeds. If we don't,
|
||||
that means that all blocks in our storage are bad, and we've reached the end of
|
||||
our device's usable life. At this point, littlefs will return an "out of space"
|
||||
error, which is technically true, there are no more good blocks, but as an
|
||||
added benefit also matches the error condition expected by users of dynamically
|
||||
sized data.
|
||||
error. This is technically true, as there are no more good blocks, but as an
|
||||
added benefit it also matches the error condition expected by users of
|
||||
dynamically sized data.
|
||||
|
||||
---
|
||||
|
||||
@@ -1187,7 +1187,7 @@ original data even after it has been corrupted. One such mechanism for this is
|
||||
ECC is an extension to the idea of a checksum. Where a checksum such as CRC can
|
||||
detect that an error has occurred in the data, ECC can detect and actually
|
||||
correct some amount of errors. However, there is a limit to how many errors ECC
|
||||
can detect, call the [Hamming bound][wikipedia-hamming-bound]. As the number of
|
||||
can detect: the [Hamming bound][wikipedia-hamming-bound]. As the number of
|
||||
errors approaches the Hamming bound, we may still be able to detect errors, but
|
||||
can no longer fix the data. If we've reached this point the block is
|
||||
unrecoverable.
|
||||
@@ -1202,7 +1202,7 @@ chip itself.
|
||||
In littlefs, ECC is entirely optional. Read errors can instead be prevented
|
||||
proactively by wear leveling. But it's important to note that ECC can be used
|
||||
at the block device level to modestly extend the life of a device. littlefs
|
||||
respects any errors reported by the block device, allow a block device to
|
||||
respects any errors reported by the block device, allowing a block device to
|
||||
provide additional aggressive error detection.
|
||||
|
||||
---
|
||||
@@ -1231,7 +1231,7 @@ Generally, wear leveling algorithms fall into one of two categories:
|
||||
we need to consider all blocks, including blocks that already contain data.
|
||||
|
||||
As a tradeoff for code size and complexity, littlefs (currently) only provides
|
||||
dynamic wear leveling. This is a best efforts solution. Wear is not distributed
|
||||
dynamic wear leveling. This is a best effort solution. Wear is not distributed
|
||||
perfectly, but it is distributed among the free blocks and greatly extends the
|
||||
life of a device.
|
||||
|
||||
@@ -1378,7 +1378,7 @@ We can make several improvements. First, instead of giving each file its own
|
||||
metadata pair, we can store multiple files in a single metadata pair. One way
|
||||
to do this is to directly associate a directory with a metadata pair (or a
|
||||
linked list of metadata pairs). This makes it easy for multiple files to share
|
||||
the directory's metadata pair for logging and reduce the collective storage
|
||||
the directory's metadata pair for logging and reduces the collective storage
|
||||
overhead.
|
||||
|
||||
The strict binding of metadata pairs and directories also gives users
|
||||
@@ -1816,12 +1816,12 @@ while manipulating the directory tree (foreshadowing!).
|
||||
|
||||
## The move problem
|
||||
|
||||
We have one last challenge. The move problem. Phrasing the problem is simple:
|
||||
We have one last challenge: the move problem. Phrasing the problem is simple:
|
||||
|
||||
How do you atomically move a file between two directories?
|
||||
|
||||
In littlefs we can atomically commit to directories, but we can't create
|
||||
an atomic commit that span multiple directories. The filesystem must go
|
||||
an atomic commit that spans multiple directories. The filesystem must go
|
||||
through a minimum of two distinct states to complete a move.
|
||||
|
||||
To make matters worse, file moves are a common form of synchronization for
|
||||
@@ -1831,13 +1831,13 @@ atomic moves right.
|
||||
So what can we do?
|
||||
|
||||
- We definitely can't just let power-loss result in duplicated or lost files.
|
||||
This could easily break user's code and would only reveal itself in extreme
|
||||
This could easily break users' code and would only reveal itself in extreme
|
||||
cases. We were only able to be lazy about the threaded linked-list because
|
||||
it isn't user facing and we can handle the corner cases internally.
|
||||
|
||||
- Some filesystems propagate COW operations up the tree until finding a common
|
||||
parent. Unfortunately this interacts poorly with our threaded tree and brings
|
||||
back the issue of upward propagation of wear.
|
||||
- Some filesystems propagate COW operations up the tree until a common parent
|
||||
is found. Unfortunately this interacts poorly with our threaded tree and
|
||||
brings back the issue of upward propagation of wear.
|
||||
|
||||
- In a previous version of littlefs we tried to solve this problem by going
|
||||
back and forth between the source and destination, marking and unmarking the
|
||||
@@ -1852,7 +1852,7 @@ introduction of a mechanism called "global state".
|
||||
---
|
||||
|
||||
Global state is a small set of state that can be updated from _any_ metadata
|
||||
pair. Combining global state with metadata pair's ability to update multiple
|
||||
pair. Combining global state with metadata pairs' ability to update multiple
|
||||
entries in one commit gives us a powerful tool for crafting complex atomic
|
||||
operations.
|
||||
|
||||
@@ -1910,7 +1910,7 @@ the filesystem is mounted.
|
||||
|
||||
You may have noticed that global state is very expensive. We keep a copy in
|
||||
RAM and a delta in an unbounded number of metadata pairs. Even if we reset
|
||||
the global state to its initial value we can't easily clean up the deltas on
|
||||
the global state to its initial value, we can't easily clean up the deltas on
|
||||
disk. For this reason, it's very important that we keep the size of global
|
||||
state bounded and extremely small. But, even with a strict budget, global
|
||||
state is incredibly valuable.
|
||||
|
||||
3
Makefile
3
Makefile
@@ -29,7 +29,7 @@ override CFLAGS += -DLFS_YES_TRACE
|
||||
endif
|
||||
override CFLAGS += -I.
|
||||
override CFLAGS += -std=c99 -Wall -pedantic
|
||||
override CFLAGS += -Wextra -Wshadow -Wjump-misses-init
|
||||
override CFLAGS += -Wextra -Wshadow -Wjump-misses-init -Wundef
|
||||
# Remove missing-field-initializers because of GCC bug
|
||||
override CFLAGS += -Wno-missing-field-initializers
|
||||
|
||||
@@ -55,6 +55,7 @@ test: \
|
||||
test_attrs \
|
||||
test_move \
|
||||
test_orphan \
|
||||
test_relocations \
|
||||
test_corrupt
|
||||
@rm test.c
|
||||
test_%: tests/test_%.sh
|
||||
|
||||
@@ -53,6 +53,7 @@ const struct lfs_config cfg = {
|
||||
.block_count = 128,
|
||||
.cache_size = 16,
|
||||
.lookahead_size = 16,
|
||||
.block_cycles = 500,
|
||||
};
|
||||
|
||||
// entry point
|
||||
@@ -109,7 +110,7 @@ directory functions, with the deviation that the allocation of filesystem
|
||||
structures must be provided by the user.
|
||||
|
||||
All POSIX operations, such as remove and rename, are atomic, even in event
|
||||
of power-loss. Additionally, no file updates are not actually committed to
|
||||
of power-loss. Additionally, file updates are not actually committed to
|
||||
the filesystem until sync or close is called on the file.
|
||||
|
||||
## Other notes
|
||||
|
||||
@@ -102,6 +102,7 @@ int lfs_emubd_create(const struct lfs_config *cfg, const char *path) {
|
||||
if (res < 1) {
|
||||
err = -errno;
|
||||
LFS_TRACE("lfs_emubd_create -> %"PRId32, err);
|
||||
fclose(f);
|
||||
return err;
|
||||
}
|
||||
|
||||
@@ -124,6 +125,7 @@ int lfs_emubd_create(const struct lfs_config *cfg, const char *path) {
|
||||
if (res < 1) {
|
||||
err = -errno;
|
||||
LFS_TRACE("lfs_emubd_create -> %"PRId32, err);
|
||||
fclose(f);
|
||||
return err;
|
||||
}
|
||||
|
||||
@@ -178,6 +180,7 @@ int lfs_emubd_read(const struct lfs_config *cfg, lfs_block_t block,
|
||||
if (err) {
|
||||
err = -errno;
|
||||
LFS_TRACE("lfs_emubd_read -> %d", err);
|
||||
fclose(f);
|
||||
return err;
|
||||
}
|
||||
|
||||
@@ -185,6 +188,7 @@ int lfs_emubd_read(const struct lfs_config *cfg, lfs_block_t block,
|
||||
if (res < size && !feof(f)) {
|
||||
err = -errno;
|
||||
LFS_TRACE("lfs_emubd_read -> %d", err);
|
||||
fclose(f);
|
||||
return err;
|
||||
}
|
||||
|
||||
@@ -230,6 +234,7 @@ int lfs_emubd_prog(const struct lfs_config *cfg, lfs_block_t block,
|
||||
if (err) {
|
||||
err = -errno;
|
||||
LFS_TRACE("lfs_emubd_prog -> %d", err);
|
||||
fclose(f);
|
||||
return err;
|
||||
}
|
||||
|
||||
@@ -237,6 +242,7 @@ int lfs_emubd_prog(const struct lfs_config *cfg, lfs_block_t block,
|
||||
if (res < size) {
|
||||
err = -errno;
|
||||
LFS_TRACE("lfs_emubd_prog -> %d", err);
|
||||
fclose(f);
|
||||
return err;
|
||||
}
|
||||
|
||||
@@ -244,6 +250,7 @@ int lfs_emubd_prog(const struct lfs_config *cfg, lfs_block_t block,
|
||||
if (err) {
|
||||
err = -errno;
|
||||
LFS_TRACE("lfs_emubd_prog -> %d", err);
|
||||
fclose(f);
|
||||
return err;
|
||||
}
|
||||
|
||||
@@ -252,6 +259,7 @@ int lfs_emubd_prog(const struct lfs_config *cfg, lfs_block_t block,
|
||||
if (res < 1) {
|
||||
err = -errno;
|
||||
LFS_TRACE("lfs_emubd_prog -> %d", err);
|
||||
fclose(f);
|
||||
return err;
|
||||
}
|
||||
|
||||
@@ -340,6 +348,7 @@ int lfs_emubd_sync(const struct lfs_config *cfg) {
|
||||
if (res < 1) {
|
||||
int err = -errno;
|
||||
LFS_TRACE("lfs_emubd_sync -> %d", err);
|
||||
fclose(f);
|
||||
return err;
|
||||
}
|
||||
|
||||
@@ -364,6 +373,7 @@ int lfs_emubd_sync(const struct lfs_config *cfg) {
|
||||
if (res < 1) {
|
||||
err = -errno;
|
||||
LFS_TRACE("lfs_emubd_sync -> %d", err);
|
||||
fclose(f);
|
||||
return err;
|
||||
}
|
||||
|
||||
@@ -388,6 +398,7 @@ int lfs_emubd_sync(const struct lfs_config *cfg) {
|
||||
if (res < 1) {
|
||||
err = -errno;
|
||||
LFS_TRACE("lfs_emubd_sync -> %d", err);
|
||||
fclose(f);
|
||||
return err;
|
||||
}
|
||||
|
||||
|
||||
256
lfs.c
256
lfs.c
@@ -7,19 +7,21 @@
|
||||
#include "lfs.h"
|
||||
#include "lfs_util.h"
|
||||
|
||||
#define LFS_BLOCK_NULL ((lfs_block_t)-1)
|
||||
#define LFS_BLOCK_INLINE ((lfs_block_t)-2)
|
||||
|
||||
/// Caching block device operations ///
|
||||
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
|
||||
// written with identical data (during relocates)
|
||||
(void)lfs;
|
||||
rcache->block = 0xffffffff;
|
||||
rcache->block = LFS_BLOCK_NULL;
|
||||
}
|
||||
|
||||
static inline void lfs_cache_zero(lfs_t *lfs, lfs_cache_t *pcache) {
|
||||
// zero to avoid information leak
|
||||
memset(pcache->buffer, 0xff, lfs->cfg->cache_size);
|
||||
pcache->block = 0xffffffff;
|
||||
pcache->block = LFS_BLOCK_NULL;
|
||||
}
|
||||
|
||||
static int lfs_bd_read(lfs_t *lfs,
|
||||
@@ -27,7 +29,7 @@ static int lfs_bd_read(lfs_t *lfs,
|
||||
lfs_block_t block, lfs_off_t off,
|
||||
void *buffer, lfs_size_t size) {
|
||||
uint8_t *data = buffer;
|
||||
LFS_ASSERT(block != 0xffffffff);
|
||||
LFS_ASSERT(block != LFS_BLOCK_NULL);
|
||||
if (off+size > lfs->cfg->block_size) {
|
||||
return LFS_ERR_CORRUPT;
|
||||
}
|
||||
@@ -121,7 +123,7 @@ static int lfs_bd_cmp(lfs_t *lfs,
|
||||
|
||||
static int lfs_bd_flush(lfs_t *lfs,
|
||||
lfs_cache_t *pcache, lfs_cache_t *rcache, bool validate) {
|
||||
if (pcache->block != 0xffffffff && pcache->block != 0xfffffffe) {
|
||||
if (pcache->block != LFS_BLOCK_NULL && pcache->block != LFS_BLOCK_INLINE) {
|
||||
LFS_ASSERT(pcache->block < lfs->cfg->block_count);
|
||||
lfs_size_t diff = lfs_alignup(pcache->size, lfs->cfg->prog_size);
|
||||
int err = lfs->cfg->prog(lfs->cfg, pcache->block,
|
||||
@@ -171,7 +173,7 @@ static int lfs_bd_prog(lfs_t *lfs,
|
||||
lfs_block_t block, lfs_off_t off,
|
||||
const void *buffer, lfs_size_t size) {
|
||||
const uint8_t *data = buffer;
|
||||
LFS_ASSERT(block != 0xffffffff);
|
||||
LFS_ASSERT(block != LFS_BLOCK_NULL);
|
||||
LFS_ASSERT(off + size <= lfs->cfg->block_size);
|
||||
|
||||
while (size > 0) {
|
||||
@@ -201,7 +203,7 @@ static int lfs_bd_prog(lfs_t *lfs,
|
||||
|
||||
// pcache must have been flushed, either by programming and
|
||||
// entire block or manually flushing the pcache
|
||||
LFS_ASSERT(pcache->block == 0xffffffff);
|
||||
LFS_ASSERT(pcache->block == LFS_BLOCK_NULL);
|
||||
|
||||
// prepare pcache, first condition can no longer fail
|
||||
pcache->block = block;
|
||||
@@ -229,7 +231,7 @@ static inline void lfs_pair_swap(lfs_block_t pair[2]) {
|
||||
}
|
||||
|
||||
static inline bool lfs_pair_isnull(const lfs_block_t pair[2]) {
|
||||
return pair[0] == 0xffffffff || pair[1] == 0xffffffff;
|
||||
return pair[0] == LFS_BLOCK_NULL || pair[1] == LFS_BLOCK_NULL;
|
||||
}
|
||||
|
||||
static inline int lfs_pair_cmp(
|
||||
@@ -350,7 +352,7 @@ static inline bool lfs_gstate_hasmovehere(const struct lfs_gstate *a,
|
||||
|
||||
static inline void lfs_gstate_xororphans(struct lfs_gstate *a,
|
||||
const struct lfs_gstate *b, bool orphans) {
|
||||
a->tag ^= LFS_MKTAG(0x800, 0, 0) & (b->tag ^ (orphans << 31));
|
||||
a->tag ^= LFS_MKTAG(0x800, 0, 0) & (b->tag ^ ((uint32_t)orphans << 31));
|
||||
}
|
||||
|
||||
static inline void lfs_gstate_xormove(struct lfs_gstate *a,
|
||||
@@ -571,7 +573,7 @@ static int lfs_dir_getread(lfs_t *lfs, const lfs_mdir_t *dir,
|
||||
while (size > 0) {
|
||||
lfs_size_t diff = size;
|
||||
|
||||
if (pcache && pcache->block == 0xfffffffe &&
|
||||
if (pcache && pcache->block == LFS_BLOCK_INLINE &&
|
||||
off < pcache->off + pcache->size) {
|
||||
if (off >= pcache->off) {
|
||||
// is already in pcache?
|
||||
@@ -588,7 +590,7 @@ static int lfs_dir_getread(lfs_t *lfs, const lfs_mdir_t *dir,
|
||||
diff = lfs_min(diff, pcache->off-off);
|
||||
}
|
||||
|
||||
if (rcache->block == 0xfffffffe &&
|
||||
if (rcache->block == LFS_BLOCK_INLINE &&
|
||||
off < rcache->off + rcache->size) {
|
||||
if (off >= rcache->off) {
|
||||
// is already in rcache?
|
||||
@@ -606,7 +608,7 @@ static int lfs_dir_getread(lfs_t *lfs, const lfs_mdir_t *dir,
|
||||
}
|
||||
|
||||
// load to cache, first condition can no longer fail
|
||||
rcache->block = 0xfffffffe;
|
||||
rcache->block = LFS_BLOCK_INLINE;
|
||||
rcache->off = lfs_aligndown(off, lfs->cfg->read_size);
|
||||
rcache->size = lfs_min(lfs_alignup(off+hint, lfs->cfg->read_size),
|
||||
lfs->cfg->cache_size);
|
||||
@@ -723,7 +725,7 @@ static int lfs_dir_traverse(lfs_t *lfs,
|
||||
uint16_t fromid = lfs_tag_size(tag);
|
||||
uint16_t toid = lfs_tag_id(tag);
|
||||
int err = lfs_dir_traverse(lfs,
|
||||
buffer, 0, 0xffffffff, NULL, 0, true,
|
||||
buffer, 0, LFS_BLOCK_NULL, NULL, 0, true,
|
||||
LFS_MKTAG(0x600, 0x3ff, 0),
|
||||
LFS_MKTAG(LFS_TYPE_STRUCT, 0, 0),
|
||||
fromid, fromid+1, toid-fromid+diff,
|
||||
@@ -783,15 +785,15 @@ static lfs_stag_t lfs_dir_fetchmatch(lfs_t *lfs,
|
||||
// now scan tags to fetch the actual dir and find possible match
|
||||
for (int i = 0; i < 2; i++) {
|
||||
lfs_off_t off = 0;
|
||||
lfs_tag_t ptag = 0xffffffff;
|
||||
lfs_tag_t ptag = LFS_BLOCK_NULL;
|
||||
|
||||
uint16_t tempcount = 0;
|
||||
lfs_block_t temptail[2] = {0xffffffff, 0xffffffff};
|
||||
lfs_block_t temptail[2] = {LFS_BLOCK_NULL, LFS_BLOCK_NULL};
|
||||
bool tempsplit = false;
|
||||
lfs_stag_t tempbesttag = besttag;
|
||||
|
||||
dir->rev = lfs_tole32(dir->rev);
|
||||
uint32_t crc = lfs_crc(0xffffffff, &dir->rev, sizeof(dir->rev));
|
||||
uint32_t crc = lfs_crc(LFS_BLOCK_NULL, &dir->rev, sizeof(dir->rev));
|
||||
dir->rev = lfs_fromle32(dir->rev);
|
||||
|
||||
while (true) {
|
||||
@@ -844,7 +846,7 @@ static lfs_stag_t lfs_dir_fetchmatch(lfs_t *lfs,
|
||||
}
|
||||
|
||||
// reset the next bit if we need to
|
||||
ptag ^= (lfs_tag_chunk(tag) & 1U) << 31;
|
||||
ptag ^= (lfs_tag_t)(lfs_tag_chunk(tag) & 1U) << 31;
|
||||
|
||||
// toss our crc into the filesystem seed for
|
||||
// pseudorandom numbers
|
||||
@@ -860,7 +862,7 @@ static lfs_stag_t lfs_dir_fetchmatch(lfs_t *lfs,
|
||||
dir->split = tempsplit;
|
||||
|
||||
// reset crc
|
||||
crc = 0xffffffff;
|
||||
crc = LFS_BLOCK_NULL;
|
||||
continue;
|
||||
}
|
||||
|
||||
@@ -927,6 +929,11 @@ static lfs_stag_t lfs_dir_fetchmatch(lfs_t *lfs,
|
||||
if (res == LFS_CMP_EQ) {
|
||||
// found a match
|
||||
tempbesttag = tag;
|
||||
} else if ((LFS_MKTAG(0x7ff, 0x3ff, 0) & tag) ==
|
||||
(LFS_MKTAG(0x7ff, 0x3ff, 0) & tempbesttag)) {
|
||||
// found an identical tag, but contents didn't match
|
||||
// this must mean that our besttag has been overwritten
|
||||
tempbesttag = -1;
|
||||
} else if (res == LFS_CMP_GT &&
|
||||
lfs_tag_id(tag) <= lfs_tag_id(tempbesttag)) {
|
||||
// found a greater match, keep track to keep things sorted
|
||||
@@ -973,9 +980,10 @@ static lfs_stag_t lfs_dir_fetchmatch(lfs_t *lfs,
|
||||
|
||||
static int lfs_dir_fetch(lfs_t *lfs,
|
||||
lfs_mdir_t *dir, const lfs_block_t pair[2]) {
|
||||
// note, mask=-1, tag=0 can never match a tag since this
|
||||
// note, mask=-1, tag=-1 can never match a tag since this
|
||||
// pattern has the invalid bit set
|
||||
return lfs_dir_fetchmatch(lfs, dir, pair, -1, 0, NULL, NULL, NULL);
|
||||
return (int)lfs_dir_fetchmatch(lfs, dir, pair,
|
||||
(lfs_tag_t)-1, (lfs_tag_t)-1, NULL, NULL, NULL);
|
||||
}
|
||||
|
||||
static int lfs_dir_getgstate(lfs_t *lfs, const lfs_mdir_t *dir,
|
||||
@@ -1008,7 +1016,7 @@ static int lfs_dir_getinfo(lfs_t *lfs, lfs_mdir_t *dir,
|
||||
lfs_stag_t tag = lfs_dir_get(lfs, dir, LFS_MKTAG(0x780, 0x3ff, 0),
|
||||
LFS_MKTAG(LFS_TYPE_NAME, id, lfs->name_max+1), info->name);
|
||||
if (tag < 0) {
|
||||
return tag;
|
||||
return (int)tag;
|
||||
}
|
||||
|
||||
info->type = lfs_tag_type3(tag);
|
||||
@@ -1017,7 +1025,7 @@ static int lfs_dir_getinfo(lfs_t *lfs, lfs_mdir_t *dir,
|
||||
tag = lfs_dir_get(lfs, dir, LFS_MKTAG(0x700, 0x3ff, 0),
|
||||
LFS_MKTAG(LFS_TYPE_STRUCT, id, sizeof(ctz)), &ctz);
|
||||
if (tag < 0) {
|
||||
return tag;
|
||||
return (int)tag;
|
||||
}
|
||||
lfs_ctz_fromle32(&ctz);
|
||||
|
||||
@@ -1060,7 +1068,7 @@ static int lfs_dir_find_match(void *data,
|
||||
return LFS_CMP_EQ;
|
||||
}
|
||||
|
||||
static int lfs_dir_find(lfs_t *lfs, lfs_mdir_t *dir,
|
||||
static lfs_stag_t lfs_dir_find(lfs_t *lfs, lfs_mdir_t *dir,
|
||||
const char **path, uint16_t *id) {
|
||||
// we reduce path to a single name if we can find it
|
||||
const char *name = *path;
|
||||
@@ -1248,7 +1256,7 @@ static int lfs_dir_commitcrc(lfs_t *lfs, struct lfs_commit *commit) {
|
||||
}
|
||||
|
||||
// read erased state from next program unit
|
||||
lfs_tag_t tag = 0xffffffff;
|
||||
lfs_tag_t tag = LFS_BLOCK_NULL;
|
||||
int err = lfs_bd_read(lfs,
|
||||
NULL, &lfs->rcache, sizeof(tag),
|
||||
commit->block, noff, &tag, sizeof(tag));
|
||||
@@ -1273,8 +1281,8 @@ static int lfs_dir_commitcrc(lfs_t *lfs, struct lfs_commit *commit) {
|
||||
}
|
||||
|
||||
commit->off += sizeof(tag)+lfs_tag_size(tag);
|
||||
commit->ptag = tag ^ (reset << 31);
|
||||
commit->crc = 0xffffffff; // reset crc for next "commit"
|
||||
commit->ptag = tag ^ ((lfs_tag_t)reset << 31);
|
||||
commit->crc = LFS_BLOCK_NULL; // reset crc for next "commit"
|
||||
}
|
||||
|
||||
// flush buffers
|
||||
@@ -1287,7 +1295,7 @@ static int lfs_dir_commitcrc(lfs_t *lfs, struct lfs_commit *commit) {
|
||||
lfs_off_t off = commit->begin;
|
||||
lfs_off_t noff = off1;
|
||||
while (off < end) {
|
||||
uint32_t crc = 0xffffffff;
|
||||
uint32_t crc = LFS_BLOCK_NULL;
|
||||
for (lfs_off_t i = off; i < noff+sizeof(uint32_t); i++) {
|
||||
// leave it up to caching to make this efficient
|
||||
uint8_t dat;
|
||||
@@ -1341,10 +1349,10 @@ static int lfs_dir_alloc(lfs_t *lfs, lfs_mdir_t *dir) {
|
||||
|
||||
// set defaults
|
||||
dir->off = sizeof(dir->rev);
|
||||
dir->etag = 0xffffffff;
|
||||
dir->etag = LFS_BLOCK_NULL;
|
||||
dir->count = 0;
|
||||
dir->tail[0] = 0xffffffff;
|
||||
dir->tail[1] = 0xffffffff;
|
||||
dir->tail[0] = LFS_BLOCK_NULL;
|
||||
dir->tail[1] = LFS_BLOCK_NULL;
|
||||
dir->erased = false;
|
||||
dir->split = false;
|
||||
|
||||
@@ -1375,6 +1383,7 @@ static int lfs_dir_split(lfs_t *lfs,
|
||||
lfs_mdir_t *dir, const struct lfs_mattr *attrs, int attrcount,
|
||||
lfs_mdir_t *source, uint16_t split, uint16_t end) {
|
||||
// create tail directory
|
||||
lfs_alloc_ack(lfs);
|
||||
lfs_mdir_t tail;
|
||||
int err = lfs_dir_alloc(lfs, &tail);
|
||||
if (err) {
|
||||
@@ -1434,7 +1443,7 @@ static int lfs_dir_compact(lfs_t *lfs,
|
||||
// find size
|
||||
lfs_size_t size = 0;
|
||||
int err = lfs_dir_traverse(lfs,
|
||||
source, 0, 0xffffffff, attrs, attrcount, false,
|
||||
source, 0, LFS_BLOCK_NULL, attrs, attrcount, false,
|
||||
LFS_MKTAG(0x400, 0x3ff, 0),
|
||||
LFS_MKTAG(LFS_TYPE_NAME, 0, 0),
|
||||
begin, end, -begin,
|
||||
@@ -1500,10 +1509,14 @@ static int lfs_dir_compact(lfs_t *lfs,
|
||||
end = begin;
|
||||
}
|
||||
}
|
||||
#if LFS_MIGRATE
|
||||
} else if (lfs_pair_cmp(dir->pair, lfs->root) == 0 && lfs->lfs1) {
|
||||
// we can't relocate our root during migrations, as this would
|
||||
// cause the superblock to get updated, which would clobber v1
|
||||
#ifdef LFS_MIGRATE
|
||||
} else if (lfs->lfs1) {
|
||||
// do not proactively relocate blocks during migrations, this
|
||||
// can cause a number of failure states such: clobbering the
|
||||
// v1 superblock if we relocate root, and invalidating directory
|
||||
// pointers if we relocate the head of a directory. On top of
|
||||
// this, relocations increase the overall complexity of
|
||||
// lfs_migration, which is already a delicate operation.
|
||||
#endif
|
||||
} else {
|
||||
// we're writing too much, time to relocate
|
||||
@@ -1526,8 +1539,8 @@ static int lfs_dir_compact(lfs_t *lfs,
|
||||
struct lfs_commit commit = {
|
||||
.block = dir->pair[1],
|
||||
.off = 0,
|
||||
.ptag = 0xffffffff,
|
||||
.crc = 0xffffffff,
|
||||
.ptag = LFS_BLOCK_NULL,
|
||||
.crc = LFS_BLOCK_NULL,
|
||||
|
||||
.begin = 0,
|
||||
.end = lfs->cfg->block_size - 8,
|
||||
@@ -1556,7 +1569,7 @@ static int lfs_dir_compact(lfs_t *lfs,
|
||||
|
||||
// traverse the directory, this time writing out all unique tags
|
||||
err = lfs_dir_traverse(lfs,
|
||||
source, 0, 0xffffffff, attrs, attrcount, false,
|
||||
source, 0, LFS_BLOCK_NULL, attrs, attrcount, false,
|
||||
LFS_MKTAG(0x400, 0x3ff, 0),
|
||||
LFS_MKTAG(LFS_TYPE_NAME, 0, 0),
|
||||
begin, end, -begin,
|
||||
@@ -1641,7 +1654,6 @@ relocate:
|
||||
if (err && (err != LFS_ERR_NOSPC && !exhausted)) {
|
||||
return err;
|
||||
}
|
||||
|
||||
continue;
|
||||
}
|
||||
|
||||
@@ -1682,8 +1694,8 @@ static int lfs_dir_commit(lfs_t *lfs, lfs_mdir_t *dir,
|
||||
}
|
||||
|
||||
// calculate changes to the directory
|
||||
lfs_tag_t deletetag = 0xffffffff;
|
||||
lfs_tag_t createtag = 0xffffffff;
|
||||
lfs_tag_t deletetag = LFS_BLOCK_NULL;
|
||||
lfs_tag_t createtag = LFS_BLOCK_NULL;
|
||||
for (int i = 0; i < attrcount; i++) {
|
||||
if (lfs_tag_type3(attrs[i].tag) == LFS_TYPE_CREATE) {
|
||||
createtag = attrs[i].tag;
|
||||
@@ -1729,7 +1741,7 @@ static int lfs_dir_commit(lfs_t *lfs, lfs_mdir_t *dir,
|
||||
.block = dir->pair[0],
|
||||
.off = dir->off,
|
||||
.ptag = dir->etag,
|
||||
.crc = 0xffffffff,
|
||||
.crc = LFS_BLOCK_NULL,
|
||||
|
||||
.begin = dir->off,
|
||||
.end = lfs->cfg->block_size - 8,
|
||||
@@ -1813,8 +1825,8 @@ compact:
|
||||
if (lfs_pair_cmp(d->m.pair, copy.pair) == 0) {
|
||||
d->m = *dir;
|
||||
if (d->id == lfs_tag_id(deletetag)) {
|
||||
d->m.pair[0] = 0xffffffff;
|
||||
d->m.pair[1] = 0xffffffff;
|
||||
d->m.pair[0] = LFS_BLOCK_NULL;
|
||||
d->m.pair[1] = LFS_BLOCK_NULL;
|
||||
} else if (d->id > lfs_tag_id(deletetag)) {
|
||||
d->id -= 1;
|
||||
if (d->type == LFS_TYPE_DIR) {
|
||||
@@ -1934,7 +1946,7 @@ int lfs_dir_open(lfs_t *lfs, lfs_dir_t *dir, const char *path) {
|
||||
LFS_TRACE("lfs_dir_open(%p, %p, \"%s\")", (void*)lfs, (void*)dir, path);
|
||||
lfs_stag_t tag = lfs_dir_find(lfs, &dir->m, &path, NULL);
|
||||
if (tag < 0) {
|
||||
LFS_TRACE("lfs_dir_open -> %d", tag);
|
||||
LFS_TRACE("lfs_dir_open -> %"PRId32, tag);
|
||||
return tag;
|
||||
}
|
||||
|
||||
@@ -1953,7 +1965,7 @@ int lfs_dir_open(lfs_t *lfs, lfs_dir_t *dir, const char *path) {
|
||||
lfs_stag_t res = lfs_dir_get(lfs, &dir->m, LFS_MKTAG(0x700, 0x3ff, 0),
|
||||
LFS_MKTAG(LFS_TYPE_STRUCT, lfs_tag_id(tag), 8), pair);
|
||||
if (res < 0) {
|
||||
LFS_TRACE("lfs_dir_open -> %d", res);
|
||||
LFS_TRACE("lfs_dir_open -> %"PRId32, res);
|
||||
return res;
|
||||
}
|
||||
lfs_pair_fromle32(pair);
|
||||
@@ -2062,10 +2074,14 @@ int lfs_dir_seek(lfs_t *lfs, lfs_dir_t *dir, lfs_off_t off) {
|
||||
dir->pos = lfs_min(2, off);
|
||||
off -= dir->pos;
|
||||
|
||||
while (off != 0) {
|
||||
dir->id = lfs_min(dir->m.count, off);
|
||||
dir->pos += dir->id;
|
||||
off -= dir->id;
|
||||
// skip superblock entry
|
||||
dir->id = (off > 0 && lfs_pair_cmp(dir->head, lfs->root) == 0);
|
||||
|
||||
while (off > 0) {
|
||||
int diff = lfs_min(dir->m.count - dir->id, off);
|
||||
dir->id += diff;
|
||||
dir->pos += diff;
|
||||
off -= diff;
|
||||
|
||||
if (dir->id == dir->m.count) {
|
||||
if (!dir->m.split) {
|
||||
@@ -2078,6 +2094,8 @@ int lfs_dir_seek(lfs_t *lfs, lfs_dir_t *dir, lfs_off_t off) {
|
||||
LFS_TRACE("lfs_dir_seek -> %d", err);
|
||||
return err;
|
||||
}
|
||||
|
||||
dir->id = 0;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -2101,8 +2119,6 @@ int lfs_dir_rewind(lfs_t *lfs, lfs_dir_t *dir) {
|
||||
return err;
|
||||
}
|
||||
|
||||
dir->m.pair[0] = dir->head[0];
|
||||
dir->m.pair[1] = dir->head[1];
|
||||
dir->id = 0;
|
||||
dir->pos = 0;
|
||||
LFS_TRACE("lfs_dir_rewind -> %d", 0);
|
||||
@@ -2129,7 +2145,7 @@ static int lfs_ctz_find(lfs_t *lfs,
|
||||
lfs_block_t head, lfs_size_t size,
|
||||
lfs_size_t pos, lfs_block_t *block, lfs_off_t *off) {
|
||||
if (size == 0) {
|
||||
*block = 0xffffffff;
|
||||
*block = LFS_BLOCK_NULL;
|
||||
*off = 0;
|
||||
return 0;
|
||||
}
|
||||
@@ -2327,6 +2343,7 @@ int lfs_file_opencfg(lfs_t *lfs, lfs_file_t *file,
|
||||
file->cfg = cfg;
|
||||
file->flags = flags | LFS_F_OPENED;
|
||||
file->pos = 0;
|
||||
file->off = 0;
|
||||
file->cache.buffer = NULL;
|
||||
|
||||
// allocate entry for file if it doesn't exist
|
||||
@@ -2426,7 +2443,7 @@ int lfs_file_opencfg(lfs_t *lfs, lfs_file_t *file,
|
||||
|
||||
if (lfs_tag_type3(tag) == LFS_TYPE_INLINESTRUCT) {
|
||||
// load inline files
|
||||
file->ctz.head = 0xfffffffe;
|
||||
file->ctz.head = LFS_BLOCK_INLINE;
|
||||
file->ctz.size = lfs_tag_size(tag);
|
||||
file->flags |= LFS_F_INLINE;
|
||||
file->cache.block = file->ctz.head;
|
||||
@@ -2614,7 +2631,7 @@ static int lfs_file_flush(lfs_t *lfs, lfs_file_t *file) {
|
||||
}
|
||||
|
||||
// keep our reference to the rcache in sync
|
||||
if (lfs->rcache.block != 0xffffffff) {
|
||||
if (lfs->rcache.block != LFS_BLOCK_NULL) {
|
||||
lfs_cache_drop(lfs, &orig.cache);
|
||||
lfs_cache_drop(lfs, &lfs->rcache);
|
||||
}
|
||||
@@ -2735,14 +2752,14 @@ lfs_ssize_t lfs_file_read(lfs_t *lfs, lfs_file_t *file,
|
||||
// flush out any writes
|
||||
int err = lfs_file_flush(lfs, file);
|
||||
if (err) {
|
||||
LFS_TRACE("lfs_file_read -> %"PRId32, err);
|
||||
LFS_TRACE("lfs_file_read -> %d", err);
|
||||
return err;
|
||||
}
|
||||
}
|
||||
|
||||
if (file->pos >= file->ctz.size) {
|
||||
// eof if past end
|
||||
LFS_TRACE("lfs_file_read -> %"PRId32, 0);
|
||||
LFS_TRACE("lfs_file_read -> %d", 0);
|
||||
return 0;
|
||||
}
|
||||
|
||||
@@ -2758,11 +2775,11 @@ lfs_ssize_t lfs_file_read(lfs_t *lfs, lfs_file_t *file,
|
||||
file->ctz.head, file->ctz.size,
|
||||
file->pos, &file->block, &file->off);
|
||||
if (err) {
|
||||
LFS_TRACE("lfs_file_read -> %"PRId32, err);
|
||||
LFS_TRACE("lfs_file_read -> %d", err);
|
||||
return err;
|
||||
}
|
||||
} else {
|
||||
file->block = 0xfffffffe;
|
||||
file->block = LFS_BLOCK_INLINE;
|
||||
file->off = file->pos;
|
||||
}
|
||||
|
||||
@@ -2778,7 +2795,7 @@ lfs_ssize_t lfs_file_read(lfs_t *lfs, lfs_file_t *file,
|
||||
LFS_MKTAG(LFS_TYPE_INLINESTRUCT, file->id, 0),
|
||||
file->off, data, diff);
|
||||
if (err) {
|
||||
LFS_TRACE("lfs_file_read -> %"PRId32, err);
|
||||
LFS_TRACE("lfs_file_read -> %d", err);
|
||||
return err;
|
||||
}
|
||||
} else {
|
||||
@@ -2786,7 +2803,7 @@ lfs_ssize_t lfs_file_read(lfs_t *lfs, lfs_file_t *file,
|
||||
NULL, &file->cache, lfs->cfg->block_size,
|
||||
file->block, file->off, data, diff);
|
||||
if (err) {
|
||||
LFS_TRACE("lfs_file_read -> %"PRId32, err);
|
||||
LFS_TRACE("lfs_file_read -> %d", err);
|
||||
return err;
|
||||
}
|
||||
}
|
||||
@@ -2815,7 +2832,7 @@ lfs_ssize_t lfs_file_write(lfs_t *lfs, lfs_file_t *file,
|
||||
// drop any reads
|
||||
int err = lfs_file_flush(lfs, file);
|
||||
if (err) {
|
||||
LFS_TRACE("lfs_file_write -> %"PRId32, err);
|
||||
LFS_TRACE("lfs_file_write -> %d", err);
|
||||
return err;
|
||||
}
|
||||
}
|
||||
@@ -2826,7 +2843,7 @@ lfs_ssize_t lfs_file_write(lfs_t *lfs, lfs_file_t *file,
|
||||
|
||||
if (file->pos + size > lfs->file_max) {
|
||||
// Larger than file limit?
|
||||
LFS_TRACE("lfs_file_write -> %"PRId32, LFS_ERR_FBIG);
|
||||
LFS_TRACE("lfs_file_write -> %d", LFS_ERR_FBIG);
|
||||
return LFS_ERR_FBIG;
|
||||
}
|
||||
|
||||
@@ -2852,7 +2869,7 @@ lfs_ssize_t lfs_file_write(lfs_t *lfs, lfs_file_t *file,
|
||||
int err = lfs_file_outline(lfs, file);
|
||||
if (err) {
|
||||
file->flags |= LFS_F_ERRED;
|
||||
LFS_TRACE("lfs_file_write -> %"PRId32, err);
|
||||
LFS_TRACE("lfs_file_write -> %d", err);
|
||||
return err;
|
||||
}
|
||||
}
|
||||
@@ -2869,7 +2886,7 @@ lfs_ssize_t lfs_file_write(lfs_t *lfs, lfs_file_t *file,
|
||||
file->pos-1, &file->block, &file->off);
|
||||
if (err) {
|
||||
file->flags |= LFS_F_ERRED;
|
||||
LFS_TRACE("lfs_file_write -> %"PRId32, err);
|
||||
LFS_TRACE("lfs_file_write -> %d", err);
|
||||
return err;
|
||||
}
|
||||
|
||||
@@ -2884,11 +2901,11 @@ lfs_ssize_t lfs_file_write(lfs_t *lfs, lfs_file_t *file,
|
||||
&file->block, &file->off);
|
||||
if (err) {
|
||||
file->flags |= LFS_F_ERRED;
|
||||
LFS_TRACE("lfs_file_write -> %"PRId32, err);
|
||||
LFS_TRACE("lfs_file_write -> %d", err);
|
||||
return err;
|
||||
}
|
||||
} else {
|
||||
file->block = 0xfffffffe;
|
||||
file->block = LFS_BLOCK_INLINE;
|
||||
file->off = file->pos;
|
||||
}
|
||||
|
||||
@@ -2905,7 +2922,7 @@ lfs_ssize_t lfs_file_write(lfs_t *lfs, lfs_file_t *file,
|
||||
goto relocate;
|
||||
}
|
||||
file->flags |= LFS_F_ERRED;
|
||||
LFS_TRACE("lfs_file_write -> %"PRId32, err);
|
||||
LFS_TRACE("lfs_file_write -> %d", err);
|
||||
return err;
|
||||
}
|
||||
|
||||
@@ -2914,7 +2931,7 @@ relocate:
|
||||
err = lfs_file_relocate(lfs, file);
|
||||
if (err) {
|
||||
file->flags |= LFS_F_ERRED;
|
||||
LFS_TRACE("lfs_file_write -> %"PRId32, err);
|
||||
LFS_TRACE("lfs_file_write -> %d", err);
|
||||
return err;
|
||||
}
|
||||
}
|
||||
@@ -2941,7 +2958,7 @@ lfs_soff_t lfs_file_seek(lfs_t *lfs, lfs_file_t *file,
|
||||
// write out everything beforehand, may be noop if rdonly
|
||||
int err = lfs_file_flush(lfs, file);
|
||||
if (err) {
|
||||
LFS_TRACE("lfs_file_seek -> %"PRId32, err);
|
||||
LFS_TRACE("lfs_file_seek -> %d", err);
|
||||
return err;
|
||||
}
|
||||
|
||||
@@ -2957,7 +2974,7 @@ lfs_soff_t lfs_file_seek(lfs_t *lfs, lfs_file_t *file,
|
||||
|
||||
if (npos > lfs->file_max) {
|
||||
// file position out of range
|
||||
LFS_TRACE("lfs_file_seek -> %"PRId32, LFS_ERR_INVAL);
|
||||
LFS_TRACE("lfs_file_seek -> %d", LFS_ERR_INVAL);
|
||||
return LFS_ERR_INVAL;
|
||||
}
|
||||
|
||||
@@ -2978,6 +2995,7 @@ int lfs_file_truncate(lfs_t *lfs, lfs_file_t *file, lfs_off_t size) {
|
||||
return LFS_ERR_INVAL;
|
||||
}
|
||||
|
||||
lfs_off_t pos = file->pos;
|
||||
lfs_off_t oldsize = lfs_file_size(lfs, file);
|
||||
if (size < oldsize) {
|
||||
// need to flush since directly changing metadata
|
||||
@@ -3000,14 +3018,12 @@ int lfs_file_truncate(lfs_t *lfs, lfs_file_t *file, lfs_off_t size) {
|
||||
file->ctz.size = size;
|
||||
file->flags |= LFS_F_DIRTY | LFS_F_READING;
|
||||
} else if (size > oldsize) {
|
||||
lfs_off_t pos = file->pos;
|
||||
|
||||
// flush+seek if not already at end
|
||||
if (file->pos != oldsize) {
|
||||
int err = lfs_file_seek(lfs, file, 0, LFS_SEEK_END);
|
||||
if (err < 0) {
|
||||
LFS_TRACE("lfs_file_truncate -> %d", err);
|
||||
return err;
|
||||
lfs_soff_t res = lfs_file_seek(lfs, file, 0, LFS_SEEK_END);
|
||||
if (res < 0) {
|
||||
LFS_TRACE("lfs_file_truncate -> %"PRId32, res);
|
||||
return (int)res;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -3015,17 +3031,17 @@ int lfs_file_truncate(lfs_t *lfs, lfs_file_t *file, lfs_off_t size) {
|
||||
while (file->pos < size) {
|
||||
lfs_ssize_t res = lfs_file_write(lfs, file, &(uint8_t){0}, 1);
|
||||
if (res < 0) {
|
||||
LFS_TRACE("lfs_file_truncate -> %d", res);
|
||||
return res;
|
||||
LFS_TRACE("lfs_file_truncate -> %"PRId32, res);
|
||||
return (int)res;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// restore pos
|
||||
int err = lfs_file_seek(lfs, file, pos, LFS_SEEK_SET);
|
||||
if (err < 0) {
|
||||
LFS_TRACE("lfs_file_truncate -> %d", err);
|
||||
return err;
|
||||
}
|
||||
// restore pos
|
||||
lfs_soff_t res = lfs_file_seek(lfs, file, pos, LFS_SEEK_SET);
|
||||
if (res < 0) {
|
||||
LFS_TRACE("lfs_file_truncate -> %"PRId32, res);
|
||||
return (int)res;
|
||||
}
|
||||
|
||||
LFS_TRACE("lfs_file_truncate -> %d", 0);
|
||||
@@ -3044,8 +3060,8 @@ int lfs_file_rewind(lfs_t *lfs, lfs_file_t *file) {
|
||||
LFS_TRACE("lfs_file_rewind(%p, %p)", (void*)lfs, (void*)file);
|
||||
lfs_soff_t res = lfs_file_seek(lfs, file, 0, LFS_SEEK_SET);
|
||||
if (res < 0) {
|
||||
LFS_TRACE("lfs_file_rewind -> %d", res);
|
||||
return res;
|
||||
LFS_TRACE("lfs_file_rewind -> %"PRId32, res);
|
||||
return (int)res;
|
||||
}
|
||||
|
||||
LFS_TRACE("lfs_file_rewind -> %d", 0);
|
||||
@@ -3073,8 +3089,8 @@ int lfs_stat(lfs_t *lfs, const char *path, struct lfs_info *info) {
|
||||
lfs_mdir_t cwd;
|
||||
lfs_stag_t tag = lfs_dir_find(lfs, &cwd, &path, NULL);
|
||||
if (tag < 0) {
|
||||
LFS_TRACE("lfs_stat -> %d", tag);
|
||||
return tag;
|
||||
LFS_TRACE("lfs_stat -> %"PRId32, tag);
|
||||
return (int)tag;
|
||||
}
|
||||
|
||||
int err = lfs_dir_getinfo(lfs, &cwd, lfs_tag_id(tag), info);
|
||||
@@ -3094,8 +3110,8 @@ int lfs_remove(lfs_t *lfs, const char *path) {
|
||||
lfs_mdir_t cwd;
|
||||
lfs_stag_t tag = lfs_dir_find(lfs, &cwd, &path, NULL);
|
||||
if (tag < 0 || lfs_tag_id(tag) == 0x3ff) {
|
||||
LFS_TRACE("lfs_remove -> %d", (tag < 0) ? tag : LFS_ERR_INVAL);
|
||||
return (tag < 0) ? tag : LFS_ERR_INVAL;
|
||||
LFS_TRACE("lfs_remove -> %"PRId32, (tag < 0) ? tag : LFS_ERR_INVAL);
|
||||
return (tag < 0) ? (int)tag : LFS_ERR_INVAL;
|
||||
}
|
||||
|
||||
lfs_mdir_t dir;
|
||||
@@ -3105,8 +3121,8 @@ int lfs_remove(lfs_t *lfs, const char *path) {
|
||||
lfs_stag_t res = lfs_dir_get(lfs, &cwd, LFS_MKTAG(0x700, 0x3ff, 0),
|
||||
LFS_MKTAG(LFS_TYPE_STRUCT, lfs_tag_id(tag), 8), pair);
|
||||
if (res < 0) {
|
||||
LFS_TRACE("lfs_remove -> %d", res);
|
||||
return res;
|
||||
LFS_TRACE("lfs_remove -> %"PRId32, res);
|
||||
return (int)res;
|
||||
}
|
||||
lfs_pair_fromle32(pair);
|
||||
|
||||
@@ -3168,8 +3184,8 @@ int lfs_rename(lfs_t *lfs, const char *oldpath, const char *newpath) {
|
||||
lfs_mdir_t oldcwd;
|
||||
lfs_stag_t oldtag = lfs_dir_find(lfs, &oldcwd, &oldpath, NULL);
|
||||
if (oldtag < 0 || lfs_tag_id(oldtag) == 0x3ff) {
|
||||
LFS_TRACE("lfs_rename -> %d", (oldtag < 0) ? oldtag : LFS_ERR_INVAL);
|
||||
return (oldtag < 0) ? oldtag : LFS_ERR_INVAL;
|
||||
LFS_TRACE("lfs_rename -> %"PRId32, (oldtag < 0) ? oldtag : LFS_ERR_INVAL);
|
||||
return (oldtag < 0) ? (int)oldtag : LFS_ERR_INVAL;
|
||||
}
|
||||
|
||||
// find new entry
|
||||
@@ -3178,8 +3194,8 @@ int lfs_rename(lfs_t *lfs, const char *oldpath, const char *newpath) {
|
||||
lfs_stag_t prevtag = lfs_dir_find(lfs, &newcwd, &newpath, &newid);
|
||||
if ((prevtag < 0 || lfs_tag_id(prevtag) == 0x3ff) &&
|
||||
!(prevtag == LFS_ERR_NOENT && newid != 0x3ff)) {
|
||||
LFS_TRACE("lfs_rename -> %d", (prevtag < 0) ? prevtag : LFS_ERR_INVAL);
|
||||
return (prevtag < 0) ? prevtag : LFS_ERR_INVAL;
|
||||
LFS_TRACE("lfs_rename -> %"PRId32, (prevtag < 0) ? prevtag : LFS_ERR_INVAL);
|
||||
return (prevtag < 0) ? (int)prevtag : LFS_ERR_INVAL;
|
||||
}
|
||||
|
||||
lfs_mdir_t prevdir;
|
||||
@@ -3199,8 +3215,8 @@ int lfs_rename(lfs_t *lfs, const char *oldpath, const char *newpath) {
|
||||
lfs_stag_t res = lfs_dir_get(lfs, &newcwd, LFS_MKTAG(0x700, 0x3ff, 0),
|
||||
LFS_MKTAG(LFS_TYPE_STRUCT, newid, 8), prevpair);
|
||||
if (res < 0) {
|
||||
LFS_TRACE("lfs_rename -> %d", res);
|
||||
return res;
|
||||
LFS_TRACE("lfs_rename -> %"PRId32, res);
|
||||
return (int)res;
|
||||
}
|
||||
lfs_pair_fromle32(prevpair);
|
||||
|
||||
@@ -3294,7 +3310,7 @@ lfs_ssize_t lfs_getattr(lfs_t *lfs, const char *path,
|
||||
id = 0;
|
||||
int err = lfs_dir_fetch(lfs, &cwd, lfs->root);
|
||||
if (err) {
|
||||
LFS_TRACE("lfs_getattr -> %"PRId32, err);
|
||||
LFS_TRACE("lfs_getattr -> %d", err);
|
||||
return err;
|
||||
}
|
||||
}
|
||||
@@ -3305,7 +3321,7 @@ lfs_ssize_t lfs_getattr(lfs_t *lfs, const char *path,
|
||||
buffer);
|
||||
if (tag < 0) {
|
||||
if (tag == LFS_ERR_NOENT) {
|
||||
LFS_TRACE("lfs_getattr -> %"PRId32, LFS_ERR_NOATTR);
|
||||
LFS_TRACE("lfs_getattr -> %d", LFS_ERR_NOATTR);
|
||||
return LFS_ERR_NOATTR;
|
||||
}
|
||||
|
||||
@@ -3367,6 +3383,12 @@ static int lfs_init(lfs_t *lfs, const struct lfs_config *cfg) {
|
||||
lfs->cfg = cfg;
|
||||
int err = 0;
|
||||
|
||||
// validate that the lfs-cfg sizes were initiated properly before
|
||||
// performing any arithmetic logics with them
|
||||
LFS_ASSERT(lfs->cfg->read_size != 0);
|
||||
LFS_ASSERT(lfs->cfg->prog_size != 0);
|
||||
LFS_ASSERT(lfs->cfg->cache_size != 0);
|
||||
|
||||
// check that block size is a multiple of cache size is a multiple
|
||||
// of prog and read sizes
|
||||
LFS_ASSERT(lfs->cfg->cache_size % lfs->cfg->read_size == 0);
|
||||
@@ -3374,7 +3396,7 @@ static int lfs_init(lfs_t *lfs, const struct lfs_config *cfg) {
|
||||
LFS_ASSERT(lfs->cfg->block_size % lfs->cfg->cache_size == 0);
|
||||
|
||||
// check that the block size is large enough to fit ctz pointers
|
||||
LFS_ASSERT(4*lfs_npw2(0xffffffff / (lfs->cfg->block_size-2*4))
|
||||
LFS_ASSERT(4*lfs_npw2(LFS_BLOCK_NULL / (lfs->cfg->block_size-2*4))
|
||||
<= lfs->cfg->block_size);
|
||||
|
||||
// block_cycles = 0 is no longer supported.
|
||||
@@ -3412,10 +3434,10 @@ static int lfs_init(lfs_t *lfs, const struct lfs_config *cfg) {
|
||||
lfs_cache_zero(lfs, &lfs->rcache);
|
||||
lfs_cache_zero(lfs, &lfs->pcache);
|
||||
|
||||
// setup lookahead, must be multiple of 64-bits
|
||||
// setup lookahead, must be multiple of 64-bits, 32-bit aligned
|
||||
LFS_ASSERT(lfs->cfg->lookahead_size > 0);
|
||||
LFS_ASSERT(lfs->cfg->lookahead_size % 8 == 0 &&
|
||||
(uintptr_t)lfs->cfg->lookahead_buffer % 8 == 0);
|
||||
(uintptr_t)lfs->cfg->lookahead_buffer % 4 == 0);
|
||||
if (lfs->cfg->lookahead_buffer) {
|
||||
lfs->free.buffer = lfs->cfg->lookahead_buffer;
|
||||
} else {
|
||||
@@ -3446,8 +3468,8 @@ static int lfs_init(lfs_t *lfs, const struct lfs_config *cfg) {
|
||||
}
|
||||
|
||||
// setup default state
|
||||
lfs->root[0] = 0xffffffff;
|
||||
lfs->root[1] = 0xffffffff;
|
||||
lfs->root[0] = LFS_BLOCK_NULL;
|
||||
lfs->root[1] = LFS_BLOCK_NULL;
|
||||
lfs->mlist = NULL;
|
||||
lfs->seed = 0;
|
||||
lfs->gstate = (struct lfs_gstate){0};
|
||||
@@ -3755,7 +3777,7 @@ int lfs_fs_traverse(lfs_t *lfs,
|
||||
if (tag == LFS_ERR_NOENT) {
|
||||
continue;
|
||||
}
|
||||
LFS_TRACE("lfs_fs_traverse -> %d", tag);
|
||||
LFS_TRACE("lfs_fs_traverse -> %"PRId32, tag);
|
||||
return tag;
|
||||
}
|
||||
lfs_ctz_fromle32(&ctz);
|
||||
@@ -3879,6 +3901,12 @@ static int lfs_fs_relocate(lfs_t *lfs,
|
||||
d->m.pair[0] = newpair[0];
|
||||
d->m.pair[1] = newpair[1];
|
||||
}
|
||||
|
||||
if (d->type == LFS_TYPE_DIR &&
|
||||
lfs_pair_cmp(oldpair, ((lfs_dir_t*)d)->head) == 0) {
|
||||
((lfs_dir_t*)d)->head[0] = newpair[0];
|
||||
((lfs_dir_t*)d)->head[1] = newpair[1];
|
||||
}
|
||||
}
|
||||
|
||||
// find parent
|
||||
@@ -4064,11 +4092,11 @@ lfs_ssize_t lfs_fs_size(lfs_t *lfs) {
|
||||
lfs_size_t size = 0;
|
||||
int err = lfs_fs_traverse(lfs, lfs_fs_size_count, &size);
|
||||
if (err) {
|
||||
LFS_TRACE("lfs_fs_size -> %"PRId32, err);
|
||||
LFS_TRACE("lfs_fs_size -> %d", err);
|
||||
return err;
|
||||
}
|
||||
|
||||
LFS_TRACE("lfs_fs_size -> %"PRId32, err);
|
||||
LFS_TRACE("lfs_fs_size -> %d", err);
|
||||
return size;
|
||||
}
|
||||
|
||||
@@ -4250,7 +4278,7 @@ static int lfs1_dir_fetch(lfs_t *lfs,
|
||||
continue;
|
||||
}
|
||||
|
||||
uint32_t crc = 0xffffffff;
|
||||
uint32_t crc = LFS_BLOCK_NULL;
|
||||
lfs1_dir_tole32(&test);
|
||||
lfs1_crc(&crc, &test, sizeof(test));
|
||||
lfs1_dir_fromle32(&test);
|
||||
@@ -4435,8 +4463,8 @@ static int lfs1_mount(lfs_t *lfs, struct lfs1 *lfs1,
|
||||
}
|
||||
|
||||
lfs->lfs1 = lfs1;
|
||||
lfs->lfs1->root[0] = 0xffffffff;
|
||||
lfs->lfs1->root[1] = 0xffffffff;
|
||||
lfs->lfs1->root[0] = LFS_BLOCK_NULL;
|
||||
lfs->lfs1->root[1] = LFS_BLOCK_NULL;
|
||||
|
||||
// setup free lookahead
|
||||
lfs->free.off = 0;
|
||||
@@ -4606,7 +4634,7 @@ int lfs_migrate(lfs_t *lfs, const struct lfs_config *cfg) {
|
||||
id, entry1.d.nlen), name},
|
||||
{LFS_MKTAG(
|
||||
isdir ? LFS_TYPE_DIRSTRUCT : LFS_TYPE_CTZSTRUCT,
|
||||
id, sizeof(&entry1.d.u)), &entry1.d.u}));
|
||||
id, sizeof(entry1.d.u)), &entry1.d.u}));
|
||||
lfs1_entry_fromle32(&entry1.d);
|
||||
if (err) {
|
||||
goto cleanup;
|
||||
@@ -4629,7 +4657,7 @@ int lfs_migrate(lfs_t *lfs, const struct lfs_config *cfg) {
|
||||
|
||||
lfs_pair_tole32(dir2.pair);
|
||||
err = lfs_dir_commit(lfs, &dir2, LFS_MKATTRS(
|
||||
{LFS_MKTAG(LFS_TYPE_SOFTTAIL, 0x3ff, 0),
|
||||
{LFS_MKTAG(LFS_TYPE_SOFTTAIL, 0x3ff, 8),
|
||||
dir1.d.tail}));
|
||||
lfs_pair_fromle32(dir2.pair);
|
||||
if (err) {
|
||||
@@ -4685,7 +4713,7 @@ int lfs_migrate(lfs_t *lfs, const struct lfs_config *cfg) {
|
||||
dir2.pair[1] = dir1.pair[1];
|
||||
dir2.rev = dir1.d.rev;
|
||||
dir2.off = sizeof(dir2.rev);
|
||||
dir2.etag = 0xffffffff;
|
||||
dir2.etag = LFS_BLOCK_NULL;
|
||||
dir2.count = 0;
|
||||
dir2.tail[0] = lfs->lfs1->root[0];
|
||||
dir2.tail[1] = lfs->lfs1->root[1];
|
||||
|
||||
@@ -250,6 +250,14 @@ scripts/test.py << TEST
|
||||
lfs_unmount(&lfs) => 0;
|
||||
TEST
|
||||
|
||||
## Below, these tests depend _very_ heavily on the geometry of the
|
||||
## block device being tested, they should be removed and replaced
|
||||
## by generalized tests. For now we'll just skip if the geometry
|
||||
## is customized.
|
||||
|
||||
if [[ ! $MAKEFLAGS =~ "LFS_BLOCK_CYCLES" ]]
|
||||
then
|
||||
|
||||
echo "--- Chained dir exhaustion test ---"
|
||||
scripts/test.py << TEST
|
||||
lfs_mount(&lfs, &cfg) => 0;
|
||||
@@ -481,4 +489,6 @@ scripts/test.py << TEST
|
||||
lfs_unmount(&lfs) => 0;
|
||||
TEST
|
||||
|
||||
fi
|
||||
|
||||
scripts/results.py
|
||||
|
||||
@@ -179,7 +179,7 @@ echo "--- Really big path test ---"
|
||||
scripts/test.py << TEST
|
||||
lfs_mount(&lfs, &cfg) => 0;
|
||||
memset(path, 'w', LFS_NAME_MAX);
|
||||
path[LFS_NAME_MAX+1] = '\0';
|
||||
path[LFS_NAME_MAX] = '\0';
|
||||
lfs_mkdir(&lfs, path) => 0;
|
||||
lfs_remove(&lfs, path) => 0;
|
||||
lfs_file_open(&lfs, &file, path,
|
||||
@@ -189,7 +189,7 @@ scripts/test.py << TEST
|
||||
|
||||
memcpy(path, "coffee/", strlen("coffee/"));
|
||||
memset(path+strlen("coffee/"), 'w', LFS_NAME_MAX);
|
||||
path[strlen("coffee/")+LFS_NAME_MAX+1] = '\0';
|
||||
path[strlen("coffee/")+LFS_NAME_MAX] = '\0';
|
||||
lfs_mkdir(&lfs, path) => 0;
|
||||
lfs_remove(&lfs, path) => 0;
|
||||
lfs_file_open(&lfs, &file, path,
|
||||
|
||||
139
tests/test_relocations.sh
Executable file
139
tests/test_relocations.sh
Executable file
@@ -0,0 +1,139 @@
|
||||
#!/bin/bash
|
||||
set -eu
|
||||
export TEST_FILE=$0
|
||||
trap 'export TEST_LINE=$LINENO' DEBUG
|
||||
|
||||
ITERATIONS=20
|
||||
COUNT=10
|
||||
|
||||
echo "=== Relocation tests ==="
|
||||
rm -rf blocks
|
||||
scripts/test.py << TEST
|
||||
lfs_format(&lfs, &cfg) => 0;
|
||||
// fill up filesystem so only ~16 blocks are left
|
||||
lfs_mount(&lfs, &cfg) => 0;
|
||||
lfs_file_open(&lfs, &file, "padding", LFS_O_CREAT | LFS_O_WRONLY) => 0;
|
||||
memset(buffer, 0, 512);
|
||||
while (LFS_BLOCK_COUNT - lfs_fs_size(&lfs) > 16) {
|
||||
lfs_file_write(&lfs, &file, buffer, 512) => 512;
|
||||
}
|
||||
lfs_file_close(&lfs, &file) => 0;
|
||||
// make a child dir to use in bounded space
|
||||
lfs_mkdir(&lfs, "child") => 0;
|
||||
lfs_unmount(&lfs) => 0;
|
||||
TEST
|
||||
|
||||
echo "--- Dangling split dir test ---"
|
||||
scripts/test.py << TEST
|
||||
lfs_mount(&lfs, &cfg) => 0;
|
||||
for (int j = 0; j < $ITERATIONS; j++) {
|
||||
for (int i = 0; i < $COUNT; i++) {
|
||||
sprintf(path, "child/test%03d_loooooooooooooooooong_name", i);
|
||||
lfs_file_open(&lfs, &file, path, LFS_O_CREAT | LFS_O_WRONLY) => 0;
|
||||
lfs_file_close(&lfs, &file) => 0;
|
||||
}
|
||||
|
||||
lfs_dir_open(&lfs, &dir, "child") => 0;
|
||||
lfs_dir_read(&lfs, &dir, &info) => 1;
|
||||
lfs_dir_read(&lfs, &dir, &info) => 1;
|
||||
for (int i = 0; i < $COUNT; i++) {
|
||||
sprintf(path, "test%03d_loooooooooooooooooong_name", i);
|
||||
lfs_dir_read(&lfs, &dir, &info) => 1;
|
||||
strcmp(info.name, path) => 0;
|
||||
}
|
||||
lfs_dir_read(&lfs, &dir, &info) => 0;
|
||||
lfs_dir_close(&lfs, &dir) => 0;
|
||||
|
||||
if (j == $ITERATIONS-1) {
|
||||
break;
|
||||
}
|
||||
|
||||
for (int i = 0; i < $COUNT; i++) {
|
||||
sprintf(path, "child/test%03d_loooooooooooooooooong_name", i);
|
||||
lfs_remove(&lfs, path) => 0;
|
||||
}
|
||||
}
|
||||
lfs_unmount(&lfs) => 0;
|
||||
TEST
|
||||
scripts/test.py << TEST
|
||||
lfs_mount(&lfs, &cfg) => 0;
|
||||
lfs_dir_open(&lfs, &dir, "child") => 0;
|
||||
lfs_dir_read(&lfs, &dir, &info) => 1;
|
||||
lfs_dir_read(&lfs, &dir, &info) => 1;
|
||||
for (int i = 0; i < $COUNT; i++) {
|
||||
sprintf(path, "test%03d_loooooooooooooooooong_name", i);
|
||||
lfs_dir_read(&lfs, &dir, &info) => 1;
|
||||
strcmp(info.name, path) => 0;
|
||||
}
|
||||
lfs_dir_read(&lfs, &dir, &info) => 0;
|
||||
lfs_dir_close(&lfs, &dir) => 0;
|
||||
for (int i = 0; i < $COUNT; i++) {
|
||||
sprintf(path, "child/test%03d_loooooooooooooooooong_name", i);
|
||||
lfs_remove(&lfs, path) => 0;
|
||||
}
|
||||
lfs_unmount(&lfs) => 0;
|
||||
TEST
|
||||
|
||||
echo "--- Outdated head test ---"
|
||||
scripts/test.py << TEST
|
||||
lfs_mount(&lfs, &cfg) => 0;
|
||||
for (int j = 0; j < $ITERATIONS; j++) {
|
||||
for (int i = 0; i < $COUNT; i++) {
|
||||
sprintf(path, "child/test%03d_loooooooooooooooooong_name", i);
|
||||
lfs_file_open(&lfs, &file, path, LFS_O_CREAT | LFS_O_WRONLY) => 0;
|
||||
lfs_file_close(&lfs, &file) => 0;
|
||||
}
|
||||
|
||||
lfs_dir_open(&lfs, &dir, "child") => 0;
|
||||
lfs_dir_read(&lfs, &dir, &info) => 1;
|
||||
lfs_dir_read(&lfs, &dir, &info) => 1;
|
||||
for (int i = 0; i < $COUNT; i++) {
|
||||
sprintf(path, "test%03d_loooooooooooooooooong_name", i);
|
||||
lfs_dir_read(&lfs, &dir, &info) => 1;
|
||||
strcmp(info.name, path) => 0;
|
||||
info.size => 0;
|
||||
|
||||
sprintf(path, "child/test%03d_loooooooooooooooooong_name", i);
|
||||
lfs_file_open(&lfs, &file, path, LFS_O_WRONLY) => 0;
|
||||
lfs_file_write(&lfs, &file, "hi", 2) => 2;
|
||||
lfs_file_close(&lfs, &file) => 0;
|
||||
}
|
||||
lfs_dir_read(&lfs, &dir, &info) => 0;
|
||||
|
||||
lfs_dir_rewind(&lfs, &dir) => 0;
|
||||
lfs_dir_read(&lfs, &dir, &info) => 1;
|
||||
lfs_dir_read(&lfs, &dir, &info) => 1;
|
||||
for (int i = 0; i < $COUNT; i++) {
|
||||
sprintf(path, "test%03d_loooooooooooooooooong_name", i);
|
||||
lfs_dir_read(&lfs, &dir, &info) => 1;
|
||||
strcmp(info.name, path) => 0;
|
||||
info.size => 2;
|
||||
|
||||
sprintf(path, "child/test%03d_loooooooooooooooooong_name", i);
|
||||
lfs_file_open(&lfs, &file, path, LFS_O_WRONLY) => 0;
|
||||
lfs_file_write(&lfs, &file, "hi", 2) => 2;
|
||||
lfs_file_close(&lfs, &file) => 0;
|
||||
}
|
||||
lfs_dir_read(&lfs, &dir, &info) => 0;
|
||||
|
||||
lfs_dir_rewind(&lfs, &dir) => 0;
|
||||
lfs_dir_read(&lfs, &dir, &info) => 1;
|
||||
lfs_dir_read(&lfs, &dir, &info) => 1;
|
||||
for (int i = 0; i < $COUNT; i++) {
|
||||
sprintf(path, "test%03d_loooooooooooooooooong_name", i);
|
||||
lfs_dir_read(&lfs, &dir, &info) => 1;
|
||||
strcmp(info.name, path) => 0;
|
||||
info.size => 2;
|
||||
}
|
||||
lfs_dir_read(&lfs, &dir, &info) => 0;
|
||||
lfs_dir_close(&lfs, &dir) => 0;
|
||||
|
||||
for (int i = 0; i < $COUNT; i++) {
|
||||
sprintf(path, "child/test%03d_loooooooooooooooooong_name", i);
|
||||
lfs_remove(&lfs, path) => 0;
|
||||
}
|
||||
}
|
||||
lfs_unmount(&lfs) => 0;
|
||||
TEST
|
||||
|
||||
scripts/results.py
|
||||
@@ -428,4 +428,78 @@ scripts/test.py << TEST
|
||||
TEST
|
||||
done
|
||||
|
||||
echo "--- Root seek test ---"
|
||||
./scripts/test.py << TEST
|
||||
lfs_mount(&lfs, &cfg) => 0;
|
||||
for (int i = 3; i < $MEDIUMSIZE; i++) {
|
||||
sprintf(path, "hi%03d", i);
|
||||
lfs_mkdir(&lfs, path) => 0;
|
||||
}
|
||||
|
||||
lfs_dir_open(&lfs, &dir, "/") => 0;
|
||||
for (int i = 0; i < $MEDIUMSIZE; i++) {
|
||||
if (i == 0) {
|
||||
sprintf(path, ".");
|
||||
} else if (i == 1) {
|
||||
sprintf(path, "..");
|
||||
} else if (i == 2) {
|
||||
sprintf(path, "hello");
|
||||
} else {
|
||||
sprintf(path, "hi%03d", i);
|
||||
}
|
||||
lfs_dir_read(&lfs, &dir, &info) => 1;
|
||||
strcmp(path, info.name) => 0;
|
||||
}
|
||||
lfs_dir_read(&lfs, &dir, &info) => 0;
|
||||
lfs_dir_close(&lfs, &dir) => 0;
|
||||
|
||||
for (int j = 0; j < $MEDIUMSIZE; j++) {
|
||||
lfs_soff_t off = -1;
|
||||
|
||||
lfs_dir_open(&lfs, &dir, "/") => 0;
|
||||
for (int i = 0; i < $MEDIUMSIZE; i++) {
|
||||
if (i == 0) {
|
||||
sprintf(path, ".");
|
||||
} else if (i == 1) {
|
||||
sprintf(path, "..");
|
||||
} else if (i == 2) {
|
||||
sprintf(path, "hello");
|
||||
} else {
|
||||
sprintf(path, "hi%03d", i);
|
||||
}
|
||||
|
||||
if (i == j) {
|
||||
off = lfs_dir_tell(&lfs, &dir);
|
||||
off >= 0 => true;
|
||||
}
|
||||
|
||||
lfs_dir_read(&lfs, &dir, &info) => 1;
|
||||
strcmp(path, info.name) => 0;
|
||||
}
|
||||
lfs_dir_read(&lfs, &dir, &info) => 0;
|
||||
lfs_dir_close(&lfs, &dir) => 0;
|
||||
|
||||
lfs_dir_open(&lfs, &dir, "/") => 0;
|
||||
lfs_dir_seek(&lfs, &dir, off) => 0;
|
||||
for (int i = j; i < $MEDIUMSIZE; i++) {
|
||||
if (i == 0) {
|
||||
sprintf(path, ".");
|
||||
} else if (i == 1) {
|
||||
sprintf(path, "..");
|
||||
} else if (i == 2) {
|
||||
sprintf(path, "hello");
|
||||
} else {
|
||||
sprintf(path, "hi%03d", i);
|
||||
}
|
||||
|
||||
lfs_dir_read(&lfs, &dir, &info) => 1;
|
||||
strcmp(path, info.name) => 0;
|
||||
}
|
||||
lfs_dir_read(&lfs, &dir, &info) => 0;
|
||||
lfs_dir_close(&lfs, &dir) => 0;
|
||||
}
|
||||
|
||||
lfs_unmount(&lfs) => 0;
|
||||
TEST
|
||||
|
||||
scripts/results.py
|
||||
|
||||
@@ -107,6 +107,57 @@ scripts/test.py << TEST
|
||||
lfs_unmount(&lfs) => 0;
|
||||
TEST
|
||||
|
||||
echo "--- Write, truncate, and read ---"
|
||||
scripts/test.py << TEST
|
||||
lfs_mount(&lfs, &cfg) => 0;
|
||||
lfs_file_open(&lfs, &file, "sequence",
|
||||
LFS_O_RDWR | LFS_O_CREAT | LFS_O_TRUNC) => 0;
|
||||
|
||||
lfs_size_t size = lfs.cfg->cache_size;
|
||||
lfs_size_t qsize = size / 4;
|
||||
uint8_t *wb = buffer;
|
||||
uint8_t *rb = buffer + size;
|
||||
for (lfs_off_t j = 0; j < size; ++j) {
|
||||
wb[j] = j;
|
||||
}
|
||||
|
||||
/* Spread sequence over size */
|
||||
lfs_file_write(&lfs, &file, wb, size) => size;
|
||||
lfs_file_size(&lfs, &file) => size;
|
||||
lfs_file_tell(&lfs, &file) => size;
|
||||
|
||||
lfs_file_seek(&lfs, &file, 0, LFS_SEEK_SET) => 0;
|
||||
lfs_file_tell(&lfs, &file) => 0;
|
||||
|
||||
/* Chop off the last quarter */
|
||||
lfs_size_t trunc = size - qsize;
|
||||
lfs_file_truncate(&lfs, &file, trunc) => 0;
|
||||
lfs_file_tell(&lfs, &file) => 0;
|
||||
lfs_file_size(&lfs, &file) => trunc;
|
||||
|
||||
/* Read should produce first 3/4 */
|
||||
lfs_file_read(&lfs, &file, rb, size) => trunc;
|
||||
memcmp(rb, wb, trunc) => 0;
|
||||
|
||||
/* Move to 1/4 */
|
||||
lfs_file_size(&lfs, &file) => trunc;
|
||||
lfs_file_seek(&lfs, &file, qsize, LFS_SEEK_SET) => qsize;
|
||||
lfs_file_tell(&lfs, &file) => qsize;
|
||||
|
||||
/* Chop to 1/2 */
|
||||
trunc -= qsize;
|
||||
lfs_file_truncate(&lfs, &file, trunc) => 0;
|
||||
lfs_file_tell(&lfs, &file) => qsize;
|
||||
lfs_file_size(&lfs, &file) => trunc;
|
||||
|
||||
/* Read should produce second quarter */
|
||||
lfs_file_read(&lfs, &file, rb, size) => trunc - qsize;
|
||||
memcmp(rb, wb + qsize, trunc - qsize) => 0;
|
||||
|
||||
lfs_file_close(&lfs, &file) => 0;
|
||||
lfs_unmount(&lfs) => 0;
|
||||
TEST
|
||||
|
||||
echo "--- Truncate and write ---"
|
||||
scripts/test.py << TEST
|
||||
lfs_mount(&lfs, &cfg) => 0;
|
||||
|
||||
Reference in New Issue
Block a user