filerw.c

ST5518机顶盒系统文件系统源代码！绝对超值！

/******************************************************************************

    File Name   : FileRW.c

    Description : Unit test for file read/write.

******************************************************************************/

/* Includes ---------------------------------------------------------------- */

#include <stdlib.h>
#include <stdio.h>
#include <ctype.h>
#include <string.h>
#include <assert.h>

#include "wrapper.h"
#include "stavfs.h"

/* Private Types ----------------------------------------------------------- */

typedef struct RWTestPart_s
{
    U32 BlockSize; /* size of chunks to read/write in */
    U32 BlockReps; /* number of times to do it before moving on to next entry */
} RWTestPart_t;

/* Private Constants ------------------------------------------------------- */

#define NODIFF (-1)  /* for FirstDiff */

#define SECTORS_PER_CLUSTER (4)  /* a property of the partition we are using */
#define CLUSTER_SIZE (SECTORS_PER_CLUSTER * DISK_SECTOR_SIZE)
   
#define CLUSTERS_PER_BLOCK (256) /* a property of the file system */
#define CLUSTER_BLOCK_SIZE (CLUSTERS_PER_BLOCK * CLUSTER_SIZE)


/* pattern for sector and cluster boundaries test */
static RWTestPart_t SectClustPattern[] = {

  {     DISK_SECTOR_SIZE / 4  , 4 },
  {     DISK_SECTOR_SIZE      , 4 },
  { 3 * DISK_SECTOR_SIZE / 2  , 4 },
  {     DISK_SECTOR_SIZE / 2  , 1 },
  {     CLUSTER_SIZE          , 1 },
  { 2 * CLUSTER_SIZE          , 1 },
  { 3 * CLUSTER_SIZE / 2      , 2 },

};

/* pattern for cluster block boundaries test */
static RWTestPart_t ClustBlockPattern[] = {

  { 2 * CLUSTER_SIZE          , CLUSTERS_PER_BLOCK / 2     },
    /* first starts and last ends on a cluster block boundary */

  { 3 * CLUSTER_SIZE          , CLUSTERS_PER_BLOCK / 3 + 1 },
    /* last straddles a cluster block boundary */

};

/* static buffer capable of holding the largest block we want to read/write in one go: */
static U8 Buffer[3 * CLUSTER_SIZE];

#define RESCAN_CHUNK_SIZE 500


    /* Same data as Timeshift except for the last byte, which should help to avoid
        accidental matches where sectors are infact mispositioned */

static U8 StdData[3 * DISK_SECTOR_SIZE / 2 - 1] = {

    0XE0, 0XE1, 0XE2, 0XE3, 0XE4, 0XE5, 0XE6, 0XE7, 0XE8, 0XE9, 0XEA, 0XEB, 0XEC, 0XED, 0XEE, 0XEF,
    0XF0, 0XF1, 0XF2, 0XF3, 0XF4, 0XF5, 0XF6, 0XF7, 0XF8, 0XF9, 0XFA, 0XFB, 0XFC, 0XFD, 0XFE, 0XFF,
    0X00, 0X01, 0X02, 0X03, 0X04, 0X05, 0X06, 0X07, 0X08, 0X09, 0X0A, 0X0B, 0X0C, 0X0D, 0X0E, 0X0F,
    0X10, 0X11, 0X12, 0X13, 0X14, 0X15, 0X16, 0X17, 0X18, 0X19, 0X1A, 0X1B, 0X1C, 0X1D, 0X1E, 0X1F,
    0X20, 0X21, 0X22, 0X23, 0X24, 0X25, 0X26, 0X27, 0X28, 0X29, 0X2A, 0X2B, 0X2C, 0X2D, 0X2E, 0X2F,
    0X30, 0X31, 0X32, 0X33, 0X34, 0X35, 0X36, 0X37, 0X38, 0X39, 0X3A, 0X3B, 0X3C, 0X3D, 0X3E, 0X3F,
    0X40, 0X41, 0X42, 0X43, 0X44, 0X45, 0X46, 0X47, 0X48, 0X49, 0X4A, 0X4B, 0X4C, 0X4D, 0X4E, 0X4F,
    0X90, 0X91, 0X92, 0X93, 0X94, 0X95, 0X96, 0X97, 0X98, 0X99, 0X9A, 0X9B, 0X9C, 0X9D, 0X9E, 0X9F,

    0XB0, 0XB1, 0XB2, 0XB3, 0XB4, 0XB5, 0XB6, 0XB7, 0XB8, 0XB9, 0XBA, 0XBB, 0XBC, 0XBD, 0XBE, 0XBF,
    0XA0, 0XA1, 0XA2, 0XA3, 0XA4, 0XA5, 0XA6, 0XA7, 0XA8, 0XA9, 0XAA, 0XAB, 0XAC, 0XAD, 0XAE, 0XAF,
    0X50, 0X51, 0X52, 0X53, 0X54, 0X55, 0X56, 0X57, 0X58, 0X59, 0X5A, 0X5B, 0X5C, 0X5D, 0X5E, 0X5F,
    0X60, 0X61, 0X62, 0X63, 0X64, 0X65, 0X66, 0X67, 0X68, 0X69, 0X6A, 0X6B, 0X6C, 0X6D, 0X6E, 0X6F,
    0X70, 0X71, 0X72, 0X73, 0X74, 0X75, 0X76, 0X77, 0X78, 0X79, 0X7A, 0X7B, 0X7C, 0X7D, 0X7E, 0X7F,
    0X80, 0X81, 0X82, 0X83, 0X84, 0X85, 0X86, 0X87, 0X88, 0X89, 0X8A, 0X8B, 0X8C, 0X8D, 0X8E, 0X8F,
    0X90, 0X91, 0X92, 0X93, 0X94, 0X95, 0X96, 0X97, 0X98, 0X99, 0X9A, 0X9B, 0X9C, 0X9D, 0X9E, 0X9F,
    0XA0, 0XA1, 0XA2, 0XA3, 0XA4, 0XA5, 0XA6, 0XA7, 0XA8, 0XA9, 0XAA, 0XAB, 0XAC, 0XAD, 0XAE, 0XAF,

    0XB0, 0XB1, 0XB2, 0XB3, 0XB4, 0XB5, 0XB6, 0XB7, 0XB8, 0XB9, 0XBA, 0XBB, 0XBC, 0XBD, 0XBE, 0XBF,
    0XC0, 0XC1, 0XC2, 0XC3, 0XC4, 0XC5, 0XC6, 0XC7, 0XC8, 0XC9, 0XCA, 0XCB, 0XCC, 0XCD, 0XCE, 0XCF,
    0XD0, 0XD1, 0XD2, 0XD3, 0XD4, 0XD5, 0XD6, 0XD7, 0XD8, 0XD9, 0XDA, 0XDB, 0XDC, 0XDD, 0XDE, 0XDF,
    0XE0, 0XE1, 0XE2, 0XE3, 0XE4, 0XE5, 0XE6, 0XE7, 0XE8, 0XE9, 0XEA, 0XEB, 0XEC, 0XED, 0XEE, 0XEF,
    0XF0, 0XF1, 0XF2, 0XF3, 0XF4, 0XF5, 0XF6, 0XF7, 0XF8, 0XF9, 0XFA, 0XFB, 0XFC, 0XFD, 0XFE, 0XFF,
    0X00, 0X01, 0X02, 0X03, 0X04, 0X05, 0X06, 0X07, 0X08, 0X09, 0X0A, 0X0B, 0X0C, 0X0D, 0X0E, 0X0F,
    0X10, 0X11, 0X12, 0X13, 0X14, 0X15, 0X16, 0X17, 0X18, 0X19, 0X1A, 0X1B, 0X1C, 0X1D, 0X1E, 0X1F,
    0X20, 0X21, 0X22, 0X23, 0X24, 0X25, 0X26, 0X27, 0X28, 0X29, 0X2A, 0X2B, 0X2C, 0X2D, 0X2E, 0X2F,

    0X30, 0X31, 0X32, 0X33, 0X34, 0X35, 0X36, 0X37, 0X38, 0X39, 0X3A, 0X3B, 0X3C, 0X3D, 0X3E, 0X3F,
    0X40, 0X41, 0X42, 0X43, 0X44, 0X45, 0X46, 0X47, 0X48, 0X49, 0X4A, 0X4B, 0X4C, 0X4D, 0X4E, 0X4F,
    0X50, 0X51, 0X52, 0X53, 0X54, 0X55, 0X56, 0X57, 0X58, 0X59, 0X5A, 0X5B, 0X5C, 0X5D, 0X5E, 0X5F,
    0X60, 0X61, 0X62, 0X63, 0X64, 0X65, 0X66, 0X67, 0X68, 0X69, 0X6A, 0X6B, 0X6C, 0X6D, 0X6E, 0X6F,
    0X70, 0X71, 0X72, 0X73, 0X74, 0X75, 0X76, 0X77, 0X78, 0X79, 0X7A, 0X7B, 0X7C, 0X7D, 0X7E, 0X7F,
    0X80, 0X81, 0X82, 0X83, 0X84, 0X85, 0X86, 0X87, 0X88, 0X89, 0X8A, 0X8B, 0X8C, 0X8D, 0X8E, 0X8F,
    0X90, 0X91, 0X92, 0X93, 0X94, 0X95, 0X96, 0X97, 0X98, 0X99, 0X9A, 0X9B, 0X9C, 0X9D, 0X9E, 0X9F,
    0XD0, 0XD1, 0XD2, 0XD3, 0XD4, 0XD5, 0XD6, 0XD7, 0XD8, 0XD9, 0XDA, 0XDB, 0XDC, 0XDD, 0XDE, 0XDF,

    0X00, 0X01, 0X02, 0X03, 0X04, 0X05, 0X06, 0X07, 0X08, 0X09, 0X0A, 0X0B, 0X0C, 0X0D, 0X0E, 0X0F,
    0X80, 0X81, 0X82, 0X83, 0X84, 0X85, 0X86, 0X87, 0X88, 0X89, 0X8A, 0X8B, 0X8C, 0X8D, 0X8E, 0X8F,
    0X50, 0X51, 0X52, 0X53, 0X54, 0X55, 0X56, 0X57, 0X58, 0X59, 0X5A, 0X5B, 0X5C, 0X5D, 0X5E, 0X5F,
    0X60, 0X61, 0X62, 0X63, 0X64, 0X65, 0X66, 0X67, 0X68, 0X69, 0X6A, 0X6B, 0X6C, 0X6D, 0X6E, 0X6F,
    0XE0, 0XE1, 0XE2, 0XE3, 0XE4, 0XE5, 0XE6, 0XE7, 0XE8, 0XE9, 0XEA, 0XEB, 0XEC, 0XED, 0XEE, 0XEF,
    0XF0, 0XF1, 0XF2, 0XF3, 0XF4, 0XF5, 0XF6, 0XF7, 0XF8, 0XF9, 0XFA, 0XFB, 0XFC, 0XFD, 0XFE, 0XFF,
    0XA0, 0XA1, 0XA2, 0XA3, 0XA4, 0XA5, 0XA6, 0XA7, 0XA8, 0XA9, 0XAA, 0XAB, 0XAC, 0XAD, 0XAE, 0XAF,
    0XB0, 0XB1, 0XB2, 0XB3, 0XB4, 0XB5, 0XB6, 0XB7, 0XB8, 0XB9, 0XBA, 0XBB, 0XBC, 0XBD, 0XBE, 0XBF,

    0XC0, 0XC1, 0XC2, 0XC3, 0XC4, 0XC5, 0XC6, 0XC7, 0XC8, 0XC9, 0XCA, 0XCB, 0XCC, 0XCD, 0XCE, 0XCF,
    0X10, 0X11, 0X12, 0X13, 0X14, 0X15, 0X16, 0X17, 0X18, 0X19, 0X1A, 0X1B, 0X1C, 0X1D, 0X1E, 0X1F,
    0X20, 0X21, 0X22, 0X23, 0X24, 0X25, 0X26, 0X27, 0X28, 0X29, 0X2A, 0X2B, 0X2C, 0X2D, 0X2E, 0X2F,
    0X30, 0X31, 0X32, 0X33, 0X34, 0X35, 0X36, 0X37, 0X38, 0X39, 0X3A, 0X3B, 0X3C, 0X3D, 0X3E, 0X3F,
    0X70, 0X71, 0X72, 0X73, 0X74, 0X75, 0X76, 0X77, 0X78, 0X79, 0X7A, 0X7B, 0X7C, 0X7D, 0X7E, 0X7F,
    0XC0, 0XC1, 0XC2, 0XC3, 0XC4, 0XC5, 0XC6, 0XC7, 0XC8, 0XC9, 0XCA, 0XCB, 0XCC, 0XCD, 0XCE, 0XCF,
    0XD0, 0XD1, 0XD2, 0XD3, 0XD4, 0XD5, 0XD6, 0XD7, 0XD8, 0XD9, 0XDA, 0XDB, 0XDC, 0XDD, 0XDE, 0XDF,
    0XE0, 0XE1, 0XE2, 0XE3, 0XE4, 0XE5, 0XE6, 0XE7, 0XE8, 0XE9, 0XEA, 0XEB, 0XEC, 0XED, 0XEE,
};


/* Private Variables ------------------------------------------------------- */

/* Private Macros ---------------------------------------------------------- */

/* Private Function Prototypes --------------------------------------------- */

static S32          FirstDiff      (U8 * a_p, U8 * b_p, S32 Len);
static U32          RWTestTotalSize(RWTestPart_t * PartsList_p, int CntParts);
static TestResult_t WriteTestData  (STAVFS_FileHandle_t FileHandle, U32 AbsPos, U32 Size);
static TestResult_t ReadTestData   (STAVFS_FileHandle_t FileHandle, U32 AbsPos, U32 Size);
static TestResult_t RunTestPattern (STAVFS_FileHandle_t FileHandle, U32 * AbsPos_p,
                                    RWTestPart_t * Pattern_p, int CntParts, BOOL DoWrite);

static TestResult_t RWTest         (int TestNo, TestVariant_t Variant);

/* Functions --------------------------------------------------------------- */





/******************************************************************************
Function Name : FileRW
  Description : File read/write test section function.
   Parameters :
******************************************************************************/
BOOL FileRW (parse_t * pars_p, char *result_sym_p)
{
    char *Description = "Unit Test file read/write";
    
    TestCall_t TestList[] =
    {
        RWTest,       /* Test 001 : use SectClustPattern and no streaming */
        RWTest,       /* Test 002 : use ClustBlockPattern and streaming */
    };
    
    GenericTest (pars_p, result_sym_p,
                 Description,
                 TestList, TABLE_LEN(TestList)-1,
		 TEST_VARIANT_C /* three variants */);
                 
    return (FALSE);
}





/******************************************************************************
Function Name : RWTest
  Description : Run a read-write test
   Parameters :
******************************************************************************/
static TestResult_t RWTest(int TestNo, TestVariant_t Variant)
{
    TestResult_t        Result;

    STAVFS_Handle_t     DiskHandle;

    STAVFS_OpenMode_t   OpenMode;
    U64                 FileSize;
    
    RWTestPart_t *      Pattern_p;
    int                 CntParts;
    U32                 TotalSize;
    
    switch(TestNo)
    {
    case 0: /* Test 001 to the outside world */
        Pattern_p = SectClustPattern;
        CntParts  = TABLE_LEN(SectClustPattern);
        OpenMode  = 0; /* no streaming */
        break;
        
    case 1: /* Test 002 to the outside world */
        Pattern_p = ClustBlockPattern;
        CntParts  = TABLE_LEN(ClustBlockPattern);
        OpenMode  = STAVFS_STREAM_FILE;
        break;
        
    default:
        return TEST_NOT_WRITTEN;
    }
    
    TotalSize = RWTestTotalSize(Pattern_p, CntParts);
    
    switch(Variant)
    {
    case TEST_VARIANT_A:
        /* just test writing and reading */
        
        I64_SetValue (TotalSize, 0, FileSize);
        break;
        
    case TEST_VARIANT_B:
        /* test auto-expand too */
        
        I64_SetValue (0, 0, FileSize);
        break;
        
    case TEST_VARIANT_C:
        /* check cyclic files do the same thing. They have to be allocated up-front,
          with at least 1 byte more than we intend to write before reading. They also
          can't be closed and reopened between write and read, so add read access to
          the initial open */
          
        OpenMode |= STAVFS_CYCLIC_MODE | STAVFS_READ_MODE;
        I64_SetValue (TotalSize + 1, 0, FileSize);
        break;
        
    default:
        return TEST_NOT_WRITTEN;
    }

    Result = OpenPartition(0, 1, "Dev1", &DiskHandle);
    if (TEST_PASSED == Result)
    {
        STAVFS_FileHandle_t FileHandle;
        BOOL GotFile; /* monitors whether closing is necessary after first open */
        U32  AbsPos, ReadSize; /* for second pass */
        U64  RestartPos; /* for cyclic case */
        
        /* open and write a file according to the relevant test pattern */
        
        if (ST_NO_ERROR != STAVFS_OpenFile (DiskHandle, STAVFS_NULL_FILE_HANDLE, "rwtest",
                                            STAVFS_WRITE_MODE | OpenMode, FileSize, &FileHandle))
        {
            STTBX_Print (("Error opening file\n"));
            Result = TEST_FAILED;
        }
        else
        {
            GotFile = TRUE; /* it stays this way for a cyclic test */
            
            AbsPos = 0;
            if (TEST_PASSED != RunTestPattern (FileHandle, &AbsPos, Pattern_p, CntParts, TRUE))
            {
                Result = TEST_FAILED; /* message already displayed */
            }
            
            else if ((OpenMode & STAVFS_CYCLIC_MODE) == 0)
            {
                /* close and reopen gives a cleaner test where possible (non-cyclic files) */
                
                GotFile = FALSE; /* don't try a close if this one (or the open) fails */
                
                if (ST_NO_ERROR != STAVFS_CloseFile (FileHandle))
                {
                    STTBX_Print (("Error closing %s file\n"));
                    Result = TEST_FAILED;
                }
                
                else if (ST_NO_ERROR != STAVFS_OpenFile (DiskHandle, STAVFS_NULL_FILE_HANDLE, "rwtest",
                                                         STAVFS_READ_MODE | OpenMode, FileSize, &FileHandle))
                {
                    STTBX_Print (("Error re-opening file for read (1)\n"));
                    Result = TEST_FAILED;
                }

            }
            
            if (Result == TEST_PASSED)