xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

update index TFile write

This commit is contained in:
yihaoDeng 2021-12-20 23:12:51 +08:00
parent 3489d290fb
commit 4f52726463
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
source/libs/index/src/index_tfile.c
View File

@ -42,9 +42,12 @@ static int tfileCompare(const void *a, const void *b) {
size_t bLen = strlen(bName); size_t bLen = strlen(bName);
return strncmp(aName, bName, aLen > bLen ? aLen : bLen); return strncmp(aName, bName, aLen > bLen ? aLen : bLen);
} }
static int tfileParseFileName(const char *filename, uint64_t *suid) { static int tfileParseFileName(const char *filename, uint64_t *suid, int *colId, int *version) {
if (3 == sscanf(filename, "%" PRIu64 "-%d-%d.tindex", suid, colId, version)) {
return 0; // read suid & colid & version success
return 0;
}
return -1;
} }
static void tfileSerialCacheKey(TFileCacheKey *key, char *buf) { static void tfileSerialCacheKey(TFileCacheKey *key, char *buf) {
SERIALIZE_MEM_TO_BUF(buf, key, suid); SERIALIZE_MEM_TO_BUF(buf, key, suid);
@ -68,6 +71,12 @@ TFileCache *tfileCacheCreate(const char *path) {
taosArraySort(files, tfileCompare); taosArraySort(files, tfileCompare);
for (size_t i = 0; i < taosArrayGetSize(files); i++) { for (size_t i = 0; i < taosArrayGetSize(files); i++) {
char *file = taosArrayGetP(files, i); char *file = taosArrayGetP(files, i);
uint64_t suid;
int colId, version;
if (0 != tfileParseFileName(file, &suid, &colId, &version)) {
// invalid file, just skip
continue;
}
free((void *)file); free((void *)file);
} }
taosArrayDestroy(files); taosArrayDestroy(files);