fc-magnetite: src/cs/drivers/drv_app/ffs/board/tcases.c comparison

comparison src/cs/drivers/drv_app/ffs/board/tcases.c @ 0:945cf7f506b2

src/cs: chipsetsw import from tcs211-fcmodem binary blobs and LCD demo files have been excluded, all line endings are LF only

author	Mychaela Falconia <falcon@freecalypso.org>
date	Sun, 25 Sep 2016 22:50:11 +0000
parents
children

comparison

equal deleted inserted replaced

--1:000000000000
+:945cf7f506b2
+/******************************************************************************
+* Flash File System (ffs)
+* Idea, design and coding by Mads Meisner-Jensen, mmj@ti.com
+*
+* ffs test cases
+*
+* $Id: tcases.c 1.13.1.1.1.66 Thu, 08 Jan 2004 15:05:23 +0100 tsj $
+*
+******************************************************************************/
+#ifndef TARGET
+#include "ffs.cfg"
+#endif
+#include "ffs/ffs_api.h"  // Temp
+#include "ffs/ffs.h"
+#include "ffs/board/tffs.h"
+#include "ffs/board/core.h" // only for block/object recovery test flags
+#include "ffs/board/tdata.h"
+#include "ffs/board/ffstrace.h"
+#include "ffs/board/drv.h"
+#include "ffs/pcm.h"
+#if((TARGET == 1) || (RIV_ENV==1))
+#include "rvf/rvf_api.h"  // this include rv_general.h and rvf_target.h
+#include "rvm/rvm_use_id_list.h"
+#endif
+#include <stdio.h>
+#include <string.h>
+#include <stdlib.h>
+#include <limits.h>
+#include <assert.h>
+#define LUDIR  "/europe/sweden"
+#define MFDIR "/pcm"
+// TODO: reimplement test case bfull (not valid any more).
+// TODO: Cleanup in beginning of each test case for as many cases as
+// possible, so they can be re-run.
+// TODO: Make as many cases as possible fully independent of number of
+// blocks and size of blocks in ffs.
+// TODO: Every testcase should test if it is applicable to the current
+// environment, e.g. some tests are impossible if e have a 2 or 3 block
+// file system.
+// TODO: test case for testing age functionality
+// TODO: Implement case_ren
+// TODO: Implement case_rm
+// NOTEME: DO something with test case flags (PC, IT, RND)?
+// Should we make a test case where we use case_lsr to make map of objects (
+// ensuring mapsize is prime). In a loop, we select a random object (object
+// index[rnd%size]) and perform a random operation on that object?
+// Should test data (tdata[]) be of sizes 2^n+n or Xn+n where n = 0..15
+// Should all test files have suffix ".<tdata-index>"? This would make very
+// easy data checking!
+// Add compiler define: WITH_PCM
+//unsigned char ffs_image[4*4*1024];
+//int ffs_ram_image_address = (int) &ffs_image;
+/******************************************************************************
+* Prototypes and Globals
+******************************************************************************/
+// Helper functions
+int case_cleanup(int min_space);
+int case_mk_rand_file(char *dirname, int max_size, int min_size);
+int ignore_file(char *pathname);
+int case_trace_mask(int p0, int p1);
+int case_reinit(int p0, int p1);
+int case_debug_help(int p0, int p1);
+struct object_s {
+char *name;
+struct xstat_s stat;
+};
+const struct testcase_s testcase[];
+// Benchmark (not in use yet)
+struct results_s {
+int w16B;
+int w256B;
+int w4096B;
+int rew4096B;
+int r16B;
+int r256B;
+int r4096B;
+int lfile;
+int ldir;
+int lonef;
+};
+/******************************************************************************
+* Collective Test Cases
+******************************************************************************/
+// test cases: all, alot, most, much + specific ones
+int case_all(int p0, int p1)
+{
+#if (TARGET == 1)
+UINT32 time_begin, elapsed;
+time_begin = tffs_timer_begin();
+#endif
+// We have to run test case 'init' after test case 'format'. This is
+// because 'init' test case calls test_ffs_params_get() which
+// initializes variables used in many of the testcases.
+error = test_run("ninit;format;i;world;eu;pcm;apiexc;"
+"bigf;open;rw;seek;append;ren;mopen;"
+"jnl;irec;drec;trunc;brec;stat;"
+"lu;fc;root;dirs;frd;bfull;dsync;"
+"ssym;find;ri;x;fwflags;query;octrl");
+#if (TARGET == 1)
+elapsed = tffs_timer_end(time_begin);
+ttw(ttr(TTrAll, "Time elapsed %ds" NL, elapsed / 1000));
+#endif
+test_statistics_print();
+return error;
+// Not implemented test cases...
+return test_run("rm;pcm;");
+}
+int case_alot(int p0, int p1)
+{
+return test_run("ninit;format;ri;i;ri;world;ri;eu;ri;fwflags;ri;"
+"bigf;ri;open;ri;rw;ri;seek;ri;append;ri;ren;ri;"
+"jnl;ri;irec;ri;brec;ri;stat;ri;trunc;ri;mopen;ri;"
+"lu;ri;fc;ri;root;ri;dirs;ri;frd;ri;bfull;ri;"
+"ssym;ri;find;ri;x;ri;dsync;ri;pcm;ri;query;ri;octrl");
+}
+int case_tall(int p0, int p1)
+{
+return test_run("ninit;format;i;world;eu;fwflags;"
+"bigf;jnl;irec;drec;ren;apiexc;"
+"stat;open;rw;seek;trunc;append;octrl;"
+"lu;fc;root;dirs;frd;bfull;pcm;query;"
+"ssym;find;x;ex;bf;nb;mopen;dsync;brec");
+}
+// Ad hoc test case
+int case_test(int p0, int p1)
+{
+return test_run("format;i;world;eu;ri;mopen1;ri;fwflags;ri;"
+"bigf;ri;jnl;ri;irec;ri;drec;ri;brec;ri;pcm;ri;"
+"trunc1;ri;stat;open1;ri;rw1;ri;seek1;ri;ren;ri;"
+"lu;ri;fc;ri;root;ri;dirs;ri;frd;ri;bfull;ri;"
+"ssym;ri;find;ri;x;ri;append;ri;dsync;ri;");
+}
+extern struct dev_s dev;
+// Agressive all. Run case 'all' for dev.numblocks in the range dev.numblocks..4
+int case_aall(int p0, int p1)
+{
+char myname[20];
+int i, failed = 0;
+if (dev.numblocks * dev.blocksize > 1024*1024)
+strcpy(myname, "/ffs/b999");
+else
+strcpy(myname, "/ffs/b99");
+/** There's no need to test for i=127,126,125,124..3,2,1. So for i
+* >= 20 we progress a little faster. */
+for (i = dev.numblocks; i >= 3; i -= (i >= 20 ? i/4 : 1))
+{
+tw(tr(TR_FUNC, TrTest, "TEST aall. %d\n", i));
+ttw(ttr(TTrTest, "TEST aall. %d" NL, i));
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+sprintf(myname, "/ffs/b%d", i);
+tffs_format(myname, 0x2BAD);
+expect(error, EFFS_OK);
+failed += test_run("i;world;eu;bigf;bfull;"
+"jnl;irec;drec;brec;stat;dsync;"
+"open;rw;seek;trunc;ren;mopen;"
+"lu;fc;root;dirs;frd;append;"
+"ssym;find;ri;x");
+}
+return failed;
+}
+// This is a collection of all failing testcases to be investigated.
+int case_fail(int p0, int p1)
+{
+int result;
+const char imeifile[] = "/europe/norway/IMEI";
+switch (p0) {
+case 1:
+tw(tr(TR_FUNC, TrTestHigh,
+"remember to run case_fcontrol before this one\n"));
+// Make symlink to imeifile and try to update it
+error = tffs_symlink("/europe/imie", imeifile);
+expect(error, EFFS_ACCESS);
+error = tffs_fwrite("/europe/imie", TDATA(1));
+expect(error, EFFS_ACCESS);
+break;
+case 2:
+if (1) {
+const char bigfile[] = "/iceberg";
+int bytes_max, file_size;
+char myname[] = "/ffs/b7";
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format(myname, 0x2BAD);
+expect(error, EFFS_OK);
+ffs_query(Q_BYTES_FREE, (uint32 *) &bytes_max);
+// File the system with this huge file
+file_size = bytes_max;
+ttw(ttr(TTrTest, "Bigfile of size %d" NL, file_size));
+tw(tr(TR_FUNC, TrTestHigh, "Bigfile of size %d\n", file_size));
+error = tffs_fcreate(bigfile, (char *) tdata[TDATA_HUGE], file_size);
+expect(error, EFFS_OK);
+}
+break;
+default:
+result = 1;
+}
+return result;
+}
+// zzz to easy search ;-)
+// NOTE: Move the below tests
+extern char *tdata_huge;
+// Test that a FFS API blocking call that not is able to send a mail to FFS fails as expected and don't lock the system (it must unlock and delete the mutex).
+int case_okay(int p0, int p1)
+{
+error = tffs_fwrite("/test", tdata[TDATA_HUGE], 20);
+expect_ok(error);
+error = tffs_fread("/test", bigbuf, 20);
+expect_ok(error);
+bigbuf[20] = 0;
+tw(tr(TR_FUNC, TrTestHigh, "String '%s'\n", bigbuf));
+return EFFS_OK;
+}
+// Run testcases in a random order. Only the test cases in the test case
+// table that are marked as re-runnable, are run.
+int case_rand(int p0, int p1)
+{
+int i, n, seed, max = 0, error = 0;
+const struct testcase_s *p;
+// This is a way to activate trace at a defined test number. If rand
+// test number 134 fail it is possible to activate trace at test number
+// 133 etc. Note we have to change activate_trace_nr manual before compile.
+int activate_trace_nr = 0;
+int trace_mask = 0xFFDFF;
+// NOTE: use p1 as active_trace_nr? or make it
+p0 = (p0 == 0 ? 117 : p0); // Number of test cases to run
+p1 = (p1 == 0 ? 567 : p1); // Initial seed
+seed = p1;
+if (seed == 1) {
+; // TODO: Set seed as a variable of current time
+}
+// TODO: Initialize seed from p1.
+// First count total number of test cases
+for (p = testcase; p->name; p++)
+max++;
+tw(tr(TR_FUNC, TrTestHigh,
+"Number of available random test cases = %d\n", max));
+for (i = 0; i < p0; i++)
+{
+do {
+n = rand() % max;
+} while ((testcase[n].flags & RND) == 0);
+if ((i + 1) == activate_trace_nr) {
+#if (TARGET == 0)
+tr_init(trace_mask, 2, 0 );
+#else
+ttr_init(trace_mask);
+#endif
+tw(tr_bstat());
+}
+tw(tr(TR_FUNC, TrTest, "Nr: %d", i + 1));
+ttw(ttr(TTrTest, "Nr: %d" NL, i + 1));
+if ((error = test_run(testcase[n].name)))
+break;
+}
+if (p1 == 1)
+tw(tr(TR_FUNC, TrTestHigh, "Initial seed = %d\n", seed));
+test_statistics_print();
+return error;
+}
+/******************************************************************************
+* Population Tests
+******************************************************************************/
+int case_world(int p0, int p1)
+{
+int i;
+const char *dirs[] = { "/antarctica",    "/africa",
+"/asia",          "/europe",
+"/north-america", "/south-america",
+"/australia" };
+// Cleanup
+for (i = 0; i < sizeof(dirs)/sizeof(char *); i++) {
+tffs_remove(dirs[i]);
+}
+for (i = 0; i < sizeof(dirs)/sizeof(char *); i++) {
+error = tffs_mkdir(dirs[i]);
+expect(error, EFFS_OK);
+}
+return 0;
+}
+int case_europe(int p0, int p1)
+{
+int i;
+const char *dirs[] = { "/europe/denmark", "/europe/sweden",
+"/europe/norway",  "/europe/finland" };
+// Cleanup
+for (i = 0; i < sizeof(dirs)/sizeof(char *); i++) {
+error = tffs_remove(dirs[i]);
+}
+for (i = 0; i < sizeof(dirs)/sizeof(char *); i++) {
+error = tffs_mkdir(dirs[i]);
+expect(error, EFFS_OK);
+}
+return 0;
+}
+int case_denmark(int p0, int p1)
+{
+// Cleanup
+tffs_remove("/europe/denmark/jutland");
+tffs_remove("/europe/denmark/sealand");
+error = tffs_mkdir("/europe/denmark/jutland");
+expect(error, EFFS_OK);
+error = tffs_mkdir("/europe/denmark/sealand");
+expect(error, EFFS_OK);
+return 0;
+}
+/******************************************************************************
+* Atomic Tests
+******************************************************************************/
+int case_init(int p0, int p1)
+{
+error = tffs_initialize();
+// ignore error
+error = test_ffs_params_get();
+expect(error, EFFS_OK);
+return 0;
+}
+int case_exit(int p0, int p1)
+{
+error = tffs_exit();
+expect(error, EFFS_OK);
+return 0;
+}
+int case_only_preformat(int p0, int p1)
+{
+tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+return 0;
+}
+int case_only_format(int p0, int p1)
+{
+tffs_format("/ffs", 0x2BAD);
+expect(error, EFFS_OK);
+return 0;
+}
+int case_reset(int p0, int p1)
+{
+error = tffs_initialize();
+// ignore result
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format("/ffs", 0x2BAD);
+expect(error, EFFS_OK);
+error = tffs_exit();
+expect(error, EFFS_OK);
+return 0;
+}
+int case_status(int p0, int p1)
+{
+error = test_run("lsr");
+return error;
+}
+/******************************************************************************
+* Special Tests
+******************************************************************************/
+// Test FFS with only 2 blocks in device
+int case_twob(int p0, int p1)
+{
+int space_left;
+int size, i;
+char myname[] = "/two_block99";
+// Format ffs to use only 2 block no journal file and no reserved space.
+// Make some directoryes.
+// Fill ffs allmost to the edge and try to write over the edge.
+// Read back all the files.
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format("/ffs/b2j0m0", 0x2BAD);
+expect(error, EFFS_OK);
+error = test_run("i;world;eu;x");
+if(error) return 1;
+// Calculate the amount of space that is left to user data because some space
+// is used to directoryes
+space_left = dev.blocksize - (13 * 20);
+tw(tr(TR_FUNC, TrTestHigh, "Space left: %d\n", space_left));
+size = space_left;
+for(i = 0; i < 6; i++) {
+size = size/2;
+sprintf(myname, "/two_block%d", i);
+error = tffs_fwrite(myname, (char*)tdata[TDATA_HUGE],
+size >= 20 ? size - 20 : 0);
+expect(error, EFFS_OK);
+}
+error = tffs_fwrite(myname, (char*)tdata[TDATA_HUGE], space_left/5);
+expect(error, EFFS_NOSPACE);
+// 20 is the average space used to the file name + word align.
+size = space_left;
+for(i = 0; i < 6; i++) {
+size = size/2;
+sprintf(myname, "/two_block%d", i);
+error = tffs_fread(myname, bigbuf, bigbuf_size);
+expect(error, size >= 20 ? size - 20 : 0);
+}
+//error = ffs_object_control(0, OC_DEV_DEVICE, 0x080D);
+//if (error < 0) return error;
+return 0;
+}
+// Test FFS with only 3 blocks in device
+int case_threeb(int p0, int p1)
+{
+char mytest[20];
+// Format ffs to use only 3 blocks, make directoryes and run test case
+// rand <p0> number of times.
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format("/ffs/b3r24", 0x2BAD);
+expect(error, EFFS_OK);
+error = test_run("i;world;eu;x");
+if (error) return 1;
+if(p0 == 0) p0 = 233;
+sprintf(mytest, "rand%d", p0);
+return test_run(mytest);
+}
+// Simulate a typical usage of ffs. We expect one part of the data will be
+// what we call 'static' data (calibration files etc) the other part is the
+// 'dynamic' data (wap, sms etc) we do also expect that they don't fill FFS
+// completely thus we have a 'free' part.
+int case_customer(int nblocks, int nloops)
+{
+int free_part = 5, static_part = 47, dynamic_part = 47;
+int free_size, static_size, dynamic_size;
+int bytes_free, bytes_max, bytes_used;
+int file_size_max, file_size_min, file_size_avg;
+int i, j, max_obj_block, num_static_files;
+char myname[] = "/ffs/bxxx/";
+char file_name[FFS_FILENAME_MAX + 1];
+char path[FFS_FILENAME_MAX * 2];
+char static_dir[] ="/READONLY";
+char dynamic_dir[] = "/rand";
+struct dir_s dir;
+if (nblocks == 0)
+nblocks = 7;
+if (nloops == 0)
+nloops = 300;
+error = tffs_preformat(0xDEAD);      expect(error, EFFS_OK);
+sprintf(myname, "/ffs/b%d", nblocks);
+error = tffs_format(myname, 0x2BAD); expect(error, EFFS_OK);
+tffs_mkdir(dynamic_dir); expect(error, EFFS_OK);
+tffs_mkdir(static_dir);  expect(error, EFFS_OK);
+ffs_query(Q_BYTES_FREE, &bytes_max);
+free_size = bytes_max * free_part / 100;
+static_size = bytes_max * static_part / 100;
+dynamic_size = bytes_max * dynamic_part / 100;
+tw(tr(TR_FUNC, TrTest, "Free:%d,%dkB. Static:%d,%dkB, Dynamic:%d,%dkB\n",
+free_part, free_size/1024, static_part, static_size/1024,
+dynamic_part, dynamic_size/1024));
+// Find max average objects per block
+max_obj_block = fs.block_files_max;
+if (max_obj_block > fs.objects_max / (dev.numblocks -1 - fs.blocks_free_min))
+max_obj_block = fs.objects_max / (dev.numblocks -1 - fs.blocks_free_min);
+tw(tr(TR_FUNC, TrTest, "Max average objects per block %d\n", max_obj_block));
+ttw(ttr(TTrTest, "Max avg obj per block %d" NL, max_obj_block));
+// Average (minimum) file size (avoid to reach block_files_max and
+// objects_max)
+file_size_avg = dev.blocksize / max_obj_block;
+ffs_query(Q_BYTES_USED, &bytes_used);
+tw(tr(TR_FUNC, TrTest, "Write static files (avg size %d)\n", file_size_avg));
+ttw(ttr(TTrTest, "avg size %d" NL, file_size_avg));
+do {
+i++;
+file_size_min = 5;
+// For each 5 file we make one huge.
+file_size_max = i % 5 ? file_size_avg * 2 : file_size_avg * 15;
+// For each 6 file we make one small.
+file_size_max = i % 6 ? file_size_max : 5;
+// Saturate, avoid to make one file that parses the total static_size
+if (file_size_max > static_size - bytes_used)
+file_size_max = file_size_min = static_size - bytes_used;
+// For each 7 file we create one dynamic (If the block is full with only
+// valid objects do we risk that this block never will be reclaimed!).
+if (i % 7)
+error = case_mk_rand_file(dynamic_dir, file_size_max, file_size_min);
+else
+error = case_mk_rand_file(static_dir, file_size_max, file_size_min);
+expect_ok(error);
+ffs_query(Q_BYTES_USED, &bytes_used);
+} while (bytes_used < static_size);
+num_static_files = tffs_opendir(static_dir, &dir);
+expect_ok(num_static_files);
+tw(tr(TR_FUNC, TrTest, "Written %d files\n", num_static_files));
+ttw(ttr(TTrTest, "Written %d files" NL, num_static_files));
+// In a loop we continue to write data until only the wanted free_part is
+// left, after that we remove half of the just created files and then write
+// again and again...
+j = 0;
+tw(tr(TR_FUNC, TrTest, "Write and remove dynamic files\n"));
+ttw(ttr(TTrTest, "Write and remove dynamic files" NL));
+for (i = 0; i < nloops; i++) {
+if (i % 10 == 0) {
+tw(tr(TR_FUNC, TrTest, "loop %d\n", i));
+ttw(ttr(TTrTest, "loop %d" NL, i));
+}
+ffs_query(Q_BYTES_FREE, &bytes_free);
+do {
+j++;
+file_size_min = 5;
+file_size_max = j % 5 ? file_size_avg * 2 : file_size_avg * 15;
+file_size_max = j % 6 ? file_size_max : 5;
+// Saturate, avoid using the free space.
+if (file_size_max > bytes_free - free_size)
+file_size_max = file_size_min = bytes_free - free_size;
+if (file_size_max < 0)
+break;
+error = case_mk_rand_file(dynamic_dir, file_size_max, file_size_min);
+// NOTE it is very difficult to avoid EFFS_FSFULL because cleanup will
+// sometimes only remove the big files thus there will exist a lot of small
+// that use all the inodes.
+if (error == EFFS_FSFULL) {
+tw(tr(TR_FUNC, TrTest, "Warning no free inodes\n"));
+ttw(ttr(TTrTest, "Warning no free inodes" NL));
+error = case_cleanup(free_size + dynamic_size);
+}
+else
+expect_ok(error);
+ffs_query(Q_BYTES_FREE, &bytes_free);
+} while (bytes_free > free_size);
+error = case_cleanup(free_size + dynamic_size / 2);
+expect_ok(error);
+}
+error = case_reinit(0, 0);
+expect(EFFS_OK, error);
+tw(tr(TR_FUNC, TrTest, "Verify all files\n"));
+ttw(ttr(TTrTest, "Verify all files" NL));
+for (i = 0; i < 2; i++) {
+if (i == 0) {
+error = tffs_opendir(static_dir, &dir);
+expect_eq(error, num_static_files);
+}
+else {
+error = tffs_opendir(dynamic_dir, &dir);
+expect_ok(error);
+}
+while ((error = tffs_readdir(&dir, file_name, sizeof(file_name))) > 0) {
+if (i == 0)
+strcpy(path, static_dir);
+else
+strcpy(path, dynamic_dir);
+strcat(path, "/");
+strcat(path, file_name);
+error = tffs_stat(path, &stat);
+expect_ok(error);
+error = test_expect_file(path, tdata[TDATA_HUGE], stat.size);
+if (error) return 1;
+}
+}
+test_statistics_print();
+return 0;
+}
+// TODO cleanup this test. Use stat and verify some of the files etc.
+// Used to test ConQuest issue FFS_FIX-11368 We fill FFS with a lot of small
+// files. Then by turn remove some files and write new files, always very
+// close to max avaible bytes.
+// Note the below test is not able to run in big configuration because it
+// creates a lot of small files thus we reach EFFS_FSFULL 'out of inodes'
+int case_ffull(int p0, int p1)
+{
+int error, i, bytes_free, file_size, max_write_size = 1000;
+char myname[] = "/ffs/bxxx/";
+if (p0 == 0)
+p0 = 100; // Default 100 loops
+if (p1 == 0 || p1 > 999)
+p1 = 3;   // Default run in 3 blocks
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+sprintf(myname, "/ffs/b%d", p1);
+error = tffs_format(myname, 0x2BAD);
+expect(error, EFFS_OK);
+tffs_mkdir("/rand");
+expect(error, EFFS_OK);
+tw(tr(TR_FUNC, TrTest, "Fill it with files until it fails\n"));
+ttw(ttr(TTrTest, "Fill it with files until it fails" NL));
+// We have to avoid too many small files or else do we reach objects_max
+ffs_query(Q_BYTES_FREE, &bytes_free);
+max_write_size = bytes_free / fs.objects_max * 2.5;
+do {
+error = case_mk_rand_file("/rand", max_write_size, 0);
+} while (error >= 0 );
+tw(tr(TR_FUNC, TrTest, "Fill done (%d)\n" ,error));
+ttw(ttr(TTrTest, "Fill done (%d)" NL, error));
+expect(error, EFFS_NOSPACE);  // Now are we sure that it is full
+tw(tr(TR_FUNC, TrTest, "Cleanup and fill again \n"));
+for (i = 0; i < (1 + p0); i++) {
+tw(tr(TR_FUNC, TrTestHigh, "Loop %d \n", i + 1));
+ttw(ttr(TTrTest, "Loop %d" NL, i + 1));
+tw(tr_bstat());
+error = case_cleanup(max_write_size * 3);
+tw(tr_bstat());
+do {
+ffs_query(Q_BYTES_FREE, &bytes_free);
+// Saturate size
+file_size = bytes_free > max_write_size ? max_write_size :bytes_free;
+// Query BYTES_FREE don't count the below data use.
+//file_size -= (FFS_FILENAME_MAX + 1 + dev.atomsize);
+if (file_size < 0)
+break;
+error = case_mk_rand_file("/rand", file_size - (FFS_FILENAME_MAX+1), 0);
+if (error == EFFS_FSFULL) { // Out of inodes
+error = case_cleanup(max_write_size * 6);
+// Create bigger files to avoid '-11', auto fit :-)
+max_write_size *= 1.1;  // Add 10%
+tw(tr(TR_FUNC, TrTestHigh, "Out of inodes, write size: %d \n",
+max_write_size));
+continue;
+}
+expect_ok(error);
+} while (file_size != bytes_free);
+}
+tw(tr(TR_FUNC, TrTest, "Test finish (%d) \n", error));
+ttw(ttr(TTrTest, "Test finish (%d)" NL, error));
+if (error >= 0)
+return EFFS_OK;
+return error;
+}
+int case_rivtype(int p0, int p1)
+{
+// Use the compiler to test if the types are correctly defined. We don't
+// need to run this test just make a compilation.
+T_FFS_OPEN_FLAGS flags = FFS_O_RDONLY;
+T_FFS_SIZE size = 20;
+T_FFS_RET error = -10;
+T_FFS_WHENCE whence = FFS_SEEK_SET;
+T_FFS_STAT stat;
+T_FFS_DIR dir;
+T_FFS_FD fd = FFS_FD_OFFSET;
+T_RV_RETURN callback;
+T_FFS_FILE_CNF confirm;
+T_FFS_OBJECT_TYPE objt = OT_FILE;
+// Use the defined variables to avoid the boring warning: unused
+// variable 'xx'
+if (flags != FFS_O_RDONLY)  return 1;
+if (size != 20)             return 1;
+if (error != -10)           return 1;
+if (whence != FFS_SEEK_SET) return 1;
+if (fd != FFS_FD_OFFSET)    return 1;
+if (objt != OT_FILE)        return 1;
+stat.type = 1;
+if (stat.type != 1) return 1;
+dir.this = 5;
+if (dir.this != 5) return 1;
+callback.addr_id = 3;
+if (callback.addr_id != 3) return 1;
+confirm.error = -1;
+if (confirm.error != -1) return 1;
+return 0;
+}
+/******************************************************************************
+* Pseudo Tests
+******************************************************************************/
+// Recursively read objects in directory. Does NOT check for buffer
+// overflow!
+int case_dir_list(char *dirname, struct object_s **pplist, char **ppnames)
+{
+struct object_s *plist, *plist_start, *plist_end;
+char pathname[6 * 20];
+struct dir_s dir;
+char *pnames, *pn;
+int i, pathlen;
+//tw(tr(TR_BEGIN, TrTestHigh, "dir_list('%s', %d, 0x%x)\n",
+//      dirname, (int)*pplist/sizeof(struct object_s), *ppnames));
+plist_start = plist = *pplist;
+pnames = *ppnames;
+strcpy(pathname, dirname);
+pathlen = strlen(pathname);
+// remove trailing slash. It is tiring to handle the root directory
+// differently from other directories. In a future ffs revision, this
+// trailing slash should be allowed!
+if (pathname[pathlen - 1] == '/') {
+pathname[pathlen - 1] = 0;
+pathlen--;
+}
+if (strlen(pathname) == 0)
+error = tffs_opendir("/", &dir);
+else
+error = tffs_opendir(pathname, &dir);
+expect_ok(error);
+pn = pathname + strlen(pathname);
+*pn++ = '/';
+*pn = 0;
+error = 1;
+for (i = 0; (error = tffs_readdir(&dir, pn, 21)) > 0; i++)
+{
+error = tffs_xlstat(pathname, &plist->stat);
+expect(error, EFFS_OK);
+// Copy full object pathname to buffer, working downwards.
+pnames -= strlen(pathname) + 1;
+// Check for buffer overflow (if pnames <= plist)
+expect_gt((int) pnames, (int) plist);
+strcpy(pnames, pathname);
+plist->name = pnames;
+plist++;
+}
+*pplist = plist;
+*ppnames = pnames;
+// For each directory in the retrieved list, recurse.
+plist_end = plist;
+for (plist = plist_start; plist < plist_end; plist++) {
+if (plist->stat.type == OT_DIR)
+i += case_dir_list(plist->name, pplist, ppnames);
+}
+// tw(tr(TR_END, TrTestHigh, "} %d\n", i));
+return i;
+}
+int case_find(int p0, int p1)
+{
+struct object_s *plist, *plist_start;
+char *pnames, *pnames_start;
+int n, names_used, list_used;
+plist  = plist_start  = (struct object_s *) bigbuf;
+pnames = pnames_start = bigbuf + bigbuf_size;
+n = case_dir_list("/", &plist, &pnames);
+list_used = n * sizeof(struct object_s);
+names_used = pnames_start - pnames;
+tw(tr(TR_FUNC, TrTestHigh, "Buffer space used: %d + %d = %d\n",
+list_used, names_used, list_used + names_used));
+ttw(ttr(TTrTest, "Buffer space used: %d + %d = %d" NL,
+list_used, names_used, list_used + names_used));
+return 0;
+}
+// TODO: We should accumulate all stat.space and check it vs. the number of
+// bytes used!
+int case_lsr(int p0, int p1)
+{
+struct object_s *plist, *plist_start;
+char *pnames, *pnames_start;
+char of[3];
+int i, n;
+plist  = plist_start  = (struct object_s *) bigbuf;
+pnames = pnames_start = bigbuf + bigbuf_size;
+n = case_dir_list("/", &plist, &pnames);
+tw(tr(TR_FUNC, TrTestHigh, "Total %d objects.\n", n));
+ttw(ttr(TTrTest, "Total %d objects" NL, n));
+plist = plist_start;
+for (i = 0; i < n; i++, plist++) {
+strcpy(of, "  ");
+switch (plist->stat.type) {
+case OT_FILE: of[0] = ' '; break;
+case OT_DIR:  of[0] = 'd'; break;
+case OT_LINK: of[0] = 'l'; break;
+}
+if (plist->stat.flags & OF_READONLY)
+of[1] = 'r';
+#if (TARGET == 0)
+printf("%3d: %s %3d %2d/%04X (%4d,%4d) %5d %s\n",
+i, of,
+plist->stat.inode, plist->stat.block,
+plist->stat.location, plist->stat.sequence, plist->stat.updates,
+plist->stat.size, &plist->name[1]);
+#else
+ttw(ttr(TTrTest, "%3d: %s %3d %2d/%04X (%4d,%4d) %5d %s" NL,
+i, of,
+plist->stat.inode, plist->stat.block,
+plist->stat.location, plist->stat.sequence, plist->stat.updates,
+plist->stat.size, &plist->name[1]));
+#endif
+}
+return 0;
+}
+/******************************************************************************
+* Normal Tests
+******************************************************************************/
+int case_format(int p0, int p1)
+{
+error = tffs_preformat(0xD00D);
+expect(error, EFFS_INVALID);
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format("/ffs/", 0xDEAD);
+expect(error, EFFS_INVALID);
+error = tffs_format("ffs", 0x2BAD);
+expect(error, EFFS_BADNAME);
+error = tffs_format("", 0x2BAD);
+expect(error, EFFS_BADNAME);
+error = tffs_format("/", 0x2BAD);
+expect(error, EFFS_OK);
+error = tffs_format("/ffs", 0x2BAD);
+expect(error, EFFS_NOPREFORMAT);
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format(0, 0x2BAD);
+//error = tffs_format("/ffs/i256o128", 0x2BAD);
+expect(error, EFFS_OK);
+return 0;
+}
+// Test that it is illegal to modify root inode as if it was a normal file
+// or directory
+int case_root(int p0, int p1)
+{
+error = tffs_opendir("/", &dir);
+expect_ok(error);
+error = tffs_fcreate("/", "foo", 3);
+expect(error, EFFS_EXISTS);
+error = tffs_fupdate("/", "bar", 3);
+expect(error, EFFS_NOTAFILE);
+error = tffs_fwrite("/", "foo", 3);
+expect(error, EFFS_NOTAFILE);
+error = tffs_remove("/");
+expect(error, EFFS_ACCESS);
+return 0;
+}
+// Test object lookup, object names etc.
+int case_lookup(int p0, int p1)
+{
+// Swedish Provinces: Blekinge, Smaaland, Halland, Vaermland, Dalarna,
+// Dalsland, Gotland, Gaestrikland, Haelsingland, Bohuslaen,
+// Haerjedalen, Jaemtland, Lappland, Medelpad, Norrbotten, Naerke,
+// Soedermanland, Uppland, Vaesterbotten
+// Smaaland Cities: Vetlanda, Bodafors, Rottne, Ljungby, Nybro,
+// Hultsfred, Oskarshamn, Vimmerby, Hyltebruk, Joenkoeping, Vaexjoe
+tffs_mkdir("/europe");
+tffs_mkdir("/europe/sweden");
+// test init
+error = tffs_mkdir(LUDIR "/Smaaland");
+expect(error, EFFS_OK);
+// test BAD_FILENAME
+error = tffs_fcreate("", TDATA(0));
+expect(error, EFFS_BADNAME);
+// test EFFS_EXISTS
+error = tffs_fcreate(LUDIR "/Smaaland/vetlanda", TDATA(0));
+expect(error, EFFS_OK);
+error = tffs_fcreate(LUDIR "/Smaaland/vetlanda", TDATA(0));
+expect(error, EFFS_EXISTS);
+error = tffs_mkdir(LUDIR "/Smaaland");
+expect(error, EFFS_EXISTS);
+error = tffs_fwrite(LUDIR "/Smaaland/vetlanda", TDATA(1));
+expect(error, EFFS_OK);
+// test EFFS_BADNAME
+error = tffs_fcreate(LUDIR "/Smaaland/A_Zaz.0+9-7!", TDATA(2));
+expect(error, EFFS_BADNAME);
+error = tffs_fcreate(LUDIR "/Smaaland/A_Zaz.0+9-7#%$", TDATA(2));
+expect(error, EFFS_OK);
+// test ending slash
+error = tffs_mkdir(LUDIR "/Smaaland/Vaexjoe/");
+expect(error, EFFS_NOTADIR);
+error = tffs_fcreate(LUDIR "/Smaaland/Vaexjoe/", TDATA(3));
+expect(error, EFFS_NOTADIR);
+// test EFFS_NAMETOOLONG
+error = tffs_fcreate(LUDIR "/Smaaland/Hultsfred-is-21-chars", TDATA(4));
+expect(error, EFFS_NAMETOOLONG);
+error = tffs_fcreate(LUDIR "/Smaaland/Bodafors-is-20-chars", TDATA(4));
+expect(error, EFFS_OK);
+error = tffs_mkdir(LUDIR "/Vaermland-is-21-chars");
+expect(error, EFFS_NAMETOOLONG);
+error = tffs_mkdir(LUDIR "/Dalsland-is-20-chars");
+expect(error, EFFS_OK);
+// test EFFS_NOTADIR
+error = tffs_mkdir(LUDIR "/DontMakeSeveral/DirsAt/TheSameTime");
+expect(error, EFFS_NOTADIR);
+error = tffs_fread(LUDIR "/Lappland/Bodafors-is-20-chars", bigbuf, 1024);
+tw(tr(TR_END, TrApi, "} %d\n", error)); // Avoid wrong indent
+expect(error, EFFS_NOTADIR);
+error = tffs_fread(LUDIR "/Lappland/", bigbuf, 1024);
+tw(tr(TR_END, TrApi, "} %d\n", error)); // Avoid wrong indent
+expect(error, EFFS_NOTADIR);
+error = tffs_fread(LUDIR "/Smaaland/Bodafors", TDATA(4));
+tw(tr(TR_END, TrApi, "} %d\n", error)); // Avoid wrong indent
+expect(error, EFFS_NOTFOUND);
+// test EFFS_PATHTOODEEP
+error = tffs_mkdir(LUDIR "/Gotland"); // 3. level
+expect(error, EFFS_OK);
+error = tffs_mkdir(LUDIR "/Gotland/Visby"); // 4. level
+expect(error, EFFS_OK);
+error = tffs_mkdir(LUDIR "/Gotland/Visby/level5"); // 5. level
+expect(error, EFFS_OK);
+error = tffs_mkdir(LUDIR "/Gotland/Visby/level5/level6"); // 6. level
+expect(error, EFFS_OK);
+error = tffs_mkdir(LUDIR "/Gotland/Visby/level5/level6/level7"); // 7. level
+expect(error, EFFS_PATHTOODEEP);
+error = tffs_fcreate(LUDIR "/Gotland/Visby/level5/level6/level7",
+TDATA(5)); // 7. level
+expect(error, EFFS_PATHTOODEEP);
+// final checks
+error = test_expect_file(LUDIR "/Smaaland/vetlanda", TDATA(1));
+if (error) return 1;
+error = test_expect_file(LUDIR "/Smaaland/Bodafors-is-20-chars", TDATA(4));
+if (error) return 1;
+error = tffs_opendir(LUDIR "/Dalsland-is-20-chars", &dir);
+expect_ok(error);
+error = tffs_opendir(LUDIR "/Gotland/Visby/level5/level6", &dir);
+expect_ok(error);
+// cleanup
+error = tffs_remove(LUDIR "/Smaaland/A_Zaz.0+9-7");
+return 0;
+}
+// Test fcontrol and read-only semantics. TODO: We still need to perform
+// same tests on a dir and a symlink and thru a symlink.
+int case_fcontrol(int p0, int p1)
+{
+struct ffs_state_s old, new;
+const char rofile[]   = "/europe/norway/rofile";
+const char imeifile[] = "/europe/norway/IMEI";
+fd_t fdi;
+// Cleanup
+tffs_remove(rofile);
+tffs_remove("/europe/norway");
+tffs_remove("/europe");
+// Initialize
+error = tffs_mkdir("/europe");
+error = tffs_mkdir("/europe/norway");
+error = tffs_fcreate(rofile, TDATA(2));
+expect(error, EFFS_OK);
+error = tffs_stat(rofile, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.flags, 0);
+test_ffs_state_get(&old);
+// set read-only flag
+error = tffs_fcontrol(rofile, OC_FLAGS, OF_READONLY);
+expect(error, EFFS_OK);
+error = tffs_stat(rofile, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.flags, OF_READONLY);
+test_ffs_state_get(&new);
+expect_eq(new.objects_total, old.objects_total);
+expect_ne(new.inodes_used,  old.inodes_used);
+test_ffs_state_copy(&old, &new);
+// Set illegal flags. Try to fupdate file. Then try to set read-only
+// flag again.
+error = tffs_fcontrol(rofile, OC_FLAGS, 1<<0);
+expect(error, EFFS_INVALID);
+error = tffs_fcontrol(rofile, OC_FLAGS, 1<<3);
+expect(error, EFFS_INVALID);
+error = tffs_fcontrol(rofile, OC_FLAGS, 1<<5);
+expect(error, EFFS_INVALID);
+error = tffs_fcontrol(rofile, OC_FLAGS, 1<<6);
+expect(error, EFFS_INVALID);
+error = tffs_fupdate(rofile, TDATA(3));
+expect(error, EFFS_OK);
+error = tffs_fcreate("/europe/norway/tease", TDATA(2));
+expect(error, EFFS_OK);
+tffs_remove("/europe/norway/tease");
+error = tffs_fcontrol(rofile, OC_FLAGS, OF_READONLY);
+expect(error, EFFS_OK);
+error = tffs_stat(rofile, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.flags, OF_READONLY);
+test_ffs_state_get(&new);
+expect_eq(new.objects_total, old.objects_total);
+expect_ne(new.inodes_used,  old.inodes_used);
+test_ffs_state_copy(&old, &new);
+// clear read-only flag (this works because ffs_is_modifiable() by
+// default returns true for all objects except for object names ending
+// in "IMEI".
+error = tffs_fcontrol(rofile, OC_FLAGS, 0);
+expect(error, EFFS_OK);
+error = tffs_stat(rofile, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.flags, 0);
+test_ffs_state_get(&new);
+expect_eq(new.objects_total, old.objects_total);
+expect_ne(new.inodes_used,  old.inodes_used);
+test_ffs_state_copy(&old, &new);
+// Set read-only flag (again)
+error = tffs_fcontrol(rofile, OC_FLAGS, OF_READONLY);
+expect(error, EFFS_OK);
+error = tffs_stat(rofile, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.flags, OF_READONLY);
+test_ffs_state_get(&new);
+expect_eq(new.objects_total, old.objects_total);
+expect_ne(new.inodes_used,  old.inodes_used);
+test_ffs_state_copy(&old, &new);
+// Set read-only flag of IMEI file
+error = tffs_fcreate(imeifile, TDATA(2));
+expect(error, EFFS_OK);
+error = tffs_stat(imeifile, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.flags, 0);
+error = tffs_fcontrol(imeifile, OC_FLAGS, OF_READONLY);
+expect(error, EFFS_OK);
+error = tffs_stat(imeifile, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.flags, OF_READONLY);
+test_ffs_state_get(&new);
+expect_eq(new.objects_total, old.objects_total + 1);
+expect_ne(new.inodes_used,  old.inodes_used);
+test_ffs_state_copy(&old, &new);
+// Try to remove, fupdate, fwrite and fcontrol IMEI file.
+error = tffs_remove(imeifile);
+expect(error, EFFS_ACCESS);
+error = tffs_fupdate(imeifile, TDATA(0));
+expect(error, EFFS_ACCESS);
+error = tffs_fwrite(imeifile, TDATA(0));
+expect(error, EFFS_ACCESS);
+error = tffs_fcontrol(imeifile, OC_FLAGS, 0);
+expect(error, EFFS_ACCESS);
+// Try to open IMEI file in write-only and read-only
+fdi = tffs_open(imeifile, FFS_O_WRONLY | FFS_O_APPEND);
+expect(fdi, EFFS_ACCESS);
+fdi = tffs_open(imeifile, FFS_O_RDONLY);
+expect(fdi, FFS_FD_OFFSET);
+error = tffs_close(fdi);
+expect(error, EFFS_OK);
+return 0;
+}
+// Test symlink functionality of simple symlink implementation.
+// Fixme: add remove file through symlink, stat a dir through a symlink.
+int case_ssym(int p0, int p1)
+{
+int size;
+fd_t fdi;
+// two links, read files thru links
+// link to link to file, open file
+// link to non-valid object
+//
+// make three test files, a link to each of these, one link to dir, one
+// link to non-existing object, one link to link to file
+tffs_mkdir("/europe");
+tffs_mkdir("/europe/denmark");
+error = tffs_fwrite("/europe/denmark/aalborg", TDATA(1));
+expect(error, EFFS_OK);
+error = tffs_symlink("/europe/aal", "/europe/denmark/aalborg");
+expect(error, EFFS_OK);
+error = tffs_symlink("/dk", "/europe/denmark");
+expect(error, EFFS_OK);
+error = tffs_fwrite("/europe/denmark/aarhus", TDATA(2));
+expect(error, EFFS_OK);
+error = tffs_symlink("/europe/aar", "/europe/denmark/aarhus");
+expect(error, EFFS_OK);
+error = tffs_symlink("/europe/se", "/europe/non-existing");
+expect(error, EFFS_OK);
+error = tffs_fwrite("/europe/denmark/billund", TDATA(3));
+expect(error, EFFS_OK);
+error = tffs_symlink("/europe/bil", "/europe/denmark/billund");
+expect(error, EFFS_OK);
+error = tffs_symlink("/lego", "/europe/bil");
+expect(error, EFFS_OK);
+error = tffs_fwrite("/europe/denmark/norresundby", TDATA(2));
+expect(error, EFFS_OK);
+error = tffs_symlink("/europe/nor", "/europe/denmark/norresundby");
+expect(error, EFFS_OK);
+// Test link to dir
+error = tffs_opendir("/dk", &dir);
+expect(error, EFFS_NOTAFILE); // TODO: strange error!
+error = tffs_stat("/dk", &stat);
+expect(error, EFFS_NOTAFILE); // TODO: strange error!
+error = tffs_linkstat("/dk", &stat);
+expect(error, EFFS_OK);
+// Test link to link to file
+error = tffs_stat("/lego", &stat);
+expect(error, EFFS_NOTAFILE); // TODO: strange error?!
+error = tffs_linkstat("/lego", &stat);
+expect(error, EFFS_OK);
+error = tffs_fread("/lego", bigbuf, bigbuf_size);
+tw(tr(TR_END, TrApi, "} %d\n", error));  // Avoid wrong indent
+expect(error, EFFS_NOTAFILE);
+// Test link to non-existing object
+error = tffs_opendir("/europe/se", &dir);
+expect(error, EFFS_NOTFOUND);
+error = tffs_stat("/europe/se", &stat);
+expect(error, EFFS_NOTFOUND);
+error = tffs_linkstat("/europe/se", &stat);
+expect(error, EFFS_OK);
+// Read files through links
+error = test_expect_file("/europe/aal", TDATA(1));
+if (error) return 1;
+error = test_expect_file("/europe/aar", TDATA(2));
+if (error) return 1;
+error = test_expect_file("/europe/bil", TDATA(3));
+if (error) return 1;
+// Write files through links
+error = tffs_fwrite("/europe/aal", TDATA(3));
+expect(error, EFFS_OK);
+error = tffs_fupdate("/europe/aar", TDATA(4));
+expect(error, EFFS_OK);
+error = tffs_fupdate("/europe/bil", TDATA(5));
+expect(error, EFFS_OK);
+// Open file and write and read files through links
+fdi = tffs_open("/europe/nor", FFS_O_WRONLY | FFS_O_TRUNC | FFS_O_APPEND);
+expect(fdi, FFS_FD_OFFSET);
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE], 50);
+expect(size, 50);
+error = tffs_close(fdi);
+expect(error, 0);
+fdi = tffs_open("/europe/nor", FFS_O_RDONLY);
+expect(fdi, FFS_FD_OFFSET);
+size = tffs_read(fdi, bigbuf, 62);
+expect(size, 50);
+error = test_expect_data((char*)tdata[TDATA_HUGE], bigbuf, 50);
+if (error) return 1;
+error = tffs_close(fdi);
+expect(error, 0);
+// remove "lego" link, recreate it to link to "billund", read file data
+// through link, re-write file data through link
+error = tffs_symlink("/lego", "/europe/denmark/billund");
+expect(error, EFFS_NOTAFILE); // TODO: strange error?!
+error = tffs_fupdate("/lego", "/europe/denmark/billund",
+strlen("/europe/denmark/billund"));
+expect(error, EFFS_NOTAFILE);
+error = tffs_remove("/lego");
+expect(error, EFFS_OK);
+error = tffs_symlink("/lego", "/europe/denmark/billund");
+expect(error, EFFS_OK);
+error = test_expect_file("/lego", TDATA(5));
+if (error) return 1;
+error = tffs_fupdate("/lego", TDATA(2));
+expect(error, EFFS_OK);
+// Re-Read files through links
+error = test_expect_file("/europe/aal", TDATA(3));
+if (error) return 1;
+error = test_expect_file("/europe/aar", TDATA(4));
+if (error) return 1;
+error = test_expect_file("/europe/bil", TDATA(2));
+if (error) return 1;
+// Clean up
+error = tffs_remove("/europe/aal");
+expect(error, EFFS_OK);
+error = tffs_remove("/dk");
+expect(error, EFFS_OK);
+error = tffs_remove("/europe/aar");
+expect(error, EFFS_OK);
+error = tffs_remove("/europe/se");
+expect(error, EFFS_OK);
+error = tffs_remove("/europe/bil");
+expect(error, EFFS_OK);
+error = tffs_remove("/lego");
+expect(error, EFFS_OK);
+error = tffs_remove("/europe/nor");
+expect(error, EFFS_OK);
+return 0;
+}
+// Test symlink functionality of full symlink implementation
+int case_fsym(int p0, int p1)
+{
+fd_t fdi;
+// make relative link to directory, stat link and directory
+error = tffs_symlink("/sa", "/south-america"); // relative link
+expect(error, EFFS_OK);
+error = tffs_linkstat("/sa", &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.type, OT_LINK);
+error = tffs_stat("/sa", &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.type, OT_DIR);
+// create directory thru a symlink
+error = tffs_mkdir("/sa/brazil");
+expect(error, EFFS_OK);
+error = tffs_symlink("/br.ba", "/brazil/buenos-aires"); // relative link
+expect(error, EFFS_OK);
+// create file via symlink, stat the new file
+error = tffs_fcreate("/sa/brazil/buenos-aires", TDATA(2));
+expect(error, EFFS_OK);
+error = tffs_stat("/sa/br.ba", &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.type, OT_FILE);
+fdi = tffs_open("/sa/peru", FFS_O_WRONLY | FFS_O_TRUNC |
+FFS_O_APPEND | FFS_O_CREATE);
+expect(fdi, FFS_FD_OFFSET);
+error = tffs_close(fdi);
+expect(error, 0);
+// create file thru a symlink, stat the new file. Will this work?
+error = tffs_symlink("/br.br", "/brazil/brasilia"); // relative link
+expect(error, EFFS_OK);
+error = tffs_fcreate("/sa/br.br", TDATA(3)); // ???
+expect(error, EFFS_OK);
+error = tffs_stat("/sa/br.br", &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.type, OT_FILE);
+// Create symlink that is a link to absolute link path
+error = tffs_symlink("/south-america/cape-horn", "/sa/ar"); // absolute link
+expect(error, EFFS_OK);
+error = tffs_fcreate("/south-america/argentina", TDATA(0));
+expect(error, EFFS_OK);
+error = tffs_symlink("/sa/ar", "/south-america/argentina");
+expect(error, EFFS_OK);
+// TODO: Test very deep path
+// TODO: Test circular link
+// TODO: Test if ending slash is allowed on dirs and symlinks
+tw(tr(TR_FUNC, TrTest, "WARNING: Test case not implemented!\n"));
+ttw(str(TTrTest, "Test case not implemented!" NL));
+return 0;
+}
+// Check every combination of name length and data size within the device
+// atomsize,
+int case_fread(int p0, int p1)
+{
+const char fullname[] = "123456789ABCDEF0123456789ABCDEF";
+int i, j, dirlen, mysize;
+char *mydata;
+char myname[20+20+32] = "/australia/f";
+case_cleanup(0x11 * param.atomsize * param.atomsize);
+tffs_mkdir("/australia");
+mydata = (char *) tdata[TDATA_HUGE];
+dirlen = strlen(myname);
+for (j = 0; j < param.atomsize; j++) {
+mysize = j * 0x11 /* + 0x100 */;
+ttw(ttr(TTrTest, "frd: size = %x" NL, mysize));
+tw(tr(TR_FUNC, TrTestHigh, "frd: size = %x\n", mysize));
+// remove files
+for (i = 0; i < param.atomsize; i++) {
+strncpy(&myname[dirlen], fullname, i);
+myname[dirlen + i] = 0;
+error = tffs_remove(myname);
+}
+// fcreate files with varying name lengths but same alignment.
+for (i = 0; i < param.atomsize; i++) {
+strncpy(&myname[dirlen], fullname, i);
+myname[dirlen + i] = 0;
+error = tffs_fwrite(myname, mydata, mysize);
+expect(error, EFFS_OK);
+}
+// Now check all the files written
+for (i = 0; i < param.atomsize; i++) {
+strncpy(&myname[dirlen], fullname, i);
+myname[dirlen + i] = 0;
+//tw(tr(TR_FUNC, TrTestHigh, "frd: txf('f...', %x, %d)\n",
+//      mydata, mysize));
+error = test_expect_file(myname, mydata, mysize);
+if (error) return 1;
+}
+mydata += 0x10;
+}
+for (i = 0; i < param.atomsize; i++) {
+strncpy(&myname[dirlen], fullname, i);
+myname[dirlen + i] = 0;
+error = tffs_remove(myname);
+expect(error, EFFS_OK);
+}
+return 0;
+}
+/******************************************************************************
+* Non-finished
+******************************************************************************/
+// Test Directories
+int case_dirs(int p0, int p1)
+{
+// remove empty dir, non-empty dir
+// open/readdir empty dir, non-empty dir
+char name[21];
+int i, j;
+struct dir_s dir[3];
+const char *names[3][5] = {
+{ "china",    "japan",    "korea", "india", 0 },
+{ "bombay",   "newdelhi", 0,       0,       0 },
+{ "hongkong", "shanghai", "hk",    0,       0 }
+};
+// Cleanup
+tffs_mkdir("/asia");
+tffs_remove("/asia/india/bombay");
+tffs_remove("/asia/india/newdelhi");
+tffs_remove("/asia/india");
+error = tffs_mkdir("/asia/china");
+expect(error, EFFS_OK);
+error = tffs_mkdir("/asia/china/beijing");
+expect(error, EFFS_OK);
+error = tffs_mkdir("/asia/china/hongkong");
+expect(error, EFFS_OK);
+error = tffs_fcreate("/asia/china/hongkong/hkfile1", TDATA(1));
+expect(error, EFFS_OK);
+error = tffs_fcreate("/asia/china/shanghai", TDATA(2));
+expect(error, EFFS_OK);
+error = tffs_symlink("/asia/china/hk", "/asia/china/hongkong");
+expect(error, EFFS_OK);
+error = tffs_mkdir("/asia/japan");
+expect(error, EFFS_OK);
+error = tffs_fcreate("/asia/thailand", TDATA(0));
+expect(error, EFFS_OK);
+error = tffs_fcreate("/asia/korea", TDATA(2));
+expect(error, EFFS_OK);
+error = tffs_fcreate("/asia/japan/tokyo", TDATA(3));
+expect(error, EFFS_OK);
+error = tffs_fupdate("/asia/japan/tokyo", TDATA(4));
+expect(error, EFFS_OK);
+error = tffs_mkdir("/asia/india");
+expect(error, EFFS_OK);
+error = tffs_fcreate("/asia/india/bombay", TDATA(0));
+expect(error, EFFS_OK);
+error = tffs_fcreate("/asia/india/newdelhi", TDATA(1));
+expect(error, EFFS_OK);
+error = tffs_fcreate("/asia/india/calcutta", TDATA(2));
+expect(error, EFFS_OK);
+error = tffs_opendir("/asia", &dir[0]);
+expect(error, 5);
+error = tffs_opendir("/asia/india", &dir[1]);
+expect(error, 3);
+error = tffs_opendir("/asia/china", &dir[2]);
+expect(error, 4);
+// remove first, middle and last entry in a dir
+error = tffs_remove("/asia/china/beijing");
+expect(error, EFFS_OK);
+error = tffs_remove("/asia/thailand");
+expect(error, EFFS_OK);
+error = tffs_remove("/asia/india/calcutta");
+expect(error, EFFS_OK);
+for (j = 0; j < 5; j++) {
+for (i = 0; i < 3; i++) {
+error = tffs_readdir(&dir[i], name, 21);
+if (names[i][j] == NULL) {
+expect(error, EFFS_OK);
+}
+else {
+expect_gt(error, EFFS_OK);
+tw(tr(TR_FUNC, TrTestHigh, "dir[%d]: %10s, expected: %s\n",
+i, name, names[i][j]));
+test_expect_data(name, TDATA_STRING(names[i][j]));
+}
+}
+}
+error = tffs_remove("/asia/china");
+expect(error, EFFS_DIRNOTEMPTY);
+error = tffs_remove("/asia/china/hongkong");
+expect(error, EFFS_DIRNOTEMPTY);
+error = tffs_remove("/asia/china/hongkong/hkfile1");
+expect(error, EFFS_OK);
+error = tffs_remove("/asia/china/shanghai");
+expect(error, EFFS_OK);
+error = tffs_remove("/asia/china/hk");
+expect(error, EFFS_OK);
+error = tffs_remove("/asia/china");
+expect(error, EFFS_DIRNOTEMPTY);
+error = tffs_remove("/asia/china/hongkong");
+expect(error, EFFS_OK);
+error = tffs_opendir("/asia/china", &dir[2]);
+expect(error, 0);
+error = tffs_remove("/asia/china");
+expect(error, EFFS_OK);
+error = tffs_remove("/asia/korea");
+expect(error, EFFS_OK);
+error = tffs_remove("/asia/japan/tokyo");
+expect(error, EFFS_OK);
+error = tffs_remove("/asia/japan");
+expect(error, EFFS_OK);
+return 0;
+}
+// Check that expected stat data was read
+int case_expect_stat(const char *name, int n)
+{
+error = tffs_stat(name, &stat);
+expect(error, EFFS_OK);
+// test type, size, flags, space?
+// test range of location, inode, block
+return 0;
+}
+// Test stat
+int case_stat(int p0, int p1)
+{
+struct xstat_s xstat;
+struct stat_s stat;
+char myname[] = "/Stat_file";
+char sym_name[] = "/sf";
+char stream_name[] = "/Stat_stream";
+fd_t fdi;
+int size, i, file_size = 0;
+// test stat on dirs, symlinks and files
+// check stat.block (by writing two HUGE files)
+case_cleanup(fs.chunk_size_max / 5 * 20);
+// NOTEME: this is a very limited test
+error = tffs_fwrite(myname, (char *)tdata[TDATA_HUGE], 99);
+expect_ok(error);
+error = tffs_stat(myname, &stat);
+expect(error, EFFS_OK);
+expect(stat.type, OT_FILE);
+expect(stat.flags, 0);
+expect_ok(stat.inode);
+expect(stat.size, 99);
+//    error = tffs_xstat(myname, &xstat);
+//    expect(error, EFFS_OK);
+//    expect(error, EFFS_OK);
+//    expect(xstat.type, OT_FILE);
+//    expect(xstat.flags, 0);
+//    expect_ok(xstat.inode);
+//    expect(xstat.size, 99);
+//    expect(xstat.space, 112);
+//    expect_ok(xstat.location);
+//   expect_ok(xstat.block);
+//    expect_ok(xstat.sequence);
+//    expect_ok(xstat.updates);
+error = tffs_linkstat(myname, &stat);
+expect(error, EFFS_OK);
+expect(error, EFFS_OK);
+expect(stat.type, OT_FILE);
+expect(stat.flags, 0);
+expect_ok(stat.inode);
+expect(stat.size, 99);
+error = tffs_xlstat(myname, &xstat);
+expect(error, EFFS_OK);
+expect(error, EFFS_OK);
+expect(xstat.type, OT_FILE);
+expect(xstat.flags, 0);
+expect_ok(xstat.inode);
+expect(xstat.size, 99);
+expect(xstat.space, 112);
+expect_ok(xstat.location);
+expect_ok(xstat.block);
+expect_ok(xstat.sequence);
+expect_ok(xstat.updates);
+// Symlink
+tffs_symlink(sym_name, myname);
+error = tffs_xlstat(sym_name, &xstat);
+expect(error, EFFS_OK);
+expect(error, EFFS_OK);
+expect(xstat.type, OT_LINK);
+expect(xstat.flags, 0);
+expect_ok(xstat.inode);
+expect(xstat.size, sizeof(myname));
+expect(xstat.space, 16);
+expect_ok(xstat.location);
+expect_ok(xstat.block);
+expect_ok(xstat.sequence);
+expect_ok(xstat.updates);
+// Stream stat test
+// Use xstat to return the size of the file
+fdi = tffs_open(stream_name, FFS_O_WRONLY | FFS_O_CREATE |
+FFS_O_TRUNC  | FFS_O_APPEND);
+expect(fdi, FFS_FD_OFFSET);
+for (i = 0; i < 20; i++) {
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE],
+fs.chunk_size_max / 5);
+expect(size, fs.chunk_size_max / 5);
+file_size +=size;
+error = tffs_xlstat(stream_name, &xstat);
+expect(error, EFFS_OK);
+expect_eq(xstat.size, file_size);
+error = tffs_fstat(fdi, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.size, file_size);
+}
+error = tffs_close(fdi);
+expect(error, EFFS_OK);
+// Test if the file size is right if opened in read-only
+fdi = tffs_open(stream_name, FFS_O_RDONLY);
+expect(fdi, FFS_FD_OFFSET);
+error = tffs_xlstat(stream_name, &xstat);
+expect(error, EFFS_OK);
+expect_eq(xstat.size, file_size);
+// Test a lot of difference fdi
+for (i = -3; i < FFS_FD_OFFSET + fs.fd_max + 3; i++) {
+error = tffs_fstat(i, &stat);
+if (i == FFS_FD_OFFSET) {
+expect(error, EFFS_OK);
+}
+else expect(error, EFFS_BADFD);
+}
+error = tffs_close(fdi);
+expect(error, EFFS_OK);
+return 0;
+}
+int case_remove(int p0, int p1)
+{
+tw(tr(TR_FUNC, TrTest, "WARNING: Test case not implemented!\n"));
+ttw(str(TTrTest, "Test case not implemented!" NL));
+return 0;
+}
+int case_rename(int p0, int p1)
+{
+fd_t fdi;
+int size, i;
+struct dir_s dir;
+// create file A
+// rename A to B
+// check file A is gone
+// check file B is same as file A
+// do all the same for directory
+// do all the same for symlink
+// test and ensure that dir rename "foo" to "foo/bar" is impossible!
+// Cleanup before run
+tffs_remove("/Walt_Disney/RUP");
+tffs_remove("/Uncle_Scrooge");
+tffs_remove("/Walt_Disney/Minnie");
+tffs_remove("/Walt_Disney");
+tffs_remove("/Duck");
+// Init
+tffs_mkdir("/Disney");
+tffs_mkdir("/Hell");
+error = tffs_fwrite("/IMEI", TDATA(2));
+if (error < 0 && error != EFFS_ACCESS) return 1;
+error = tffs_fcontrol("/IMEI", OC_FLAGS, OF_READONLY);
+if (error < 0 && error != EFFS_ACCESS) return 1;
+tw(tr(TR_FUNC, TrTestHigh, "Rename file\n")); /* Rename file */
+error = tffs_fwrite("/Mickey", TDATA(3));
+expect(error, EFFS_OK);
+error = tffs_fwrite("/Pluto", TDATA(2));
+expect(error, EFFS_OK);
+error = tffs_rename("/Pluto", "/Dog");
+expect(error, EFFS_OK);
+error = tffs_fupdate("/Pluto", TDATA(2));
+expect(error, EFFS_NOTFOUND);
+error = test_expect_file("/Dog", TDATA(2));
+if (error) return 1;
+error = tffs_rename("/Dog", "/Hell/RIP");
+expect(error, EFFS_OK);
+error = tffs_rename("/Hell/RIP", "/RAP");
+expect(error, EFFS_OK);
+error = tffs_rename("/RAP", "/Disney/RUP");
+expect(error, EFFS_OK);
+error = test_expect_file("/Disney/RUP", TDATA(2));
+if (error) return 1;
+// Rename a file to an existing file
+error = tffs_rename("/Mickey", "/Disney/RUP");
+expect(error, EFFS_OK);
+// Have the data changed?
+error = test_expect_file("/Disney/RUP", TDATA(3));
+if (error) return 1;
+// Try rename a file to an exisitng read-only file
+error = tffs_rename("/Disney/RUP", "/IMEI");
+expect(error, EFFS_ACCESS);
+// Try rename a file to an existing dir
+error = tffs_rename("/Disney/RUP", "/Hell");
+expect(error, EFFS_NOTAFILE);
+error = tffs_rename("/Disney/RUP", "/BADNAME?");
+expect(error, EFFS_BADNAME);
+error = tffs_remove("/Hell");
+expect(error, EFFS_OK);
+tw(tr(TR_FUNC, TrTestHigh, "Rename symlink\n")); /* Rename symlink */
+tffs_symlink("/Goose", "/Disney/RUP"); // 5
+error = tffs_rename("/Goose", "/Duck");
+expect(error, EFFS_OK);
+error = tffs_fupdate("/Goose", TDATA(2));
+expect(error, EFFS_NOTFOUND);
+error = test_expect_file("/Duck", TDATA(3));
+if (error) return 1;
+error = test_expect_file("/Disney/RUP", TDATA(3));
+if (error) return 1;
+tw(tr(TR_FUNC, TrTestHigh, "Rename dir\n"));     /* Rename dir */
+// * FIXME BUG * FIXME BUG * FIXME BUG * The below test to not fail instead
+// the directory is removed
+// error = tffs_rename("/Disney", "/Disney/foo");
+// expect(error, EFFS_OK);
+tffs_mkdir("/Disney/Donald_Duck");
+expect(error, EFFS_OK);
+error = ffs_rename("/Disney/Donald_Duck", "/Uncle_Scrooge");
+expect(error, EFFS_OK);
+error = tffs_opendir("/Uncle_Scrooge", &dir);
+expect(error, EFFS_OK);
+error = tffs_opendir("/Disney/Donald_Duck", &dir);
+expect(error, EFFS_NOTFOUND);
+error = tffs_rename("/Disney", "/Walt_Disney");
+expect(error, EFFS_OK);
+tffs_mkdir("/Disney");  // Create 'Disney' dir again
+expect(error, EFFS_OK);
+// Try rename to existing dir
+error = tffs_rename("/Disney", "/Walt_Disney");
+expect(error, EFFS_EXISTS);
+// Try rename to existing file
+error = tffs_rename("/Disney", "/Walt_Disney/RUP");
+expect(error, EFFS_EXISTS);
+tw(tr(TR_FUNC, TrTestHigh, "Rename seghead\n")); /* Rename seghead */
+fdi = tffs_open("/Walt_Disney/Mickey", FFS_O_WRONLY | FFS_O_CREATE);
+expect(fdi, FFS_FD_OFFSET);
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE], fs.chunk_size_max + 1);
+expect(size, fs.chunk_size_max + 1);
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE] + size, fs.chunk_size_max);
+expect(size, fs.chunk_size_max);
+error = tffs_rename("/Walt_Disney/Mickey", "/Walt_Disney/Minnie");
+expect(error, EFFS_LOCKED);
+tffs_close(fdi);
+error = tffs_rename("/Walt_Disney/Mickey", "/Walt_Disney/Minnie");
+expect(error, EFFS_OK);
+fdi = tffs_open("/Walt_Disney/Minnie", FFS_O_RDONLY);
+expect(fdi, FFS_FD_OFFSET);
+i = 0;
+do {
+size = tffs_read(fdi, bigbuf, bigbuf_size);
+error = test_expect_data((char*)tdata[TDATA_HUGE] + i, bigbuf, size);
+if (error) return 1;
+i += size;
+} while (size);
+error = tffs_close(fdi);
+expect(error, 0);
+error = test_expect_file("/Walt_Disney/Minnie", (char *)tdata[TDATA_HUGE],
+2 * fs.chunk_size_max + 1);
+if (error) return 1;
+// Rename a big file to an existing big file
+error = tffs_fwrite("/Mickey", (char *)tdata[TDATA_HUGE] + 5,
+2.5 * fs.chunk_size_max);
+expect(error, EFFS_OK);
+error = tffs_rename("/Mickey", "/Walt_Disney/Minnie");
+expect(error, EFFS_OK);
+error = test_expect_file("/Walt_Disney/Minnie", (char *)tdata[TDATA_HUGE] + 5,
+2.5 * fs.chunk_size_max);
+if (error) return 1;
+error = tffs_fread("/Mickey", 0 , 0);
+expect(error, EFFS_NOTFOUND);
+return 0;
+}
+// One of the problems with the rename function is that we need to copy the
+// data part from the old obj to the new obj. When we allocate data for the
+// new obj we risk that the data alloc caused a data reclaim which relocated
+// the old obj thus the source have been moved!
+int case_rename_extended(int p0, int p1)
+{
+int i, old_drec_most_lost, rename_file_relocated = 0;
+int fsize, offset;
+char myname1[] = "/rename1/rename1/foo";
+char myname2[] = "/rename2/rename2/bar";
+if (p0 == 0) p0 = 100;
+if (p1 == 0) p1 = 5;
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format("/ffs/b3r24", 0x2BAD);
+expect(error, EFFS_OK);
+fsize = 2.5 * fs.chunk_size_max; // Test with more than one chunk
+tffs_mkdir("/rename1");
+tffs_mkdir("/rename1/rename1");
+tffs_mkdir("/rename2");
+tffs_mkdir("/rename2/rename2");
+error = tffs_file_write(myname1, (char*)tdata[TDATA_HUGE], fsize,
+FFS_O_CREATE | FFS_O_TRUNC);
+// Test if rename can handle when the objects are relocaded while the
+// rename is in progress
+for (i = 0; i < p0; i++) {
+tw(tr(TR_FUNC, TrTest, "Rename number %d\n", i));
+offset = i % 2 ? 3 : 9;
+error = tffs_file_write(myname2, (char*)tdata[TDATA_HUGE] + offset, fsize,
+FFS_O_CREATE | FFS_O_TRUNC);
+// Get data reclaim candidate most_lost
+old_drec_most_lost = stats.drec.most_lost;
+error = tffs_rename(myname2, myname1);
+expect(error, EFFS_OK);
+error = test_expect_file(myname1, tdata[TDATA_HUGE] + offset, fsize);
+expect(error, EFFS_OK);
+error = tffs_fread(myname2, 0, 0);
+expect(error, EFFS_NOTFOUND);
+// Has the rename triggered a data_reclaim()?
+if (old_drec_most_lost != stats.drec.most_lost) {
+rename_file_relocated++;
+tw(tr(TR_FUNC, TrTest, "Rename objects relocated %d\n",
+rename_file_relocated));
+if (rename_file_relocated >= p1)
+return EFFS_OK;
+}
+}
+return 1;
+}
+// Test Big files
+int case_bigfile(int p0, int p1)
+{
+struct ffs_state_s old, new;
+const char bigfile[] = "/antarctica/iceberg";
+int bytes_max, file_size;
+#if 1
+ttw(ttr(TTrTest, "WARNING: We need to re-implement this test. Skip test" NL));
+tw(tr(TR_FUNC, TrTest, "WARNING: We need to re-implement this test. Skip test\n"));
+return 0;
+#endif
+if (param.data_blocks <= 1) {
+ttw(ttr(TTrTest, "WARNING: Too few blocks to run. Skip test" NL));
+tw(tr(TR_FUNC, TrTest, "WARNING: Too few blocks to run. Skip test\n"));
+return 0;
+}
+error = case_cleanup(fs.filesize_max);
+expect(error, EFFS_NOSPACE); // We can not cleanup this amount.
+ffs_query(Q_BYTES_FREE, (uint32 *) &bytes_max);
+test_ffs_state_get(&old);
+// We don't have enough space for this amount because the name dos also
+// use some space
+file_size = bytes_max + 1;
+// Try to make a file of a size that is bigger than the total free space
+// in the file system.
+ttw(ttr(TTrTest, "Bigfile of size %d" NL, file_size));
+tw(tr(TR_FUNC, TrTestHigh, "Bigfile of size %d\n", file_size));
+error = tffs_fcreate(bigfile,
+(char *) tdata[TDATA_HUGE], file_size);
+expect(error, EFFS_NOSPACE);
+test_ffs_state_get(&new);
+expect_eq(old.bytes_free, new.bytes_free);
+// File the system with this huge file
+file_size = bytes_max - FFS_FILENAME_MAX - dev.atomsize;
+ttw(ttr(TTrTest, "Bigfile of size %d" NL, file_size));
+tw(tr(TR_FUNC, TrTestHigh, "Bigfile of size %d\n", file_size));
+error = tffs_fcreate(bigfile,
+(char *) tdata[TDATA_HUGE], file_size);
+expect(error, EFFS_OK);
+error = test_expect_file((char *) bigfile,
+(char *) tdata[TDATA_HUGE], file_size);
+if (error) return 1;
+test_ffs_state_get(&new);
+expect_gt(old.bytes_free, new.bytes_free - file_size);
+tffs_remove(bigfile);
+return 0;
+}
+/******************************************************************************
+* Reclaim Test Cases
+******************************************************************************/
+// Test that ffs internal state is same after a re-ffs_init()
+int case_reinit(int p0, int p1)
+{
+struct ffs_state_s old, new;
+test_ffs_state_get(&old);
+error = tffs_initialize();
+expect(error, EFFS_OK);
+test_ffs_state_get(&new);
+error = test_expect_state(&old, &new);
+if (error) return 1;
+return 0;
+}
+// Test inodes reclaim
+int case_irec(int p0, int p1)
+{
+// African states: kenya, egypt, marocco, namibia, nigeria, mozambique,
+// tanzania, ghana, togo, liberia, mali, congo
+struct ffs_state_s old, new;
+int i, j, updates;
+if (p0 == 0)
+p0 = 7;
+tffs_mkdir("/africa");
+// Initialize
+tffs_fwrite("/africa/kenya", TDATA(0)); // 1
+tffs_mkdir("/africa/east"); // 2
+tffs_fwrite("/africa/tanzania", TDATA(1)); // 3
+tffs_fwrite("/africa/east/egypt", TDATA(2)); // 4
+tffs_symlink("/africa/et", "africa/east/egypt"); // 5
+tffs_mkdir("/africa/west"); // 7
+tffs_fupdate("/africa/et", TDATA(3)); // 6
+tffs_fwrite("/africa/west/liberia", TDATA(0)); // 8
+for (j = 0; j < p0; j++) {
+test_ffs_state_get(&old);
+updates = param.inodes_max - old.inodes_used;
+ttw(ttr(TTrTest, "loop %d: updates = %d" NL, j, updates));
+tw(tr(TR_FUNC, TrTestHigh, "loop %d: updates = %d\n", j, updates));
+for (i = 0; i < (updates / 10) + 10; i++) {
+// cleanup...
+error = tffs_remove("/africa/east/egypt");
+expect(error, EFFS_OK);
+error = tffs_remove("/africa/east");
+expect(error, EFFS_OK);
+error = tffs_remove("/africa/et");
+expect(error, EFFS_OK);
+error = tffs_remove("/africa/west/liberia");
+expect(error, EFFS_OK);
+error = tffs_remove("/africa/west");
+expect(error, EFFS_OK);
+// use 10 inodes...
+error = tffs_fwrite("/africa/kenya", TDATA(0)); // 1
+expect(error, EFFS_OK);
+error = tffs_mkdir("/africa/east"); // 2
+expect(error, EFFS_OK);
+error = tffs_fwrite("/africa/tanzania", (char *) tdata[0], 0); // 3
+expect(error, EFFS_OK);
+error = tffs_fcreate("/africa/east/egypt", TDATA(2)); // 4
+expect(error, EFFS_OK);
+error = tffs_symlink("/africa/et", "/africa/east/egypt"); // 5
+expect(error, EFFS_OK);
+error = tffs_mkdir("/africa/west"); // 7
+expect(error, EFFS_OK);
+error = tffs_fupdate("/africa/et", TDATA(3)); // 6
+expect(error, EFFS_OK);
+error = tffs_fcreate("/africa/west/liberia", TDATA(0)); // 8
+expect(error, EFFS_OK);
+error = tffs_fupdate("/africa/west/liberia", TDATA(1)); // 9
+expect(error, EFFS_OK);
+error = tffs_fupdate("/africa/tanzania", TDATA(2)); // 10
+expect(error, EFFS_OK);
+}
+test_ffs_state_get(&new);
+expect_eq(old.objects_total, new.objects_total);
+error = test_expect_file("/africa/tanzania", TDATA(2));
+if (error) return 1;
+error = test_expect_file("/africa/west/liberia", TDATA(1));
+if (error) return 1;
+error = test_expect_file("/africa/east/egypt", TDATA(3));
+if (error) return 1;
+error = test_expect_file("/africa/kenya", TDATA(0));
+if (error) return 1;
+}
+return 0;
+}
+#if 1
+// FIXME: Is this test case still valid after the new ffs_file_write() which
+// makes several chunks instead of on big?
+// Test data reclaim. Use up to maximum half the total space available.
+// drec params: percentage of avail to use, numupdates. We must not have too
+// big files due to fragmentation problems
+#define DREC_DIR "/north-america/usa"
+#define DREC_CHUNKS 6
+int case_drec(int p0, int p1)
+{
+static struct test_file_s files[] =
+{
+{ DREC_DIR "/alaska", 0, 0 },
+{ DREC_DIR "/arkansas", 0, 0 },
+{ DREC_DIR "/california", 0, 0 },
+{ DREC_DIR "/colorado", 0, 0 },
+{ DREC_DIR "/dakota", 0, 0 }, // north, south?
+{ DREC_DIR "/DistrictOfColumbia", 0, 0 }, // state?
+{ DREC_DIR "/florida", 0, 0 },
+{ DREC_DIR "/Georgia", 0, 0 },
+{ DREC_DIR "/hawaii", 0, 0 },
+{ DREC_DIR "/Idaho", 0, 0 },
+{ DREC_DIR "/Illinois", 0, 0 },
+{ DREC_DIR "/Iowa", 0, 0 },
+{ DREC_DIR "/kentucky", 0, 0 },
+{ DREC_DIR "/maine", 0, 0 },
+{ DREC_DIR "/Massachusettes", 0, 0 }, // spelling?
+{ DREC_DIR "/michigan", 0, 0 },
+{ DREC_DIR "/minnesota", 0, 0 },
+{ DREC_DIR "/mississippi", 0, 0 },
+{ DREC_DIR "/missouri", 0, 0 },
+{ DREC_DIR "/Montana", 0, 0 },
+{ DREC_DIR "/Nevada", 0, 0 },
+{ DREC_DIR "/NewHampshire", 0, 0 },
+{ DREC_DIR "/NewJersey", 0, 0 },
+{ DREC_DIR "/NewMexico", 0, 0 },
+{ DREC_DIR "/NewYork", 0, 0 }, // state?
+{ DREC_DIR "/north-carolina", 0, 0 },
+{ DREC_DIR "/ohio", 0, 0 },
+{ DREC_DIR "/oklahoma", 0, 0 },
+{ DREC_DIR "/Oregon", 0, 0 },
+{ DREC_DIR "/Pensylvania", 0, 0 },
+{ DREC_DIR "/RhodeIsland", 0, 0 }, // state?
+{ DREC_DIR "/south-carolina", 0, 0 },
+{ DREC_DIR "/Tennesee", 0, 0 },
+{ DREC_DIR "/texas", 0, 0 },
+{ DREC_DIR "/utah", 0, 0 },
+{ DREC_DIR "/Vermont", 0, 0 },
+{ DREC_DIR "/virginia", 0, 0 },
+{ DREC_DIR "/washington", 0, 0 },
+{ DREC_DIR "/Wyoming", 0, 0 },
+{ DREC_DIR "/40", 0, 0 },
+{ DREC_DIR "/41", 0, 0 },
+{ DREC_DIR "/42", 0, 0 },
+{ DREC_DIR "/43", 0, 0 },
+{ DREC_DIR "/44", 0, 0 },
+{ DREC_DIR "/45", 0, 0 },
+{ DREC_DIR "/46", 0, 0 },
+{ DREC_DIR "/47", 0, 0 },
+{ DREC_DIR "/48", 0, 0 },
+{ DREC_DIR "/49", 0, 0 },
+{ DREC_DIR "/50", 0, 0 },
+{ DREC_DIR "/51", 0, 0 },
+{ DREC_DIR "/52", 0, 0 },
+};
+struct chunk_s {
+int ratio;
+int high;
+int low;
+};
+const struct chunk_s chunk[DREC_CHUNKS] = {
+{ 15, 65536, 32768 },
+{ 15, 32768, 16384 },
+{ 25, 16384,  8192 },
+{ 20,  8192,  4096 },
+{ 15,  4096,  2048 },
+{ 10,  2048,     0 }
+};
+int i, j, n, num_files;
+int num, pct;
+int size_used, size_max, size_chunk;
+int size_chunk_used, size_chunk_low, size_chunk_high;
+num = (p0 == 0 ? 11 : p0);
+pct = (p1 == 0 ? 50 : p1);
+tffs_mkdir("/north-america");
+tffs_mkdir("/north-america/usa");
+size_max   = pct * param.bytes_avail / 100;
+size_used  = 0;
+num_files  = sizeof(files) / sizeof(struct test_file_s);
+n = 0;
+tw(tr(TR_FUNC, TrTestHigh, "pct = %d%% = %dk\n",  pct, size_max/1024));
+for (i = 0; i < DREC_CHUNKS; i++) {
+size_chunk = chunk[i].ratio * size_max / 100;
+size_chunk_low  = chunk[i].low  / 256 * fs.filesize_max / 256;
+size_chunk_high = chunk[i].high / 256 * fs.filesize_max / 256;
+tw(tr(TR_FUNC, TrTestHigh, "%4dk of [%d..%d]: ",
+size_chunk/1024, size_chunk_high, size_chunk_low));
+ttw(ttr(TTrTest, "%4dk of [%d..%d]: ",
+size_chunk/1024, size_chunk_high, size_chunk_low));
+size_chunk_used = 0;
+// If the total chunk size can guaranteeable be contained...
+if (size_chunk >= chunk[i].high) {
+for (j = 0; j < size_chunk / size_chunk_high; j++) {
+if (n >= num_files) {
+tw(tr(TR_FUNC, TrTestHigh, "j too big\n"));
+ttw(str(TTrTest, "j too big" NL));
+break;
+}
+files[n].size = size_chunk_low +
+rand() % (size_chunk_high - size_chunk_low);
+#ifdef WIN32
+/* due to limitation in MS Visual C */
+if( files[n].size  > 65535 )
+files[n].size = 65535;
+#endif //WIN32
+files[n].data = (char *) tdata[TDATA_HUGE] + n;
+tw(tr(TR_NULL, TrTestHigh, "%d:%s ",
+files[n].size, &files[n].name[strlen(DREC_DIR)+1]));
+ttw(ttr(TTrTest, "%d:%s " NL,
+files[n].size, &files[n].name[strlen(DREC_DIR)+1]));
+size_chunk_used += files[n].size;
+n++;
+// FIXME: We should let all the unused bytes from this
+// chunk spill over into the next chunk so we use the
+// full percentage specified by p1.
+}
+size_used += size_chunk_used;
+}
+tw(tr(TR_NULL, TrTestHigh, "(%dk)\n", size_chunk_used/1024));
+ttw(ttr(TTrTest, "(%dk)" NL, size_chunk_used/1024));
+}
+tw(tr(TR_FUNC, TrTestHigh, "pct = %d%% = %dk\n",
+100 * size_used/param.bytes_avail, size_used/1024));
+ttw(ttr(TTrTest, "pct = %d%% = %dk" NL,
+100 * size_used/param.bytes_avail, size_used/1024));
+for (j = 0; j < num; j++) {
+ttw(ttr(TTrTest, "drec: %d. write" NL, j+1));
+tw(tr(TR_FUNC, TrTestHigh, "drec: %d. write\n", j+1));
+for (i = 0; i < n; i++) {
+error = tffs_fwrite(files[i].name, files[i].data, files[i].size);
+expect(error, EFFS_OK);
+}
+}
+for (i = 0; i < n; i++) {
+error = test_expect_file(files[i].name, files[i].data, files[i].size);
+if (error)
+return 1;
+error = tffs_remove(files[i].name);
+expect(error, EFFS_OK);
+}
+tffs_remove("/north-america/usa");
+tffs_remove("/north-america");
+return 0;
+}
+#else
+// Test data reclaim. Use up to maximum half the total space available.
+// drec params: percentage of avail to use, numupdates. We must not have too
+// big files due to fragmentation problems
+int case_drec(int p0, int p1)
+{
+struct blabla_s {
+int ratio;
+int high;
+int low;
+};
+struct blabla_s sizes[4] =
+{
+{  10, 65536, 32768 },
+{  40, 21800, 16384 },
+{  45, 16384,  2048 },
+{   5,  2048,     0 }
+};
+static struct test_file_s files[] =
+{
+{ DRECDIR "/alaska", 0, 0 },
+{ DRECDIR "/arkansas", 0, 0 },
+{ DRECDIR "/california", 0, 0 },
+{ DRECDIR "/colorado", 0, 0 },
+{ DRECDIR "/dakota", 0, 0 }, // north, south?
+{ DRECDIR "/DistrictOfColumbia", 0, 0 }, // state?
+{ DRECDIR "/florida", 0, 0 },
+{ DRECDIR "/Georgia", 0, 0 },
+{ DRECDIR "/hawaii", 0, 0 },
+{ DRECDIR "/Idaho", 0, 0 },
+{ DRECDIR "/Illinois", 0, 0 },
+{ DRECDIR "/Iowa", 0, 0 },
+{ DRECDIR "/kentucky", 0, 0 },
+{ DRECDIR "/maine", 0, 0 },
+{ DRECDIR "/Massachusettes", 0, 0 }, // spelling?
+{ DRECDIR "/michigan", 0, 0 },
+{ DRECDIR "/minnesota", 0, 0 },
+{ DRECDIR "/mississippi", 0, 0 },
+{ DRECDIR "/missouri", 0, 0 },
+{ DRECDIR "/Montana", 0, 0 },
+{ DRECDIR "/Nevada", 0, 0 },
+{ DRECDIR "/NewHampshire", 0, 0 },
+{ DRECDIR "/NewJersey", 0, 0 },
+{ DRECDIR "/NewMexico", 0, 0 },
+{ DRECDIR "/NewYork", 0, 0 }, // state?
+{ DRECDIR "/north-carolina", 0, 0 },
+{ DRECDIR "/ohio", 0, 0 },
+{ DRECDIR "/oklahoma", 0, 0 },
+{ DRECDIR "/Oregon", 0, 0 },
+{ DRECDIR "/Pensylvania", 0, 0 },
+{ DRECDIR "/RhodeIsland", 0, 0 }, // state?
+{ DRECDIR "/south-carolina", 0, 0 },
+{ DRECDIR "/Tennesee", 0, 0 },
+{ DRECDIR "/texas", 0, 0 },
+{ DRECDIR "/utah", 0, 0 },
+{ DRECDIR "/Vermont", 0, 0 },
+{ DRECDIR "/virginia", 0, 0 },
+{ DRECDIR "/washington", 0, 0 },
+{ DRECDIR "/Wyoming", 0, 0 },
+{ DRECDIR "/40", 0, 0 },
+{ DRECDIR "/41", 0, 0 },
+{ DRECDIR "/42", 0, 0 },
+{ DRECDIR "/43", 0, 0 },
+{ DRECDIR "/44", 0, 0 },
+{ DRECDIR "/45", 0, 0 },
+{ DRECDIR "/46", 0, 0 },
+{ DRECDIR "/47", 0, 0 },
+{ DRECDIR "/48", 0, 0 },
+{ DRECDIR "/49", 0, 0 },
+{ DRECDIR "/50", 0, 0 },
+{ DRECDIR "/51", 0, 0 },
+{ DRECDIR "/52", 0, 0 },
+};
+int i, j, n, size, size_target;
+int num, percentage;
+error = tffs_mkdir("/north-america");
+percentage = (p1 == 0 ? 50 : p1);
+n = sizeof(files)/sizeof(struct test_file_s);
+size_target = percentage * param.bytes_avail / 100;
+size = 0;
+for (i = 0; i < 4; i++) {
+sizes[i].ratio = sizes[i].ratio * size_target / 100;
+sizes[i].high  = sizes[i].high / 256 * fs.filesize_max / 256;
+sizes[i].low   = sizes[i].low  / 256 * fs.filesize_max / 256;
+size += sizes[i].ratio;
+}
+ttw(ttr(TTrTest, "%4dk in total" NL, size / 1024));
+tw(tr(TR_FUNC, TrTestHigh, "%4dk in total\n", size / 1024));
+j = 0;
+size = size_target = 0;
+for (i = 0; i < 4; i++) {
+ttw(ttr(TTrTest, "%4dk: %d..%d = ",
+sizes[i].ratio / 1024, sizes[i].high, sizes[i].low));
+tw(tr(TR_FUNC, TrTestHigh, "%4dk: %d..%d = ",
+sizes[i].ratio / 1024, sizes[i].high, sizes[i].low));
+size_target += sizes[i].ratio;
+while (size < size_target) {
+files[j].data = (char *) tdata[TDATA_HUGE] + j;
+files[j].size = rand() % (sizes[i].high - sizes[i].low)
++ sizes[i].low;
+size += files[j].size;
+ttw(ttr(TTrTest, "%d:%s, ",
+files[j].size, &files[j].name[strlen(DRECDIR)+1]));
+tw(tr(TR_NULL, TrTestHigh, "%d:%s, ",
+files[j].size, &files[j].name[strlen(DRECDIR)+1]));
+j++;
+if (j >= n) {
+// TODO: better error handling?
+ttw(str(TTrTest, "j too big" NL));
+tw(tr(TR_FUNC, TrTestHigh, "j too big\n"));
+return -1;
+}
+}
+ttw(str(TTrTest, "" NL));
+tw(tr(TR_NULL, TrTestHigh, "\n"));
+}
+n = j;
+error = tffs_mkdir(DRECDIR);
+num = (p0 == 0 ? 5 : p0);
+for (j = 0; j < num; j++) {
+ttw(ttr(TTrTest, "drec: %d. write" NL, j+1));
+tw(tr(TR_FUNC, TrTestHigh, "drec: %d. write\n", j+1));
+for (i = 0; i < n; i++) {
+error = tffs_fwrite(files[i].name, files[i].data, files[i].size);
+expect(error, EFFS_OK);
+}
+// error = test_run("ri");
+// if (error) return 1;
+}
+for (i = 0; i < n; i++) {
+error = test_expect_file(files[i].name, files[i].data, files[i].size);
+if (error) return 1;
+error = tffs_remove(files[i].name);
+expect(error, EFFS_OK);
+}
+return 0;
+}
+#endif
+void save_block_ages(int *age)
+{
+int i;
+struct block_header_s *bhp;
+for (i = 0; i < dev.numblocks; i++)
+{
+bhp = (struct block_header_s *) offset2addr(dev.binfo[i].offset);
+age[i] = bhp->age;
+tw(tr(TR_FUNC, TrTestHigh, "b,age(%d,%d)\n", i, age[i]));
+}
+}
+// NOTE: This chech includes the inode block thus the inode block also needs
+// to be reclaimed before this functions returns ok
+int has_all_block_ages_changed(int *age)
+{
+int i;
+struct block_header_s *bhp;
+for (i = 0; i < dev.numblocks; i++)
+{
+bhp = (struct block_header_s *) offset2addr(dev.binfo[i].offset);
+if (age[i] == bhp->age)
+return 0; // Age have not changed
+}
+return 1;
+}
+#define chunkalign(size) (((size) + fs.chunk_size_max-1) & ~(fs.chunk_size_max-1))
+// Fill a data blocks with the maximum possible numbers of objects
+int fill_block_with_max_objects(void)
+{
+static int n = 1000; // Avoid white spaces in the filename
+int fsize, i, b, nobjects, bfree_space;
+char myname[] = "Fb_max-xxxx";
+char *mydata = (char *) tdata[TDATA_HUGE];
+// Find an approximate objects size
+fsize = dev.blocksize / fs.block_files_max - sizeof(myname) - 1;
+// Fill approximate 75% of a data block
+for (i = 0; i < fs.block_files_max / 4 * 3; i++, n++) {
+sprintf(myname, "/Fb_max-%4d", n);
+error = tffs_file_write(myname,(char*) mydata, fsize, FFS_O_CREATE);
+expect_ok(error);
+}
+// Find the block we currently are filling with objects.
+error = tffs_xlstat(myname, &xstat);
+expect_ok(error);
+b = xstat.block;
+bfree_space = dev.blocksize - bstat[b].used;
+tw(tr(TR_FUNC, TrTestHigh, "Block: %d, Free space:%dkB\n", b ,bfree_space>>10));
+// Calculate the exact file size to fill a block with max number of files
+nobjects = fs.block_files_max - bstat[b].objects - fs.block_files_reserved;
+fsize = bfree_space / nobjects - sizeof(myname);
+fsize &= ~dev.atomnotmask;     // Avoid padding
+tw(tr(TR_FUNC, TrTestHigh, "Exact file size (%d)\n", fsize));
+// Fill the rest of the block
+for (i = 0; i < nobjects; i++, n++) {
+sprintf(myname, "/Fb_max-%4d", n);
+error = tffs_file_write(myname, (char*) mydata, fsize, FFS_O_CREATE);
+expect_ok(error);
+}
+tw(tr(TR_FUNC, TrTest, "Filled block %d done\n", b));
+return EFFS_OK;
+}
+// Stress test data reclaim and test wearleveling.
+// NOTE: This test can not run in less than 7 blocks
+int case_adrec(int nwrites, int nage_change)
+{
+int i, j, n, inodes_reserved, nobjects, bytes_max;
+int blocks, fsize;
+int dynamic_fsize = 1000;
+char static_name[] = "/Static-xxxx";
+char dynamic_name[] = "/Dynamic";
+int *age = (int*) smallbuf;
+/* Flow:
+Format ffs.
+Fill N number of blocks with the maximum possible numbers of objects.
+Fill the rest of FFS except from a few kbytes. Use almost all the inodes.
+Trigger data reclaim by continue to update a file.
+Test if all flash blocks are used for wearleveling.
+*/
+if (nwrites == 0)  // Number of updates of the dynamic file (timeout)
+nwrites = 1000000;
+if (nage_change == 0) //
+nage_change = 2;
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format("/ffs", 0x2BAD);
+expect(error, EFFS_OK);
+// Major hack, disable journal and reserved space or else there will be
+// created new journals inside the blocks where we wish to have only
+// static objects
+fs.ijournal = 0;
+fs.reserved_space = 0;
+// Minimum amount of inodes to fill FFS:
+ffs_query(Q_BYTES_FREE, &bytes_max);
+inodes_reserved = bytes_max / fs.chunk_size_max;
+// We need to calculate the amount of inodes we can use and still
+// garanti that we have enough inodes to fill all data blocks with data.
+nobjects  = fs.objects_max - inodes_reserved;
+// How many blocks can we fill?
+blocks = nobjects / fs.block_files_max;
+// Fill N number of data blocks with the maximum possible numbers of objects
+tw(tr(TR_FUNC, TrTest, "Fill %d blocks with max obj \n", blocks));
+n = 1000; // Avoid white spaces in the filename
+for (j = 0; j < blocks; j++) {
+error = fill_block_with_max_objects();
+expect_ok(error);
+}
+// Restore journal and reserved space
+error = tffs_initialize();
+expect_ok(error);
+// Fill the rest of FFS except from 3 times the dynamic size, futhermore
+// keep 4 objects 'free'
+ffs_query(Q_OBJECTS_FREE, &nobjects);
+tw(tr(TR_FUNC, TrTest, "Fill almost the rest of FFS\n"));
+n = 1000;        // Avoid white spaces in the filename
+while (nobjects - 4 > 0) {
+ffs_query(Q_BYTES_FREE, &bytes_max);
+fsize = (bytes_max - dynamic_fsize * 3) / (nobjects - 4);
+tw(tr(TR_FUNC, TrTestHigh, "space,obj,fsize (%dk,%d,%d)\n",
+bytes_max/1024, nobjects, fsize));
+if (fsize > fs.chunk_size_max) {
+// Roundup to the closet complete chunk or else we use to many inodes
+fsize = chunkalign(fsize);
+tw(tr(TR_FUNC, TrTestHigh, "Chunkalign %d\n", fsize));
+}
+sprintf(static_name, "/Static-%4d", n++);
+error = tffs_file_write(static_name, (char*)tdata[TDATA_HUGE], fsize,
+FFS_O_CREATE);
+if (error == EFFS_NOSPACE) {
+tw(tr(TR_FUNC, TrTest, "WARNING: Fill failed with out of data space\n"));
+break;
+}
+else
+expect_ok(error);
+ffs_query(Q_OBJECTS_FREE, &nobjects);
+}
+tw(tr(TR_FUNC, TrTest, "Fill done, all static objects are written\n"));
+case_debug_help(2,0);  // bstat trace
+// Save the age of all blocks
+save_block_ages(age);
+tw(tr(TR_FUNC, TrTest, "Update the dynamic file max %d times\n", nwrites));
+for (i = 0, j = 0; i < nwrites; i++) {
+error = tffs_file_write(dynamic_name, (char*)tdata[TDATA_HUGE],
+dynamic_fsize,
+FFS_O_CREATE | FFS_O_TRUNC);
+expect_ok(error);
+if (i%1000 == 0)
+tw(tr(TR_FUNC, TrTest, "Write number %d\n", i));
+if (has_all_block_ages_changed(age) == 1) {
+tw(tr(TR_FUNC, TrTest,"All block ages have changed %d\n", j));
+j++;
+save_block_ages(age);
+}
+if (j >= nage_change)
+break;
+}
+test_statistics_print();
+case_debug_help(2,0);  // bstat trace
+if (j >= nage_change)
+return 0;
+return 1;  //Error
+}
+/******************************************************************************
+* Journalling and Recover Test Cases
+******************************************************************************/
+// Test journalling. Both for normal objects but also for journal file
+// itself! The following operations are tested for proper recovery: fcreate,
+// fupdate, relocate, delete, clean, fcontrol
+int case_journal(int p0, int p1)
+{
+struct test_file_s tf;
+struct ffs_state_s old, new;
+struct xstat_s stat_old, stat_new;
+int i, myspace = 0, mytmpspace, offset;
+char mytmpname[] = "/test-journal-tmp";
+int testflags[] = {
+JOURNAL_TEST_EMPTY,      // object not committed
+JOURNAL_TEST_WRITING,    // object not committed
+JOURNAL_TEST_READY,      // object ok
+JOURNAL_TEST_COMMITTING, // object ok
+JOURNAL_TEST_COMMITTED,  // object ok
+JOURNAL_TEST_DONE,       // object ok
+};
+tf.name = "/test-journal";
+tf.data = (char *) tdata[2];
+tf.size = sdata[2];
+#if 1
+// NOTEME: Workaround, the below use of state_get can not handle if we
+// create a new journal while we run the test. Instead we create a
+// new journal before the test if we are close to full.
+if (fs.journal_pos >= fs.journal_size - (FFS_JOURNAL_MARGIN + 12) *
+sizeof(struct journal_s)) {
+tw(tr(TR_FUNC, TrTest, "Journal file (near) full!\n"));
+journal_create(fs.ijournal);
+}
+// NOTEME: Workaround, this test is unabel to handle a
+// block_alloc(). The 'extra' amount of lost space caused by a
+// block_alloc() and its block header dos cheat the test to fail.
+offset = data_prealloc(1024);
+expect_gt(offset, 0);
+#endif
+// init
+#if 1
+error = tffs_fwrite(mytmpname, tf.data, tf.size);
+expect(error, EFFS_OK);
+error = tffs_xlstat(mytmpname, &stat_old);
+expect(error, EFFS_OK);
+mytmpspace = stat_old.space;
+ttw(ttr(TTrTest, "file '%s' uses %d bytes" NL, mytmpname, mytmpspace));
+tw(tr(TR_FUNC, TrTestHigh, "file '%s' uses %d bytes\n", mytmpname, mytmpspace));
+#endif
+error = tffs_fcreate(tf.name, tf.data, tf.size);
+expect(error, EFFS_OK);
+error = tffs_xlstat(tf.name, &stat_old);
+expect(error, EFFS_OK);
+myspace = stat_old.space;
+error = tffs_fcreate("/dummy", 0, 0);
+expect(error, EFFS_OK);
+ttw(ttr(TTrTest, "file '%s' uses %d bytes" NL, tf.name, myspace));
+tw(tr(TR_FUNC, TrTestHigh, "file '%s' uses %d bytes\n", tf.name, myspace));
+ttw(str(TTrTest, "fcreate:" NL));
+tw(tr(TR_BEGIN, TrTestHigh, "fcreate:\n"));
+stat_old.inode = 0;
+for (i = 0; i < sizeof(testflags)/sizeof(int); i++)
+{
+// clean up from operation being tested
+tffs_remove(tf.name);
+ttw(ttr(TTrTest, "fs.testflags = 0x%x" NL, testflags[i]));
+tw(tr(TR_FUNC, TrTestHigh, "fs.testflags = 0x%x\n", testflags[i]));
+test_ffs_state_get(&old);
+error = tffs_fcontrol("/dummy", OC_FS_TESTFLAGS, testflags[i]);
+expect(error, EFFS_OK);
+error = tffs_fcreate(tf.name, tf.data, tf.size);
+expect(error, EFFS_OK);
+error = tffs_initialize();
+expect(error, EFFS_OK);
+test_ffs_state_get(&new);
+tw(tr(TR_FUNC, TrTestHigh,
+"bytes_used new = %7d, old = %7d, diff = %d\n",
+new.bytes_used, old.bytes_used, new.bytes_used - old.bytes_used));
+tw(tr(TR_FUNC, TrTestHigh,
+"bytes_lost new = %7d, old = %7d, diff = %d\n",
+new.bytes_lost, old.bytes_lost,
+new.bytes_lost - old.bytes_lost));
+expect_eq(new.bytes_used, old.bytes_used + myspace);
+error = tffs_xlstat(tf.name, &stat_new);
+if (i < 2) {
+// object was not committed, so object must not exist
+expect(error, EFFS_NOTFOUND);
+expect_eq(new.objects_total, old.objects_total);
+expect_eq(new.bytes_lost,    old.bytes_lost + myspace);
+}
+else {
+// object was committed, so object must exist
+expect(error, EFFS_OK);
+expect_ne(stat_old.inode, stat_new.inode);
+expect_eq(new.objects_total, old.objects_total + 1);
+expect_eq(new.bytes_lost,    old.bytes_lost);
+}
+}
+ttw(str(TTrTest, "" NL));
+tw(tr(TR_END, TrTestHigh, ""));
+ttw(str(TTrTest, "fupdate:" NL));
+tw(tr(TR_BEGIN, TrTestHigh, "fupdate:\n"));
+error = tffs_xlstat(tf.name, &stat_old);
+expect(error, EFFS_OK);
+for (i = 0; i < sizeof(testflags)/sizeof(int); i++)
+{
+ttw(ttr(TTrTest, "fs.testflags = 0x%x" NL, testflags[i]));
+tw(tr(TR_FUNC, TrTestHigh, "fs.testflags = 0x%x\n", testflags[i]));
+test_ffs_state_get(&old);
+error = tffs_fcontrol("/dummy", OC_FS_TESTFLAGS, testflags[i]);
+expect(error, EFFS_OK);
+error = tffs_fupdate(tf.name, tf.data, tf.size);
+error = tffs_initialize();
+expect(error, EFFS_OK);
+error = tffs_xlstat(tf.name, &stat_new);
+expect(error, EFFS_OK);
+if (i < 2) {
+// object was not committed, so stats must be equal
+error = test_expect_data(&stat_new, &stat_old, sizeof(stat));
+if (error) return 1;
+}
+else {
+// object was committed, so inodes must not be equal
+expect_ne(stat_old.inode, stat_new.inode);
+}
+test_ffs_state_get(&new);
+tw(tr(TR_FUNC, TrTestHigh,
+"bytes_used new = %7d, old = %7d, diff = %d\n",
+new.bytes_used, old.bytes_used, new.bytes_used - old.bytes_used));
+tw(tr(TR_FUNC, TrTestHigh,
+"bytes_lost new = %7d, old = %7d, diff = %d\n",
+new.bytes_lost, old.bytes_lost,
+new.bytes_lost - old.bytes_lost));
+expect_eq(new.objects_total, old.objects_total);
+expect_eq(new.bytes_used,    old.bytes_used + myspace);
+expect_eq(new.bytes_lost,    old.bytes_lost + myspace);
+}
+ttw(str(TTrTest, "" NL));
+tw(tr(TR_END, TrTestHigh, ""));
+ttw(str(TTrTest, "rename:" NL));
+tw(tr(TR_BEGIN, TrTestHigh, "rename:\n"));
+error = tffs_fwrite(tf.name, tf.data, tf.size);
+expect(error, EFFS_OK);
+error = tffs_xlstat(tf.name, &stat_old);
+expect(error, EFFS_OK);
+for (i = 0; i < sizeof(testflags)/sizeof(int); i++)
+{
+ttw(ttr(TTrTest, "fs.testflags = 0x%x" NL, testflags[i]));
+tw(tr(TR_FUNC, TrTestHigh, "fs.testflags = 0x%x\n", testflags[i]));
+error = tffs_fwrite(mytmpname, tf.data, tf.size);
+expect_ok(error);
+error = tffs_fcontrol("/dummy", OC_FS_TESTFLAGS, testflags[i]);
+expect(error, EFFS_OK);
+test_ffs_state_get(&old);
+error = tffs_rename(mytmpname, tf.name);
+expect_ok(error);
+error = tffs_initialize();
+expect(error, EFFS_OK);
+test_ffs_state_get(&new);
+// tf.name MUST always exist
+error = tffs_xlstat(tf.name, &stat_new);
+expect(error, EFFS_OK);
+tw(tr(TR_FUNC, TrTestHigh,
+"bytes_used new = %7d, old = %7d, diff = %d\n",
+new.bytes_used, old.bytes_used, new.bytes_used - old.bytes_used));
+tw(tr(TR_FUNC, TrTestHigh,
+"bytes_lost new = %7d, old = %7d, diff = %d\n",
+new.bytes_lost, old.bytes_lost,
+new.bytes_lost - old.bytes_lost));
+error = tffs_xlstat(mytmpname, &stat_new);
+if (i < 2) {
+// Journal not READY, so test-journal-tmp must exist
+expect(error, EFFS_OK);
+expect_eq(new.objects_total, old.objects_total);
+expect_eq(new.bytes_used,    old.bytes_used + myspace);
+expect_eq(new.bytes_lost,    old.bytes_lost + myspace);
+}
+else {
+// Journal ready, so test-journal-tmp must not exist
+expect(error, EFFS_NOTFOUND);
+expect_eq(new.objects_total, old.objects_total - 1);
+expect_eq(new.bytes_used,    old.bytes_used + myspace);
+expect_eq(new.bytes_lost,    old.bytes_lost + myspace + mytmpspace);
+expect_ne(stat_old.inode, stat_new.inode);
+}
+}
+ttw(str(TTrTest, "" NL));
+tw(tr(TR_END, TrTestHigh, ""));
+// cleanup
+tffs_remove(tf.name);
+tffs_remove("/dummy");
+return 0;
+}
+// Test block recovery
+int case_brecover(int p0, int p1)
+{
+struct test_file_s tf;
+struct ffs_state_s old, new;
+int j, inodes_block_old = 0, inodes_block_new = 0;
+int i, error;
+uint16 free_blocks;
+int testflags[] = {
+BLOCK_COMMIT_BEFORE,
+BLOCK_COMMIT_NO_VALID,
+BLOCK_COMMIT_OLD_FREE,
+BLOCK_COMMIT_AFTER
+};
+int testflags_2[] = {
+BLOCK_RECLAIM_ALLOC,
+BLOCK_RECLAIM_CLEANING,
+BLOCK_RECLAIM_NO_CLEAN,
+};
+tf.name = "/dummy4fctrl";
+tf.data = (char *) tdata[0];
+tf.size = sdata[0];
+error = tffs_fwrite(tf.name, tf.data, tf.size);
+expect(error, EFFS_OK);
+for (j = 0; j < 3; j++)
+{
+test_ffs_state_get(&old);
+//case_lsr(0, 0);  // temp
+error = ffs_query(Q_FS_INODES, (uint16 *) &inodes_block_old);
+expect(error, EFFS_OK);
+// Trigger block_commit() to fail
+error = tffs_fcontrol(tf.name, OC_FS_TESTFLAGS, testflags[j]);
+expect(error, EFFS_OK);
+inodes_reclaim();
+error = tffs_initialize();
+expect(error, EFFS_OK);
+error = ffs_query(Q_FS_INODES, (uint16 *) &inodes_block_new);
+expect(error, EFFS_OK);
+ttw(ttr(TTrTest, "inodes block %d -> %d" NL,
+inodes_block_old, inodes_block_new));
+tw(tr(TR_FUNC, TrTestHigh, "inodes block %d -> %d\n",
+inodes_block_old, inodes_block_new));
+switch (j) {
+case 0: expect(inodes_block_old, inodes_block_new); break;
+case 1: expect_ne(inodes_block_old, inodes_block_new); break;
+case 2: expect_ne(inodes_block_old, inodes_block_new); break;
+case 3: expect_ne(inodes_block_old, inodes_block_new); break;
+}
+test_ffs_state_get(&new);
+if (test_expect_objects(&old, &new))
+return 1;
+}
+// FIXME: The below test often fails (recalaim data block and create new
+// jouranl file makes it to fail)
+if (p0 == 9) {
+// Test BLOCK_RECLAIM Fill up all data blocks until only one is
+// free.
+tw(tr(TR_FUNC, TrTest, "Test Block reclaim\n"));
+ttw(ttr(TTrTest, "Test Block reclaim..." ));
+tffs_mkdir("/rand");
+ffs_query(Q_BLOCKS_FREE, (uint16 *) &free_blocks);
+while (free_blocks > 1) {
+error = case_mk_rand_file("/rand", 10000, 0);
+if (error < 0) {
+tw(tr(TR_FUNC, TrTest, "ERROR: case_mk_rand_file failed\n"));
+return 1;
+}
+ffs_query(Q_BLOCKS_FREE, (uint16 *) &free_blocks);
+}
+// case_mk_rand_file() will trigger a block_reclaim which will be
+// interruptet by the activated testflags. This will cause the FFS to
+// use the last free block! After a new init of ffs must it have
+// recovered.
+ttw(ttr(TTrTest, "use last block..."));
+for (i = 0; i < sizeof(testflags_2)/sizeof(int); i++)
+{
+error = tffs_fcontrol(tf.name, OC_FS_TESTFLAGS, testflags_2[i]);
+expect(error, EFFS_OK);
+do {
+case_cleanup(20000);
+error = case_mk_rand_file("/rand", 7000, 0);
+} while (error >= 0);
+expect(error, EFFS_NOSPACE);
+ffs_query(Q_BLOCKS_FREE, (uint16 *) &free_blocks);
+if (free_blocks != 0) {
+tw(tr(TR_FUNC, TrTestHigh, "ERROR: We still have free blocks!\n"));
+return 1;
+}
+error = tffs_initialize();// NOTE: error "WARNING: block_alloc failed" is okay.
+expect_ok(error);
+ffs_query(Q_BLOCKS_FREE, (uint16 *) &free_blocks);
+if (free_blocks != 1) {
+tw(tr(TR_FUNC, TrTestHigh,
+"ERROR: Wrong number of blocks free: %d\n", free_blocks));
+return 1;
+}
+}
+// NOTE: We have to make this clenaup because we can not run if FFS is
+// near full
+case_cleanup(dev.blocksize);
+// This test will make data_block_reclaim() to fail before it has
+// relocated all objects
+ttw(ttr(TTrTest, "interrupt block_reclaim()..."));
+for (i = 0; i < 4; i++)
+{
+error = tffs_fcontrol(tf.name, OC_FS_TESTFLAGS, BLOCK_RECOVER_OBJECTS);
+expect(error, EFFS_OK);
+do {
+case_cleanup(20000);
+error = case_mk_rand_file("/rand", 7000, 0);
+} while (error >= 0);
+expect(error, EFFS_NOSPACE);
+// NOTE: error "WARNING: block_alloc failed" is okay.
+error = tffs_initialize();
+expect_ok(error);
+}
+// Free up some space to the next test case.
+case_cleanup(dev.blocksize * 4);
+ttw(ttr(TTrTest, "Done" NL));
+}
+return 0;
+}
+/******************************************************************************
+* Specific/Special Test Cases
+******************************************************************************/
+// FIXME: Is this test case still valid after the new ffs_file_write() which
+// makes seveal chunks instead of on big?
+// Test filling a block to the full block size. We write N files of
+// decreasing powers of two, starting at half the block size. At the end we
+// are guaranteed to have at least one completelt full block. Also, we know
+// we have used at least <block_size> bytes of storage.
+int case_bfull(int p0, int p1)
+{
+struct ffs_state_s old, new;
+char myname[40] = "/antarctica/ice-";
+int i, size, mysize, dirlen, space;
+if (param.data_blocks <= 1) {
+ttw(ttr(TTrTest, "WARNING: Too few blocks to run. Skip test" NL));
+tw(tr(TR_FUNC, TrTest, "WARNING: Too few blocks to run. Skip test\n"));
+return 0;
+}
+error = tffs_mkdir("/antarctica");
+error = case_cleanup(param.block_size + 10000);
+expect_ok(error);
+test_ffs_state_get(&old);
+dirlen = strlen(myname);
+space = 0;
+size = param.block_size/2;
+for (i = 0; size > 0; i++) {
+mysize = size - param.atomsize;
+if (mysize < 0)
+mysize = size;
+sprintf(&myname[dirlen], "%d", size);
+error = tffs_fwrite(myname, (char *) tdata[TDATA_HUGE], mysize);
+expect(error, EFFS_OK);
+error = tffs_xlstat(myname, &xstat);
+expect(error, EFFS_OK);
+ttw(ttr(TTrTest, "%6d: %s" NL, xstat.space, myname));
+tw(tr(TR_FUNC, TrTestHigh, "%6d: %s\n", xstat.space, myname));
+space += xstat.space;
+size >>= 1;
+}
+test_ffs_state_get(&new);
+// Check space used. We have used a little more than <space> because we
+// have probably allocated one or two new blocks, and that is
+// dev.atomsize more bytes per block.
+tw(tr(TR_FUNC, TrTestHigh,
+"old.free = %d, new.free = %d, space used in test = %d\n",
+old.bytes_free, new.bytes_free, space));
+expect_gt(old.bytes_free, new.bytes_free + space - 1);
+// remove half of the files
+size = param.block_size/2;
+for (i = 0; size > 0; i++) {
+if (i & 1) {
+sprintf(&myname[dirlen], "%d", size);
+error = tffs_remove(myname);
+expect(error, EFFS_OK);
+}
+size >>= 1;
+}
+return 0;
+}
+int case_list(int p0, int p1)
+{
+const struct testcase_s *p;
+tw(tr(TR_FUNC, TrTestHigh, "bigbuf   = 0x%X, %d\n", bigbuf,   bigbuf_size));
+tw(tr(TR_FUNC, TrTestHigh, "smallbuf = 0x%X, %d\n", smallbuf, smallbuf_size));
+ttw(ttr(TTrTest, "bigbuf   = 0x%X, %d" NL, bigbuf,   bigbuf_size));
+ttw(ttr(TTrTest, "smallbuf = 0x%X, %d" NL, smallbuf, smallbuf_size));
+ttw(str(TTrTest, "Test Cases:" NL));
+for (p = testcase; p->name != 0; p++) {
+tw(tr(TR_FUNC, TrTest, "%8s: %s\n", p->name, p->comment));
+ttw(ttr(TTrTest, "%8s: %s" NL, p->name, p->comment));
+}
+return 0;
+}
+// Stress test the target.
+// p0 is number of times to run. Default is 10.
+// p1 is number of milli-seconds to wait between each file update.
+int case_stress(int p0, int p1)
+{
+char myname[20];
+int i, mysize;
+char *mydata;
+mydata = (char *) tdata[TDATA_HUGE];
+mysize = 9 * param.block_size / 16;
+if (p0 == 0) p0 = 10;
+if (p1 == 0) p1 = 1000;
+for (i = 0; i < p0; i++) {
+sprintf(myname, "/stress-%d", i);
+ttw(ttr(TTrTest, "/stress %d" NL, i));
+error = tffs_fcreate(myname, (char *)mydata, mysize);
+expect(error, EFFS_OK);
+tffs_delay(p1);
+error = tffs_remove(myname);
+expect(error, EFFS_OK);
+}
+return 0;
+}
+// Test ffs with many (small) files. p0 is number of times to write all the
+// files. Default is two e.g. one create and one update
+int case_mfiles(int p0, int p1)
+{
+char myname[40];
+int i, j;
+static struct test_file_s tf[] =
+{
+{ MFDIR "/MSCAP",   0,    6 },
+{ MFDIR "/IMEI",    0,    8 },
+{ MFDIR "/CLASS2",  0,    3 },
+{ MFDIR "/CLASS3",  0,    2 },
+{ MFDIR "/MSSUP",   0,    5 },
+{ MFDIR "/MSSET",   0,   83 },
+{ MFDIR "/UPN",     0,  165 },
+{ MFDIR "/CTIM",    0,   92 },
+{ MFDIR "/CCNT",    0,   52 },
+{ MFDIR "/ECC",     0,   15 },
+{ MFDIR "/ORG",     0, 2650 },
+{ MFDIR "/BCCHINF", 0,   54 },
+{ MFDIR "/CCP",     0,    7 },
+{ MFDIR "/EXT1",    0,   13 },
+{ MFDIR "/SIMLCK",  0,   62 },
+{ MFDIR "/SIMLCKEXT",0, 172 },
+{ MFDIR "/SECURITY", 0,   8 },
+{ MFDIR "/MAIN",    0,    8 },
+{ MFDIR "/SFK",     0,    8 },
+{ MFDIR "/FAULT",   0,    8 },
+{ MFDIR "/DEBUG",   0,    8 },
+{ MFDIR "/POWER",   0,    8 },
+{ MFDIR "/KEYB",    0,   64 },
+{ MFDIR "/RADIO",   0,    8 },
+{ MFDIR "/CGMI",    0,   20 },
+{ MFDIR "/CGMM",    0,   20 },
+{ MFDIR "/CGMR",    0,   20 },
+{ MFDIR "/CGSN",    0,   20 },
+{ MFDIR "/SMSPRFL", 0,  206 },
+{ MFDIR "/PLMN",    0,   68 },
+{ MFDIR "/ATRADIO", 0, 2700 },
+{ MFDIR "/GROUP",   0, 1122 }
+};
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format("/ffs/i2048o1024", 0x2BAD);
+expect(error, EFFS_OK);
+error = tffs_mkdir(MFDIR);
+expect(error, EFFS_OK);
+if (p0 == 0) p0 = 2;
+for (j = 0; j < p0; j++) {
+tw(tr(TR_FUNC, TrTestHigh, "mf: Writing many files, loop %d\n", j));
+tw(tr(TR_FUNC, TrTestHigh, "SMS000..SMS099\n"));
+for (i = 0; i < 100; i++) {
+sprintf(myname, MFDIR "/SMS%03d", i);
+error = tffs_fwrite(myname, (char *) tdata[TDATA_HUGE], 176);
+expect(error, EFFS_OK);
+}
+tw(tr(TR_FUNC, TrTestHigh, "LDN/LRN/LMN000..LDN/LRN/LMN009\n"));
+for (i = 0; i < 10; i++) {
+sprintf(myname, MFDIR "/LDN%03d", i);
+error = tffs_fwrite(myname, (char *) tdata[TDATA_HUGE], 31);
+expect(error, EFFS_OK);
+sprintf(myname, MFDIR "/LRN%03d", i);
+error = tffs_fwrite(myname, (char *) tdata[TDATA_HUGE], 32);
+expect(error, EFFS_OK);
+sprintf(myname, MFDIR "/LMN%03d", i);
+error = tffs_fwrite(myname, (char *) tdata[TDATA_HUGE], 30);
+expect(error, EFFS_OK);
+}
+tw(tr(TR_FUNC, TrTestHigh, "ADN000..ADN149\n"));
+for (i = 0; i < 150; i++) {
+sprintf(myname, MFDIR "/ADN%03d", i);
+error = tffs_fwrite(myname, (char *) tdata[TDATA_HUGE], 43);
+expect(error, EFFS_OK);
+}
+tw(tr(TR_FUNC, TrTestHigh, "PCM Files...\n"));
+for (i = 0; i < sizeof(tf)/sizeof(struct test_file_s); i++) {
+error = tffs_fwrite(tf[i].name,
+(char *) tdata[TDATA_HUGE], tf[i].size);
+expect(error, EFFS_OK);
+}
+}
+error = tffs_exit();
+expect(error, EFFS_OK);
+return 0;
+}
+int case_open(int p0, int p1)
+{
+fd_t fdi;
+char myname[20];
+int i, size;
+#define RDONLY FFS_O_RDONLY
+#define WRONLY FFS_O_WRONLY
+#define APPEND FFS_O_APPEND
+#define CREATE FFS_O_CREATE
+#define EXCL   FFS_O_EXCL
+#define TRUNC  FFS_O_TRUNC
+ffs_options_t non_exist_invalid[] = {
+( 0 ),
+( RDONLY |                   CREATE                ),
+( RDONLY |                   CREATE | EXCL         ),
+( RDONLY |                   CREATE |        TRUNC ),
+( RDONLY |                   CREATE | EXCL | TRUNC ),
+( RDONLY |                            EXCL         ),
+( RDONLY |                            EXCL | TRUNC ),
+( RDONLY |                                   TRUNC ),
+(                                     EXCL         ),
+(                                     EXCL | TRUNC ),
+(                                            TRUNC ),
+(                            CREATE |        TRUNC ),
+(                            CREATE | EXCL | TRUNC ),
+(                            CREATE | EXCL         ),
+(                            CREATE                ),
+(                   APPEND                         ),
+(                   APPEND |          EXCL         ),
+(                   APPEND |          EXCL | TRUNC ),
+(                   APPEND |                 TRUNC ),
+(                   APPEND | CREATE |        TRUNC ),
+(                   APPEND | CREATE | EXCL         ),
+(                   APPEND | CREATE | EXCL         ),
+(                   APPEND | CREATE                ),
+( RDONLY |          APPEND                         ),
+( RDONLY |          APPEND |          EXCL         ),
+( RDONLY |          APPEND |          EXCL | TRUNC ),
+( RDONLY |          APPEND |                 TRUNC ),
+( RDONLY |          APPEND | CREATE |        TRUNC ),
+( RDONLY |          APPEND | CREATE | EXCL | TRUNC ),
+( RDONLY |          APPEND | CREATE | EXCL         ),
+( RDONLY |          APPEND | CREATE                )
+};
+ffs_options_t non_exist_notfound[] = {
+(          WRONLY | APPEND                         ),
+(          WRONLY | APPEND |          EXCL         ),
+(          WRONLY | APPEND |          EXCL | TRUNC ),
+(          WRONLY | APPEND |                 TRUNC ),
+(          WRONLY                                  ),
+(          WRONLY |                   EXCL         ),
+(          WRONLY |                   EXCL | TRUNC ),
+(          WRONLY |                          TRUNC ),
+( RDONLY | WRONLY                                  ),
+( RDONLY | WRONLY |                   EXCL         ),
+( RDONLY | WRONLY |                   EXCL | TRUNC ),
+( RDONLY | WRONLY |                          TRUNC ),
+( RDONLY | WRONLY | APPEND                         ),
+( RDONLY | WRONLY | APPEND |          EXCL         ),
+( RDONLY | WRONLY | APPEND |          EXCL | TRUNC ),
+( RDONLY | WRONLY | APPEND |                 TRUNC ),
+( RDONLY                                           )
+};
+ffs_options_t non_exist_fd_offset[] = {
+(          WRONLY | APPEND | CREATE |        TRUNC ),
+(          WRONLY | APPEND | CREATE | EXCL | TRUNC ),
+(          WRONLY | APPEND | CREATE | EXCL         ),
+(          WRONLY | APPEND | CREATE                ),
+(          WRONLY |          CREATE |        TRUNC ),
+(          WRONLY |          CREATE | EXCL | TRUNC ),
+(          WRONLY |          CREATE | EXCL         ),
+(          WRONLY |          CREATE                ),
+( RDONLY | WRONLY |          CREATE |        TRUNC ),
+( RDONLY | WRONLY |          CREATE | EXCL | TRUNC ),
+( RDONLY | WRONLY |          CREATE | EXCL         ),
+( RDONLY | WRONLY |          CREATE                ),
+( RDONLY | WRONLY | APPEND | CREATE |        TRUNC ),
+( RDONLY | WRONLY | APPEND | CREATE | EXCL | TRUNC ),
+( RDONLY | WRONLY | APPEND | CREATE | EXCL         ),
+( RDONLY | WRONLY | APPEND | CREATE                )
+};
+ffs_options_t exist_invalid[] = {
+(                                     EXCL         ),
+(                                     EXCL | TRUNC ),
+(                                            TRUNC ),
+(                            CREATE |        TRUNC ),
+(                            CREATE | EXCL | TRUNC ),
+(                            CREATE | EXCL         ),
+(                            CREATE                ),
+(                   APPEND                         ),
+(                   APPEND |          EXCL         ),
+(                   APPEND |          EXCL | TRUNC ),
+(                   APPEND |                 TRUNC ),
+(                   APPEND | CREATE |        TRUNC ),
+(                   APPEND | CREATE | EXCL | TRUNC ),
+(                   APPEND | CREATE | EXCL         ),
+(                   APPEND | CREATE                ),
+( RDONLY |          APPEND                         ),
+( RDONLY |          APPEND |          EXCL         ),
+( RDONLY |          APPEND |          EXCL | TRUNC ),
+( RDONLY |          APPEND |                 TRUNC ),
+( RDONLY |          APPEND | CREATE |        TRUNC ),
+( RDONLY |          APPEND | CREATE | EXCL | TRUNC ),
+( RDONLY |          APPEND | CREATE | EXCL         ),
+( RDONLY |          APPEND | CREATE                ),
+( RDONLY |                            EXCL         ),
+( RDONLY |                            EXCL | TRUNC ),
+( RDONLY |                                   TRUNC ),
+( RDONLY |                   CREATE |        TRUNC ),
+( RDONLY |                   CREATE | EXCL | TRUNC ),
+( RDONLY |                   CREATE | EXCL         ),
+( RDONLY |                   CREATE                )
+};
+ffs_options_t exist_exist[] = {
+(          WRONLY | APPEND | CREATE | EXCL | TRUNC ),
+(          WRONLY | APPEND | CREATE | EXCL         ),
+(          WRONLY |          CREATE | EXCL | TRUNC ),
+(          WRONLY |          CREATE | EXCL         ),
+( RDONLY | WRONLY |          CREATE | EXCL | TRUNC ),
+( RDONLY | WRONLY |          CREATE | EXCL         ),
+( RDONLY | WRONLY | APPEND | CREATE | EXCL | TRUNC ),
+( RDONLY | WRONLY | APPEND | CREATE | EXCL         )
+};
+ffs_options_t exist_fd_offset[] = {
+(          WRONLY | APPEND                         ),
+(          WRONLY | APPEND |          EXCL         ),
+(          WRONLY | APPEND |          EXCL | TRUNC ),
+(          WRONLY | APPEND |                 TRUNC ),
+(          WRONLY | APPEND | CREATE |        TRUNC ),
+(          WRONLY | APPEND | CREATE                ),
+( RDONLY                                           ),
+( RDONLY | WRONLY                                  ),
+( RDONLY | WRONLY |                   EXCL         ),
+( RDONLY | WRONLY |                   EXCL | TRUNC ),
+( RDONLY | WRONLY |                          TRUNC ),
+( RDONLY | WRONLY |          CREATE |        TRUNC ),
+( RDONLY | WRONLY |          CREATE                ),
+( RDONLY | WRONLY | APPEND                         ),
+( RDONLY | WRONLY | APPEND |          EXCL         ),
+( RDONLY | WRONLY | APPEND |          EXCL | TRUNC ),
+( RDONLY | WRONLY | APPEND |                 TRUNC ),
+( RDONLY | WRONLY | APPEND | CREATE |        TRUNC ),
+( RDONLY | WRONLY | APPEND | CREATE                ),
+(          WRONLY                                  ),
+(          WRONLY |                   EXCL         ),
+(          WRONLY |                   EXCL | TRUNC ),
+(          WRONLY |                          TRUNC ),
+( WRONLY |                   CREATE |        TRUNC ),
+( WRONLY |                   CREATE                )
+};
+// Cleanup
+for (i = 0; i < 20; i++) {
+sprintf(myname, "/stream%d", i);
+tffs_remove(myname);
+}
+tw(tr(TR_FUNC, TrTestHigh, "Various open options, file non-existing\n"));
+ttw(str(TTrTest, "Various open options, file non-existing" NL));
+for (i = 0; i < sizeof(non_exist_invalid)/sizeof(ffs_options_t); i++) {
+sprintf(myname, "/stream%d", i - i/20 * 20);
+fdi = tffs_open(myname, non_exist_invalid[i]);
+expect(fdi, EFFS_INVALID);
+}
+for (i = 0; i < sizeof(non_exist_notfound)/sizeof(ffs_options_t); i++) {
+sprintf(myname, "/stream%d", i - i/20 * 20);
+fdi = tffs_open(myname, non_exist_notfound[i]);
+expect(fdi, EFFS_NOTFOUND);
+}
+for (i = 0; i < sizeof(non_exist_fd_offset)/sizeof(ffs_options_t); i++) {
+sprintf(myname, "/stream%d", i - i/20 * 20);
+fdi = tffs_open(myname, non_exist_fd_offset[i]);
+expect(fdi, FFS_FD_OFFSET);
+tffs_close(fdi);
+}
+// Make FFS_FD_MAX number of files and write some data for later use
+tw(tr(TR_FUNC, TrTestHigh, "Create %d files with data \n", fs.fd_max));
+for (i = 0; i < fs.fd_max; i++) {
+sprintf(myname, "/stream%d", i);
+fdi = tffs_open(myname, FFS_O_WRONLY | FFS_O_CREATE | FFS_O_TRUNC);
+expect(fdi, i + FFS_FD_OFFSET);
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE], 31);
+expect(size, 31);
+}
+// Try to open one more file, this will make a error!
+sprintf(myname, "/stream%d", i++);
+fdi = tffs_open(myname, FFS_O_WRONLY | FFS_O_CREATE | FFS_O_TRUNC);
+expect(fdi, EFFS_NUMFD);
+for (i = 0; i < fs.fd_max; i++) {
+error = tffs_close(i + FFS_FD_OFFSET);
+expect(error, EFFS_OK);
+}
+tw(tr(TR_FUNC, TrTestHigh,
+"Open same file multiple times in RDONLY mode\n"));
+for (i = 0; i < fs.fd_max; i++) {
+fdi = tffs_open("/stream2", FFS_O_RDONLY);
+expect(fdi, i + FFS_FD_OFFSET);
+}
+for (i = 0; i < fs.fd_max; i++) {
+error = tffs_close(i + FFS_FD_OFFSET);
+expect(error, 0);
+}
+tw(tr(TR_FUNC, TrTestHigh,
+"Open in WRONLY and try to open same file in WR or RD\n"));
+fdi = tffs_open("/stream1", FFS_O_WRONLY | FFS_O_APPEND);
+expect(fdi, FFS_FD_OFFSET);
+fdi = tffs_open("/stream1", FFS_O_WRONLY | FFS_O_APPEND);
+expect(fdi, EFFS_LOCKED);
+fdi = tffs_open("/stream1", FFS_O_RDONLY );
+expect(fdi, EFFS_LOCKED);
+error = tffs_close(FFS_FD_OFFSET);
+expect(error, 0);
+tw(tr(TR_FUNC, TrTestHigh,
+"Open in READONLY and try to open same file WRONLY\n"));
+fdi = tffs_open("/stream1", FFS_O_RDONLY);
+expect(fdi, FFS_FD_OFFSET);
+fdi = tffs_open("/stream1", FFS_O_WRONLY | FFS_O_APPEND);
+expect(fdi, EFFS_LOCKED);
+error = tffs_close(FFS_FD_OFFSET);
+expect(error, 0);
+tw(tr(TR_FUNC, TrTestHigh, "Various open options, file exists\n"));
+ttw(str(TTrTest, "Various open options, file exists" NL));
+for (i = 0; i < sizeof(exist_invalid)/sizeof(ffs_options_t); i++) {
+sprintf(myname, "/stream%d", i - i/20 * 20);
+fdi = tffs_open(myname, exist_invalid[i]);
+expect(fdi, EFFS_INVALID);
+}
+for (i = 0; i < sizeof(exist_exist)/sizeof(ffs_options_t); i++) {
+sprintf(myname, "/stream%d", i - i/20 * 20);
+fdi = tffs_open(myname, exist_exist[i]);
+expect(fdi, EFFS_EXISTS);
+tffs_close(fdi);
+}
+for (i = 0; i < sizeof(exist_fd_offset)/sizeof(ffs_options_t); i++) {
+sprintf(myname, "/stream%d", i - i/10 * 10);
+fdi = tffs_open(myname, exist_fd_offset[i]);
+expect(fdi, FFS_FD_OFFSET);
+tffs_close(fdi);
+}
+tw(tr(TR_FUNC, TrTestHigh, "Try to create a file with a dir name\n"));
+error = tffs_mkdir("/streams");
+fdi = tffs_open("/streams", FFS_O_WRONLY | FFS_O_APPEND | FFS_O_CREATE);
+expect(fdi, EFFS_NOTAFILE);
+tw(tr(TR_FUNC, TrTestHigh,
+"Try to use fwrite, fcreate, fread and remove on a open file\n"));
+fdi = tffs_open("/stream1", FFS_O_WRONLY | FFS_O_APPEND);
+expect(fdi, FFS_FD_OFFSET);
+error = tffs_fcreate("/stream1", TDATA(2));
+expect(error, EFFS_EXISTS);
+error = tffs_file_write("/stream1", (char *) tdata[TDATA_HUGE], 31,
+FFS_O_CREATE | FFS_O_TRUNC);
+expect(error, EFFS_LOCKED);
+error = tffs_file_read("/stream1", bigbuf, 31);
+expect(error, EFFS_LOCKED);
+error = tffs_remove("/stream1");
+expect(error, EFFS_LOCKED);
+error = tffs_close(fdi);
+expect(error, 0);
+#undef RDONLY
+#undef WRONLY
+#undef APPEND
+#undef CREATE
+#undef EXCL
+#undef TRUNC
+return 0;
+}
+int twrite_seek(fd_t fdi, offset_t offset, int whence)
+{
+int size;
+size = tffs_write(fdi, (char*) tdata[TDATA_HUGE] + 10, 100);
+if (test_expect(size, 100) < 0) return -1;
+offset = tffs_seek(fdi, offset, whence);
+if (test_expect_ok(offset)) return -1;
+return offset;
+}
+int tseek_read(fd_t fdi, offset_t offset, int whence, offset_t src_offset)
+{
+int size;
+offset = tffs_seek(fdi, offset, whence);
+if (test_expect_ok(offset)) return -1;
+size = tffs_read(fdi, bigbuf, 100);
+if (test_expect(size, 100) < 0) return -1;
+error = test_expect_data((char*)tdata[TDATA_HUGE] + src_offset, bigbuf, size);
+if (error) return error;
+return offset;
+}
+int tseek_write(fd_t fdi, offset_t offset, int whence, offset_t src_offset)
+{
+int size;
+offset = tffs_seek(fdi, offset, whence);
+if (test_expect_ok(offset)) return -1;
+size = tffs_write(fdi, (char*) tdata[TDATA_HUGE] + src_offset + offset,
+fs.chunk_size_max / 2);
+if (test_expect(size, fs.chunk_size_max / 2) < 0) return -1;
+return offset;
+}
+int case_rw(int p0, int p1)
+{
+int i, size, offset;
+fd_t fdi;
+const char *dirs[] = { "/streams", "/streams/rw", "/streams/rw/multi",
+"/streams/rw/multi/write" };
+error = case_cleanup(5 * fs.chunk_size_max);
+expect_ok(error);
+for (i = 0; i < sizeof(dirs)/sizeof(char *); i++) {
+error = tffs_mkdir(dirs[i]);
+}
+tw(tr(TR_FUNC, TrTestHigh,
+"Test create and append of file, small and huge\n"));
+ttw(str(TTrTest, "Test create and append of file, small and huge" NL));
+fdi = tffs_open("/streams/rw_test",
+FFS_O_WRONLY | FFS_O_CREATE | FFS_O_TRUNC);
+expect(fdi, FFS_FD_OFFSET);
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE], 31);
+expect(size, 31);
+error = tffs_close(fdi); expect(error, EFFS_OK);
+fdi = tffs_open("/streams/rw_test", FFS_O_WRONLY | FFS_O_APPEND);
+expect(fdi, FFS_FD_OFFSET);
+size = tffs_write(fdi, (char*) tdata[TDATA_HUGE] + 31, 2 * fs.chunk_size_max);
+expect(size, 2 * fs.chunk_size_max);
+error = tffs_close(fdi); expect(error, EFFS_OK);
+tw(tr(TR_FUNC, TrTestLow, "Validate data \n"));
+ttw(ttr(TTrTest, "Validate data" NL));
+size = tffs_fread("/streams/rw_test", bigbuf, bigbuf_size);
+expect(size, 31 + 2 * fs.chunk_size_max);
+error = test_expect_data((char *)tdata[TDATA_HUGE], bigbuf, size);
+if (error) return 1;
+// Provoke EFFS_FILETOOBIG
+error = tffs_fread("/streams/rw_test", bigbuf, size - 1);
+expect(error, EFFS_FILETOOBIG);
+error = tffs_fread("/streams/rw_test", bigbuf, size + 1);
+expect_ok(error);
+error = tffs_fread("/streams/rw_test", bigbuf, size);
+expect_ok(error);
+// Update file from zero, middle (between to chunks) and end. File with
+// and without data in seghead. Update the first 100 bytes (new data
+// have a offset of 10 so the data not is identical with the existing
+// ones).
+fdi = tffs_open("/streams/rw_test", FFS_O_RDWR);
+expect(fdi, FFS_FD_OFFSET);
+// write 100 bytes and seek to 50 bytes before end of the first chunk
+expect_ok(twrite_seek(fdi, fs.chunk_size_max - 50, FFS_SEEK_SET));
+// write 100 bytes, seek to 50 bytes from the end of the file
+expect_ok(twrite_seek(fdi, -50, FFS_SEEK_END));
+// Write 100 bytes. This will update the last 19 bytes of second chunk,
+// update and append data to the last chunk.  Read the last data but
+// only 80 bytes because they are in the buffer
+expect_ok(twrite_seek(fdi, -80, FFS_SEEK_CUR));
+tw(tr(TR_FUNC, TrTestLow, "Validate data \n"));
+ttw(ttr(TTrTest, "Validate data" NL));
+size = tffs_read(fdi, bigbuf, 100);
+expect(size, 80);
+error = test_expect_data((char *)tdata[TDATA_HUGE] + 10 + 20, bigbuf, size);
+if (error) return 1;
+// Seek to start of file and read the first 100 bytes that was updated
+offset = tseek_read(fdi, 0, FFS_SEEK_SET, 10);
+expect_ok(offset);
+// Read 100 bytes more to make sure that the old data still is valid
+offset = tseek_read(fdi, 0, FFS_SEEK_CUR, 100);
+expect_ok(offset);
+// Seek to 50 bytes before end of the first chunk and read 100 bytes
+offset = tseek_read(fdi, fs.chunk_size_max - 50, FFS_SEEK_SET, 10);
+expect_ok(offset);
+// Read 100 bytes more to make sure that the old data still is valid
+offset = tseek_read(fdi, 0, FFS_SEEK_CUR, offset + 100);
+expect_ok(offset);
+// Read the last 100 bytes (updated data from 2 chunks)
+offset = tseek_read(fdi, -100, FFS_SEEK_END, 10);
+expect_ok(offset);
+error = tffs_close(fdi);
+expect(error, EFFS_OK);
+// Test where there is data in the seghead
+size = tffs_file_write("/streams/rw_test", (char*) tdata[TDATA_HUGE],
+2 * fs.chunk_size_max, FFS_O_CREATE | FFS_O_TRUNC);
+fdi = tffs_open("/streams/rw_test", FFS_O_RDWR);
+expect(fdi, FFS_FD_OFFSET);
+// Update the last half of the last chunk
+expect_ok(tseek_write(fdi, -fs.chunk_size_max / 2, FFS_SEEK_END, 10));
+// Update the first half of the last chunk
+expect_ok(tseek_write(fdi, fs.chunk_size_max, FFS_SEEK_SET, 10));
+// Update the first half of the seghead
+expect_ok(tseek_write(fdi, 0, FFS_SEEK_SET, 10));
+// Update the last half of the seghead, but flush the buffer so it have
+// to write and read the previous updated data
+error = tffs_fdatasync(fdi);
+expect(error, EFFS_OK);
+size = tffs_write(fdi, (char*) tdata[TDATA_HUGE] + 10 + fs.chunk_size_max/2,
+fs.chunk_size_max/2);
+expect(size, fs.chunk_size_max/2);
+tw(tr(TR_FUNC, TrTestLow, "Validate data \n"));
+ttw(ttr(TTrTest, "Validate data" NL));
+// Read the complete file, all the data should have a offset of 10 bytes now!
+offset = tffs_seek(fdi, 0, FFS_SEEK_SET);
+expect_ok(offset);
+size = tffs_read(fdi, bigbuf, bigbuf_size);
+expect(size, 2 * fs.chunk_size_max);
+error = test_expect_data((char *)tdata[TDATA_HUGE] + 10, bigbuf, size);
+if (error) return 1;
+error = tffs_close(fdi); expect(error, 0);
+// Test bad fdi, write in RDONLY and read from WRONLY
+fdi = tffs_open("/streams/rw_test", FFS_O_RDONLY);
+expect(fdi, FFS_FD_OFFSET);
+size = tffs_read(fdi + 1, bigbuf, 31);
+expect(size, EFFS_BADFD);
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE], 31);
+tw(tr(TR_END, TrApi, "} %d\n", size)); // Avoid wrong indent
+expect(size, EFFS_INVALID);
+error = tffs_close(fdi);  expect(error, 0);
+fdi = tffs_open("/streams/rw_test", FFS_O_WRONLY | FFS_O_APPEND);
+expect(fdi, FFS_FD_OFFSET);
+size = tffs_read(fdi, bigbuf, 31);
+expect(size, EFFS_INVALID);
+error = tffs_close(fdi); expect(error, 0);
+// Test for bad file name
+fdi = tffs_open("/stream&!'*", FFS_O_WRONLY | FFS_O_CREATE);
+expect(fdi, EFFS_BADNAME);
+// Test for bad file name
+fdi = tffs_open("/%$#.+-_,Z19", FFS_O_WRONLY | FFS_O_CREATE);
+expect(fdi, FFS_FD_OFFSET);
+tffs_close(fdi);
+return 0;
+}
+int case_multi_open(int p0, int p1)
+{
+int i, j, size;
+fd_t fdi;
+const char *dirs[] = { "/streams", "/streams/rw", "/streams/rw/multi",
+"/streams/rw/multi/write" };
+const char *file[] = { "/x-rw", "/streams/rw/x-rw",
+"/streams/rw/multi/x-rw",
+"/streams/rw/multi/write/x-rw" };
+error = case_cleanup(fs.fd_max * 50 * 10 + 5000);
+expect_ok(error);
+for (i = 0; i < sizeof(dirs)/sizeof(char *); i++) {
+error = tffs_mkdir(dirs[i]);
+}
+// Open multiply files from difference subdirectorys
+// and write/read X times to/from file (this also test truncate option)
+for (i = 0; i < fs.fd_max; i++) {
+fdi = tffs_open( file[i], FFS_O_WRONLY | FFS_O_APPEND |
+FFS_O_CREATE | FFS_O_TRUNC);
+expect(fdi, i + FFS_FD_OFFSET);
+}
+for (i = 0; i < fs.fd_max; i++) {
+for (j = 0; j < 10; j++) {
+size = tffs_write(i + FFS_FD_OFFSET, (char *) tdata[TDATA_HUGE], 50);
+expect(size, 50);
+}
+}
+// Run test with p0 != 0 to stress the test
+if (p0) { error = test_run("irec;drec;"); if (error > 0) return 1; }
+for (i = 0; i < fs.fd_max; i++) {
+error = tffs_close(i + FFS_FD_OFFSET);
+expect(error, 0);
+}
+for (i = 0; i < fs.fd_max; i++) {
+fdi = tffs_open( file[i], FFS_O_RDONLY);
+expect(fdi, i + FFS_FD_OFFSET);
+}
+if(p0) { error = test_run("irec;drec;"); if (error > 0) return 1; }
+for (i = 0; i < fs.fd_max; i++) {
+for (j = 0; j < 10; j++) {
+size = tffs_read(i + FFS_FD_OFFSET, bigbuf, 50);
+expect(size, 50);
+error = test_expect_data((char *)tdata[TDATA_HUGE], bigbuf, size);
+if (error) return 1;
+}
+}
+for (i = 0; i < fs.fd_max; i++) {
+error = tffs_close(i + FFS_FD_OFFSET);
+expect(error, 0);
+}
+return 0;
+}
+int case_seek(int p0, int p1)
+{
+fd_t fdi;
+int size, offset;
+error = case_cleanup(3 * fs.chunk_size_max);
+expect_ok(error);
+// The seek function itself don't care if the file is open in read or
+// write mode.
+error = tffs_mkdir("/streams");
+offset = tffs_seek(FFS_FD_OFFSET, 0, FFS_SEEK_SET);
+expect(offset, EFFS_BADFD);
+/* Make file to seek on */
+fdi = tffs_open("/streams/seek", FFS_O_RDWR | FFS_O_CREATE | FFS_O_TRUNC);
+expect(fdi, FFS_FD_OFFSET);
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE], 3 * fs.chunk_size_max);
+expect(size, 3 * fs.chunk_size_max);
+/*  Simple test in RDWR without any writes. Test good and bad offset */
+tw(tr(TR_FUNC, TrTestHigh, "seek and RDWR \n"));
+ttw(str(TTrTest, "seek and RDWR" NL));
+offset = ffs_seek(fdi, 0, 5);
+expect(offset, EFFS_INVALID );
+tw(tr(TR_FUNC, TrTestHigh, "ffs_seek(FFS_SEEK_SET)\n"));
+ttw(str(TTrTest, "ffs_seek(FFS_SEEK_SET)" NL));
+offset = tffs_seek(fdi, -1, FFS_SEEK_SET);
+expect(offset, EFFS_INVALID);
+offset = tffs_seek(fdi, 3 * fs.chunk_size_max + 1, FFS_SEEK_SET);
+expect(offset, EFFS_INVALID);
+offset = tffs_seek(fdi, 15, FFS_SEEK_SET);
+expect(offset, 15);
+size = tffs_read(fdi, bigbuf, fs.chunk_size_max/10);
+expect(size, fs.chunk_size_max/10);
+error = test_expect_data((char *)tdata[TDATA_HUGE] + 15,
+bigbuf, fs.chunk_size_max/10);
+if (error) return 1;
+offset = tffs_seek(fdi, 0, FFS_SEEK_SET);
+expect(offset, 0);
+size = tffs_read(fdi, bigbuf, bigbuf_size);
+error = test_expect_data((char*)tdata[TDATA_HUGE], bigbuf, size);
+if (error) return 1;
+tw(tr(TR_FUNC, TrTestHigh, "ffs_seek(FFS_SEEK_CUR)\n"));
+ttw(str(TTrTest, "ffs_seek(FFS_SEEK_CUR)" NL));
+offset = tffs_seek(fdi, -(3 * fs.chunk_size_max + 1), FFS_SEEK_CUR);
+expect(offset, EFFS_INVALID);
+offset = tffs_seek(fdi, 1, FFS_SEEK_CUR);
+expect(offset, EFFS_INVALID);
+offset = tffs_seek(fdi, 0, FFS_SEEK_CUR);
+expect(offset, 3 * fs.chunk_size_max);
+offset = tffs_seek(fdi, -30, FFS_SEEK_CUR);
+expect(offset, 3 * fs.chunk_size_max - 30);
+offset = tffs_seek(fdi, 20, FFS_SEEK_CUR);
+expect(offset, 3 * fs.chunk_size_max - 30 + 20);
+size = tffs_read(fdi, bigbuf, 3 * fs.chunk_size_max);
+expect(size, 10);
+error = test_expect_data((char *)tdata[TDATA_HUGE] +
+(3 * fs.chunk_size_max - 10), bigbuf, 10);
+if (error) return 1;
+tw(tr(TR_FUNC, TrTestHigh, "ffs_seek(FFS_SEEK_END)\n"));
+ttw(str(TTrTest, "ffs_seek(FFS_SEEK_END)" NL));
+offset = tffs_seek(fdi, -(3 * fs.chunk_size_max + 1), FFS_SEEK_END);
+expect(offset, EFFS_INVALID);
+offset = tffs_seek(fdi, 1, FFS_SEEK_END);
+expect(offset, EFFS_INVALID);
+offset = tffs_seek(fdi, 0, FFS_SEEK_END);
+expect(offset, 3 * fs.chunk_size_max);
+offset = tffs_seek(fdi, -15, FFS_SEEK_END);
+expect(offset, 3 * fs.chunk_size_max - 15);
+size = tffs_read(fdi, bigbuf, 20);
+expect(size, 15);
+error = test_expect_data((char *)tdata[TDATA_HUGE] +
+(3 * fs.chunk_size_max - 15), bigbuf, size);
+if (error) return 1;
+error = tffs_close(fdi);
+expect(error, 0);
+// Seek in write-mode with write in different places of the file. Test
+// on the dirty flag to se if the buffer is flushed ad the rigth time
+tw(tr(TR_FUNC, TrTestHigh, "seek and WRONLY \n"));
+ttw(str(TTrTest, "seek and WRONLY" NL));
+fdi = tffs_open("/streams/seek", FFS_O_WRONLY);
+// Write and seek in the last chunk, buffer must be dirty so long the fp
+// not have been moved away from that chunk!
+offset = tffs_seek(fdi, -20, FFS_SEEK_END); expect_ok(offset);
+expect(fs.fd[fdi - FFS_FD_OFFSET].dirty, 0);
+size = tffs_write(fdi, (char*) tdata[TDATA_HUGE], 10); expect(size, 10);
+expect(fs.fd[fdi - FFS_FD_OFFSET].dirty, 1);
+offset = tffs_seek(fdi, -100, FFS_SEEK_CUR); expect_ok(offset);
+expect(fs.fd[fdi - FFS_FD_OFFSET].dirty, 1);
+size = tffs_write(fdi, (char*) tdata[TDATA_HUGE], 10); expect(size, 10);
+expect(fs.fd[fdi - FFS_FD_OFFSET].dirty, 1);
+offset = tffs_seek(fdi, -fs.chunk_size_max/4, FFS_SEEK_CUR); expect_ok(offset);
+expect(fs.fd[fdi - FFS_FD_OFFSET].dirty, 1);
+size = tffs_write(fdi, (char*) tdata[TDATA_HUGE], 10); expect(size, 10);
+expect(fs.fd[fdi - FFS_FD_OFFSET].dirty, 1);
+offset = tffs_seek(fdi, offset + 10, FFS_SEEK_SET); expect_ok(offset);
+expect(fs.fd[fdi - FFS_FD_OFFSET].dirty, 1);
+size = tffs_write(fdi, (char*) tdata[TDATA_HUGE], 10); expect(size, 10);
+expect(fs.fd[fdi - FFS_FD_OFFSET].dirty, 1);
+// Write and seek across several chunks, the buffer must be flushed after
+// leaving a 'dirty' chunk.
+offset = tffs_seek(fdi, 10, FFS_SEEK_SET); expect_ok(offset);
+expect(fs.fd[fdi - FFS_FD_OFFSET].dirty, 0);
+size = tffs_write(fdi, (char*) tdata[TDATA_HUGE], 10); expect(size, 10);
+expect(fs.fd[fdi - FFS_FD_OFFSET].dirty, 1);
+offset = tffs_seek(fdi, -50, FFS_SEEK_END); expect_ok(offset);
+expect(fs.fd[fdi - FFS_FD_OFFSET].dirty, 0);
+size = tffs_write(fdi, (char*) tdata[TDATA_HUGE], 100); expect(size, 100);
+expect(fs.fd[fdi - FFS_FD_OFFSET].dirty, 1);
+offset = tffs_seek(fdi, -fs.chunk_size_max, FFS_SEEK_CUR); expect_ok(offset);
+expect(fs.fd[fdi - FFS_FD_OFFSET].dirty, 0);
+size = tffs_write(fdi, (char*) tdata[TDATA_HUGE], fs.chunk_size_max / 2);
+expect(size, fs.chunk_size_max / 2);
+expect(fs.fd[fdi - FFS_FD_OFFSET].dirty, 1);
+offset = tffs_seek(fdi, fs.chunk_size_max, FFS_SEEK_SET); expect_ok(offset);
+expect(fs.fd[fdi - FFS_FD_OFFSET].dirty, 0);
+size = tffs_write(fdi, (char*) tdata[TDATA_HUGE], 50); expect(size, 50);
+expect(fs.fd[fdi - FFS_FD_OFFSET].dirty, 1);
+error = tffs_close(fdi);
+expect(error, 0);
+return 0;
+}
+// NOTEME: move to other place later
+int case_trunc(int p0, int p1)
+{
+fd_t fdi;
+int size, f_size, trunc_size, i;
+T_FFS_STAT stat;
+char fname[] = "/truncate/normal_file";
+char sname[] = "/truncate/stream_file";
+char imeifile[] = "/truncate/IMEI";
+tffs_remove(fname);
+tffs_remove(sname);
+error = case_cleanup(5 * fs.chunk_size_max);
+expect_ok(error);
+tffs_mkdir("/truncate");
+// Try to truncate a non existing file
+error = tffs_truncate(fname, 0);
+expect(error, EFFS_NOTFOUND);
+// Try to truncate a directory
+error = tffs_truncate("/truncate", 0);
+expect(error, EFFS_NOTAFILE);
+f_size = fs.chunk_size_max + 100;
+error = tffs_file_write(fname, (char *)tdata[TDATA_HUGE], f_size,
+FFS_O_TRUNC | FFS_O_WRONLY | FFS_O_CREATE);
+expect(error, EFFS_OK);
+/* Test truncate from file size + 3 to file size - 3 */
+for (i = 0; i < 6; i++) {
+trunc_size = f_size + 3 - i;
+tw(tr(TR_FUNC, TrTestLow, "TRUNC file to size %d \n", trunc_size));
+error = tffs_truncate(fname, trunc_size);
+expect(error, EFFS_OK);
+error = tffs_lstat(fname, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.size, (f_size < trunc_size ? f_size : trunc_size));
+}
+tw(tr(TR_FUNC, TrTestLow, "Validate data \n"));
+size = tffs_fread(fname, bigbuf, f_size);
+expect(size, trunc_size);  // ++ because of the last -- in for()
+error = test_expect_data((char *)tdata[TDATA_HUGE], bigbuf, size);
+if (error) return 1;
+tw(tr(TR_FUNC, TrTestLow, "Truncate file while it is open \n"));
+fdi = tffs_open(fname, FFS_O_WRONLY | FFS_O_APPEND);
+expect(fdi, FFS_FD_OFFSET);
+size = tffs_write(fdi, (char *) &tdata[TDATA_HUGE][trunc_size], 31);
+expect(size, 31);
+f_size = trunc_size + 31;
+// Truncate to a size less than fp, this will fail
+error = tffs_ftruncate(fdi, f_size - 1);
+expect(error, EFFS_INVALID);
+// Move fp otherwise it will not be possible to truncate
+error = ffs_seek(fdi, 0, FFS_SEEK_SET);
+expect(error, 0);
+// Test truncate from file size + 3 to file size - 3
+for (i = 0; i < 6; i++) {
+trunc_size = f_size + 3 - i;
+tw(tr(TR_FUNC, TrTestLow, "TRUNC file to size %d \n", trunc_size));
+error = tffs_ftruncate(fdi, trunc_size);
+expect(error, EFFS_OK);
+error = tffs_lstat(fname, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.size, (f_size < trunc_size ? f_size : trunc_size));
+}
+error = tffs_close(fdi);
+expect(error, EFFS_OK);
+tw(tr(TR_FUNC, TrTestLow, "Validate data \n"));
+size = tffs_fread(fname, bigbuf, f_size);
+expect(size, trunc_size);
+error = test_expect_data((char *)tdata[TDATA_HUGE], bigbuf, size);
+if (error) return 1;
+// We need to test ftruncate with a size less than the first chunk
+fdi = tffs_open(fname, FFS_O_WRONLY);
+expect(fdi, FFS_FD_OFFSET);
+error = tffs_ftruncate(fdi, 10);
+expect(error, EFFS_OK);
+error = tffs_ftruncate(fdi, 10);  // same size twice to complicate it
+expect(error, EFFS_OK);
+error = tffs_lstat(fname, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.size, 10);
+error = tffs_ftruncate(fdi, 0);
+expect(error, EFFS_OK);
+error = tffs_ftruncate(fdi, 0);
+expect(error, EFFS_OK);
+error = tffs_lstat(fname, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.size, 0);
+error = tffs_close(fdi);
+expect(error, EFFS_OK);
+// Stream file test, make 2 segments and test around the end of segment
+// 1 (file closed)
+fdi = tffs_open(sname, FFS_O_WRONLY | FFS_O_CREATE | FFS_O_TRUNC
+| FFS_O_APPEND);
+expect(fdi, FFS_FD_OFFSET);
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE], fs.chunk_size_max + 1);
+expect(size, fs.chunk_size_max + 1);
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE], 31);
+expect(size, 31);
+error = tffs_close(fdi);
+expect(error, EFFS_OK);
+f_size = fs.chunk_size_max + 1 + 31;
+for (i = 0; i < 6; i++) {
+trunc_size = fs.chunk_size_max + 1 + 3 - i;
+tw(tr(TR_FUNC, TrTestLow, "TRUNC stream to size %d \n", trunc_size));
+error = tffs_truncate(sname, trunc_size);
+expect(error, EFFS_OK);
+error = tffs_lstat(sname, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.size, trunc_size);
+}
+tw(tr(TR_FUNC, TrTestLow, "Validate data \n"));
+size = tffs_fread(sname, bigbuf, f_size);
+expect(size, trunc_size);
+error = test_expect_data((char *)tdata[TDATA_HUGE], bigbuf, size);
+if (error) return 1;
+// Try to enlarge the file.
+tw(tr(TR_FUNC, TrTestLow, "Try to enlarge the file \n"));
+error = tffs_truncate(sname, trunc_size + 1);
+expect(error, EFFS_OK);
+error = tffs_lstat(sname, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.size, trunc_size);
+fdi = tffs_open(sname, FFS_O_WRONLY);
+expect(fdi, FFS_FD_OFFSET);
+error = tffs_ftruncate(fdi, trunc_size + 1);
+expect(error, EFFS_OK);
+error = tffs_lstat(sname, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.size, trunc_size);
+error = tffs_close(fdi);
+expect(error, EFFS_OK);
+// Make a file with 2 segments + some data in the buffer, test around
+// end of segment 2 and the begining of segment 1 (file open).
+tw(tr(TR_FUNC, TrTestLow, "Truncate stream while it is open \n"));
+// Make segment 1
+fdi = tffs_open(sname, FFS_O_WRONLY | FFS_O_APPEND | FFS_O_TRUNC);
+expect(fdi, FFS_FD_OFFSET);
+f_size = tffs_write(fdi, (char *) tdata[TDATA_HUGE],
+2 * fs.chunk_size_max + 1);
+expect(f_size, 2 * fs.chunk_size_max + 1);
+// Move fp otherwise it will not be possible to truncate
+error = ffs_seek(fdi, 0, FFS_SEEK_SET);
+expect(error, 0);
+// Test around end of segment 2
+for (i = 0; i < 16; i++) {
+trunc_size = f_size + 3 - i;
+tw(tr(TR_FUNC, TrTestLow, "TRUNC stream to size %d \n",
+trunc_size));
+error = tffs_ftruncate(fdi, trunc_size);
+expect(error, EFFS_OK);
+error = tffs_lstat(sname, &stat); expect(error, EFFS_OK);
+expect_eq(stat.size, (f_size < trunc_size ? f_size : trunc_size));
+}
+// Test around begining of segment 1
+for (i = 0; i < 6; i++) {
+trunc_size = 3 - i;
+tw(tr(TR_FUNC, TrTestLow, "TRUNC stream to size %d \n",
+trunc_size));
+error = tffs_ftruncate(fdi, trunc_size);
+if (trunc_size >= 0) {
+expect(error, EFFS_OK);
+}
+else {
+expect(error, EFFS_INVALID);
+break;
+}
+error = tffs_lstat(sname, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.size, (trunc_size));
+}
+error = tffs_close(fdi);
+expect(error, EFFS_OK);
+// Make, truncate and append to a file (use ffs_ftruncate())
+fdi = tffs_open(sname, FFS_O_WRONLY | FFS_O_CREATE | FFS_O_TRUNC
+| FFS_O_APPEND);
+expect(fdi, FFS_FD_OFFSET);
+f_size = tffs_write(fdi, (char *) tdata[TDATA_HUGE], fs.chunk_size_max);
+expect(f_size, fs.chunk_size_max );
+tw(tr(TR_FUNC, TrTestLow, "write 1/2 buf size, trunc 1/4 buf size\n"));
+// write 1/2 buf size and truncate 1/4 buf size x times
+for (i = 0; i < 8; i++) {
+size = tffs_write(fdi, (char *) &tdata[TDATA_HUGE][f_size],
+fs.chunk_size_max / 2);
+if (size < 0) return size;
+f_size += size;
+size = tffs_seek(fdi, - fs.chunk_size_max / 4, FFS_SEEK_CUR);
+expect(size, f_size - fs.chunk_size_max / 4);
+error = tffs_ftruncate(fdi, f_size - fs.chunk_size_max / 4);
+expect(error, EFFS_OK);
+f_size -= fs.chunk_size_max / 4;
+error = tffs_lstat(sname, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.size, f_size);
+}
+error = tffs_close(fdi);
+expect(error, EFFS_OK);
+tw(tr(TR_FUNC, TrTestLow, "Validate data \n"));
+size = tffs_fread(sname, bigbuf, bigbuf_size);
+expect(size, f_size);
+error = test_expect_data((char *)tdata[TDATA_HUGE], bigbuf, f_size);
+if (error) return 1;
+// backwards trunc 1/2 write 1/4 x times
+tw(tr(TR_FUNC, TrTestLow, "trunc 1/2 buf size, write 1/4 buf size\n"));
+fdi = tffs_open(sname, FFS_O_WRONLY | FFS_O_APPEND);
+expect(fdi, FFS_FD_OFFSET);
+for (i = 0; i < 8; i++) {
+size = tffs_seek(fdi, - fs.chunk_size_max / 2, FFS_SEEK_CUR);
+expect(size, f_size - fs.chunk_size_max / 2);
+error = tffs_ftruncate(fdi, f_size - fs.chunk_size_max / 2);
+expect(error, EFFS_OK);
+f_size -= fs.chunk_size_max / 2;
+f_size += tffs_write(fdi, (char *) &tdata[TDATA_HUGE][f_size],
+fs.chunk_size_max / 4);
+error = tffs_lstat(sname, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.size, f_size);
+}
+if (p0) { error = test_run("irec"); if (error > 0) return 1; }
+error = tffs_close(fdi);
+expect(error, EFFS_OK);
+tw(tr(TR_FUNC, TrTestLow, "Validate data \n"));
+size = tffs_fread(sname, bigbuf, bigbuf_size);
+expect(size, f_size);
+error = test_expect_data((char *)tdata[TDATA_HUGE], bigbuf, f_size);
+if (error) return 1;
+tw(tr(TR_FUNC, TrTestLow, "Make 2 segments, truncate to zero and append\n"));
+fdi = tffs_open(sname, FFS_O_WRONLY | FFS_O_CREATE | FFS_O_TRUNC
+| FFS_O_APPEND);
+expect(fdi, FFS_FD_OFFSET);
+size = tffs_write(fdi, (char*) tdata[TDATA_HUGE], 2 * fs.chunk_size_max + 10);
+expect(size, 2 * fs.chunk_size_max + 10);
+// Move fp otherwise it will not be possible to truncate
+error = ffs_seek(fdi, 0, FFS_SEEK_SET);
+expect(error, 0);
+error = tffs_ftruncate(fdi, 0);
+expect(error, EFFS_OK);
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE], 150);
+expect(size, 150 );
+error = tffs_close(fdi);
+expect(error, EFFS_OK);
+if (p0) { error = test_run("irec;brec"); if (error > 0) return 1; }
+tw(tr(TR_FUNC, TrTestLow, "Validate data \n"));
+f_size = tffs_fread(sname, bigbuf, bigbuf_size);
+expect(f_size, size);
+error = test_expect_data((char *)tdata[TDATA_HUGE], bigbuf, f_size);
+if (error) return 1;
+// Truncate through a symlink
+error = tffs_symlink("/str", sname);
+expect(error, EFFS_OK);
+error = tffs_truncate("/str", 100);
+expect(error, EFFS_OK);
+f_size = tffs_fread(sname, bigbuf, bigbuf_size);
+expect(f_size, 100);
+error = test_expect_data((char *)tdata[TDATA_HUGE], bigbuf, f_size);
+if (error) return 1;
+tffs_remove("/str");
+// truncate a file which only have data in the stream buffer
+fdi = tffs_open(sname, FFS_O_WRONLY | FFS_O_CREATE | FFS_O_TRUNC
+| FFS_O_APPEND);
+expect(fdi, FFS_FD_OFFSET);
+f_size = tffs_write(fdi, (char *) tdata[TDATA_HUGE], 3);
+expect(f_size, 3);
+// Move fp otherwise it will not be possible to truncate
+error = ffs_seek(fdi, 0, FFS_SEEK_SET);
+expect(error, 0);
+tw(tr(TR_FUNC, TrTestLow, "Truncate in buffer\n"));
+for (i = 0; i < 4; i++) {
+error = tffs_ftruncate(fdi, --f_size);
+if (f_size >= 0) {
+expect(error, EFFS_OK);
+error = tffs_lstat(sname, &stat);
+expect(error, EFFS_OK);
+expect_eq(stat.size, f_size);
+}
+else {
+expect(error, EFFS_INVALID);
+}
+}
+error = tffs_close(fdi);
+expect(error, EFFS_OK);
+// Try to truncate a read-only file
+error = tffs_fwrite(imeifile, TDATA(0));
+// The file is maybe already created!
+error = tffs_fcontrol(imeifile, OC_FLAGS, OF_READONLY);
+error = tffs_truncate(imeifile, 0);
+expect(error, EFFS_ACCESS);
+// Use ffs_truncate() on a file open in read mode
+fdi = tffs_open(fname, FFS_O_RDONLY);
+error = tffs_truncate(fname, 0);
+expect(error, EFFS_LOCKED);
+error = tffs_ftruncate(fdi, 0);
+expect(error, EFFS_INVALID);
+error = tffs_close(fdi);
+expect_ok(error);
+return 0;
+}
+int case_append(int p0, int p1)
+{
+fd_t fdi;
+int size, fsize;
+char sname[] = "/stream/append1";
+char fname[] = "/stream/append2";
+int offset = 0;
+if (param.data_blocks <= 1) {
+ttw(ttr(TTrTest, "WARNING: Too few blocks to run. Skip test" NL));
+tw(tr(TR_FUNC, TrTest, "WARNING: Too few blocks to run. Skip test\n"));
+return 0;
+}
+case_cleanup(fs.chunk_size_max * 5);
+tffs_mkdir("/stream");
+fdi = tffs_open(sname, FFS_O_RDWR | FFS_O_APPEND | FFS_O_TRUNC |
+FFS_O_CREATE);
+expect(fdi, FFS_FD_OFFSET);
+// Write data in buf and seek in the buf
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE], fs.chunk_size_max / 2);
+expect_gt(size, 0);
+offset = ffs_seek(fdi, -fs.chunk_size_max / 4, FFS_SEEK_CUR);
+expect_gt(offset, 0);
+expect(1, fs.fd[fdi - FFS_FD_OFFSET].dirty);
+// Append data and seek in the buffer ad the end of the last chunk
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE] +
+fs.fd[fdi - FFS_FD_OFFSET].size, fs.chunk_size_max);
+expect_gt(size, 0);
+offset = ffs_seek(fdi, -fs.chunk_size_max / 4, FFS_SEEK_END);
+expect_gt(offset, 0);
+size = tffs_read(fdi, bigbuf, fs.chunk_size_max / 4);
+expect(size, fs.chunk_size_max / 4);
+expect(1, fs.fd[fdi - FFS_FD_OFFSET].dirty);
+// Append data and seek away from buf
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE] +
+fs.fd[fdi - FFS_FD_OFFSET].size, fs.chunk_size_max * 1.5);
+expect_gt(size, 0);
+offset = ffs_seek(fdi, -fs.chunk_size_max * 2, FFS_SEEK_END);
+expect_gt(offset, 0);
+size = tffs_read(fdi, bigbuf, fs.chunk_size_max / 4);
+expect(size, fs.chunk_size_max / 4);
+// Append again and validate the data
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE] +
+fs.fd[fdi - FFS_FD_OFFSET].size, fs.chunk_size_max / 2);
+expect_gt(size, 0);
+offset = ffs_seek(fdi, 0, FFS_SEEK_SET);
+expect(0, offset);
+size = tffs_read(fdi, bigbuf, fs.fd[fdi - FFS_FD_OFFSET].size);
+expect_gt(size, 0);
+error = test_expect_data((char *)tdata[TDATA_HUGE], bigbuf, size);
+if (error) return 1;
+error = tffs_close(fdi);
+expect_ok(error);
+// Append on a file with data in the seghead
+fsize = fs.chunk_size_max / 4;
+error = tffs_file_write(fname, (char *)tdata[TDATA_HUGE], fsize,
+FFS_O_TRUNC | FFS_O_WRONLY | FFS_O_CREATE);
+expect(error, EFFS_OK);
+fdi = tffs_open(fname, FFS_O_RDWR | FFS_O_APPEND);
+expect(fdi, FFS_FD_OFFSET);
+// Write data in buf and seek in the buf
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE] + fsize,
+fs.chunk_size_max / 2);
+expect_gt(size, 0);
+fsize += size;
+offset = ffs_seek(fdi, 0, FFS_SEEK_SET);
+expect(offset, 0);
+expect(1, fs.fd[fdi - FFS_FD_OFFSET].dirty);
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE] + fsize,
+fs.chunk_size_max / 2);
+expect_gt(size, 0);
+fsize += size;
+error = test_expect_data((char *)tdata[TDATA_HUGE], bigbuf, fsize);
+if (error) return 1;
+error = tffs_close(fdi);
+expect_ok(error);
+return 0;
+}
+int case_datasync(int p0, int p1)
+{
+fd_t fdi;
+int size, fsize, offset, i;
+char myname[] = "/datasync";
+error = case_cleanup(4 * fs.chunk_size_max);
+expect_ok(error);
+fdi = tffs_open(myname, FFS_O_RDWR | FFS_O_TRUNC | FFS_O_CREATE);
+expect(fdi, FFS_FD_OFFSET);
+fsize = 0;
+for (i = 0; i < 10; i++) {
+// Write data in buf and use datasync
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE] + fsize,
+fs.chunk_size_max / 3);
+expect_gt(size, 0);
+fsize += size;
+error = tffs_fdatasync(fdi);
+expect(error, EFFS_OK);
+expect(0, fs.fd[fdi - FFS_FD_OFFSET].dirty);
+}
+error = tffs_fdatasync(fdi + 1);
+expect(error, EFFS_BADFD);
+// Seek to chunk 2, write data, seek, use fdatasync
+offset = tffs_seek(fdi, fs.chunk_size_max * 2.5, FFS_SEEK_SET);
+expect_gt(offset, 0);
+size = tffs_write(fdi, (char *) tdata[TDATA_HUGE] + offset,
+fs.chunk_size_max / 4);
+expect_gt(size, 0);
+offset = tffs_seek(fdi, -fs.chunk_size_max / 2, FFS_SEEK_CUR);
+expect_gt(offset, 0);
+error = tffs_fdatasync(fdi);
+expect(error, EFFS_OK);
+expect(0, fs.fd[fdi - FFS_FD_OFFSET].dirty);
+error = tffs_close(fdi);
+expect_ok(error);
+tw(tr(TR_FUNC, TrTestLow, "Validate data \n"));
+size = tffs_fread(myname, bigbuf, fsize);
+tw(tr(TR_FUNC, TrTestLow, "size: %d fsize: %d \n", size, fsize));
+expect(size, fsize);
+error = test_expect_data((char *)tdata[TDATA_HUGE], bigbuf, size);
+if (error) return 1;
+return 0;
+}
+int case_fw_flags(int p0, int p1)
+{
+int i;
+char myname[] = "/file_write";
+tffs_remove(myname);
+tw(tr(TR_FUNC, TrTestHigh, "Test ffs_file_write() flags, file non-exist\n"));
+for (i = 0; i < 0xFE; i++) {
+error = tffs_file_write(myname, 0,0, i);
+if (is_open_option(i, FFS_O_CREATE)) {
+expect_ok(error);
+error = tffs_remove(myname);
+expect_ok(error);
+}
+else
+expect(EFFS_NOTFOUND, error);
+}
+tw(tr(TR_FUNC, TrTestHigh, "Test ffs_file_write() flags, file exist\n"));
+error = tffs_file_write(myname, 0,0, FFS_O_CREATE);
+expect_ok(error);
+for (i = 0; i < 0xFF; i++) {
+error = tffs_file_write(myname, 0,0, i);
+if (is_open_option(i, FFS_O_EXCL) && is_open_option(i, FFS_O_CREATE)) {
+expect(error, EFFS_EXISTS);
+}
+else
+expect_ok(error);
+}
+return 0;
+}
+drv_Return_Type pcm_init(void);
+int case_pcm(int p0, int p1)
+{
+UBYTE version;
+UBYTE imei[] = "12345678";
+int size;
+ffs_mkdir("/pcm");
+// Write imei file to ffs. Run init (this reads the imei file), remove
+// the file from flash, write the imei to flash from pcm and validate
+// data.
+error = ffs_file_write("/pcm/IMEI", &imei, sizeof(imei), FFS_O_CREATE);
+expect_ok(error);
+error = pcm_init();
+expect(PCM_INITIALIZED, error);
+error = pcm_ReadFile((UBYTE *) EF_IMEI_ID, SIZE_EF_IMEI, imei, &version);
+expect(PCM_OK, error);
+error = ffs_remove("/pcm/IMEI");
+expect_ok(error);
+error =  pcm_WriteFile((UBYTE *) EF_IMEI_ID, SIZE_EF_IMEI, imei);
+expect(PCM_OK, error);
+tw(tr(TR_FUNC, TrTestLow, "Validate data \n"));
+size = tffs_fread("/pcm/IMEI", bigbuf, bigbuf_size);
+expect(size, SIZE_EF_IMEI);
+error = test_expect_data(imei, bigbuf, size);
+if (error) return 1;
+// TODO: test pcm_WriteRecord and pcm_ReadRecord.
+return 0;
+}
+int case_api_exceptions(int p0, int p1)
+{
+int i;
+T_FFS_DIR dir;
+T_FFS_FD myfdi;
+char myname[] = "/BAD";
+char mydir[] = "/tdir";
+char mylink[] = "/tlink";
+char mytfile[] = "/tfile";
+char buf[] = "foobar";
+// Create test file and dir
+error = tffs_file_write(mytfile, buf, sizeof(buf), FFS_O_CREATE);
+expect_ok(error);
+error = tffs_mkdir(mydir);
+if (error < 0 && error != EFFS_EXISTS) return 1;
+error = tffs_symlink(mytfile, mylink);
+if (error < 0 && error != EFFS_EXISTS) return 1;
+error = tffs_opendir(mydir, &dir);
+expect_ok(error);
+myfdi = tffs_open("/tsream", FFS_O_WRONLY | FFS_O_CREATE | FFS_O_TRUNC);
+expect(myfdi, FFS_FD_OFFSET);
+expect(tffs_write(myfdi, buf, sizeof(buf)), sizeof(buf));
+// Test all API functions for pathname with null pointers.
+for (i = 0; i < 17; i++) {
+switch (i) {
+case 0: error = tffs_open(0, FFS_O_WRONLY | FFS_O_CREATE); break;
+case 1: error = tffs_truncate(0, 1);    break;
+case 2: error = tffs_file_write(0, buf, sizeof(buf), FFS_O_CREATE); break;
+case 3: error = tffs_stat(0, &stat);    break;
+case 4: error = tffs_lstat(0, &stat);   break;
+case 5: error = tffs_xlstat(0, &xstat); break;
+case 6: error = tffs_remove(0);         break;
+case 7: error = tffs_mkdir(0);          break;
+case 8: error = tffs_opendir(0, &dir);  break;
+case 9: error = tffs_symlink(0, myname); break;
+case 10: error = tffs_symlink("/link", 0); break;
+case 11: error = tffs_readlink(0, buf, sizeof(buf)); break;
+case 12: error = tffs_rename(0, "/test"); break;
+case 13: error = tffs_rename(mytfile, 0); break;
+case 14: error = tffs_file_write(0, buf, sizeof(buf), FFS_O_CREATE); break;
+case 15: error = tffs_file_read(0, buf, sizeof(buf)); break;
+case 16: error = tffs_fcontrol(0, OC_FLAGS, OF_READONLY); break;
+default: error = EFFS_INVALID;
+}
+expect(error, EFFS_BADNAME);
+}
+// Test all API functions with buffer null pointers.
+for (i = 0; i < 13; i++) {
+switch (i) {
+case 0: error = tffs_file_write(myname, 0, 100, FFS_O_CREATE); break;
+case 1: error = tffs_file_read(mytfile, 0, 40); break;
+case 2: error = tffs_opendir(mydir, 0); break;
+case 3: error = ffs_readdir (0, buf, sizeof(buf)); break;
+case 4: error = ffs_readdir (&dir, 0, 100); break;
+case 5: error = tffs_readlink(mylink, 0, 1); break;
+case 6: error = tffs_stat(mytfile, 0); break;
+case 7: error = tffs_lstat(mylink, 0); break;
+case 8: error = tffs_xlstat(mylink, 0); break;
+case 9: error = tffs_query(Q_BYTES_FREE, 0); break;
+case 10: error = tffs_fstat(myfdi, 0); break;
+case 11: error = tffs_write(myfdi, 0, 10); break;
+case 12: error = tffs_read(myfdi, 0, 40); break;
+default: error = 0;
+}
+expect(error, EFFS_INVALID);
+}
+expect_ok(tffs_close(myfdi));
+// Make sure we still can create empty files!
+error = tffs_file_write("/empty_file", 0, 0, FFS_O_CREATE);
+expect_ok(error);
+// Open file for test of negative size
+myfdi = tffs_open(myname, FFS_O_RDWR | FFS_O_CREATE |
+FFS_O_TRUNC | FFS_O_APPEND);
+expect(myfdi, FFS_FD_OFFSET);
+// Test all API 'size' parameters with a negative size
+for (i = 0; i < 11; i++) {
+switch (i) {
+// Try modify
+case 0: error = tffs_write(myfdi, buf, -1); break;
+case 1: error = tffs_truncate(myname, -1); break;
+case 2: error = tffs_fwrite(myname, buf, -2); break;
+case 3: error = tffs_fcreate(myname, buf, -3); break;
+case 4: error = tffs_fupdate(myname, buf, -56); break;
+case 5: error = tffs_file_write(myname, buf, -100, FFS_O_CREATE); break;
+// Try read
+case 6: error = tffs_fread(mytfile, bigbuf, -1); break;
+case 7: error = tffs_file_read(mytfile, bigbuf, -2); break;
+case 8: error = tffs_readdir(&dir, bigbuf, -3); break;
+case 9: error = tffs_readlink(mytfile, bigbuf, -4); break;
+case 10: error = tffs_read(myfdi, bigbuf, -5); break;
+default: error = 0;
+}
+expect(error, EFFS_INVALID);
+}
+error = tffs_close(myfdi);
+expect_ok(error);
+return EFFS_OK;
+}
+int case_api_notformated(int p0, int p1)
+{
+int i;
+struct dir_s dir;
+fd_t fdi;
+char buf[20];
+uint16 q_out;
+struct xstat_s xstat;
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+for(i=1; i<24; i++)
+{
+switch(i)
+{
+case 1:  error = tffs_open("apinf", FFS_O_WRONLY);          break;
+case 2:  error = tffs_close(fdi);                         break;
+case 3:  error = tffs_write(fdi, "abcdefghij", 10);       break;
+case 4:  error = tffs_read(fdi, buf, 2);                  break;
+case 5:  error = tffs_seek(fdi, 0, FFS_SEEK_SET);         break;
+case 6:  error = tffs_truncate("apinf", 0);                 break;
+case 7:  error = tffs_fdatasync(fdi);                     break;
+case 8:  error = tffs_stat("apinf", &stat);                 break;
+case 9:  error = tffs_fstat(fdi, &stat);                  break;
+case 10: error = tffs_lstat("apinf", &stat);                break;
+case 11: error = tffs_xlstat("apinf", &xstat);              break;
+case 12: error = ffs_remove("/apinf");                      break;
+case 13: error = ffs_mkdir("/apinf");                       break;
+case 14: error = ffs_opendir("/apinf", &dir);               break;
+case 15: error = tffs_readdir(&dir, "/ffs", 21);          break;
+case 16: error = tffs_symlink("/europe/imie", "imei");    break;
+case 17: error = ffs_rename("/Pluto", "/Dog");            break;
+case 18: error = ffs_file_write("/non-exist", "1234567890", 10, FFS_O_TRUNC);          break;
+case 19: error = tffs_file_read("/stream1", buf, 10);     break;
+case 20: error = tffs_fcreate("/", "apinf", 3);             break;
+case 21: error = tffs_fupdate("/", "bar", 3);             break;
+case 22: error = tffs_fwrite("/europe/imie","0123456789", 10);          break;
+case 23: error = tffs_fcontrol("/apinf", OC_FLAGS, OF_READONLY);          break;
+}
+expect(error, EFFS_NOFORMAT);
+}
+/* query must return information even if the device isnt formated */
+error = tffs_query(Q_FS_INODES, (uint16 *) &q_out);
+expect(error, EFFS_OK);
+return 0;
+}
+int case_query(int p0, int p1)
+{
+int i;
+uint32 ret_val32;
+uint16 ret_val16;
+for(i=1; i<27; i++)
+{
+switch(i)
+{
+case 1:  error = ffs_query(Q_TM_BUFADDR, (uint32 *)&ret_val32); break;
+case 2:  error = ffs_query(Q_TM_BUFSIZE, (uint32 *)&ret_val32); break;
+case 3:  error = ffs_query(Q_DEV_BASE, (uint32 *)&ret_val32); break;
+case 4:  error = ffs_query(Q_FFS_API_VERSION, (uint16 *)&ret_val16); break;
+case 5:  error = ffs_query(Q_FFS_DRV_VERSION, (uint16 *)&ret_val16); break;
+case 6:  error = ffs_query(Q_FFS_REVISION, (uint16 *)&ret_val16); break;
+case 7:  error = ffs_query(Q_FFS_FORMAT_WRITE, (uint16 *)&ret_val16); break;
+case 8:  error = ffs_query(Q_FFS_FORMAT_READ, (uint16 *)&ret_val16); break;
+case 9:  error = ffs_query(Q_FFS_LASTERROR, (uint16 *)&ret_val16); break;
+case 10:  error = ffs_query(Q_FFS_TM_VERSION, (uint16 *)&ret_val16); break;
+case 11:  error = ffs_query(Q_OBJECTS_MAX, (uint16 *)&ret_val16); break;
+case 12:  error = ffs_query(Q_CHUNK_SIZE_MAX, (uint16 *)&ret_val16); break;
+case 13:  error = ffs_query(Q_FD_BUF_SIZE, (uint32 *)&ret_val32); break;
+case 14:  error = ffs_query(Q_FD_MAX, (uint16 *)&ret_val16); break;
+case 15:  error = ffs_query(Q_DEV_MANUFACTURER, (uint16 *)&ret_val16); break;
+case 16:  error = ffs_query(Q_DEV_DEVICE, (uint16 *)&ret_val16); break;
+case 17:  error = ffs_query(Q_DEV_DRIVER, (uint16 *)&ret_val16); break;
+case 18:  error = ffs_query(Q_LOST_HIGH, (uint16 *)&ret_val16); break;
+case 19:  error = ffs_query(Q_FS_FLAGS, (uint16 *)&ret_val16); break;
+case 20:  error = ffs_query(Q_FS_ROOT, (uint16 *)&ret_val16); break;
+case 21:  error = ffs_query(Q_STATS_DRECLAIMS, (uint32 *)&ret_val32); break;
+case 22:  error = ffs_query(Q_STATS_IRECLAIMS, (uint32 *)&ret_val32); break;
+case 23:  error = ffs_query(Q_STATS_DATA_RECLAIMED, (uint32 *)&ret_val32); break;
+case 24:  error = ffs_query(Q_STATS_INODES_RECLAIMED, (uint32 *)&ret_val32); break;
+case 25:  error = ffs_query(Q_STATS_DATA_ALLOCATED, (uint32 *)&ret_val32); break;
+case 26:  error = ffs_query(Q_REQUEST_ID_LAST, (uint32 *)&ret_val32); break;
+}
+expect(error, EFFS_OK);
+}
+return 0;
+}
+extern uint16 ffs_flash_device;
+extern uint16 ffs_flash_manufact;
+int case_octrl(int p0, int p1)
+{
+int org_fsflags = fs.flags, org_manufact = ffs_flash_manufact;
+int org_device = ffs_flash_device, org_testf = fs.testflags;
+error = object_control(0, OC_FS_FLAGS, 0x02);
+expect(error, EFFS_OK);
+error = object_control(0, OC_DEV_MANUFACT, 'T');
+expect(error, EFFS_OK);
+error = object_control(0, OC_DEV_DEVICE, 0x0F12);
+expect(error, EFFS_OK);
+error = object_control(0, OC_DEBUG_0, 0xAFFE);
+expect(error, EFFS_OK);
+error = object_control(0, OC_DEBUG_LAST+1, 0);
+expect(error, EFFS_INVALID);
+// Restore the values or else it mess up the other tests
+fs.flags = org_fsflags;
+fs.testflags = org_testf;
+ffs_flash_manufact = org_manufact;
+ffs_flash_device = org_device;
+return 0;
+}
+/***************************************************************************/
+/*          Examples from RIV111                                           */
+/***************************************************************************/
+#if (TARGET == 0)
+int case_examples(int p0, int p1)
+{
+return 0;
+}
+#else
+static req_id_t my_request_id;
+static int removed_greeting;
+static void my_callback(T_FFS_FILE_CNF *confirm)
+{
+ttw(ttr(TTrTest, "my_callback(%d, %s, %d)" NL,
+confirm->error, confirm->path, confirm->request_id));
+if (my_request_id !=  confirm->request_id) {
+ttw(ttr(TTrFatal, "error (%d, %d)" NL, confirm->request_id, my_request_id));
+return;
+}
+if (confirm->error < 0) {
+ttw(ttr(TTrTest, "FATAL: my_callback error: %d" NL, confirm->error));
+}
+else {
+ttw(ttr(TTrTest, "Remove 'greeting'" NL));
+ffs_remove_nb("/greeting", 0);
+removed_greeting = 1;
+}
+error = rvf_free_buf(confirm);
+if (error < 0)
+ttr(TTrFatal, "FFS FATAL: os_free() %d" NL, error);
+}
+// Using Function Callback
+T_RV_RETURN my_fc_cnfpath = {0, (CALLBACK_FUNC)my_callback};
+// Using Mail Callback
+#define MY_TASK_ID (MAX_RVF_TASKS - 1 - 1)  // same as FFS_TEST_TASK_ID
+T_RV_RETURN my_mail_cnfpath = {MY_TASK_ID, 0};
+int case_examples(int p0, int p1)
+{
+if(1) {
+// MMI Configuration scenario
+struct {
+int volume;
+uint32 ringtype;
+} mmi;
+int temp;
+ttw(ttr(TTrTest, "Run MMI conf." NL));
+mmi.volume = temp = 3;
+mmi.ringtype = 1111;
+ffs_mkdir("/mmi");
+ffs_fwrite("/mmi/volume", &mmi.volume, sizeof(mmi.volume));
+error = ffs_file_read("/mmi/volume", &mmi.volume, sizeof(mmi.volume));
+if (error < 0)
+return 1;
+error = test_expect_data(&temp, &mmi.volume, sizeof(mmi.volume));
+if (error < 0)
+return 1;
+}
+if(1) {
+// Using Mail Callback
+T_FFS_FILE_CNF *confirm_file;
+T_FFS_STREAM_CNF *confirm_stream;
+T_FFS_RET error;
+T_FFS_FD fdi;
+char hello[] = "Hello, world";
+T_FFS_SIZE size;
+ttw(ttr(TTrTest, "Use Mail Callback" NL));
+if ((my_request_id = ffs_open_nb("/mmi/sound",
+FFS_O_WRONLY | FFS_O_CREATE |
+FFS_O_APPEND | FFS_O_TRUNC,
+&my_mail_cnfpath)) < 0)
+return my_request_id;
+ttw(ttr(TTrTest, "Wait..." NL));
+rvf_wait(RVF_TASK_MBOX_0_EVT_MASK, 0);
+ttw(ttr(TTrTest, "Get mail" NL));
+confirm_file = (T_FFS_FILE_CNF *) rvf_read_mbox(RVF_TASK_MBOX_0);
+fdi = confirm_file->error;
+expect(FFS_FD_OFFSET, fdi);
+expect(my_request_id, confirm_file->request_id);
+expect(FFS_MESSAGE_OFFSET, confirm_file->header.msg_id);
+ttw(ttr(TTrTest, "Path '%s'" NL, confirm_file->path));
+error = rvf_free_buf(confirm_file);
+if (error < 0)
+ttr(TTrFatal, "FFS FATAL: os_free() %d" NL, error);
+if ((my_request_id = ffs_write_nb(fdi, hello, strlen(hello) ,
+&my_mail_cnfpath)) < 0)
+return my_request_id;
+ttw(ttr(TTrTest, "Wait..." NL));
+rvf_wait(RVF_TASK_MBOX_0_EVT_MASK, 0);
+ttw(ttr(TTrTest, "Get mail" NL));
+confirm_stream = (T_FFS_STREAM_CNF *) rvf_read_mbox(RVF_TASK_MBOX_0);
+size = confirm_stream->error;
+expect(strlen(hello), size);
+expect(my_request_id, confirm_stream->request_id);
+ttw(ttr(TTrTest, "fdi: %d" NL, confirm_stream->fdi));
+error = rvf_free_buf(confirm_stream);
+if (error < 0)
+ttr(TTrFatal, "FFS FATAL: os_free() %d" NL, error);
+ttw(ttr(TTrTest, "Close file" NL));
+if ((error = ffs_close(fdi)) < 0)
+return error;
+}
+if(1) {
+// Using Function Callback
+char hello[] = "Hello, world";
+T_FFS_STAT stat;
+ttw(ttr(TTrTest, "Use Function Callback" NL));
+if ((my_request_id = ffs_fcreate_nb("/greeting", hello, strlen(hello),
+&my_fc_cnfpath)) < 0)
+return my_request_id;
+// Wait until my_callback() has removed the file "greeting"
+removed_greeting = 0;
+while (removed_greeting == 0)
+tffs_delay(10);
+// NOTE: This is importent because if the test brec runs immediately
+// after his one will the brec test fail because the "greeting" file
+// is removed inside the brec test which don't expect that files is
+// removed.
+}
+return 0;
+}
+#endif
+/******************************************************************************
+* Non blocking test ffs_xx_nb()
+******************************************************************************/
+#if (TARGET == 0)
+int case_nonblock(int p0, int p1)
+{
+tw(tr(TR_FUNC, TrTest,
+"WARNING: This test can only run in target. Skip test\n"));
+return 0;
+}
+#else
+extern int request_id_last;  // from task.c
+#define WAIT_GET_TEST      ttw(ttr(TTrTest, "Wait..." NL)); rvf_wait(RVF_TASK_MBOX_0_EVT_MASK, 0); ttw(ttr(TTrTest, "Get mail" NL)); confirm_file = (T_FFS_FILE_CNF *) rvf_read_mbox(RVF_TASK_MBOX_0); ttw(ttr(TTrTest, "Path '%s'" NL, confirm_file->path)); expect(FFS_MESSAGE_OFFSET, confirm_file->header.msg_id); expect(my_id, confirm_file->request_id);
+#define WAIT_GET_TEST_FDI  ttw(ttr(TTrTest, "Wait..." NL)); rvf_wait(RVF_TASK_MBOX_0_EVT_MASK, 0); confirm_stream = (T_FFS_STREAM_CNF *) rvf_read_mbox(RVF_TASK_MBOX_0); ttw(ttr(TTrTest, "Get mail" NL)); ttw(ttr(TTrTest, "fdi: %d" NL, confirm_stream->fdi)); expect(FFS_MESSAGE_OFFSET, confirm_stream->header.msg_id); expect(FFS_FD_OFFSET, confirm_stream->fdi); expect(my_id, confirm_stream->request_id);
+#define FREE error = rvf_free_buf(confirm_file); if (error < 0) { ttr(TTrFatal, "FFS FATAL: os_free() %d" NL, error); return 1;}
+#define FREE_FDI error = rvf_free_buf(confirm_stream); if (error < 0) { ttr(TTrFatal, "FFS FATAL: os_free() %d" NL, error); return 1;}
+int case_nonblock(int p0, int p1)
+{
+T_FFS_FILE_CNF *confirm_file;
+T_FFS_STREAM_CNF *confirm_stream;
+T_FFS_RET error;
+T_FFS_FD fdi;
+char hello[] = "Hello, world";
+char myfname[] = "/non_block/file";
+char mysname[] = "/non_block/stream";
+T_FFS_SIZE size;
+int i;
+T_FFS_REQ_ID my_id;
+// mail confirm
+T_RV_RETURN cnfpath = {MY_TASK_ID, 0};
+// Test wrap arround in request_id_get(). Set id to 5 from max, the following
+// function calls will trigger the wrap arround
+request_id_last = 0x7FFFFFFF - 5;
+ttw(ttr(TTrTest, "request :%d" NL, request_id_last));
+// preformat, format, mkdir
+// open, write, ftruncate, close, remove,
+// file_write, symlink, rename, truncate, fcontrol
+my_id = ffs_preformat_nb(0xDEAD, &cnfpath);
+expect_gt(my_id, -1);
+WAIT_GET_TEST; FREE;
+my_id = ffs_format_nb("/ffs", 0x2BAD, &cnfpath);
+expect_gt(my_id, -1);
+WAIT_GET_TEST; FREE;
+my_id = ffs_mkdir_nb("/non_block", &cnfpath);
+expect_gt(my_id, -1);
+WAIT_GET_TEST; FREE;
+if ((my_id = ffs_open_nb(mysname, FFS_O_WRONLY | FFS_O_CREATE,
+&cnfpath)) < 0)
+return my_id;
+WAIT_GET_TEST;
+fdi = confirm_file->error;
+expect(FFS_FD_OFFSET, fdi);
+FREE;
+if ((my_id = ffs_write_nb(fdi, hello, strlen(hello), &cnfpath)) < 0)
+return my_id;
+WAIT_GET_TEST_FDI; FREE_FDI;
+expect(1, fs.fd[fdi - FFS_FD_OFFSET].dirty);
+if ((my_id = ffs_fdatasync_nb(fdi, &cnfpath)) < 0)
+return my_id;
+WAIT_GET_TEST_FDI; FREE_FDI;
+expect(0, fs.fd[fdi - FFS_FD_OFFSET].dirty);
+if ((my_id = ffs_seek_nb(fdi, 2, FFS_SEEK_SET, &cnfpath)) < 0)
+return my_id;
+WAIT_GET_TEST_FDI; FREE_FDI;
+expect(2, fs.fd[fdi - FFS_FD_OFFSET].fp);
+if ((my_id = ffs_ftruncate_nb(fdi, 3, &cnfpath)) < 0)
+return my_id;
+WAIT_GET_TEST_FDI;
+expect(EFFS_OK, confirm_stream->error);
+FREE_FDI;
+if ((my_id = ffs_close_nb(fdi, &cnfpath)) < 0)
+return my_id;
+WAIT_GET_TEST_FDI;
+expect(EFFS_OK, confirm_stream->error);
+FREE_FDI;
+if ((my_id = ffs_remove_nb(mysname, &cnfpath)) < 0)
+return my_id;
+WAIT_GET_TEST;
+expect(EFFS_OK, confirm_file->error);
+FREE;
+if ((my_id = ffs_file_write_nb(myfname, hello, strlen(hello),
+FFS_O_WRONLY | FFS_O_CREATE, &cnfpath)) < 0)
+return my_id;
+WAIT_GET_TEST;
+expect(EFFS_OK, confirm_file->error);
+FREE;
+if ((my_id = ffs_symlink_nb("/nb_file", myfname, &cnfpath)) < 0)
+return my_id;
+WAIT_GET_TEST;
+expect(EFFS_OK, confirm_file->error);
+FREE;
+if ((my_id = ffs_rename_nb("/nb_file", "/nbf", &cnfpath)) < 0)
+return my_id;
+WAIT_GET_TEST;
+expect(EFFS_OK, confirm_file->error);
+FREE;
+if ((my_id = ffs_truncate_nb(myfname, 0, &cnfpath)) < 0)
+return my_id;
+WAIT_GET_TEST;
+expect(EFFS_OK, confirm_file->error);
+FREE;
+if ((my_id = ffs_fcontrol_nb(myfname, OC_FLAGS, OF_READONLY, &cnfpath)) < 0)
+return my_id;
+WAIT_GET_TEST;
+expect(EFFS_OK, confirm_file->error);
+FREE;
+ttw(ttr(TTrTest, "request :%d" NL, request_id_last));
+// This should make a EFFS_MEMORY fail
+for(i = 0; i < 10000; i++) {
+my_id = ffs_fwrite_nb("/mem_test", TDATA(0), 0);
+if (my_id < 0)
+break;
+}
+ttw(ttr(TTrTest, "write nr: %d my_id: %d" NL, i, my_id));
+expect(my_id, EFFS_MEMORY);
+// All memory has been used so wait a while (let some of the writes finish)
+tffs_delay(50);
+// Make a call to a blocking function will make it possible for ffs to
+// finish all the non blocking writes.
+error = ffs_fwrite("/mem_test", TDATA(0));
+expect_ok(error);
+return 0;
+}
+#endif
+/******************************************************************************
+* Blocking test
+******************************************************************************/
+#if (TARGET == 0)
+int case_blocking(int p0, int p1)
+{
+tw(tr(TR_FUNC, TrTest,
+"WARNING: This test can only run in target. Skip test\n"));
+return 0;
+}
+#else
+#include "ffs/board/task.h"
+void my_mb_callback(T_RVF_MB_ID id)
+{ // Dummy callback function
+}
+// Test that a FFS API blocking call that not is able to send a mail to FFS fails as expected and don't lock the system (it must unlock and delete the mutex).
+int case_blocking(int p0, int p1)
+{
+UINT32 mem_unused;
+T_RVF_MB_STATUS status;
+char *buf;
+extern T_OS_MB_ID ffs_mb_id;
+// Later when all the memory is used the memory bank will be marked as
+// RED by Riviera. The RED flag is erased when the buffer is freed but
+// only if a callback function is applied.
+rvf_set_callback_func(ffs_mb_id, my_mb_callback);  // Ignore error
+mem_unused = rvf_get_mb_unused_mem(ffs_mb_id);
+ttw(ttr(TTrTest,"Unused memory: %d" NL, mem_unused));
+// When all the memory is used the blocking functions will not be able
+// to allocate memory to the FFS mail thus it must fail. After the
+// buffer has been freed the block call must again be fully functional.
+if ((buf = (char *) target_malloc(mem_unused)) == 0)
+return EFFS_MEMORY;
+error = tffs_fwrite("/blocking_test", (char*)tdata[TDATA_HUGE], 20);
+target_free(buf);
+expect(error, EFFS_MEMORY);
+error = tffs_fwrite("/blocking_test", (char*)tdata[TDATA_HUGE], 20);
+expect_ok(error);
+return EFFS_OK;
+}
+#endif
+/******************************************************************************
+* Test erase_suspend and erase_resume
+******************************************************************************
+* Test erase suspend and resume by making a call to ffs_begin() followed by
+* an ffs_read() while we are erasing. We trigger the erase by sending
+* several write mails to FFS. We let FFS get the CPU for less time than an
+* erase, which will guarantee that we interrupt the erase when we call
+* ffs_begin().
+******************************************************************************/
+#if (TARGET == 1)
+static int write_mails_left;
+static void driver_callback(T_FFS_FILE_CNF *confirm)
+{
+if (confirm->error < 0) {
+ttw(ttr(TTrTest, "FATAL: driver_callback error: %d" NL, confirm->error));
+}
+error = rvf_free_buf(confirm);
+if (error < 0)
+ttr(TTrFatal, "FFS FATAL: os_free() %d" NL, error);
+write_mails_left--;
+}
+#endif
+#if (TARGET == 0)
+int case_erase_suspend(int p0, int p1)
+{
+tw(tr(TR_FUNC, TrTestHigh, "Erase_suspend test not supported on PC sim\n"));
+return 1;
+}
+#else
+// TEST erase_suspend and erase_resume
+int case_erase_suspend(int p0, int p1)
+{
+int i, j, error, nsuspend;
+char myname[] = "/ffs/b4";      // Run test with only 4 block.
+char myfname[] = "/driver_test";
+int file_size = 1024;
+T_RV_RETURN cnfpath = {0, (CALLBACK_FUNC)driver_callback};
+ttw(ttr(TTrTest, "Erase suspend-resume test" NL));
+// To minimize the numbers of required writes before we are guarantied an
+// erase we run this test in only 4 blocks
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format(myname, 0x2BAD);
+expect(error, EFFS_OK);
+if (p0 == 0) p0 = 1;
+for (j = 0; j < p0; j++) {
+write_mails_left = 0;
+// Write 2 blocks of data (must trigger an erase)
+for (i = 0; i < 2 * (dev.blocksize/file_size); i++)
+{
+// Non blockin write
+if ((error = ffs_file_write_nb(myfname, (char *) tdata[TDATA_HUGE],
+file_size,
+FFS_O_WRONLY | FFS_O_CREATE | FFS_O_TRUNC,
+&cnfpath)) < 0)
+return error;
+write_mails_left++;
+}
+ttw(ttr(TTrTest, "Finish write calls(%d)" NL, i));
+// NOTE only tested with AMD MB driver
+switch (dev.driver) {
+case FFS_DRIVER_AMD:
+case FFS_DRIVER_SST:
+case FFS_DRIVER_INTEL:
+case FFS_DRIVER_AMD_SB:
+ttw(ttr(TTrTest, "Start read test" NL));
+nsuspend = 0;
+do {
+// NOTEME: We can also test if we get the CPU and not is delay
+// by the erase
+// This will change state to ERASE_SUSPEND if we are in
+// ERASE mode (only valid for MB driver)
+error = ffs_begin();
+expect(error, EFFS_OK);
+if (dev.state == DEV_ERASE_SUSPEND) {
+nsuspend++;
+// Read... Note it will also resume the erase (MB driver).
+error = tffs_file_read(myfname, bigbuf, file_size/4);
+expect(error, EFFS_FILETOOBIG);
+}
+rvf_delay(5);  // Let FFS get the CPU for some time
+} while (write_mails_left > 0);
+if (nsuspend <= 0) {
+ttw(ttr(TTrTest, "Arg no erase suspend" NL));
+return 1;
+}
+ttw(ttr(TTrTest, "Erase suspended %d times" NL, nsuspend));
+break;
+case FFS_DRIVER_SST_SB:
+case FFS_DRIVER_INTEL_SB:
+default:
+ttw(ttr(TTrTest, "Driver not supported by this test" NL));
+// Do not return before the cnfpath resource not is used anymore
+while (write_mails_left > 0) rvf_delay(100);
+return 1;
+}
+}
+return 0;
+}
+#endif // TARGET == 0
+/******************************************************************************
+* The 3 below testh_.. function is helper function used for the low level
+* driver tests.
+******************************************************************************/
+#if (TARGET == 1)
+uint32 int_disable(void);
+void int_enable(uint32 tmp);
+// Only start an erase, don't wait until it is finish
+// Note to use this function with SB drivers require a multi bank flash device
+int testh_nb_erase(uint8 block)
+{
+volatile char *flash = dev.base;
+volatile char *addr;
+uint32 cpsr;
+ttw(ttr(TTrTest, "e(%d)" NL, block));
+addr = block2addr(block);
+cpsr = int_disable();
+switch (dev.driver) {
+case FFS_DRIVER_AMD:
+case FFS_DRIVER_AMD_SB:
+case FFS_DRIVER_AMD_PSEUDO_SB:
+flash[0xAAAA] = 0xAA; // AMD unlock cycle 1
+flash[0x5555] = 0x55; // AMD unlock cycle 2
+flash[0xAAAA] = 0x80;
+flash[0xAAAA] = 0xAA; // AMD unlock cycle 1
+flash[0x5555] = 0x55; // AMD unlock cycle 2
+*addr         = 0x30; // AMD erase sector command
+int_enable(cpsr);
+break;
+default:
+return -1; // Not yet supported
+}
+return 0;
+}
+// Note to use this function with SB drivers require a multi bank flash device
+int testh_erase_suspend(uint8 block)
+{
+volatile char *flash = dev.base;
+volatile char *addr;
+ttw(ttr(TTrTest, "esusp(%d)" NL, block));
+addr = block2addr(block);
+switch (dev.driver) {
+case FFS_DRIVER_AMD:
+case FFS_DRIVER_AMD_SB:
+case FFS_DRIVER_AMD_PSEUDO_SB:
+*addr         = 0xB0; // AMD erase suspend command
+break;
+default:
+return -1; // Not yet supported
+}
+return 0;
+}
+int testh_get_free_block(void)
+{
+uint8 b;
+for (b = 0; b < dev.numblocks; b++)
+{
+if (is_block(b, BF_IS_FREE) || is_block(b, BF_IS_EMPTY))
+return b;
+}
+return -1;
+}
+#endif // TARGET == 1
+// NOTEME: The below test have not been used in this FFS version
+// NOTEME: We don't have an AMD init function
+/******************************************************************************
+* Test drv.init (low level driver test)
+******************************************************************************
+* Test drv.init by start an erase, call drv.init and make sure that the
+* erase is finish after we return from drv.init.
+*
+* Test drv.init by start erase, suspend the erase and make sure that the
+* erase is resumed and finish before we return from drv.init. The test is
+* valid for both AMD SB and MB driver
+******************************************************************************/
+#if (TARGET == 0)
+int case_drv_init(int p0, int p1)
+{
+tw(tr(TR_FUNC, TrTestHigh, "drv_init test not supported on PC sim\n"));
+return 1;
+}
+#else
+int case_drv_init(int p0, int p1)
+{
+volatile char *flash = dev.base;
+volatile char *addr;
+char myname[] = "/drv_init";
+uint32 cpsr;
+uint8 block;
+int free_b, i, j, command;
+enum command { ERASE, WRITE, READ };
+char action[6][3] =
+{
+{ WRITE, READ, ERASE },
+{ WRITE, ERASE, READ },
+{ READ, WRITE, ERASE },
+{ READ, ERASE, WRITE },
+{ ERASE, READ, WRITE },
+{ ERASE, WRITE, READ }
+};
+ttw(ttr(TTrTest, "Test ffsdrv.init()" NL));
+// Test drv.init 6 times there the flash is in erase mode and 6 times
+// there the flash is in erase suspend mode.
+for (i = 0; i < 12; i++)
+{
+free_b = testh_get_free_block();
+expect_ok(free_b);
+fs.debug[0] = 0;
+fs.debug[1] = 0;
+// Start erase, run driver init.
+error = testh_nb_erase(free_b);
+expect_ok(error);
+rvf_delay(20); // Make sure that the erase has started
+if (i > 6) {
+error = testh_erase_suspend(free_b);
+expect_ok(error);
+rvf_delay(20); // Make sure that the erase is suspended
+}
+error = ffsdrv.init();  // Call ffsdrv_init() instead? (inc. autodetect)
+expect_ok(error);
+if (i > 6) {
+expect(fs.debug[0], 1);    // Test that the erase was resumed
+expect_gt(fs.debug[1], 0); // Test what we did wait for erase to finish
+}
+else {
+expect(fs.debug[0], 0);    // Erase not resumed
+expect_gt(fs.debug[1], 0); // We did wait for an erase to finish
+}
+// To test that any combination of erase, read or write can be
+// performed after drv.init do we make the test below. The first
+// complete drv.init test will be like this: Start an erase, call
+// drv.init(), write a file, read the file and erase a free block.
+for (j = 0; j < 3; j++) {
+if (i < 6)
+command = action[i][j];
+else
+command =  action[i-6][j];
+switch (command) {
+case ERASE:
+free_b = testh_get_free_block();
+expect_ok(free_b);
+ffsdrv.erase(free_b);
+break;
+case READ:
+error = test_expect_file(myname, TDATA(2));
+if (error) return 1;
+break;
+case WRITE:
+error = tffs_fwrite(myname, TDATA(2));
+expect(error, EFFS_OK);
+break;
+default:
+return 1;
+}
+}
+}
+return 0;
+}
+#endif
+uint32 get_cpsr(void);
+// Test disable and enable of interrupt (Note only valid for MB drivers)
+int case_interrupt(int p0, int p1)
+{
+extern void int_enable(uint32 tmp);
+extern uint32 int_disable(void);
+uint32 cpsr;
+int i;
+uint32 xcpsr;
+switch (dev.driver) {
+case FFS_DRIVER_AMD:
+case FFS_DRIVER_INTEL:
+		break;
+	default:
+		return 1; // Not supported
+	}
+p0 *= 100;
+ttw(ttr(TTrTest, "Test interrupt code" NL));
+for (i = 0; i < p0; i++) {
+cpsr = int_disable();
+xcpsr = get_cpsr();
+if ((xcpsr & 0xC0) != 0xC0) {
+ttw(ttr(TTrTest, "FATAL int not disablet!" NL));
+return 1;
+}
+int_enable(cpsr);
+xcpsr = get_cpsr();
+if ((xcpsr & 0xC0) != 0) {
+ttw(ttr(TTrTest, "FATAL int not enablet!" NL));
+return 1;
+}
+if ((i % 1000) == 0)
+ttw(ttr(TTrTest, "loop (%d)" NL, i));
+}
+return 0;
+}
+/******************************************************************************
+* Benchmarking
+******************************************************************************/
+// Below define only for PC compile
+#if (TARGET == 0)
+#define UINT32   int
+#define tffs_timer_begin() 0
+#define tffs_timer_end(time) 5000 - time
+#endif
+const struct results_s old_results[] =
+{
+{ 0, 1, 2, 3, 4, 5, 6, 7, 8, 9 },
+{ 0, 0, 0, 0, 0, 0, 0, 0, 0, 0 }
+};
+// NOTEME: Bencmark_results() not finished.
+int bencmark_results(int manufact, int driver, int sample,
+struct results_s *meas_res)
+{
+switch(manufact) {
+case MANUFACT_AMD:
+switch(driver) {
+//        case FFS_DRIVER_AMD:
+case FFS_DRIVER_AMD_SB:
+default: return 0;
+}
+case MANUFACT_FUJITSU:
+switch(driver) {
+//        case FFS_DRIVER_AMD:
+case FFS_DRIVER_AMD_SB:
+default: return 0;
+}
+default: return 0;
+}
+}
+// Benchmark write and read operation. Measure write throughput as kBps in
+// idle and loopback mode. Both for an empty ffs where we don't have to
+// reclaim blocks and for a full ffs where block reclaims/erasures affect
+// the overall throughput. For SB flash driver as well as for DB driver. For
+// files of size:16, 256, 4096, bytes.
+int case_bm_stream_rw(int p0, int p1)
+{
+#if (TARGET == 1)
+UINT32 time_begin, elapsed, bytes_max;
+char myname[] = "/Benchmark0";
+int i, j, k, nm_files, file_size;
+int size, write_size[] = {16, 256, 4096};
+fd_t fdi;
+//ttw(ttr(TTrTest, "RVF_POOL_0_SIZE: %d" NL, RVF_POOL_0_SIZE));
+// 1 block is used for inodes, 1 have to be free, 1/4 is used for
+// journal and 1/2 is used as a margin
+// FIXME: changed to 4.75 because the SW TCS2.1 dos make some files and
+// because of this is there not enough data space left to this test.
+// NOTEME: Instead of hardwire this value then query it
+bytes_max = (dev.numblocks - 4.75) * dev.blocksize;
+file_size = bytes_max / dev.numblocks;
+ttw(ttr(TTrTest, "bytes_max: %d(- 2.75 block)" NL, bytes_max));
+// Format, measure write of 16B.
+// Format, measure write of 256B.
+// Format, measure write of 4096B.
+for (j = 0; j < 3; j++) {
+ttw(ttr(TTrTest, "Format, measure write of %dB" NL, write_size[j]));
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format("/foo", 0x2BAD);
+expect(error, EFFS_OK);
+time_begin = tffs_timer_begin();
+for (i = 0; i < dev.numblocks; i++) {
+myname[10] = i + (i <= 9 ? '0': 'A' -10);
+fdi = tffs_open(myname, FFS_O_WRONLY | FFS_O_CREATE);
+expect(fdi, FFS_FD_OFFSET);
+size = 0;
+do {
+size += error = tffs_write(fdi, (char*)tdata[TDATA_HUGE],
+write_size[j]);
+if (error < 0) {
+if (error == EFFS_NOSPACE) {
+ttw(ttr(TTrTest, "Aarg out of space" NL));
+bytes_max = size;
+break;
+}
+else
+expect_ok(error);
+}
+} while (size < file_size);
+error = tffs_close(fdi);
+expect_ok(error);
+}
+elapsed = tffs_timer_end(time_begin);
+// FFS has used the CPU for a long time so let the trace task get
+// the CPU for a while
+tffs_delay(50);
+ttw(ttr(TTrTest, "Write %dBytes %d times in %dms, %dkBps" NL NL,
+write_size[j], file_size/write_size[j], elapsed,
+(bytes_max * 1000) / (elapsed * 1024)));
+}
+ttw(ttr(TTrTest, "Rm all files, measure write of 4kB" NL));
+for (i = 0; i < dev.numblocks; i++) {
+myname[10] = i + (i <= 9 ? '0': 'A' -10);
+error = tffs_remove(myname);
+expect_ok(error);
+}
+time_begin = tffs_timer_begin();
+for (i = 0; i < dev.numblocks; i++) {
+myname[10] = i + (i <= 9 ? '0': 'A' -10);
+fdi = tffs_open(myname, FFS_O_WRONLY | FFS_O_CREATE);
+expect(fdi, FFS_FD_OFFSET);
+size = 0;
+do {
+size += tffs_write(fdi, (char*)tdata[TDATA_HUGE], write_size[2]);
+} while (size < file_size);
+error = tffs_close(fdi);
+expect_ok(error);
+}
+elapsed = tffs_timer_end(time_begin);
+tffs_delay(50);
+ttw(ttr(TTrTest, "Write %dBytes %d times in %dms, %dkBps" NL NL,
+write_size[2], file_size/write_size[2], elapsed,
+(bytes_max * 1000) / (elapsed * 1024)));
+// Read all files with 16B at a time
+for (j = 0; j < 3; j++) {
+ttw(ttr(TTrTest, "Read all files with %dB at a time" NL, write_size[j]));
+time_begin = tffs_timer_begin();
+for (i = 0; i < dev.numblocks; i++) {
+myname[10] = i + (i <= 9 ? '0': 'A' -10);
+fdi = tffs_open(myname, FFS_O_RDONLY);
+expect(fdi, FFS_FD_OFFSET);
+size = 0;
+do {
+size += tffs_read(fdi, bigbuf, write_size[j]);
+} while (size < file_size);
+error = tffs_close(fdi);
+expect(error, 0);
+}
+elapsed = tffs_timer_end(time_begin);
+ttw(ttr(TTrTest, "Read %d files of %dkB in %dms, %dkBps," NL NL,
+dev.numblocks, size/1024, elapsed,
+(dev.numblocks * size * 1000) / (elapsed * 1024)));
+}
+// Measure write and read of one big file
+ttw(ttr(TTrTest, "Format, Write and read one big file" NL));
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format("/foo", 0x2BAD);
+expect(error, EFFS_OK);
+time_begin = tffs_timer_begin();
+fdi = tffs_open(myname, FFS_O_WRONLY | FFS_O_CREATE);
+size = 0;
+do {
+size += tffs_write(fdi, bigbuf, write_size[2]);
+} while (size < bytes_max);
+error = tffs_close(fdi);
+expect(error, 0);
+elapsed = tffs_timer_end(time_begin);
+ttw(ttr(TTrTest, "Write %dkB in %dms, %dkBps" NL,
+size/1024 , elapsed, (size * 1000) / (elapsed * 1024)));
+time_begin = tffs_timer_begin();
+// read one big file (reading one big file take more time than reading
+// many files of the same total size because there is a lot more inode
+// to look through)
+fdi = tffs_open(myname, FFS_O_RDONLY);
+expect(fdi, FFS_FD_OFFSET);
+size = 0;
+do {
+size += tffs_read(fdi, bigbuf, write_size[2]);
+} while (size < bytes_max);
+error = tffs_close(fdi);
+expect(error, 0);
+elapsed = tffs_timer_end(time_begin);
+ttw(ttr(TTrTest, "Read %dkB in %dms, %dkBps," NL,
+size/1024, elapsed, (size * 1000) / (elapsed * 1024)));
+// Make a data base of old measurements her? compare with old data and
+// make a warning if the performance has decreased?
+return 0;
+#else
+return 1;
+#endif
+}
+// Benchmark ffs_file_write() and ffs_file_read()
+int case_bm_file_rw(int p0, int p1)
+{
+UINT32 time_begin, elapsed;
+char myname[] = "/Benchmark";
+int i, j;
+struct test_info_s {
+int fsize;
+int fnumber;
+};
+struct test_info_s tinfo[] = {
+{   16, 500  },
+{  256, 200  },
+{ 4096, 200  },
+{32768, 10   }
+};
+for (j = 0; j < 4; j++) {
+ttw(ttr(TTrTest, "Format, measure write of %dB" NL, tinfo[j].fsize));
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format("/foo", 0x2BAD);
+expect(error, EFFS_OK);
+time_begin = tffs_timer_begin();
+for (i = 0; i < tinfo[j].fnumber; i++) {
+error = tffs_file_write(myname, (char*)tdata[TDATA_HUGE],
+tinfo[j].fsize, FFS_O_CREATE);
+expect_ok(error);
+}
+elapsed = tffs_timer_end(time_begin);
+// FFS has used the CPU for a long time so let the trace task get
+// the CPU for a while
+tffs_delay(50);
+ttw(ttr(TTrTest, "Write %dBytes %d times in %dms, %dkBps" NL NL,
+tinfo[j].fsize, i, elapsed,
+(i * tinfo[j].fsize * 1000) / (elapsed * 1024)));
+time_begin = tffs_timer_begin();
+for (i = 0; i < tinfo[j].fnumber; i++) {
+error = tffs_file_read(myname, bigbuf, tinfo[j].fsize);
+expect_ok(error);
+}
+elapsed = tffs_timer_end(time_begin);
+ttw(ttr(TTrTest, "Read %dBytes %d times in %dms, %dkBps" NL NL,
+tinfo[j].fsize, i, elapsed,
+(i * tinfo[j].fsize * 1000) / (elapsed * 1024)));
+}
+tffs_delay(3000);
+return 0;
+}
+// We banchmark lookups by using ffs_stat()
+int case_bm_lookup(int p0, int p1)
+{
+//format, update file x times, measure lookup with ffs_stat()
+//format, make x difference files, measure lookup with ffs_stat()
+//format, make a file in max directory depth, measure lookup with ffs_stat()
+//format, make one file, measure lookup with ffs_stat() (no traverse)
+//format, make x dirs with x files, measure lookup of last file in last dir
+#if (TARGET == 1)
+UINT32 time_begin, elapsed;
+int i, j;
+char myname[] = "/benchmark";
+char mydir[100] = "";
+char depth[] = "/depth99";
+char mypath[100] = "";
+//format, update file 100 times, measure lookup with ffs_stat()
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format("/foo", 0x2BAD);
+expect(error, EFFS_OK);
+for (i = 0; i < 100; i++) {
+error = tffs_file_write(myname, 0,0, FFS_O_CREATE);
+expect_ok(error);
+}
+time_begin = tffs_timer_begin();
+for (i = 0; i < 100; i++) {
+error = tffs_stat(myname, &stat);
+expect_ok(error);
+}
+elapsed = tffs_timer_end(time_begin);
+ttw(ttr(TTrTest, "Lookup through 100 deleted objects 100 times in %dms(%d obj/s)" NL, elapsed, 100 * 1000 / elapsed));
+//format, make 100 difference files, measure lookup with ffs_stat()
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format("/foo", 0x2BAD);
+expect(error, EFFS_OK);
+for (i = 0; i < 100; i++) {
+sprintf(myname, "/benchm%d", i);
+error = tffs_file_write(myname, 0,0, FFS_O_CREATE);
+expect_ok(error);
+}
+time_begin = tffs_timer_begin();
+for (i = 0; i < 100; i++) {
+error = tffs_stat(myname, &stat);
+expect_ok(error);
+}
+elapsed = tffs_timer_end(time_begin);
+ttw(ttr(TTrTest, "Lookup through 100 difference objects 100 times in %dms(%d obj/s)"
+NL, elapsed, 100 * 1000 / elapsed));
+//format, make a file in max directory depth, measure lookup with ffs_stat()
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format("/foo", 0x2BAD);
+expect(error, EFFS_OK);
+for (i = 0; i < fs.path_depth_max - 1; i++) {
+sprintf(depth, "/depth%d", i + 1);
+strcat(mydir, depth);
+error = tffs_mkdir(mydir);
+expect_ok(error);
+}
+strcat(mydir, myname);
+error = tffs_file_write(mydir, 0,0, FFS_O_CREATE);
+expect_ok(error);
+time_begin = tffs_timer_begin();
+for (i = 0; i < 1000; i++) {
+error = tffs_stat(mydir, &stat);
+expect_ok(error);
+}
+elapsed = tffs_timer_end(time_begin);
+ttw(ttr(TTrTest, "Lookup througt %d directorys 1000 times in %dms(%d obj/s)"
+NL, fs.path_depth_max, elapsed, 1000 * 1000 / elapsed));
+//format, make x files in each directory, measure lookup with ffs_stat()
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format("/foo", 0x2BAD);
+expect(error, EFFS_OK);
+mydir[0] = 0;  // Reset/empty buffer
+for (i = 0; i < fs.path_depth_max - 1; i++) {
+sprintf(depth, "/depth%d", i + 1);
+strcat(mydir, depth);
+error = tffs_mkdir(mydir);
+expect_ok(error);
+for (j = 0; j < 5; j++){
+sprintf(myname, "/benchm%d", j);
+strcpy(mypath, mydir);
+strcat(mypath, myname);
+error = tffs_file_write(mypath, 0,0, FFS_O_CREATE);
+expect_ok(error);
+}
+}
+time_begin = tffs_timer_begin();
+for (i = 0; i < 100; i++) {
+error = tffs_stat(mypath, &stat);
+expect_ok(error);
+}
+elapsed = tffs_timer_end(time_begin);
+ttw(ttr(TTrTest, "Lookup througt %d directorys with %d files in each times in %dms(%d obj/s)"
+NL, fs.path_depth_max, j, elapsed, 100 * 1000 / elapsed));
+//format, make one file, measure lookup with ffs_stat() (no traverse)
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format("/foo", 0x2BAD);
+expect(error, EFFS_OK);
+error = tffs_file_write(myname, 0,0, FFS_O_CREATE);
+expect_ok(error);
+time_begin = tffs_timer_begin();
+for (i = 0; i < 10000; i++) {
+error = tffs_stat(myname, &stat);
+expect_ok(error);
+}
+elapsed = tffs_timer_end(time_begin);
+ttw(ttr(TTrTest, "Lookup one file 10000 times in %dms(%d obj/s)"
+NL, elapsed, 1000 * 10000 / elapsed));
+//format, make x dirs with x files, measure lookup of last file in last dir
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format("/foo", 0x2BAD);
+expect(error, EFFS_OK);
+return 0;
+#else
+return 1;
+#endif
+}
+int case_bm_seek(int p0, int p1)
+{
+UINT32 time_begin, elapsed;
+int i, pos, fsize = 20000;
+char myname[] = "/benchmark";
+fd_t fdi;
+//format, update file 100 times, measure lookup with ffs_stat()
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+error = tffs_format("/foo", 0x2BAD);
+expect(error, EFFS_OK);
+// Create test file
+error = tffs_file_write(myname, (char*)tdata[TDATA_HUGE], fsize, FFS_O_CREATE);
+expect_ok(error);
+fdi = tffs_open(myname, FFS_O_RDWR);
+expect(fdi, FFS_FD_OFFSET);
+tw(tr(TR_FUNC, TrTest, "Run read reference\n"));
+ttw(ttr(TTrTest, "Run read reference" NL));
+// Reference
+time_begin = tffs_timer_begin();
+for (i = 0; i < fsize/4; i++) {
+error = tffs_read(fdi, bigbuf, 4);
+expect_ok(error);
+}
+elapsed = tffs_timer_end(time_begin);
+tw(tr(TR_FUNC, TrTest, "Read %d entries of 4 bytes (bytes/s %d)\n",
+fsize/4, (fsize * 1000 / elapsed)));
+ttw(ttr(TTrTest, "Read %d entries of 4 bytes in %dms (bytes/s %d)" NL,
+fsize/4, elapsed, (fsize * 1000 / elapsed)));
+tw(tr(TR_FUNC, TrTest, "Benchmark seek\n"));
+ttw(ttr(TTrTest, "Benchmark seek" NL));
+error = tffs_seek(fdi, 0, FFS_SEEK_SET);
+expect_ok(error);
+pos = 0;
+// Benchmark seek
+time_begin = tffs_timer_begin();
+for (i = 0; i < fsize/4; i++) {
+error = tffs_seek(fdi, pos, FFS_SEEK_SET);
+expect_ok(error);
+pos += 4;
+error = tffs_read(fdi, bigbuf, 4);
+expect_ok(error);
+}
+elapsed = tffs_timer_end(time_begin);
+tw(tr(TR_FUNC, TrTest, "Seek and Read %d entries of 4 bytes (bytes/s %d)\n",
+fsize/4, (fsize * 1000 / elapsed)));
+ttw(ttr(TTrTest, "Seek and Read %d entries of 4 bytes in %dms (bytes/s %d)" NL,
+fsize/4, elapsed, (fsize * 1000 / elapsed)));
+error = tffs_close(fdi);
+expect_ok(error);
+return EFFS_OK;
+}
+// Benchmark the blocking 'system'. Make n number of calls to ffs_format()
+// with bad magic.
+int case_bm_blocking(int p0, int p1)
+{
+int i;
+int time_begin, elapsed;
+time_begin = tffs_timer_begin();
+for (i = 0; i < 10000; i++)
+tffs_format("/ffs", 0);
+elapsed = tffs_timer_end(time_begin);
+ttw(ttr(TTrTest, "Made %d blocking calls in %dms (ms/call %d)" NL,
+i, elapsed, elapsed / i));
+// Make sure that it did fail as we expected
+error = tffs_format("/ffs", 0);
+expect(error, EFFS_INVALID);
+return EFFS_OK;
+}
+/******************************************************************************
+* Core test case
+******************************************************************************/
+int case_seekfile(int p0, int p1)
+{
+// NOTEME: this is only a visual test add some expect() to finish it.
+char *name;
+iref_t i, dir, i_out;
+int length, flength;
+int segment_offset;
+fd_t fdi;
+error = tffs_fwrite("/File_seg", (char*)tdata[TDATA_HUGE], 50);
+expect(error, EFFS_OK);
+if ((i = object_lookup("/File_seg", &name, &dir)) < 0)
+return i;
+for (length = 52; length > 48; length--) {
+flength = segfile_seek(i, length, &i_out, &segment_offset);
+tw(tr(TR_FUNC, TrTest,
+"*** Length %d, Flength %d, Seg_offset %2d, i %d ***\n",
+length, flength, segment_offset, i_out));
+}
+fdi = tffs_open("/Stream_seg", FFS_O_WRONLY | FFS_O_CREATE);
+tffs_write(fdi, (char*)tdata[TDATA_HUGE], 55);
+tffs_close(fdi);
+fdi = tffs_open("/Stream_seg", FFS_O_WRONLY | FFS_O_APPEND);
+tffs_write(fdi, (char*)tdata[TDATA_HUGE], 50);
+tffs_close(fdi);
+fdi = tffs_open("/Stream_seg", FFS_O_WRONLY | FFS_O_APPEND);
+tffs_write(fdi, (char*)tdata[TDATA_HUGE], 45);
+tffs_close(fdi);
+if ((i = object_lookup("/Stream_seg", &name, &dir)) < 0)
+return i;
+for (length = 153; length > 148; length--) {
+flength = segfile_seek(i, length, &i_out, &segment_offset);
+tw(tr(TR_FUNC, TrTest,
+"*** Length %d, Flength %d, Seg_offset %2d, i %d ***\n",
+length, flength, segment_offset, i_out));
+}
+for (length = 107; length > 103; length--) {
+flength = segfile_seek(i, length, &i_out, &segment_offset);
+tw(tr(TR_FUNC, TrTest,
+"*** Length %d, Flength %d, Seg_offset %2d, i %d ***\n",
+length, flength, segment_offset, i_out));
+}
+for (length = 58; length > 53; length--) {
+flength = segfile_seek(i, length, &i_out, &segment_offset);
+tw(tr(TR_FUNC, TrTest,
+"*** Length %d, Flength %d, Seg_offset %2d, i %d ***\n",
+length, flength, segment_offset, i_out));
+}
+return 0;
+}
+void display_fs_params(void)
+{
+int numdatablocks;
+numdatablocks = dev.numblocks - fs.blocks_free_min - 1;
+// Note expect only one free block!
+tw(tr(TR_FUNC, TrTest, "Data blocks %d, size %dkB\n",
+numdatablocks, dev.blocksize / 1024));
+tw(tr(TR_FUNC, TrTest, "    User data:       %dkB\n",
+(numdatablocks * dev.blocksize - fs.reserved_space) / 1024));
+tw(tr(TR_FUNC, TrTest, "    reserved_space:  %dkB\n", fs.reserved_space/ 1024));
+tw(tr(TR_FUNC, TrTest, "    inodes_max:      %d\n", fs.inodes_max));
+tw(tr(TR_FUNC, TrTest, "    journal_size:    %d\n", fs.journal_size));
+tw(tr(TR_FUNC, TrTest, "    objects_max:     %d\n", fs.objects_max));
+tw(tr(TR_FUNC, TrTest, "    block_files_max: %d\n", fs.block_files_max));
+tw(tr(TR_FUNC, TrTest, "    chunk_size:      %d\n\n", fs.chunk_size_max));
+}
+// NOTE only visual test
+int case_param_init(int p0, int p1)
+{
+char myname[] = "/ffs/xx/xx/xx";
+int numblocks[] = { 8, 3, 7, 15, 31, 63, 96, 127, 61, 127};
+int i;
+for (i = 0; i < sizeof(numblocks) / sizeof(int); i++)
+{
+dev.numblocks = numblocks[i];
+if (i == 0)
+dev.blocksize = 1024 * 8;
+else if (i > 0 && i < 8)
+dev.blocksize = 1024 * 64;
+else
+dev.blocksize = 1024 * 128;
+fs_params_init(myname);
+display_fs_params();
+// TODO add some checks, test format("/ffs/bx/ox") etc.
+}
+error = tffs_initialize(); // Use the 'real' blocksize
+expect(error, EFFS_OK);
+// Test param input from the format string
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+tffs_format("/ffs/i4000/o3000", 0x2BAD);
+expect(error, EFFS_OK);
+display_fs_params();
+// Test small conf.
+tw(tr(TR_FUNC, TrTest, "Test small conf\n"));
+error = tffs_preformat(0xDEAD);
+expect(error, EFFS_OK);
+tffs_format("/ffs/b3/j8/r24/f100/o100", 0x2BAD);
+expect(error, EFFS_OK);
+display_fs_params();
+return 0;
+}
+/******************************************************************************
+* Trace mask
+******************************************************************************/
+// This is not a test case but a way to change the trace mask on the fly
+int case_trace_mask(int p0, int p1)
+{
+unsigned int temp;
+// Because p0 and p1 only is of the type int and trace_mask is a
+// unsigned int is p0 bit 1-28 and p1 is bit 29-32
+temp = p1 << 28;
+temp |= p0;
+#if (TARGET == 0)
+tr_init(temp, 2, NULL );
+tw(tr(TR_FUNC, TrAll, "trace mask = %x\n", temp));
+#else
+ttr_init(temp);
+ttw(ttr(TTrTest, "trase mask = %x" NL, temp));
+#endif
+return 0;
+}
+/******************************************************************************
+* Helper function
+******************************************************************************/
+#define CLEANUP_MIN_SIZE 1
+int ignore_file(char *pathname)
+{
+int i;
+const char *ignore[] = {
+"/.journal", "/.ffs-stats", "/.ffs-bstat.old","/dummy4fctrl" ,
+"/truncate/IMEI", "/truncate/stream_file", "/gsm/com/rfcap",
+"/var/dbg/dar" };
+const char readonly[] = "/READONLY";
+for (i = 0; i < sizeof(ignore)/sizeof(char *); i++) {
+if (ffs_strcmp(pathname, ignore[i]) == 0) {
+return 0;
+}
+}
+// Special case, we have one directory where we don't delete any objects
+if (memcmp(pathname, readonly, sizeof(readonly) - 1) == 0)
+return 0;
+return 1;
+}
+// Remove files in FFS until there is min_space left. Ignore all files that
+// are listed in the ignore string above.
+int case_cleanup(int min_space)
+{
+int free, i, n, error;
+struct object_s *plist, *plist_start;
+char *pnames, *pnames_start;
+tw(tr(TR_FUNC, TrTestLow, "case_cleanup(%d)?\n", min_space));
+ffs_query(Q_BYTES_FREE, (uint32 *) &free);
+if (free > min_space) {
+tw(tr(TR_FUNC, TrTestLow, "Total data free: %d\n", free));
+return free;    // Nothing to do
+}
+plist  = plist_start  = (struct object_s *) bigbuf;
+pnames = pnames_start = bigbuf + bigbuf_size;
+n = case_dir_list("/", &plist, &pnames);
+plist = plist_start;
+for (i = 0; i < n; i++, plist++)
+{
+ffs_query(Q_BYTES_FREE, (uint32 *) &free);
+if (free > min_space) {
+tw(tr(TR_FUNC, TrTestLow, "Total data free: %d\n", free));
+return free;
+}
+if (plist->stat.size > CLEANUP_MIN_SIZE && ignore_file(plist->name)) {
+if ((error = ffs_remove(plist->name)) < 0)
+return error;
+}
+}
+return EFFS_NOSPACE;
+}
+// Make a random file. Random filename length, random filename, random filesize.
+// Note it is up to the caller that the directory exists.
+int case_mk_rand_file(char *dirname, int max_size, int min_size)
+{
+int size, diff, filenamelen, pathlen = 0, i, error;
+char pathname[(FFS_FILENAME_MAX + 1) * FFS_PATH_DEPTH_MAX];
+// All valid filename chars
+char tabel[] = "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ"
+"abcdefghijklmnopqrtsuvwyz_-.,+%$#";
+diff = max_size - min_size;
+if (diff < 0)
+return EFFS_INVALID;
+else if (diff == 0)
+size = max_size;
+else
+size = (rand() % diff) + min_size;
+filenamelen = (rand() % (FFS_FILENAME_MAX - 1)) + 1;  // We need min one char
+tw(tr(TR_FUNC, TrTestLow, "size:%5d, filenamelen:%3d,",size, filenamelen));
+if (dirname != 0) {
+strcpy(pathname, dirname);
+pathlen = strlen(pathname);
+}
+pathname[pathlen++] = '/';
+for (i = 0; i < filenamelen; pathlen++, i++) {
+pathname[pathlen] = tabel[rand() % strlen(tabel)];
+}
+pathname[pathlen] = 0;  // Zero terminate
+tw(tr(TR_FUNC, TrTestLow, "pathname:'%s'\n", pathname, size));
+error = tffs_file_write(pathname, (char *) tdata[TDATA_HUGE], size,
+FFS_O_CREATE | FFS_O_TRUNC);
+return error;
+}
+// Various helper functions for debug
+int case_debug_help(int p0, int p1)
+{
+int tr_mask;
+switch(p0) {
+case 1:
+{
+// Write rfcap file
+char rfcap_data[] = { 0, 0xf, 0x41, 0x10, 0, 0, 0, 0, 0x50, 0,
+0, 0xa5, 0x5, 0, 0xc0, 0 };
+ttw(ttr(TTrTest, "Write rfcap file..."));
+tffs_mkdir("/gsm");  // ignore error
+tffs_mkdir("/gsm/com");
+error = tffs_file_write("/gsm/com/rfcap", rfcap_data,
+sizeof(rfcap_data), FFS_O_CREATE | FFS_O_TRUNC);
+expect_ok(error);
+ttw(ttr(TTrTest, "done" NL));
+}
+break;
+case 2:
+tr_mask = tr_query(INT_MAX);
+#if (TARGET == 0)
+tr_init(TrBstat, 2, NULL );
+tr_bstat();
+tr_init(tr_mask, 2, NULL );
+#else
+ttr_init(TTrBstat);
+tr_bstat();
+ttr_init(tr_mask);
+#endif
+break;
+case 3:
+// Make mem dump to screen
+#if (TARGET == 1)
+rvf_dump_mem();
+break;
+#else
+tw(tr(TR_FUNC, TrTestLow, "Not supported on PC\n"));
+return 1;
+#endif
+case 4:
+#if (TARGET == 1)
+rvf_dump_tasks(); break;
+#else
+tw(tr(TR_FUNC, TrTestLow, "Not supported on PC\n"));
+return 1;
+#endif
+case 5:
+#if (TARGET == 1)
+rvf_dump_pool(); break;
+#else
+tw(tr(TR_FUNC, TrTestLow, "Not supported on PC\n"));
+return 1;
+#endif
+default:
+tw(tr(TR_FUNC, TrTest, "Available helper functions:\n"));
+tw(tr(TR_FUNC, TrTest, "    1: Write rfcap file\n"));
+tw(tr(TR_FUNC, TrTest, "    2: Display bstat trace\n"));
+ttw(ttr(TTrTest, "Available helper functions:" NL));
+ttw(ttr(TTrTest, "    1: Write rfcap file" NL));
+ttw(ttr(TTrTest, "    2: Display bstat trace" NL));
+ttw(ttr(TTrTest, "    3: Memory dump to screen" NL));
+ttw(ttr(TTrTest, "    4: Tasks dump to screen" NL));
+ttw(ttr(TTrTest, "    5: Pool dump to screen" NL));
+return 0;
+}
+return 0;
+}
+/******************************************************************************
+* Hexdumping
+******************************************************************************/
+#if 0
+void hexdump(const char *buf, int size, unsigned int address, int unitsize)
+{
+char string[(8+1+1) + (1+16+1+1) + (3*16) + 1];
+int n, i;
+char *s;
+while (size > 0)
+{
+s = string;
+s += sprintf(s, "%8x: ", address); // print offset
+n = (size > 16 ? 16 : size);
+// print the textual representation
+for (i = 0; i < n; i++) {
+if (buf[i] >= ' ' && buf[i] < 127)
+*s++ = buf[i];
+else
+*s++ = '.';
+}
+// pad textual representation with spaces
+for (i = 0; i < 16 - n; i++) {
+*s++ = ' ';
+}
+*s++ = ' ';
+// print hexedecimal representation
+for (i = 0; i < n; i += unitsize) {
+switch (unitsize) {
+case 1: s += sprintf(s, "%02x ", *(unsigned char  *) (buf+i)); break;
+case 2: s += sprintf(s, "%04x ", *(unsigned short *) (buf+i)); break;
+case 4: s += sprintf(s, "%08x ", *(unsigned int *) (buf+i)); break;
+}
+}
+buf += 16;
+address += 16;
+size -= 16;
+puts(string);
+}
+}
+#endif
+/******************************************************************************
+* Test Cases
+******************************************************************************/
+const struct testcase_s testcase[] =
+{
+// Collective test cases
+{ "all",    PC       , case_all,      "All" },
+{ "alot",   PC       , case_alot,     "Almost all" },
+{ "tall",      IT    , case_tall,     "Target all" },
+{ "aall",   PC       , case_aall,     "Agressive all" },
+{ "list",   PC|IT    , case_list,     "List all testcases" },
+{ "lsr",    PC|IT    , case_lsr,      "Recursively list all objects" },
+{ "test",   PC|IT    , case_test,     "Ad hoc test" },
+{ "rand",   PC|IT    , case_rand,     "Random tests (NOT FINISHED)" },
+{ "fail",   PC|IT    , case_fail,     "Fail (just fail)" },
+{ "okay",   PC|IT    , case_okay,     "Okay (just succeed)" },
+// Atomic/small test cases
+{ "s",      PC|IT    , case_status,   "Status: ffs_init(), lsr" },
+{ "r",      PC|IT    , case_reset,    "preformat(), format(), init(), exit()" },
+{ "i",      PC|IT    , case_init,           "ffs_init()" },
+{ "x",      PC|IT    , case_exit,           "ffs_exit()" },
+{ "p",      PC|IT    , case_only_preformat, "ffs_preformat()" },
+{ "f",      PC|IT    , case_only_format,    "ffs_format()" },
+// Populate test cases
+{ "world",  PC|IT    , case_world,    "Make world" },
+{ "eu",     PC|IT    , case_europe,   "Make europe" },
+{ "dk",     PC|IT    , case_denmark,  "Make denmark" },
+// Special test cases
+{ "mf",     PC|IT    , case_mfiles,   "Test FFS with many (small) files" },
+{ "threeb", PC|IT    , case_threeb,   "Test ffs in only three blocks" },
+{ "twob",   PC|IT    , case_twob,     "Test ffs in only two blocks" },
+{ "pcm",    PC|IT    , case_pcm,      "Test PCM interface" },
+{ "stress",    IT    , case_stress,   "Stress test erase/write" },
+{ "find",   PC|IT|RND, case_find,     "Recursively traverse all objects" },
+{ "nb",     IT       , case_nonblock, "Test non block functions" },
+{ "bf",     IT|RND   , case_blocking, "Test blocking function" },
+{ "cust",   PC       , case_customer, "Test customer typical use"},
+{ "esus",   IT       , case_erase_suspend, "Test erase suspend and resume" },
+// Driver test cases
+{ "int",    IT       , case_interrupt,     "Test INT disable and enable" },
+// Benchmark test cases
+{ "bmsrw",     IT    , case_bm_stream_rw, "Benchmark stream read and writes" },
+{ "bmfrw",     IT    , case_bm_file_rw,   "Benchmark file read and writes" },
+{ "bmlu",      IT    , case_bm_lookup,    "Benchmark lookups" },
+{ "bmsk",    PC|IT   , case_bm_seek,      "Benchmark ffs_seek()" },
+{ "bmbl",    PC|IT   , case_bm_blocking,  "Benchmark blocking 'system'" },
+// Normal test cases
+{ "format", PC       , case_format,   "Test ffs_pre/format()" },
+{ "lu",     PC|IT    , case_lookup,   "Test object_lookup()" },
+{ "fc",     PC|IT    , case_fcontrol, "Test fcontrol() and read-only" },
+{ "root",   PC|IT|RND, case_root,     "Test root inode is non-modifiable" },
+{ "dirs",   PC|IT|RND, case_dirs,     "Test Directories" },
+{ "frd",    PC|IT|RND, case_fread,    "Test fread() with varying sizes/names" },
+{ "bfull",  PC|IT    , case_bfull,    "Test filling a block completely" },
+{ "ffull",  PC|IT    , case_ffull,    "Test filling ffs completely" },
+{ "bigf",   PC       , case_bigfile,  "Test big files" },
+{ "stat",   PC|IT|RND, case_stat,     "Test ffs_stat()" },
+{ "rm",     PC|IT    , case_remove,   "Test ffs_remove()" },
+{ "ren",    PC|IT|RND, case_rename,   "Test ffs_rename()" },
+{ "renext", PC|IT    , case_rename_extended, "Extended test of ffs_rename()" },
+{ "irec",   PC|IT    , case_irec,     "Test inodes reclaim" },
+{ "drec",   PC       , case_drec,     "Test data reclaim" },
+{ "adrec",  PC       , case_adrec,    "Test xxxx reclaim" },
+{ "jnl",    PC|IT    , case_journal,  "Test journalling" },
+{ "brec",   PC|IT|RND, case_brecover, "Test block recovery" },
+{ "ssym",   PC|IT|RND, case_ssym,     "Test Simple Symlinks" },
+{ "fsym",   PC|IT    , case_fsym,     "Test Full Symlinks (NOT IMPLEMENTED)" },
+{ "ri",     PC|IT|RND, case_reinit,   "Test re-ffs_init()" },
+{ "open",   PC|IT|RND, case_open,     "Test open flags" },
+{ "rw",     PC|IT|RND, case_rw,       "Test read and write files" },
+{ "mopen",  PC|IT|RND, case_multi_open, "Test open of multiply files" },
+{ "seek",   PC|IT|RND, case_seek,     "Test seek on files " },
+{ "trunc",  PC|IT|RND, case_trunc,    "Test ffs_truncate() " },
+{ "append", PC|IT|RND, case_append,   "Test append on a open file" },
+{ "dsync",  PC|IT|RND, case_datasync, "Test ffs_fdatasync" },
+{ "ex",     IT|RND,    case_examples, "Test examples from RIV111 " },
+{ "fwflags",PC|IT|RND, case_fw_flags, "Test ffs_file_write() flags" },
+{ "pcm"    ,PC|IT|RND, case_pcm,      "Test pcm interface" },
+{ "apiexc" ,PC|IT,     case_api_exceptions, "Test API exceptions" },
+{ "ninit"  ,PC|IT,     case_api_notformated, "Test API on a nformated flash"},
+{ "query"  ,PC|IT|RND, case_query,    "Test query function" },
+{ "octrl"  ,PC|IT,     case_octrl,    "Test of object control" },
+// Core test cases
+{ "seekf",  PC,        case_seekfile,  "Test core segfile_seek" },
+{ "param",  PC,        case_param_init,"Test core param_init" },
+// Helper test case
+{ "tr",     PC|IT    , case_trace_mask, "Change trace mask on the fly " },
+{ "dh",     PC|IT    , case_debug_help, "Difference help functions " },
+{ 0,        0,         0,             0 }
+};
+#if (TARGET == 1)
+// Note like the interrupt functions in drv.c this asm needs to be places ad
+// the buttom of the file or else it crach!
+uint32 get_cpsr(void)
+{
+asm("        .state16");
+asm("        adr       A2, get_cpsr32");
+asm("        bx        A2");
+asm("        .state32");
+asm("get_cpsr32");
+asm("        mrs       A1,cpsr      ; get current CPSR");
+}
+#else
+uint32 get_cpsr(void){return 0;}
+#endif

FreeCalypso > hg > fc-magnetite

comparison src/cs/drivers/drv_app/ffs/board/tcases.c @ 0:945cf7f506b2