more code
This commit is contained in:
parent
e34ff2a894
commit
eacd2ac234
|
@ -684,7 +684,7 @@ int32_t tsdbFSCreateRefSnapshot(STFileSystem *fs, TFileSetArray **fsetArr) {
|
||||||
int32_t code = 0;
|
int32_t code = 0;
|
||||||
STFileSet *fset, *fset1;
|
STFileSet *fset, *fset1;
|
||||||
|
|
||||||
fsetArr[0] = taosMemoryCalloc(sizeof(*fsetArr[0]));
|
fsetArr[0] = taosMemoryMalloc(sizeof(*fsetArr[0]));
|
||||||
if (fsetArr[0] == NULL) return TSDB_CODE_OUT_OF_MEMORY;
|
if (fsetArr[0] == NULL) return TSDB_CODE_OUT_OF_MEMORY;
|
||||||
|
|
||||||
taosThreadRwlockRdlock(&fs->tsdb->rwLock);
|
taosThreadRwlockRdlock(&fs->tsdb->rwLock);
|
||||||
|
|
|
@ -36,6 +36,9 @@ typedef enum {
|
||||||
TSDB_FOP_MODIFY,
|
TSDB_FOP_MODIFY,
|
||||||
} tsdb_fop_t;
|
} tsdb_fop_t;
|
||||||
|
|
||||||
|
#define TFILE_SET(fid_) \
|
||||||
|
(STFileSet) { .fid = (fid_) }
|
||||||
|
|
||||||
// init/clear
|
// init/clear
|
||||||
int32_t tsdbTFileSetInit(int32_t fid, STFileSet **fset);
|
int32_t tsdbTFileSetInit(int32_t fid, STFileSet **fset);
|
||||||
int32_t tsdbTFileSetInitEx(STsdb *pTsdb, const STFileSet *fset1, STFileSet **fset);
|
int32_t tsdbTFileSetInitEx(STsdb *pTsdb, const STFileSet *fset1, STFileSet **fset);
|
||||||
|
|
Loading…
Reference in New Issue