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

Merge pull request #23987 from taosdata/fix/little_fix_3.0 

fix: little fix
This commit is contained in:
Hongze Cheng 2023-12-08 17:29:24 +08:00 committed by GitHub
parent a4399d761c a0487529d0
commit 853fb6f119
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/dnode/vnode/src/tsdb/tsdbCommit2.c
View File

@ -435,7 +435,7 @@ _exit:
tsdbDebug("vgId:%d %s done, fid:%d minKey:%" PRId64 " maxKey:%" PRId64 " expLevel:%d", TD_VID(tsdb->pVnode), tsdbDebug("vgId:%d %s done, fid:%d minKey:%" PRId64 " maxKey:%" PRId64 " expLevel:%d", TD_VID(tsdb->pVnode),
__func__, committer->ctx->fid, committer->ctx->minKey, committer->ctx->maxKey, committer->ctx->expLevel); __func__, committer->ctx->fid, committer->ctx->minKey, committer->ctx->maxKey, committer->ctx->expLevel);
} }
return 0; return code;
} }
static int32_t tsdbCommitFileSetEnd(SCommitter2 *committer) { static int32_t tsdbCommitFileSetEnd(SCommitter2 *committer) {

15
source/dnode/vnode/src/vnd/vnodeAsync.c
View File

@ -177,12 +177,15 @@ static int32_t vnodeAsyncTaskDone(SVAsync *async, SVATask *task) {
} }
static int32_t vnodeAsyncCancelAllTasks(SVAsync *async) { static int32_t vnodeAsyncCancelAllTasks(SVAsync *async) {
for (int32_t i = 0; i < EVA_PRIORITY_MAX; i++) { while (async->queue[0].next != &async->queue[0] || async->queue[1].next != &async->queue[1] ||
while (async->queue[i].next != &async->queue[i]) { async->queue[2].next != &async->queue[2]) {
SVATask *task = async->queue[i].next; for (int32_t i = 0; i < EVA_PRIORITY_MAX; i++) {
task->prev->next = task->next; while (async->queue[i].next != &async->queue[i]) {
task->next->prev = task->prev; SVATask *task = async->queue[i].next;
vnodeAsyncTaskDone(async, task); task->prev->next = task->next;
task->next->prev = task->prev;
vnodeAsyncTaskDone(async, task);
}
} }
} }
return 0; return 0;