未验证 提交 7e8be12d 编写于 作者: S Shengliang Guan 提交者: GitHub

Merge pull request #10033 from taosdata/feature/mnode

rollback fetch worker
...@@ -181,7 +181,7 @@ static void *tFWorkerThreadFp(SQWorker *worker) { ...@@ -181,7 +181,7 @@ static void *tFWorkerThreadFp(SQWorker *worker) {
} }
STaosQueue *tFWorkerAllocQueue(SQWorkerPool *pool, void *ahandle, FItem fp) { 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); } void tFWorkerFreeQueue(SFWorkerPool *pool, STaosQueue *queue) { tQWorkerFreeQueue(pool, queue); }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册