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

fix: little fix

This commit is contained in:
Hongze Cheng 2023-12-08 14:11:36 +08:00
parent 11577e0eda
commit b9d056c6a8
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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;