bcache.c 文件参考

浏览源代码.

函数
VOID	BcacheAnalyse (UINT32 level)
VOID	LOS_SetDirtyRatioThreshold (UINT32 dirtyRatio)
VOID	LOS_SetSyncThreadInterval (UINT32 interval)
	设置同步间隔,5秒 更多...
INT32	LOS_SetSyncThreadPrio (UINT32 prio, const CHAR *name)
	设置同步任务优先级,10 更多...
static OsBcacheBlock *	RbFindBlock (const OsBcache *bc, UINT64 num)
	红黑树找块 更多...
static VOID	RbAddBlock (OsBcache *bc, OsBcacheBlock *block)
	添加缓存块 更多...
static VOID	RbDelBlock (OsBcache *bc, OsBcacheBlock *block)
	删除红黑树块 更多...
static VOID	ListMoveBlockToHead (OsBcache *bc, OsBcacheBlock *block)
	删除红黑树块 更多...
static VOID	FreeBlock (OsBcache *bc, OsBcacheBlock *block)
	释放块 更多...
static UINT32	GetValLog2 (UINT32 val)
static INT32	FindFlagPos (const UINT32 *arr, UINT32 len, UINT32 *p1, UINT32 *p2)
static INT32	BlockRead (OsBcache *bc, OsBcacheBlock *block, UINT8 *buf)
static INT32	BcacheGetFlag (OsBcache *bc, OsBcacheBlock *block)
static VOID	BcacheSetFlag (const OsBcache *bc, OsBcacheBlock *block, UINT32 pos, UINT32 size)
static INT32	BcacheSyncBlock (OsBcache *bc, OsBcacheBlock *block)
static void	NumListAdd (OsBcache *bc, OsBcacheBlock *block)
static void	AddBlock (OsBcache *bc, OsBcacheBlock *block)
static void	DelBlock (OsBcache *bc, OsBcacheBlock *block)
static BOOL	BlockAllDirty (const OsBcache *bc, OsBcacheBlock *block)
static OsBcacheBlock *	GetBaseBlock (OsBcache *bc)
static OsBcacheBlock *	GetSlowBlock (OsBcache *bc, BOOL read)
static VOID	WriteMergedBlocks (OsBcache *bc, OsBcacheBlock *begin, int blocks)
static VOID	MergeSyncBlocks (OsBcache *bc, OsBcacheBlock *start)
static UINT64	GetMinWriteNum (OsBcache *bc)
static OsBcacheBlock *	AllocNewBlock (OsBcache *bc, BOOL read, UINT64 num)
static INT32	BcacheSync (OsBcache *bc)
static VOID	BlockInit (OsBcache *bc, OsBcacheBlock *block, UINT64 num)
static INT32	BcacheGetBlock (OsBcache *bc, UINT64 num, BOOL readData, OsBcacheBlock **dblock)
INT32	BcacheClearCache (OsBcache *bc)
static INT32	BcacheInitCache (OsBcache *bc, UINT8 *memStart, UINT32 memSize, UINT32 blockSize)
	块设备缓存初始化 更多...
static INT32	DrvBread (struct Vnode *priv, UINT8 *buf, UINT32 len, UINT64 pos)
	读块设备数据 更多...
static INT32	DrvBwrite (struct Vnode *priv, const UINT8 *buf, UINT32 len, UINT64 pos)
	写块设备数据 更多...
INT32	BlockCacheDrvCreate (VOID *handle, UINT8 *memStart, UINT32 memSize, UINT32 blockSize, OsBcache *bc)
	初始化块设备 更多...
INT32	BlockCacheRead (OsBcache *bc, UINT8 *buf, UINT32 *len, UINT64 sector, BOOL useRead)
	读块设备缓存 更多...
INT32	BlockCacheWrite (OsBcache *bc, const UINT8 *buf, UINT32 *len, UINT64 sector)
	写块设备缓存 更多...
INT32	BlockCacheSync (OsBcache *bc)
	块缓存同步 更多...
INT32	OsSdSync (INT32 id)
INT32	LOS_BcacheSyncByName (const CHAR *name)
INT32	BcacheGetDirtyRatio (INT32 id)
INT32	LOS_GetDirtyRatioByName (const CHAR *name)
static VOID	BcacheSyncThread (UINT32 id)
VOID	BcacheSyncThreadInit (OsBcache *bc, INT32 id)
	块缓存同步任务初始化,开了个内核任务. 更多...
VOID	BcacheSyncThreadDeinit (const OsBcache *bc)
OsBcache *	BlockCacheInit (struct Vnode *devNode, UINT32 sectorSize, UINT32 sectorPerBlock, UINT32 blockNum, UINT64 blockCount)
VOID	BlockCacheDeinit (OsBcache *bcache)
static VOID	BcacheAsyncPrereadThread (VOID *arg)
VOID	ResumeAsyncPreread (OsBcache *arg1, const OsBcacheBlock *arg2)
UINT32	BcacheAsyncPrereadInit (OsBcache *bc)
UINT32	BcacheAsyncPrereadDeinit (OsBcache *bc)

变量
UINT32	g_memSize
volatile UINT32	g_blockNum
volatile UINT32	g_dataSize
volatile UINT8 *	g_memStart
volatile UINT32	g_switchTimes [CONFIG_FS_FAT_BLOCK_NUMS] = { 0 }
volatile UINT32	g_hitTimes [CONFIG_FS_FAT_BLOCK_NUMS] = { 0 }
UINT32	g_syncThreadPrio = CONFIG_FS_FAT_SYNC_THREAD_PRIO
UINT32	g_dirtyRatio = CONFIG_FS_FAT_DIRTY_RATIO
UINT32	g_syncInterval = CONFIG_FS_FAT_SYNC_INTERVAL

函数说明

AddBlock()

static void AddBlock ( OsBcache *  bc, OsBcacheBlock *  block  )

static

在文件 bcache.c 第 395 行定义.

{
    RbAddBlock(bc, block);
    NumListAdd(bc, block);
    bc->sumNum += block->num;
    bc->nBlock++;
    LOS_ListAdd(&bc->listHead, &block->listNode);
}

函数调用图:

这是这个函数的调用关系图:

AllocNewBlock()

static OsBcacheBlock * AllocNewBlock ( OsBcache *  bc, BOOL  read, UINT64  num  )

static

在文件 bcache.c 第 554 行定义.

{
    OsBcacheBlock *last = NULL;
    OsBcacheBlock *prefer = NULL;
 
    if (read) { /* read */
        return GetSlowBlock(bc, TRUE);
    }
 
    /* fallback, this may happen when the block previously flushed, use read buffer */
    if (bc->nBlock && num < GetMinWriteNum(bc)) {
        return GetSlowBlock(bc, TRUE);
    }
 
    last = RbFindBlock(bc, num - 1);  /* num=0 is ok */
    if (last == NULL || last->readBuff) {
        return GetBaseBlock(bc);      /* new block */
    }
 
    prefer = last + 1;
    if (prefer > bc->wEnd) {
        prefer = bc->wStart;
    }
 
    /* this is a sync thread synced block! */
    if (prefer->used && !prefer->modified) {
        prefer->used = FALSE;
        DelBlock(bc, prefer);
    }
 
    if (prefer->used) {
        MergeSyncBlocks(bc, prefer);
    }
 
    if (prefer->used) {
        BcacheSyncBlock(bc, prefer);
        DelBlock(bc, prefer);
    }
 
    prefer->used = TRUE;
    LOS_ListDelete(&prefer->listNode); /* del from free list */
 
    return prefer;
}

函数调用图:

这是这个函数的调用关系图:

BcacheAnalyse()

VOID BcacheAnalyse

(

UINT32

level

)

在文件 bcache.c 第 61 行定义.

{
    (VOID)level;
#ifdef BCACHE_ANALYSE
    int i;
 
    PRINTK("Bcache information:\n");
    PRINTK("    mem: %u\n", g_memSize);
    PRINTK("    block number: %u\n", g_blockNum);
    PRINTK("index, switch, hit\n");
    for (i = 0; i < g_blockNum; i++) {
        PRINTK("%5d, %6d, %3d\n", i, g_switchTimes[i], g_hitTimes[i]);
    }
#else
    PRINTK("Bcache hasn't started\n");
#endif
}

BcacheAsyncPrereadDeinit()

UINT32 BcacheAsyncPrereadDeinit

(

OsBcache *

bc

)

在文件 bcache.c 第 1210 行定义.

{
    UINT32 ret = LOS_NOK;
 
    if (bc != NULL) {
        ret = LOS_TaskDelete(bc->prereadTaskId);
        if (ret != ENOERR) {
            PRINT_ERR("Bcache async task delete failed in %s, %d\n", __FUNCTION__, __LINE__);
        }
 
        ret = LOS_EventDestroy(&bc->bcacheEvent);
        if (ret != ENOERR) {
            PRINT_ERR("Async event destroy failed in %s, %d\n", __FUNCTION__, __LINE__);
            return ret;
        }
    }
 
    return ret;
}

函数调用图:

这是这个函数的调用关系图:

BcacheAsyncPrereadInit()

UINT32 BcacheAsyncPrereadInit

(

OsBcache *

bc

)

在文件 bcache.c 第 1184 行定义.

{
    UINT32 ret;
    TSK_INIT_PARAM_S appTask;
 
    ret = LOS_EventInit(&bc->bcacheEvent);
    if (ret != ENOERR) {
        PRINT_ERR("Async event init failed in %s, %d\n", __FUNCTION__, __LINE__);
        return ret;
    }
 
    (VOID)memset_s(&appTask, sizeof(TSK_INIT_PARAM_S), 0, sizeof(TSK_INIT_PARAM_S));
    appTask.pfnTaskEntry = (TSK_ENTRY_FUNC)BcacheAsyncPrereadThread;
    appTask.uwStackSize = BCACHE_STATCK_SIZE;
    appTask.pcName = "bcache_async_task";
    appTask.usTaskPrio = BCACHE_PREREAD_PRIO;
    appTask.auwArgs[0] = (UINTPTR)bc;
    appTask.uwResved = LOS_TASK_STATUS_DETACHED;
    ret = LOS_TaskCreate(&bc->prereadTaskId, &appTask);
    if (ret != ENOERR) {
        PRINT_ERR("Bcache async task create failed in %s, %d\n", __FUNCTION__, __LINE__);
    }
 
    return ret;
}

函数调用图:

这是这个函数的调用关系图:

BcacheAsyncPrereadThread()

static VOID BcacheAsyncPrereadThread ( VOID *  arg )

static

在文件 bcache.c 第 1134 行定义.

{
    OsBcache *bc = (OsBcache *)arg;
    OsBcacheBlock *block = NULL;
    INT32 ret;
    UINT32 i;
 
    for (;;) {
        ret = (INT32)LOS_EventRead(&bc->bcacheEvent, PREREAD_EVENT_MASK,
                                   LOS_WAITMODE_OR | LOS_WAITMODE_CLR, LOS_WAIT_FOREVER);
        if (ret != ASYNC_EVENT_BIT) {
            PRINT_ERR("The event read in %s, %d is error!!!\n", __FUNCTION__, __LINE__);
            continue;
        }
 
        for (i = 1; i <= PREREAD_BLOCK_NUM; i++) {
            if ((bc->curBlockNum + i) >= bc->blockCount) {
                break;
            }
 
            (VOID)pthread_mutex_lock(&bc->bcacheMutex);
            ret = BcacheGetBlock(bc, bc->curBlockNum + i, TRUE, &block);
            if (ret != ENOERR) {
                PRINT_ERR("read block %llu error : %d!\n", bc->curBlockNum, ret);
            }
 
            (VOID)pthread_mutex_unlock(&bc->bcacheMutex);
        }
 
        if (block != NULL) {
            block->pgHit = 1; /* preread complete */
        }
    }
}

函数调用图:

这是这个函数的调用关系图:

BcacheClearCache()

INT32 BcacheClearCache

(

OsBcache *

bc

)

在文件 bcache.c 第 706 行定义.

{
    OsBcacheBlock *block = NULL;
    OsBcacheBlock *next = NULL;
    LOS_DL_LIST_FOR_EACH_ENTRY_SAFE(block, next, &bc->listHead, OsBcacheBlock, listNode) {
        DelBlock(bc, block);
    }
    return 0;
}

函数调用图:

这是这个函数的调用关系图:

BcacheGetBlock()

static INT32 BcacheGetBlock ( OsBcache *  bc, UINT64  num, BOOL  readData, OsBcacheBlock **  dblock  )

static

在文件 bcache.c 第 635 行定义.

{
    INT32 ret;
    OsBcacheBlock *block = NULL;
    OsBcacheBlock *first = NULL;
 
    /*
     * First check if the most recently used block is the requested block,
     * this can improve performance when using byte access functions.
     */
    if (LOS_ListEmpty(&bc->listHead) == FALSE) {
        first = LOS_DL_LIST_ENTRY(bc->listHead.pstNext, OsBcacheBlock, listNode);
        block = (first->num == num) ? first : RbFindBlock(bc, num);
    }
 
    if (block != NULL) {
        D(("bcache block = %llu found in cache\n", num));
#ifdef BCACHE_ANALYSE
        UINT32 index = ((UINT32)(block->data - g_memStart)) / g_dataSize;
        PRINTK(", [HIT], %llu, %u\n", num, index);
        g_hitTimes[index]++;
#endif
 
        if (first != block) {
            ListMoveBlockToHead(bc, block);
        }
        *dblock = block;
 
        if ((bc->prereadFun != NULL) && (readData == TRUE) && (block->pgHit == 1)) {
            block->pgHit = 0;
            bc->prereadFun(bc, block);
        }
 
        return ENOERR;
    }
 
    D(("bcache block = %llu NOT found in cache\n", num));
 
    block = AllocNewBlock(bc, readData, num);
    if (block == NULL) {
        block = GetSlowBlock(bc, readData);
    }
 
    if (block == NULL) {
        return -ENOMEM;
    }
#ifdef BCACHE_ANALYSE
    UINT32 index = ((UINT32)(block->data - g_memStart)) / g_dataSize;
    PRINTK(", [MISS], %llu, %u\n", num, index);
    g_switchTimes[index]++;
#endif
    BlockInit(bc, block, num);
 
    if (readData == TRUE) {
        D(("bcache reading block = %llu\n", block->num));
 
        ret = BlockRead(bc, block, block->data);
        if (ret != ENOERR) {
            return ret;
        }
        if (bc->prereadFun != NULL) {
            bc->prereadFun(bc, block);
        }
    }
 
    AddBlock(bc, block);
 
    *dblock = block;
    return ENOERR;
}

函数调用图:

这是这个函数的调用关系图:

BcacheGetDirtyRatio()

INT32 BcacheGetDirtyRatio

(

INT32

id

)

在文件 bcache.c 第 989 行定义.

{
#ifdef LOSCFG_FS_FAT_CACHE
    INT32 ret;
    los_disk *disk = get_disk(id);
    if (disk == NULL) {
        return VFS_ERROR;
    }
 
    if (pthread_mutex_lock(&disk->disk_mutex) != ENOERR) {
        PRINT_ERR("%s %d, mutex lock fail!\n", __FUNCTION__, __LINE__);
        return VFS_ERROR;
    }
    if ((disk->disk_status == STAT_INUSED) && (disk->bcache != NULL)) {
        ret = (INT32)((disk->bcache->modifiedBlock * PERCENTAGE) / GetFatBlockNums());
    } else {
        ret = VFS_ERROR;
    }
    if (pthread_mutex_unlock(&disk->disk_mutex) != ENOERR) {
        PRINT_ERR("%s %d, mutex unlock fail!\n", __FUNCTION__, __LINE__);
        return VFS_ERROR;
    }
    return ret;
#else
    return VFS_ERROR;
#endif
}

函数调用图:

这是这个函数的调用关系图:

BcacheGetFlag()

static INT32 BcacheGetFlag ( OsBcache *  bc, OsBcacheBlock *  block  )

static

在文件 bcache.c 第 266 行定义.

{
    UINT32 i, n, f, sectorPos, val, start, pos, currentSize;
    UINT32 flagUse = bc->sectorPerBlock >> UNINT_LOG2_SHIFT;
    UINT32 flag = UINT_MAX;
    INT32 ret, bits;
 
    if (block->readFlag == TRUE) {
        return ENOERR;
    }
 
    for (i = 0; i < flagUse; i++) {
        flag &= block->flag[i];
    }
 
    if (flag == UINT_MAX) {
        return ENOERR;
    }
 
    ret = BlockRead(bc, block, bc->rwBuffer);
    if (ret != ENOERR) {
        return ret;
    }
 
    for (i = 0, sectorPos = 0; i < flagUse; i++) {
        val = block->flag[i];
        /* use unsigned integer for bit map */
        for (f = 0, bits = UNSIGNED_INTEGER_BITS; bits > 0; val = ~(val << n), f++, bits = bits - (INT32)n) {
            if (val == 0) {
                n = UNSIGNED_INTEGER_BITS;
            } else {
                n = (UINT32)CLZ(val);
            }
            sectorPos += n;
            if (((f % EVEN_JUDGED) != 0) || (n == 0)) { /* Number of leading zeros of n is zero */
                goto LOOP;
            }
            if (sectorPos > ((i + 1) << UNINT_LOG2_SHIFT)) {
                start = sectorPos - n;
                currentSize = (((i + 1) << UNINT_LOG2_SHIFT) - start) * bc->sectorSize;
            } else {
                start = sectorPos - n;
                currentSize = n * bc->sectorSize;
            }
            pos = start * bc->sectorSize;
            if (memcpy_s(block->data + pos, bc->blockSize - pos, bc->rwBuffer + pos, currentSize) != EOK) {
                return VFS_ERROR;
            }
LOOP:
            if (sectorPos > ((i + 1) << UNINT_LOG2_SHIFT)) {
                sectorPos = (i + 1) << UNINT_LOG2_SHIFT;
            }
        }
    }
 
    return ENOERR;
}

函数调用图:

这是这个函数的调用关系图:

BcacheInitCache()

static INT32 BcacheInitCache ( OsBcache *  bc, UINT8 *  memStart, UINT32  memSize, UINT32  blockSize  )

static

块设备缓存初始化

在文件 bcache.c 第 716 行定义.

{
    UINT8 *blockMem = NULL;
    UINT8 *dataMem = NULL;
    OsBcacheBlock *block = NULL;
    UINT32 blockNum, i;
 
    LOS_ListInit(&bc->listHead);
    LOS_ListInit(&bc->numHead);
    bc->sumNum = 0;
    bc->nBlock = 0;
 
    if (!GetValLog2(blockSize)) {
        PRINT_ERR("GetValLog2(%u) return 0.\n", blockSize);
        return -EINVAL;
    }
 
    bc->rbRoot.rb_node = NULL;
    bc->memStart = memStart;
    bc->blockSize = blockSize;
    bc->blockSizeLog2 = GetValLog2(blockSize);
    bc->modifiedBlock = 0;
 
    /* init block memory pool */
    LOS_ListInit(&bc->freeListHead);
 
    blockNum = (memSize - DMA_ALLGN) / (sizeof(OsBcacheBlock) + bc->blockSize);
    blockMem = bc->memStart;
    dataMem = blockMem + (sizeof(OsBcacheBlock) * blockNum);
    dataMem += ALIGN_DISP((UINTPTR)dataMem);
 
#ifdef BCACHE_ANALYSE
    g_memSize = memSize;
    g_blockNum = blockNum;
    g_dataSize = bc->blockSize;
    g_memStart = dataMem;
#endif
 
    for (i = 0; i < blockNum; i++) {
        block = (OsBcacheBlock *)(VOID *)blockMem;
        block->data = dataMem;
        block->readBuff = (i < CONFIG_FS_FAT_READ_NUMS) ? TRUE : FALSE;
 
        if (i == CONFIG_FS_FAT_READ_NUMS) {
            bc->wStart = block;
        }
 
        LOS_ListTailInsert(&bc->freeListHead, &block->listNode);
 
        blockMem += sizeof(OsBcacheBlock);
        dataMem += bc->blockSize;
    }
 
    bc->wEnd = block;
 
    return ENOERR;
}

函数调用图:

这是这个函数的调用关系图:

BcacheSetFlag()

static VOID BcacheSetFlag ( const OsBcache *  bc, OsBcacheBlock *  block, UINT32  pos, UINT32  size  )

static

在文件 bcache.c 第 324 行定义.

{
    UINT32 start, num, i, j, k;
 
    if (bc->sectorSize == 0) {
        PRINT_ERR("BcacheSetFlag sectorSize is equal to zero! \n");
        return;
    }
 
    start = pos / bc->sectorSize;
    num = size / bc->sectorSize;
 
    i = start / UNSIGNED_INTEGER_BITS;
    j = start % UNSIGNED_INTEGER_BITS;
    for (k = 0; k < num; k++) {
        block->flag[i] |= 1u << (UNINT_MAX_SHIFT_BITS - j);
        j++;
        if (j == UNSIGNED_INTEGER_BITS) {
            j = 0;
            i++;
        }
    }
}

这是这个函数的调用关系图:

BcacheSync()

static INT32 BcacheSync ( OsBcache *  bc )

static

在文件 bcache.c 第 599 行定义.

{
    LOS_DL_LIST *node = NULL;
    OsBcacheBlock *block = NULL;
    INT32 ret = ENOERR;
 
    D(("bcache cache sync\n"));
 
    (VOID)pthread_mutex_lock(&bc->bcacheMutex);
    node = bc->listHead.pstPrev;
    while (&bc->listHead != node) {
        block = LOS_DL_LIST_ENTRY(node, OsBcacheBlock, listNode);
        ret = BcacheSyncBlock(bc, block);
        if (ret != ENOERR) {
            PRINT_ERR("BcacheSync error, ret = %d\n", ret);
            break;
        }
        node = node->pstPrev;
    }
    (VOID)pthread_mutex_unlock(&bc->bcacheMutex);
 
    return ret;
}

函数调用图:

这是这个函数的调用关系图:

BcacheSyncBlock()

static INT32 BcacheSyncBlock ( OsBcache *  bc, OsBcacheBlock *  block  )

static

在文件 bcache.c 第 348 行定义.

{
    INT32 ret = ENOERR;
    UINT32 len, start, end;
 
    if (block->modified == TRUE) {
        D(("bcache writing block = %llu\n", block->num));
 
        ret = FindFlagPos(block->flag, bc->sectorPerBlock >> UNINT_LOG2_SHIFT, &start, &end);
        if (ret == ENOERR) {
            len = end - start;
        } else {
            ret = BcacheGetFlag(bc, block);
            if (ret != ENOERR) {
                return ret;
            }
 
            len = bc->sectorPerBlock;
        }
 
        ret = bc->bwriteFun(bc->priv, (const UINT8 *)(block->data + (start * bc->sectorSize)),
                            len, (block->num * bc->sectorPerBlock) + start);
        if (ret == ENOERR) {
            block->modified = FALSE;
            bc->modifiedBlock--;
        } else {
            PRINT_ERR("BcacheSyncBlock fail, ret = %d, len = %u, block->num = %llu, start = %u\n",
                      ret, len, block->num, start);
        }
    }
    return ret;
}

函数调用图:

这是这个函数的调用关系图:

BcacheSyncThread()

static VOID BcacheSyncThread ( UINT32  id )

static

在文件 bcache.c 第 1024 行定义.

{
    INT32 diskID = (INT32)id;
    INT32 dirtyRatio;
    while (1) {
        dirtyRatio = BcacheGetDirtyRatio(diskID);
        if (dirtyRatio > (INT32)g_dirtyRatio) {
            (VOID)OsSdSync(diskID);
        }
        msleep(g_syncInterval);
    }
}

函数调用图:

这是这个函数的调用关系图:

BcacheSyncThreadDeinit()

VOID BcacheSyncThreadDeinit

(

const OsBcache *

bc

)

在文件 bcache.c 第 1055 行定义.

{
    if (bc != NULL) {
        if (LOS_TaskDelete(bc->syncTaskId) != ENOERR) {
            PRINT_ERR("Bcache sync task delete failed in %s, %d\n", __FUNCTION__, __LINE__);
        }
    }
}

函数调用图:

这是这个函数的调用关系图:

BcacheSyncThreadInit()

VOID BcacheSyncThreadInit	(	OsBcache *	bc,
		INT32	id
	)

块缓存同步任务初始化,开了个内核任务.

在文件 bcache.c 第 1037 行定义.

{
    UINT32 ret;
    TSK_INIT_PARAM_S appTask;
 
    (VOID)memset_s(&appTask, sizeof(TSK_INIT_PARAM_S), 0, sizeof(TSK_INIT_PARAM_S));
    appTask.pfnTaskEntry = (TSK_ENTRY_FUNC)BcacheSyncThread;
    appTask.uwStackSize = BCACHE_STATCK_SIZE;
    appTask.pcName = "bcache_sync_task";
    appTask.usTaskPrio = g_syncThreadPrio;//任务优先级
    appTask.auwArgs[0] = (UINTPTR)id;
    appTask.uwResved = LOS_TASK_STATUS_DETACHED;
    ret = LOS_TaskCreate(&bc->syncTaskId, &appTask);
    if (ret != ENOERR) {
        PRINT_ERR("Bcache sync task create failed in %s, %d\n", __FUNCTION__, __LINE__);
    }
}

函数调用图:

这是这个函数的调用关系图:

BlockAllDirty()

static BOOL BlockAllDirty ( const OsBcache *  bc, OsBcacheBlock *  block  )

static

在文件 bcache.c 第 414 行定义.

{
    UINT32 start = 0;
    UINT32 end = 0;
    UINT32 len = bc->sectorPerBlock >> UNINT_LOG2_SHIFT;
 
    if (block->modified == TRUE) {
        if (block->allDirty) {
            return TRUE;
        }
 
        if (FindFlagPos(block->flag, len, &start, &end) == ENOERR) {
            if ((end - start) == bc->sectorPerBlock) {
                block->allDirty = TRUE;
                return TRUE;
            }
        }
    }
 
    return FALSE;
}

函数调用图:

这是这个函数的调用关系图:

BlockCacheDeinit()

VOID BlockCacheDeinit

(

OsBcache *

bc

)

Description:

The BlockCacheDeinit() function shall deinit the bcache and release resources.

参数

bc	[IN] block cache instance

注意

• None.

返回值

#VOID

None.

Dependency:

• bcache.h

在文件 bcache.c 第 1122 行定义.

{
    if (bcache != NULL) {
        (VOID)pthread_mutex_destroy(&bcache->bcacheMutex);
        free(bcache->memStart);
        bcache->memStart = NULL;
        free(bcache->rwBuffer);
        bcache->rwBuffer = NULL;
        free(bcache);
    }
}

函数调用图:

这是这个函数的调用关系图:

BlockCacheDrvCreate()

INT32 BlockCacheDrvCreate	(	VOID *	handle,
		UINT8 *	memStart,
		UINT32	memSize,
		UINT32	blockSize,
		OsBcache *	bc
	)

初始化块设备

在文件 bcache.c 第 800 行定义.

{
    INT32 ret;
    bc->priv = handle;
    bc->breadFun = DrvBread;    //设置读块设备函数
    bc->bwriteFun = DrvBwrite;  //设置写块设备函数
 
    ret = BcacheInitCache(bc, memStart, memSize, blockSize);
    if (ret != ENOERR) {
        return ret;
    }
 
    if (pthread_mutex_init(&bc->bcacheMutex, NULL) != ENOERR) {
        return VFS_ERROR;
    }
    bc->bcacheMutex.attr.type = PTHREAD_MUTEX_RECURSIVE;
 
    return ENOERR;
}

函数调用图:

这是这个函数的调用关系图:

BlockCacheInit()

OsBcache * BlockCacheInit	(	struct Vnode *	devNode,
		UINT32	sectorSize,
		UINT32	sectorPerBlock,
		UINT32	blockNum,
		UINT64	blockCount
	)

Description:

The BlockCacheInit() function shall alloc memory for bcache and init it.

参数

devNode	[IN] dev node instance
sectorSize	[IN] size of a sector
sectorPerBlock	[IN] sector count per block in bcache
blockNum	[IN] block number of bcache
blockCount	[IN] block count of the disk

注意

• None.

返回值

OsBcache	* init succeded
#NULL	init failed

Dependency:

• bcache.h

在文件 bcache.c 第 1065 行定义.

{
    OsBcache *bcache = NULL;
    struct Vnode *blkDriver = devNode;
    UINT8 *bcacheMem = NULL;
    UINT8 *rwBuffer = NULL;
    UINT32 blockSize, memSize;
 
    if ((blkDriver == NULL) || (sectorSize * sectorPerBlock * blockNum == 0) || (blockCount == 0)) {
        return NULL;
    }
 
    blockSize = sectorSize * sectorPerBlock;
    if ((((UINT64)(sizeof(OsBcacheBlock) + blockSize) * blockNum) + DMA_ALLGN) > UINT_MAX) {
        return NULL;
    }
    memSize = ((sizeof(OsBcacheBlock) + blockSize) * blockNum) + DMA_ALLGN;
 
    bcache = (OsBcache *)zalloc(sizeof(OsBcache));
    if (bcache == NULL) {
        PRINT_ERR("bcache_init : malloc %u Bytes failed!\n", sizeof(OsBcache));
        return NULL;
    }
 
    bcacheMem = (UINT8 *)zalloc(memSize);
    if (bcacheMem == NULL) {
        PRINT_ERR("bcache_init : malloc %u Bytes failed!\n", memSize);
        goto ERROR_OUT_WITH_BCACHE;
    }
 
    rwBuffer = (UINT8 *)memalign(DMA_ALLGN, blockSize);
    if (rwBuffer == NULL) {
        PRINT_ERR("bcache_init : malloc %u Bytes failed!\n", blockSize);
        goto ERROR_OUT_WITH_MEM;
    }
 
    bcache->rwBuffer = rwBuffer;
    bcache->sectorSize = sectorSize;
    bcache->sectorPerBlock = sectorPerBlock;
    bcache->blockCount = blockCount;
 
    if (BlockCacheDrvCreate(blkDriver, bcacheMem, memSize, blockSize, bcache) != ENOERR) {
        goto ERROR_OUT_WITH_BUFFER;
    }
 
    return bcache;
 
ERROR_OUT_WITH_BUFFER:
    free(rwBuffer);
ERROR_OUT_WITH_MEM:
    free(bcacheMem);
ERROR_OUT_WITH_BCACHE:
    free(bcache);
    return NULL;
}

函数调用图:

这是这个函数的调用关系图:

BlockCacheRead()

INT32 BlockCacheRead	(	OsBcache *	bc,
		UINT8 *	buf,
		UINT32 *	len,
		UINT64	pos,
		BOOL	useRead
	)

读块设备缓存

Description:

The BlockCacheRead() function shall read data from the bcache, and if it doesn't hit, read the data from disk.

参数

bc	[IN] block cache instance
buf	[OUT] data buffer ptr
len	[IN] number of bytes to read
num	[IN] starting block number
pos	[IN] starting position inside starting block
useRead	[IN] whether use the read block or write block

注意

• The block number is automatically adjusted if position is greater than block size.

返回值

#0	read succeded
INT32	read failed

Dependency:

• bcache.h

在文件 bcache.c 第 824 行定义.

{
    OsBcacheBlock *block = NULL;
    UINT8 *tempBuf = buf;
    UINT32 size;
    UINT32 currentSize;
    INT32 ret = ENOERR;
    UINT64 pos;
    UINT64 num;
#ifdef BCACHE_ANALYSE
    PRINTK("bcache read:\n");
#endif
 
    if (bc == NULL || buf == NULL || len == NULL) {
        return -EPERM;
    }
 
    size = *len;
    pos = sector * bc->sectorSize;
    num = pos >> bc->blockSizeLog2;
    pos = pos & (bc->blockSize - 1);
 
    while (size > 0) {
        if ((size + pos) > bc->blockSize) {
            currentSize = bc->blockSize - (UINT32)pos;
        } else {
            currentSize = size;
        }
 
        (VOID)pthread_mutex_lock(&bc->bcacheMutex);
 
        /* useRead should be FALSE when reading large contiguous data */
        ret = BcacheGetBlock(bc, num, useRead, &block);
        if (ret != ENOERR) {
            (VOID)pthread_mutex_unlock(&bc->bcacheMutex);
            break;
        }
 
        if ((block->readFlag == FALSE) && (block->modified == TRUE)) {
            ret = BcacheGetFlag(bc, block);
            if (ret != ENOERR) {
                (VOID)pthread_mutex_unlock(&bc->bcacheMutex);
                return ret;
            }
        } else if ((block->readFlag == FALSE) && (block->modified == FALSE)) {
            ret = BlockRead(bc, block, block->data);
            if (ret != ENOERR) {
                (VOID)pthread_mutex_unlock(&bc->bcacheMutex);
                return ret;
            }
        }
 
        if (LOS_CopyFromKernel((VOID *)tempBuf, size, (VOID *)(block->data + pos), currentSize) != EOK) {
            (VOID)pthread_mutex_unlock(&bc->bcacheMutex);
            return VFS_ERROR;
        }
 
        (VOID)pthread_mutex_unlock(&bc->bcacheMutex);
 
        tempBuf += currentSize;
        size -= currentSize;
        pos = 0;
        num++;
    }
    *len -= size;
    return ret;
}

函数调用图:

这是这个函数的调用关系图:

BlockCacheSync()

INT32 BlockCacheSync

(

OsBcache *

bc

)

块缓存同步

Description:

The BlockCacheSync() function shall write-back all dirty data in the bcache into the disk.

参数

bc	[IN] block cache instance

注意

• None.

返回值

#0	sync succeded
INT32	sync failed

Dependency:

• bcache.h

在文件 bcache.c 第 951 行定义.

{
    return BcacheSync(bc);
}

函数调用图:

这是这个函数的调用关系图:

BlockCacheWrite()

INT32 BlockCacheWrite	(	OsBcache *	bc,
		const UINT8 *	buf,
		UINT32 *	len,
		UINT64	pos
	)

写块设备缓存

Description:

The BlockCacheWrite() function shall write data to the bcache.

参数

bc	[IN] block cache instance
buf	[IN] data buffer ptr
len	[IN] number of bytes to write
num	[IN] starting block number
pos	[IN] starting position inside starting block

注意

• The block number is automatically adjusted if position is greater than block size.

返回值

#0	write succeded
INT32	write failed

Dependency:

• bcache.h

在文件 bcache.c 第 892 行定义.

{
    OsBcacheBlock *block = NULL;
    const UINT8 *tempBuf = buf;
    UINT32 size = *len;
    INT32 ret = ENOERR;
    UINT32 currentSize;
    UINT64 pos;
    UINT64 num;
#ifdef BCACHE_ANALYSE
    PRINTK("bcache write:\n");
#endif
 
    pos = sector * bc->sectorSize;
    num = pos >> bc->blockSizeLog2;
    pos = pos & (bc->blockSize - 1);
 
    D(("bcache write len = %u pos = %llu bnum = %llu\n", *len, pos, num));
 
    while (size > 0) {
        if ((size + pos) > bc->blockSize) {
            currentSize = bc->blockSize - (UINT32)pos;
        } else {
            currentSize = size;
        }
 
        (VOID)pthread_mutex_lock(&bc->bcacheMutex);
        ret = BcacheGetBlock(bc, num, FALSE, &block);
        if (ret != ENOERR) {
            (VOID)pthread_mutex_unlock(&bc->bcacheMutex);
            break;
        }
 
        if (LOS_CopyToKernel((VOID *)(block->data + pos), bc->blockSize - (UINT32)pos,
            (VOID *)tempBuf, currentSize) != EOK) {
            (VOID)pthread_mutex_unlock(&bc->bcacheMutex);
            return VFS_ERROR;
        }
        if (block->modified == FALSE) {
            block->modified = TRUE;
            bc->modifiedBlock++;
        }
        if ((pos == 0) && (currentSize == bc->blockSize)) {
            (void)memset_s(block->flag, sizeof(block->flag), 0xFF, sizeof(block->flag));
            block->allDirty = TRUE;
        } else {
            BcacheSetFlag(bc, block, (UINT32)pos, currentSize);
        }
        (VOID)pthread_mutex_unlock(&bc->bcacheMutex);
 
        tempBuf += currentSize;
        size -= currentSize;
        pos = 0;
        num++;
    }
    *len -= size;
    return ret;
}

函数调用图:

这是这个函数的调用关系图:

BlockInit()

static VOID BlockInit ( OsBcache *  bc, OsBcacheBlock *  block, UINT64  num  )

static

在文件 bcache.c 第 623 行定义.

{
    (VOID)memset_s(block->flag, sizeof(block->flag), 0, sizeof(block->flag));
    block->num = num;
    block->readFlag = FALSE;
    if (block->modified == TRUE) {
        block->modified = FALSE;
        bc->modifiedBlock--;
    }
    block->allDirty = FALSE;
}

这是这个函数的调用关系图:

BlockRead()

static INT32 BlockRead ( OsBcache *  bc, OsBcacheBlock *  block, UINT8 *  buf  )

static

在文件 bcache.c 第 246 行定义.

{
    INT32 ret = bc->breadFun(bc->priv, buf, bc->sectorPerBlock,
                             (block->num) << GetValLog2(bc->sectorPerBlock));
    if (ret) {
        PRINT_ERR("BlockRead, brread_fn error, ret = %d\n", ret);
        if (block->modified == FALSE) {
            if (block->listNode.pstNext != NULL) {
                LOS_ListDelete(&block->listNode); /* list del block */
                RbDelBlock(bc, block);
            }
            FreeBlock(bc, block);
        }
        return ret;
    }
 
    block->readFlag = TRUE;
    return ENOERR;
}

函数调用图:

这是这个函数的调用关系图:

DelBlock()

static void DelBlock ( OsBcache *  bc, OsBcacheBlock *  block  )

static

在文件 bcache.c 第 404 行定义.

{
    LOS_ListDelete(&block->listNode); /* lru list del */
    LOS_ListDelete(&block->numNode);  /* num list del */
    bc->sumNum -= block->num;
    bc->nBlock--;
    RbDelBlock(bc, block);            /* rb  tree del */
    FreeBlock(bc, block);             /* free list add */
}

函数调用图:

这是这个函数的调用关系图:

DrvBread()

static INT32 DrvBread ( struct Vnode *  priv, UINT8 *  buf, UINT32  len, UINT64  pos  )

static

读块设备数据

在文件 bcache.c 第 777 行定义.

{
    struct block_operations *bops = (struct block_operations *)((struct drv_data *)priv->data)->ops;
 
    INT32 ret = bops->read(priv, buf, pos, len);
    if (ret != (INT32)len) {
        PRINT_ERR("%s failure\n", __FUNCTION__);
        return ret;
    }
    return ENOERR;
}

这是这个函数的调用关系图:

DrvBwrite()

static INT32 DrvBwrite ( struct Vnode *  priv, const UINT8 *  buf, UINT32  len, UINT64  pos  )

static

写块设备数据

在文件 bcache.c 第 789 行定义.

{
    struct block_operations *bops = (struct block_operations *)((struct drv_data *)priv->data)->ops;
    INT32 ret = bops->write(priv, buf, pos, len);
    if (ret != (INT32)len) {
        PRINT_ERR("%s failure\n", __FUNCTION__);
        return ret;
    }
    return ENOERR;
}

这是这个函数的调用关系图:

FindFlagPos()

static INT32 FindFlagPos ( const UINT32 *  arr, UINT32  len, UINT32 *  p1, UINT32 *  p2  )

static

在文件 bcache.c 第 207 行定义.

{
    UINT32 *start = p1;
    UINT32 *end = p2;
    UINT32 i, j, tmp;
    UINT32 val = 1;
 
    *start = BCACHE_MAGIC_NUM;
    *end = 0;
    for (i = 0; i < len; i++) {
        for (j = 0; j < UNSIGNED_INTEGER_BITS; j++) {
            tmp = arr[i] << j;
            tmp = tmp >> UNINT_MAX_SHIFT_BITS;
            if (tmp != val) {
                continue;
            }
            if (val && (*start == BCACHE_MAGIC_NUM)) {
                *start = (i << UNINT_LOG2_SHIFT) + j;
                val = 1 - val; /* Control parity by 0 and 1 */
            } else if (val && (*start != BCACHE_MAGIC_NUM)) {
                *start = 0;
                return VFS_ERROR;
            } else {
                *end = (i << UNINT_LOG2_SHIFT) + j;
                val = 1 - val; /* Control parity by 0 and 1 */
            }
        }
    }
    if (*start == BCACHE_MAGIC_NUM) {
        *start = 0;
        return VFS_ERROR;
    }
    if (*end == 0) {
        *end = len << UNINT_LOG2_SHIFT;
    }
 
    return ENOERR;
}

这是这个函数的调用关系图:

FreeBlock()

static VOID FreeBlock ( OsBcache *  bc, OsBcacheBlock *  block  )

inlinestatic

释放块

在文件 bcache.c 第 184 行定义.

{
    block->used = FALSE;
    LOS_ListAdd(&bc->freeListHead, &block->listNode);
}

函数调用图:

这是这个函数的调用关系图:

GetBaseBlock()

static OsBcacheBlock * GetBaseBlock ( OsBcache *  bc )

static

在文件 bcache.c 第 436 行定义.

{
    OsBcacheBlock *base = bc->wStart;
    OsBcacheBlock *end = bc->wEnd;
    while (base < end) {
        if (base->used == FALSE) {
            base->used = TRUE;
            LOS_ListDelete(&base->listNode);
            return base;
        }
        base++;
    }
 
    return NULL;
}

函数调用图:

这是这个函数的调用关系图:

GetMinWriteNum()

static UINT64 GetMinWriteNum ( OsBcache *  bc )

inlinestatic

在文件 bcache.c 第 539 行定义.

{
    UINT64 ret = 0;
    OsBcacheBlock *block = NULL;
 
    LOS_DL_LIST_FOR_EACH_ENTRY(block, &bc->numHead, OsBcacheBlock, numNode) {
        if (!block->readBuff) {
            ret = block->num;
            break;
        }
    }
 
    return ret;
}

这是这个函数的调用关系图:

GetSlowBlock()

static OsBcacheBlock * GetSlowBlock ( OsBcache *  bc, BOOL  read  )

static

在文件 bcache.c 第 453 行定义.

{
    LOS_DL_LIST *node = NULL;
    OsBcacheBlock *block = NULL;
 
    LOS_DL_LIST_FOR_EACH_ENTRY(block, &bc->freeListHead, OsBcacheBlock, listNode) {
        if (block->readBuff == read) {
            block->used = TRUE;
            LOS_ListDelete(&block->listNode);
            return block; /* get free one */
        }
    }
 
    node = bc->listHead.pstPrev;
    while (node != &bc->listHead) {
        block = LOS_DL_LIST_ENTRY(node, OsBcacheBlock, listNode);
        node = block->listNode.pstPrev;
 
        if (block->readBuff == read) {
            if (block->modified == TRUE) {
                BcacheSyncBlock(bc, block);
            }
 
            DelBlock(bc, block);
            block->used = TRUE;
            LOS_ListDelete(&block->listNode);
            return block; /* get used one */
        }
    }
 
    return NULL;
}

函数调用图:

这是这个函数的调用关系图:

GetValLog2()

static UINT32 GetValLog2 ( UINT32  val )

static

在文件 bcache.c 第 190 行定义.

{
    UINT32 i, log2;
 
    i = val;
    log2 = 0;
    while ((i & 1) == 0) { /* Check if the last bit is 1 */
        i >>= 1;
        log2++;
    }
    if (i != 1) { /* Not the power of 2 */
        return 0;
    }
 
    return log2;
}

这是这个函数的调用关系图:

ListMoveBlockToHead()

static VOID ListMoveBlockToHead ( OsBcache *  bc, OsBcacheBlock *  block  )

inlinestatic

删除红黑树块

在文件 bcache.c 第 178 行定义.

{
    LOS_ListDelete(&block->listNode);
    LOS_ListAdd(&bc->listHead, &block->listNode);
}

函数调用图:

这是这个函数的调用关系图:

LOS_BcacheSyncByName()

INT32 LOS_BcacheSyncByName

(

const CHAR *

name

)

Description:

The LOS_BcacheSyncByName() function shall sync all the data in the cache corresponding to the disk name to the disk.

参数

name	[IN] name of the disk

注意

• Now only fat filesystem support this function.

返回值

#0	On success.
INT32	On failure.

Dependency:

• fs.h

参见

None

在文件 bcache.c 第 983 行定义.

{
    INT32 diskID = los_get_diskid_byname(name);
    return OsSdSync(diskID);
}

函数调用图:

LOS_GetDirtyRatioByName()

INT32 LOS_GetDirtyRatioByName

(

const CHAR *

name

)

Description:

The LOS_GetDirtyRatioByName() function shall return the percentage of dirty blocks in the cache corresponding to the disk name.

参数

name	[IN] name of the disk

注意

• Now only fat filesystem support this function.

返回值

INT32	the percentage of dirty blocks.
#-1	On failure.

Dependency:

• fs.h

参见

None

在文件 bcache.c 第 1017 行定义.

{
    INT32 diskID = los_get_diskid_byname(name);
    return BcacheGetDirtyRatio(diskID);
}

函数调用图:

LOS_SetDirtyRatioThreshold()

VOID LOS_SetDirtyRatioThreshold

(

UINT32

dirtyRatio

)

Description:

The LOS_SetDirtyRatioThreshold() function shall set the dirty ratio threshold of bcache. When the percentage of dirty blocks in the cache is greater than the threshold, write back data to disk.

参数

dirtyRatio

[IN] Threshold of the percentage of dirty blocks, expressed in %.

注意

• The dirtyRatio must be less than or equal to 100, or the setting is invalid.

返回值

#VOID

None.

Dependency:

• fs.h

参见

LOS_SetSyncThreadInterval | LOS_SetSyncThreadPrio

在文件 bcache.c 第 85 行定义.

{
    if ((dirtyRatio != g_dirtyRatio) && (dirtyRatio <= 100)) { /* The ratio cannot exceed 100% */
        g_dirtyRatio = dirtyRatio;
    }
}

LOS_SetSyncThreadInterval()

VOID LOS_SetSyncThreadInterval

(

UINT32

interval

)

设置同步间隔,5秒

Description:

The LOS_SetSyncThreadInterval() function shall set the interval for the sync thread to wake up.

参数

interval

[IN] the interval time for the sync thread to wake up, in milliseconds, accuracy is 10ms.

注意

• None

返回值

#VOID

None.

Dependency:

• fs.h

参见

LOS_SetDirtyRatioThreshold | LOS_SetSyncThreadPrio

在文件 bcache.c 第 92 行定义.

{
    g_syncInterval = interval;
}

LOS_SetSyncThreadPrio()

INT32 LOS_SetSyncThreadPrio	(	UINT32	prio,
		const CHAR *	name
	)

设置同步任务优先级,10

Description:

The LOS_SetSyncThreadPrio() function shall set the priority of the sync thread.

参数

prio	[IN] priority of sync thread to be set
name	[IN] name of the disk

注意

• The prio must be less than 31 and be greater than 0, or the setting is invalid.
• If the parameter name is NULL, it only set the value of a global variable, and take effect the next time the thread is created. If name is not NULL and can't find the disk corresponding to name, it shall return an error.

返回值

INT32	On failure.
0	On success.

Dependency:

• fs.h

参见

LOS_SetDirtyRatioThreshold | LOS_SetSyncThreadInterval | LOS_TaskPriSet

在文件 bcache.c 第 97 行定义.

{
    INT32 ret = VFS_ERROR;
    INT32 diskID;
    los_disk *disk = NULL;
    if ((prio == 0) || (prio >= OS_TASK_PRIORITY_LOWEST)) { /* The priority can not be zero */
        return ret;
    }
 
    g_syncThreadPrio = prio;
 
    /*
     * If the name is NULL, it only sets the value of a global variable,
     * and takes effect the next time the thread is created.
     */
    if (name == NULL) {
        return ENOERR;
    }
 
    /* If the name is not NULL, it shall return an error if can't find the disk corresponding to name. */
    diskID = los_get_diskid_byname(name);//获取磁盘ID
    disk = get_disk(diskID);//获取磁盘信息
    if (disk == NULL) {
        return ret;
    }
 
    if (pthread_mutex_lock(&disk->disk_mutex) != ENOERR) {
        PRINT_ERR("%s %d, mutex lock fail!\n", __FUNCTION__, __LINE__);
        return ret;
    }
    if ((disk->disk_status == STAT_INUSED) && (disk->bcache != NULL)) {
        ret = LOS_TaskPriSet(disk->bcache->syncTaskId, prio);//设置任务优先级
    }
    if (pthread_mutex_unlock(&disk->disk_mutex) != ENOERR) {
        PRINT_ERR("%s %d, mutex unlock fail!\n", __FUNCTION__, __LINE__);
        return VFS_ERROR;
    }
    return ret;
}

函数调用图:

MergeSyncBlocks()

static VOID MergeSyncBlocks ( OsBcache *  bc, OsBcacheBlock *  start  )

static

在文件 bcache.c 第 513 行定义.

{
    INT32 mergedBlock = 0;
    OsBcacheBlock *cur = start;
    OsBcacheBlock *last = NULL;
 
    while (cur <= bc->wEnd) {
        if (!cur->used || !BlockAllDirty(bc, cur)) {
            break;
        }
 
        if (last && (last->num + 1 != cur->num)) {
            break;
        }
 
        mergedBlock++;
        last = cur;
        cur++;
    }
 
    if (mergedBlock > 0) {
        WriteMergedBlocks(bc, start, mergedBlock);
    }
}

函数调用图:

这是这个函数的调用关系图:

NumListAdd()

static void NumListAdd ( OsBcache *  bc, OsBcacheBlock *  block  )

static

在文件 bcache.c 第 381 行定义.

{
    OsBcacheBlock *temp = NULL;
 
    LOS_DL_LIST_FOR_EACH_ENTRY(temp, &bc->numHead, OsBcacheBlock, numNode) {
        if (temp->num > block->num) {
            LOS_ListTailInsert(&temp->numNode, &block->numNode);
            return;
        }
    }
 
    LOS_ListTailInsert(&bc->numHead, &block->numNode);
}

函数调用图:

这是这个函数的调用关系图:

OsSdSync()

INT32 OsSdSync

(

INT32

id

)

在文件 bcache.c 第 956 行定义.

{
#ifdef LOSCFG_FS_FAT_CACHE
    INT32 ret;
    los_disk *disk = get_disk(id);
    if ((disk == NULL) || (disk->disk_status == STAT_UNUSED)) {
        return VFS_ERROR;
    }
    if (pthread_mutex_lock(&disk->disk_mutex) != ENOERR) {
        PRINT_ERR("%s %d, mutex lock fail!\n", __FUNCTION__, __LINE__);
        return VFS_ERROR;
    }
    if ((disk->disk_status == STAT_INUSED) && (disk->bcache != NULL)) {
        ret = BcacheSync(disk->bcache);
    } else {
        ret = VFS_ERROR;
    }
    if (pthread_mutex_unlock(&disk->disk_mutex) != ENOERR) {
        PRINT_ERR("%s %d, mutex unlock fail!\n", __FUNCTION__, __LINE__);
        return VFS_ERROR;
    }
    return ret;
#else
    return VFS_ERROR;
#endif
}

函数调用图:

这是这个函数的调用关系图:

RbAddBlock()

static VOID RbAddBlock ( OsBcache *  bc, OsBcacheBlock *  block  )

static

添加缓存块

在文件 bcache.c 第 152 行定义.

{
    struct rb_node *node = bc->rbRoot.rb_node;
    struct rb_node **link = NULL;
    OsBcacheBlock *b = NULL;
 
    if (node == NULL) {
        rb_link_node(&block->rbNode, NULL, &bc->rbRoot.rb_node);
    } else {
        for (; node != NULL; link = (b->num > block->num) ? &node->rb_left : &node->rb_right, node = *link) {
            b = rb_entry(node, OsBcacheBlock, rbNode);
            if (b->num == block->num) {
                PRINT_ERR("RbAddBlock fail, b->num = %llu, block->num = %llu\n", b->num, block->num);
                return;
            }
        }
        rb_link_node(&block->rbNode, &b->rbNode, link);
    }
    rb_insert_color(&block->rbNode, &bc->rbRoot);
}

这是这个函数的调用关系图:

RbDelBlock()

static VOID RbDelBlock ( OsBcache *  bc, OsBcacheBlock *  block  )

inlinestatic

删除红黑树块

在文件 bcache.c 第 173 行定义.

{
    rb_erase(&block->rbNode, &bc->rbRoot);
}

这是这个函数的调用关系图:

RbFindBlock()

static OsBcacheBlock * RbFindBlock ( const OsBcache *  bc, UINT64  num  )

static

红黑树找块

在文件 bcache.c 第 138 行定义.

{
    OsBcacheBlock *block = NULL;
    struct rb_node *node = bc->rbRoot.rb_node;
 
    for (; node != NULL; node = (block->num < num) ? node->rb_right : node->rb_left) {
        block = rb_entry(node, OsBcacheBlock, rbNode);
        if (block->num == num) {
            return block;
        }
    }
    return NULL;
}

这是这个函数的调用关系图:

ResumeAsyncPreread()

VOID ResumeAsyncPreread	(	OsBcache *	arg1,
		const OsBcacheBlock *	arg2
	)

在文件 bcache.c 第 1169 行定义.

{
    UINT32 ret;
    OsBcache *bc = arg1;
    const OsBcacheBlock *block = arg2;
 
    if (OsCurrTaskGet()->taskID != bc->prereadTaskId) {
        bc->curBlockNum = block->num;
        ret = LOS_EventWrite(&bc->bcacheEvent, ASYNC_EVENT_BIT);
        if (ret != ENOERR) {
            PRINT_ERR("Write event failed in %s, %d\n", __FUNCTION__, __LINE__);
        }
    }
}

函数调用图:

这是这个函数的调用关系图:

WriteMergedBlocks()

static VOID WriteMergedBlocks ( OsBcache *  bc, OsBcacheBlock *  begin, int  blocks  )

static

在文件 bcache.c 第 487 行定义.

{
    INT32 ret;
    OsBcacheBlock *cur = NULL;
    OsBcacheBlock *next = NULL;
    UINT32 len = blocks * bc->sectorPerBlock;
    UINT64 pos = begin->num * bc->sectorPerBlock;
 
    ret = bc->bwriteFun(bc->priv, (const UINT8 *)begin->data, len, pos);
    if (ret != ENOERR) {
        PRINT_ERR("WriteMergedBlocks bwriteFun failed ret %d\n", ret);
        return;
    }
 
    bc->modifiedBlock -= blocks;
    cur = begin;
    while (blocks > 0) {
        next = LOS_DL_LIST_ENTRY(cur->numNode.pstNext, OsBcacheBlock, numNode);
        DelBlock(bc, cur);
        cur->modified = FALSE;
        blocks--;
        cur = next;
    }
}

函数调用图:

这是这个函数的调用关系图:

变量说明

g_blockNum

volatile UINT32 g_blockNum

在文件 bcache.c 第 54 行定义.

g_dataSize

volatile UINT32 g_dataSize

在文件 bcache.c 第 55 行定义.

g_dirtyRatio

UINT32 g_dirtyRatio = CONFIG_FS_FAT_DIRTY_RATIO

在文件 bcache.c 第 82 行定义.

g_hitTimes

volatile UINT32 g_hitTimes[CONFIG_FS_FAT_BLOCK_NUMS] = { 0 }

在文件 bcache.c 第 58 行定义.

g_memSize

UINT32 g_memSize

在文件 bcache.c 第 53 行定义.

g_memStart

volatile UINT8* g_memStart

在文件 bcache.c 第 56 行定义.

g_switchTimes

volatile UINT32 g_switchTimes[CONFIG_FS_FAT_BLOCK_NUMS] = { 0 }

在文件 bcache.c 第 57 行定义.

g_syncInterval

UINT32 g_syncInterval = CONFIG_FS_FAT_SYNC_INTERVAL

在文件 bcache.c 第 83 行定义.

g_syncThreadPrio

UINT32 g_syncThreadPrio = CONFIG_FS_FAT_SYNC_THREAD_PRIO

在文件 bcache.c 第 81 行定义.