rollback fetch worker

This commit is contained in:
Shengliang Guan 2022-01-26 06:44:54 +00:00
parent 8b476207f1
commit 29a49f325c
1 changed files with 1 additions and 1 deletions

View File

@ -181,7 +181,7 @@ static void *tFWorkerThreadFp(SQWorker *worker) {
}
STaosQueue *tFWorkerAllocQueue(SQWorkerPool *pool, void *ahandle, FItem fp) {
return tWorkerAllocQueue(pool, ahandle, fp, (ThreadFp)tFWorkerThreadFp);
return tWorkerAllocQueue(pool, ahandle, fp, (ThreadFp)tQWorkerThreadFp);
}
void tFWorkerFreeQueue(SFWorkerPool *pool, STaosQueue *queue) { tQWorkerFreeQueue(pool, queue); }