!109 XX产品上,存在使用littlefs文件系统重复打开文件会新创建Fd,与预期不一致,改为返回失败
Merge pull request !109 from li_zan/master
This commit is contained in:
commit
658c340644
|
@ -30,7 +30,6 @@
|
||||||
*/
|
*/
|
||||||
|
|
||||||
#include "lfs_api.h"
|
#include "lfs_api.h"
|
||||||
#include "iCunit.h"
|
|
||||||
|
|
||||||
lfs_t g_lfs;
|
lfs_t g_lfs;
|
||||||
FileDirInfo g_lfsDir[LFS_MAX_OPEN_DIRS] = {0};
|
FileDirInfo g_lfsDir[LFS_MAX_OPEN_DIRS] = {0};
|
||||||
|
@ -46,13 +45,19 @@ FileOpInfo GetFsOpInfo(void)
|
||||||
return g_fsOp;
|
return g_fsOp;
|
||||||
}
|
}
|
||||||
|
|
||||||
LittleFsHandleStruct *GetFreeFd(int *fd)
|
LittleFsHandleStruct *LfsAllocFd(const char *fileName, int *fd)
|
||||||
{
|
{
|
||||||
|
int len = strlen(fileName) + 1;
|
||||||
|
|
||||||
pthread_mutex_lock(&g_FslocalMutex);
|
pthread_mutex_lock(&g_FslocalMutex);
|
||||||
for (int i = 0; i < LITTLE_FS_MAX_OPEN_FILES; i++) {
|
for (int i = 0; i < LITTLE_FS_MAX_OPEN_FILES; i++) {
|
||||||
if (g_handle[i].useFlag == 0) {
|
if (g_handle[i].useFlag == 0) {
|
||||||
*fd = i;
|
*fd = i;
|
||||||
g_handle[i].useFlag = 1;
|
g_handle[i].useFlag = 1;
|
||||||
|
g_handle[i].pathName = (char *)malloc(len);
|
||||||
|
if (g_handle[i].pathName) {
|
||||||
|
memcpy_s(g_handle[i].pathName, LITTLE_FS_MAX_NAME_LEN, fileName, len);
|
||||||
|
}
|
||||||
pthread_mutex_unlock(&g_FslocalMutex);
|
pthread_mutex_unlock(&g_FslocalMutex);
|
||||||
return &(g_handle[i]);
|
return &(g_handle[i]);
|
||||||
}
|
}
|
||||||
|
@ -62,6 +67,19 @@ LittleFsHandleStruct *GetFreeFd(int *fd)
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
BOOL CheckFileIsOpen(const char *fileName)
|
||||||
|
{
|
||||||
|
for (int i = 0; i < LITTLE_FS_MAX_OPEN_FILES; i++) {
|
||||||
|
if (g_handle[i].useFlag == 1) {
|
||||||
|
if (strcmp(g_handle[i].pathName, fileName) == 0) {
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
|
||||||
lfs_dir_t *GetFreeDir()
|
lfs_dir_t *GetFreeDir()
|
||||||
{
|
{
|
||||||
pthread_mutex_lock(&g_FslocalMutex);
|
pthread_mutex_lock(&g_FslocalMutex);
|
||||||
|
@ -82,7 +100,7 @@ int InitMountInfo(const char *fileSystemType, const struct MountOps *fsMops)
|
||||||
for (int i = 0; i < MAX_FILE_SYSTEM_LEN; i++) {
|
for (int i = 0; i < MAX_FILE_SYSTEM_LEN; i++) {
|
||||||
if (g_fsmap[i].fileSystemtype == NULL) {
|
if (g_fsmap[i].fileSystemtype == NULL) {
|
||||||
g_fsmap[i].fileSystemtype = (char*)malloc(len);
|
g_fsmap[i].fileSystemtype = (char*)malloc(len);
|
||||||
memcpy_s(g_fsmap[i].fileSystemtype, len, fileSystemType, len);
|
memcpy_s(g_fsmap[i].fileSystemtype, LITTLE_FS_MAX_NAME_LEN, fileSystemType, len);
|
||||||
g_fsmap[i].fsMops = fsMops;
|
g_fsmap[i].fsMops = fsMops;
|
||||||
return VFS_OK;
|
return VFS_OK;
|
||||||
}
|
}
|
||||||
|
@ -205,16 +223,21 @@ int LfsClosedir(const DIR *dir)
|
||||||
return lfs_dir_close(&g_lfs, (lfs_dir_t *)dir);
|
return lfs_dir_close(&g_lfs, (lfs_dir_t *)dir);
|
||||||
}
|
}
|
||||||
|
|
||||||
int LfsOpen(const char *path, int openFlag, int mode)
|
int LfsOpen(const char *pathName, int openFlag, int mode)
|
||||||
{
|
{
|
||||||
int fd = INVALID_FD;
|
int fd = INVALID_FD;
|
||||||
|
|
||||||
LittleFsHandleStruct *fsHandle = GetFreeFd(&fd);
|
// if file is already open, return invalid fd
|
||||||
|
if (pathName == NULL || CheckFileIsOpen(pathName)) {
|
||||||
|
goto errout;
|
||||||
|
}
|
||||||
|
|
||||||
|
LittleFsHandleStruct *fsHandle = LfsAllocFd(pathName, &fd);
|
||||||
if (fd == INVALID_FD) {
|
if (fd == INVALID_FD) {
|
||||||
goto errout;
|
goto errout;
|
||||||
}
|
}
|
||||||
|
|
||||||
int err = lfs_file_open(&g_lfs, &(fsHandle->file), path, openFlag);
|
int err = lfs_file_open(&g_lfs, &(fsHandle->file), pathName, openFlag);
|
||||||
if (err != 0) {
|
if (err != 0) {
|
||||||
goto errout;
|
goto errout;
|
||||||
}
|
}
|
||||||
|
@ -259,9 +282,13 @@ int LfsClose(int fd)
|
||||||
return ret;
|
return ret;
|
||||||
}
|
}
|
||||||
|
|
||||||
ret = lfs_file_close(&g_lfs, &(g_handle[fd].file));
|
|
||||||
pthread_mutex_lock(&g_FslocalMutex);
|
pthread_mutex_lock(&g_FslocalMutex);
|
||||||
|
ret = lfs_file_close(&g_lfs, &(g_handle[fd].file));
|
||||||
g_handle[fd].useFlag = 0;
|
g_handle[fd].useFlag = 0;
|
||||||
|
if (g_handle[fd].pathName != NULL) {
|
||||||
|
free(g_handle[fd].pathName);
|
||||||
|
g_handle[fd].pathName = NULL;
|
||||||
|
}
|
||||||
pthread_mutex_unlock(&g_FslocalMutex);
|
pthread_mutex_unlock(&g_FslocalMutex);
|
||||||
|
|
||||||
return ret;
|
return ret;
|
||||||
|
|
|
@ -55,6 +55,7 @@ typedef unsigned mode_t;
|
||||||
|
|
||||||
typedef struct {
|
typedef struct {
|
||||||
uint8_t useFlag;
|
uint8_t useFlag;
|
||||||
|
const char *pathName;
|
||||||
lfs_file_t file;
|
lfs_file_t file;
|
||||||
} LittleFsHandleStruct;
|
} LittleFsHandleStruct;
|
||||||
|
|
||||||
|
@ -97,6 +98,7 @@ typedef struct {
|
||||||
|
|
||||||
#define LITTLE_FS_MAX_OPEN_FILES 100
|
#define LITTLE_FS_MAX_OPEN_FILES 100
|
||||||
#define LITTLE_FS_STANDARD_NAME_LENGTH 50
|
#define LITTLE_FS_STANDARD_NAME_LENGTH 50
|
||||||
|
#define LITTLE_FS_MAX_NAME_LEN 255
|
||||||
|
|
||||||
#define MAX_DEF_BUF_NUM 21
|
#define MAX_DEF_BUF_NUM 21
|
||||||
#define MAX_BUFFER_LEN 100
|
#define MAX_BUFFER_LEN 100
|
||||||
|
@ -121,7 +123,7 @@ int LfsRmdir(const char *dirName);
|
||||||
DIR *LfsOpendir(const char *dirName);
|
DIR *LfsOpendir(const char *dirName);
|
||||||
struct dirent *LfsReaddir(DIR *dir);
|
struct dirent *LfsReaddir(DIR *dir);
|
||||||
int LfsClosedir(const DIR *dir);
|
int LfsClosedir(const DIR *dir);
|
||||||
int LfsOpen(const char *path, int openFlag, int mode);
|
int LfsOpen(const char *pathName, int openFlag, int mode);
|
||||||
int LfsRead(int fd, void *buf, unsigned int len);
|
int LfsRead(int fd, void *buf, unsigned int len);
|
||||||
int LfsWrite(int fd, const void *buf, unsigned int len);
|
int LfsWrite(int fd, const void *buf, unsigned int len);
|
||||||
int LfsSeek(int fd, off_t offset, int whence);
|
int LfsSeek(int fd, off_t offset, int whence);
|
||||||
|
|
Loading…
Reference in New Issue