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

fix invalid read/write

This commit is contained in:
yihaoDeng 2023-11-14 20:46:56 +08:00
parent f4d6cf7c74
commit 20e1bd9cff
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1723,7 +1723,7 @@ int32_t taskDbGenChkpUploadData__s3(STaskDbWrapper* pDb, void* bkdChkpMgt, int64
int32_t code = 0; int32_t code = 0;
SBkdMgt* p = (SBkdMgt*)bkdChkpMgt; SBkdMgt* p = (SBkdMgt*)bkdChkpMgt;
char* temp = taosMemoryCalloc(1, strlen(pDb->path)); char* temp = taosMemoryCalloc(1, strlen(pDb->path) + 32);
sprintf(temp, "%s%s%s%" PRId64 "", pDb->path, TD_DIRSEP, "tmp", chkpId); sprintf(temp, "%s%s%s%" PRId64 "", pDb->path, TD_DIRSEP, "tmp", chkpId);
if (taosDirExist(temp)) { if (taosDirExist(temp)) {
@ -3413,7 +3413,7 @@ int32_t compareHashTable(SHashObj* p1, SHashObj* p2, SArray* add, SArray* del) {
void hashTableToDebug(SHashObj* pTbl, char** buf) { void hashTableToDebug(SHashObj* pTbl, char** buf) {
size_t sz = taosHashGetSize(pTbl); size_t sz = taosHashGetSize(pTbl);
int32_t total = 0; int32_t total = 0;
char* p = taosMemoryCalloc(1, sz * 16); char* p = taosMemoryCalloc(1, sz * 16 + 4);
void* pIter = taosHashIterate(pTbl, NULL); void* pIter = taosHashIterate(pTbl, NULL);
while (pIter) { while (pIter) {
size_t len = 0; size_t len = 0;
@ -3425,7 +3425,9 @@ void hashTableToDebug(SHashObj* pTbl, char** buf) {
pIter = taosHashIterate(pTbl, pIter); pIter = taosHashIterate(pTbl, pIter);
taosMemoryFree(tname); taosMemoryFree(tname);
} }
if (total > 0) {
p[total - 1] = 0; p[total - 1] = 0;
}
*buf = p; *buf = p;
} }
void strArrayDebugInfo(SArray* pArr, char** buf) { void strArrayDebugInfo(SArray* pArr, char** buf) {