projects / bertos.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
Refactor countFileSize to return the size directly.
[bertos.git] / bertos / fs / battfs_test.c
diff --git a/bertos/fs/battfs_test.c b/bertos/fs/battfs_test.c
index 7b5600d588015a8258f4eeef264c80eedc56e3ba..1bcb037eaf0254c170f1b523f84648590ff22047 100644 (file)
--- a/bertos/fs/battfs_test.c
+++ b/bertos/fs/battfs_test.c
@@ -53,6 +53,7 @@
 FILE *fp;
 const char test_filename[]="battfs_disk.bin";
 
+static uint8_t page_buffer[PAGE_SIZE];
 
 static bool disk_open(struct BattFsSuper *d)
 {
@@ -68,16 +69,32 @@ static bool disk_open(struct BattFsSuper *d)
 
 static size_t disk_page_read(struct BattFsSuper *d, pgcnt_t page, pgaddr_t addr, void *buf, size_t size)
 {
-       //TRACEMSG("page:%d, addr:%d, size:%d\n", page, addr, size);
+       TRACEMSG("page:%d, addr:%d, size:%d", page, addr, size);
        fseek(fp, page * d->page_size + addr, SEEK_SET);
        return fread(buf, 1, size, fp);
 }
 
-static size_t disk_page_write(struct BattFsSuper *d, pgcnt_t page, pgaddr_t addr, const void *buf, size_t size)
+static size_t disk_buffer_write(struct BattFsSuper *d, pgaddr_t addr, const void *buf, size_t size)
 {
-       //TRACEMSG("page:%d, addr:%d, size:%d\n", page, addr, size);
-       fseek(fp, page * d->page_size + addr, SEEK_SET);
-       return fwrite(buf, 1, size, fp);
+       TRACEMSG("addr:%d, size:%d", addr, size);
+       ASSERT(addr + size <= d->page_size);
+       memcpy(&page_buffer[addr], buf, size);
+
+       return size;
+}
+
+static bool disk_page_load(struct BattFsSuper *d, pgcnt_t page)
+{
+       TRACEMSG("page:%d", page);
+       fseek(fp, page * d->page_size, SEEK_SET);
+       return fread(page_buffer, 1, d->page_size, fp) == d->page_size;
+}
+
+static bool disk_page_save(struct BattFsSuper *d, pgcnt_t page)
+{
+       TRACEMSG("page:%d", page);
+       fseek(fp, page * d->page_size, SEEK_SET);
+       return fwrite(page_buffer, 1, d->page_size, fp) == d->page_size;
 }
 
 static bool disk_page_erase(struct BattFsSuper *d, pgcnt_t page)
@@ -140,7 +157,7 @@ static void test1(BattFsSuper *disk)
                fputc(0xff, fpt);
        fclose(fpt);
        for (int i = 0; i < PAGE_COUNT; i++)
-               ref[i] = PAGE_COUNT - i - 1;
+               ref[i] = i;
 
        testCheck(disk, ref);
        kprintf("Test1: passed\n");
@@ -186,7 +203,7 @@ static void test3(BattFsSuper *disk)
 
        for (int i = PAGE_COUNT / 2; i < PAGE_COUNT; i++)
        {
-               ref[i] = PAGE_COUNT + PAGE_COUNT / 2 - i - 1;
+               ref[i] = i;
        }
 
 
@@ -194,6 +211,7 @@ static void test3(BattFsSuper *disk)
        kprintf("Test3: passed\n");
 }
 
+#if 0
 static void test4(BattFsSuper *disk)
 {
        pgcnt_t ref[PAGE_COUNT];
@@ -248,6 +266,7 @@ static void test5(BattFsSuper *disk)
        testCheck(disk, ref);
        kprintf("Test5: passed\n");
 }
+#endif
 
 static void test6(BattFsSuper *disk)
 {
@@ -256,17 +275,18 @@ static void test6(BattFsSuper *disk)
 
 
        fp = fopen(test_filename, "w+");
-
+       // page, inode, seq, fill, pgoff
        battfs_writeTestBlock(disk, 0, 0, 0, 0, 0);
        battfs_writeTestBlock(disk, 1, 0, 0, 0, 1);
        battfs_writeTestBlock(disk, 2, 0, 1, 0, 1);
-       battfs_writeTestBlock(disk, 3, 0, 0, 0, 0);
+       disk->erase(disk, 3);
+
 
        fclose(fp);
        ref[0] = 0;
        ref[1] = 2;
-       ref[2] = 3;
-       ref[3] = 1;
+       ref[2] = 1;
+       ref[3] = 3;
 
        testCheck(disk, ref);
        kprintf("Test6: passed\n");
@@ -279,17 +299,17 @@ static void test7(BattFsSuper *disk)
 
 
        fp = fopen(test_filename, "w+");
-
+       // page, inode, seq, fill, pgoff
        battfs_writeTestBlock(disk, 0, 0, 0, 0, 0);
        battfs_writeTestBlock(disk, 1, 0, 1, 0, 1);
        battfs_writeTestBlock(disk, 2, 0, 0, 0, 1);
-       battfs_writeTestBlock(disk, 3, 0, 0, 0, 0);
+       disk->erase(disk, 3);
 
        fclose(fp);
        ref[0] = 0;
        ref[1] = 1;
-       ref[2] = 3;
-       ref[3] = 2;
+       ref[2] = 2;
+       ref[3] = 3;
 
        testCheck(disk, ref);
        kprintf("Test7: passed\n");
@@ -303,7 +323,8 @@ static void test8(BattFsSuper *disk)
 
        fp = fopen(test_filename, "w+");
 
-       battfs_writeTestBlock(disk, 0, 0, 0, 0, 0);
+       // page, inode, seq, fill, pgoff
+       disk->erase(disk, 0);
        battfs_writeTestBlock(disk, 1, 0, 0, 0, 0);
        battfs_writeTestBlock(disk, 2, 0, 1, 0, 1);
        battfs_writeTestBlock(disk, 3, 0, 0, 0, 1);
@@ -327,11 +348,12 @@ static void test9(BattFsSuper *disk)
 
        fp = fopen(test_filename, "w+");
 
-       battfs_writeTestBlock(disk, 0, 0, 0, 0, 0);
+       // page, inode, seq, fill, pgoff
+       disk->erase(disk, 0);
        battfs_writeTestBlock(disk, 1, 0, 0, 0, 0);
        battfs_writeTestBlock(disk, 2, 0, 3, 0, 1);
        battfs_writeTestBlock(disk, 3, 0, 0, 0, 1);
-       battfs_writeTestBlock(disk, 4, 0, 0, 0, 0);
+       disk->erase(disk, 4);
        battfs_writeTestBlock(disk, 5, 4, 0, 0, 0);
        battfs_writeTestBlock(disk, 6, 4, 1, 0, 1);
        battfs_writeTestBlock(disk, 7, 4, 0, 0, 1);
@@ -339,12 +361,12 @@ static void test9(BattFsSuper *disk)
 
        fclose(fp);
        ref[0] = 1;
-       ref[1] = 3;
+       ref[1] = 2;
        ref[2] = 5;
        ref[3] = 6;
        ref[4] = 0;
-       ref[5] = 4;
-       ref[6] = 2;
+       ref[5] = 3;
+       ref[6] = 4;
        ref[7] = 7;
 
        testCheck(disk, ref);
@@ -359,17 +381,18 @@ static void test10(BattFsSuper *disk)
 
        fp = fopen(test_filename, "w+");
 
-       int PAGE_FILL = 116;
+       int PAGE_FILL = PAGE_SIZE - BATTFS_HEADER_LEN;
        unsigned int INODE = 0;
        unsigned int INODE2 = 4;
        unsigned int INEXISTENT_INODE = 123;
        unsigned int MODE = 0;
 
-       battfs_writeTestBlock(disk, 0, 123, 0, PAGE_FILL, 0);
+       // page, inode, seq, fill, pgoff
+       disk->erase(disk, 0);
        battfs_writeTestBlock(disk, 1, INODE, 0, PAGE_FILL, 0);
        battfs_writeTestBlock(disk, 2, INODE, 3, PAGE_FILL, 1);
        battfs_writeTestBlock(disk, 3, INODE, 0, PAGE_FILL, 1);
-       battfs_writeTestBlock(disk, 4, INODE2, 0, PAGE_FILL, 0);
+       disk->erase(disk, 4);
        battfs_writeTestBlock(disk, 5, INODE2, 0, PAGE_FILL, 0);
        battfs_writeTestBlock(disk, 6, INODE2, 1, PAGE_FILL, 1);
        battfs_writeTestBlock(disk, 7, INODE2, 0, PAGE_FILL, 1);
@@ -425,16 +448,16 @@ static void test11(BattFsSuper *disk)
 
        fp = fopen(test_filename, "w+");
 
-       unsigned int PAGE_FILL = 116;
+       unsigned int PAGE_FILL = PAGE_SIZE - BATTFS_HEADER_LEN;
        unsigned int INODE = 0;
        unsigned int INODE2 = 4;
        unsigned int MODE = 0;
 
-       battfs_writeTestBlock(disk, 0, 123, 0, PAGE_FILL, 0);
+       disk->erase(disk, 0);
        battfs_writeTestBlock(disk, 1, INODE, 0, PAGE_FILL, 0);
        battfs_writeTestBlock(disk, 2, INODE, 3, PAGE_FILL, 1);
        battfs_writeTestBlock(disk, 3, INODE, 0, PAGE_FILL, 1);
-       battfs_writeTestBlock(disk, 4, INODE2, 0, PAGE_FILL, 0);
+       disk->erase(disk, 4);
        battfs_writeTestBlock(disk, 5, INODE2, 0, PAGE_FILL, 0);
        battfs_writeTestBlock(disk, 6, INODE2, 1, PAGE_FILL, 1);
        battfs_writeTestBlock(disk, 7, INODE2, 0, PAGE_FILL, 1);
@@ -446,7 +469,7 @@ static void test11(BattFsSuper *disk)
        ASSERT(kfile_read(&fd1.fd, buf, sizeof(buf)) == sizeof(buf));
        ASSERT(fd1.fd.seek_pos == sizeof(buf));
        for (size_t i = 0; i < sizeof(buf); i++)
-               ASSERT(buf[i] == 0);
+               ASSERT(buf[i] == 0xff);
 
        ASSERT(kfile_close(&fd1.fd) == 0);
        ASSERT(battfs_close(disk));
@@ -462,16 +485,16 @@ static void test12(BattFsSuper *disk)
 
        fp = fopen(test_filename, "w+");
 
-       const unsigned int PAGE_FILL = 116;
+       const unsigned int PAGE_FILL = PAGE_SIZE - BATTFS_HEADER_LEN;
        unsigned int INODE = 0;
        unsigned int MODE = 0;
-       uint8_t buf[PAGE_FILL + 10];
+       uint8_t buf[PAGE_FILL + BATTFS_HEADER_LEN / 2];
 
-       battfs_writeTestBlock(disk, 0, 123, 0, PAGE_FILL, 0);
+       disk->erase(disk, 0);
        battfs_writeTestBlock(disk, 1, INODE, 0, PAGE_FILL, 0);
        battfs_writeTestBlock(disk, 2, INODE, 3, PAGE_FILL, 1);
        battfs_writeTestBlock(disk, 3, INODE, 0, PAGE_FILL, 1);
-       battfs_writeTestBlock(disk, 4, INODE, 0, PAGE_FILL, 0);
+       disk->erase(disk, 4);
        battfs_writeTestBlock(disk, 5, INODE, 0, PAGE_FILL, 2);
        battfs_writeTestBlock(disk, 6, INODE, 1, PAGE_FILL, 3);
        battfs_writeTestBlock(disk, 7, INODE, 0, PAGE_FILL, 3);
@@ -484,22 +507,22 @@ static void test12(BattFsSuper *disk)
        ASSERT(kfile_read(&fd1.fd, buf, sizeof(buf)) == sizeof(buf));
        ASSERT(fd1.fd.seek_pos == (kfile_off_t)sizeof(buf));
        for (size_t i = 0; i < sizeof(buf); i++)
-               ASSERT(buf[i] == 0);
+               ASSERT(buf[i] == 0xff);
 
        ASSERT(kfile_read(&fd1.fd, buf, sizeof(buf)) == sizeof(buf));
        ASSERT(fd1.fd.seek_pos == (kfile_off_t)sizeof(buf) * 2);
        for (size_t i = 0; i < sizeof(buf); i++)
-               ASSERT(buf[i] == 0);
+               ASSERT(buf[i] == 0xff);
 
        ASSERT(kfile_read(&fd1.fd, buf, sizeof(buf)) == sizeof(buf));
        ASSERT(fd1.fd.seek_pos == (kfile_off_t)sizeof(buf) * 3);
        for (size_t i = 0; i < sizeof(buf); i++)
-               ASSERT(buf[i] == 0);
+               ASSERT(buf[i] == 0xff);
 
-       ASSERT(kfile_read(&fd1.fd, buf, sizeof(buf)) == 86);
+       ASSERT(kfile_read(&fd1.fd, buf, sizeof(buf)) == PAGE_FILL * 4 - sizeof(buf) * 3);
        ASSERT(fd1.fd.seek_pos == (kfile_off_t)fd1.fd.size);
-       for (size_t i = 0; i < 86; i++)
-               ASSERT(buf[i] == 0);
+       for (size_t i = 0; i < PAGE_FILL * 4 - sizeof(buf) * 3; i++)
+               ASSERT(buf[i] == 0xff);
 
        ASSERT(kfile_seek(&fd1.fd, 0, KSM_SEEK_SET) == 0);
        ASSERT(fd1.fd.seek_pos == 0);
@@ -520,14 +543,16 @@ int battfs_testRun(void)
 
        disk.open = disk_open;
        disk.read = disk_page_read;
-       disk.write = disk_page_write;
+       disk.load = disk_page_load;
+       disk.bufferWrite = disk_buffer_write;
+       disk.save = disk_page_save;
        disk.erase = disk_page_erase;
        disk.close = disk_close;
        test1(&disk);
        test2(&disk);
        test3(&disk);
-       test4(&disk);
-       test5(&disk);
+       //test4(&disk);
+       //test5(&disk);
        test6(&disk);
        test7(&disk);
        test8(&disk);
A free, realtime operating system for embedded devices - http://bertos.org/