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

support s3

This commit is contained in:
yihaoDeng 2023-11-09 20:27:30 +08:00
parent 5f9b922a04
commit 4a99bdc2b0
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
source/libs/stream/src/streamBackendRocksdb.c
View File

@ -1738,9 +1738,9 @@ int32_t taskDbGenChkpUploadPath(void* arg, void* mgt, int64_t chkpId, int8_t typ
UPLOAD_TYPE utype = type; UPLOAD_TYPE utype = type;
if (utype == UPLOAD_RSYNC) { if (utype == UPLOAD_RSYNC) {
return taskDbGenChkpUplaodPath__rsync(pDb,chkpId, path); return taskDbGenChkpUplaodPath__rsync(pDb, chkpId, path);
} else if (utype == UPLOAD_S3) { } else if (utype == UPLOAD_S3) {
return taskDbGenChkpUplaodPath__s3(pDb,mgt, chkpId, path); return taskDbGenChkpUplaodPath__s3(pDb, mgt, chkpId, path);
} }
return -1; return -1;
} }
@ -3633,14 +3633,15 @@ int32_t bkdMgtGetDelta(SBkdMgt* bm, char* taskId, int64_t chkpId, SArray* list,
taosHashPut(bm->pDbChkpTbl, taskId, strlen(taskId), &p, sizeof(void*)); taosHashPut(bm->pDbChkpTbl, taskId, strlen(taskId), &p, sizeof(void*));
taosMemoryFree(taskPath); taosMemoryFree(taskPath);
pChkp = p;
code = dbChkpDumpTo(pChkp, dname);
taosThreadRwlockUnlock(&bm->rwLock);
return code;
} }
taosThreadRwlockUnlock(&bm->rwLock);
code = dbChkpGetDelta(pChkp, chkpId, list); code = dbChkpGetDelta(pChkp, chkpId, list);
taosThreadRwlockUnlock(&bm->rwLock);
code = dbChkpDumpTo(pChkp, dname);
return code; return code;
} }