From 5bd8fe5441f0f25a13968dfdb7292d8e4bc9d46d Mon Sep 17 00:00:00 2001 From: liuyao <54liuyao@163.com> Date: Fri, 21 Apr 2023 14:31:42 +0800 Subject: [PATCH] feat:add pause&resume --- source/dnode/vnode/src/tq/tq.c | 2 ++ 1 file changed, 2 insertions(+) diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c index 890c53cf7d..49f9d39afb 100644 --- a/source/dnode/vnode/src/tq/tq.c +++ b/source/dnode/vnode/src/tq/tq.c @@ -1207,11 +1207,13 @@ int32_t tqProcessTaskDropReq(STQ* pTq, int64_t sversion, char* msg, int32_t msgL int32_t tqProcessTaskPauseReq(STQ* pTq, int64_t sversion, char* msg, int32_t msgLen) { SVPauseStreamTaskReq* pReq = (SVPauseStreamTaskReq*)msg; + // todo(liuyao) call task api return 0; } int32_t tqProcessTaskResumeReq(STQ* pTq, int64_t sversion, char* msg, int32_t msgLen) { SVResumeStreamTaskReq* pReq = (SVResumeStreamTaskReq*)msg; + // todo(liuyao) call task api return 0; }