feat:add pause&resume

5bd8fe54 · liuyao · 5089528a · 5bd8fe54
隐藏空白更改
内联并排

Showing with 2 addition and 0 deletion

source/dnode/vnode/src/tq/tq.c source/dnode/vnode/src/tq/tq.c +2 -0

未找到文件。
--- 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;
 }