Skip to content

T
TDengine

taosdata / TDengine
1 年多 前同步成功

通知 1185
Star 22016
Fork 4786
T
TDengine
提交 f2bc0004 编写于 作者: L Liu Jicong
浏览文件
操作

fix compile

上级 b59a8222
显示空白变更内容
内联 并排
Showing with 3 addition and 6 deletion
source/dnode/mnode/impl/inc/mndSubscribe.h
浏览文件 @ f2bc0004
...@@ -28,9 +28,6 @@ void mndCleanupSubscribe(SMnode *pMnode); ...@@ -28,9 +28,6 @@ void mndCleanupSubscribe(SMnode *pMnode);
SMqSubscribeObj *mndAcquireSubscribe(SMnode *pMnode, char *CGroup, char *topicName); SMqSubscribeObj *mndAcquireSubscribe(SMnode *pMnode, char *CGroup, char *topicName);
void mndReleaseSubscribe(SMnode *pMnode, SMqSubscribeObj *pSub); void mndReleaseSubscribe(SMnode *pMnode, SMqSubscribeObj *pSub);
SSdbRaw *mndSubscribeActionEncode(SMqSubscribeObj *pSub);
SSdbRow *mndSubscribeActionDecode(SSdbRaw *pRaw);
#ifdef __cplusplus #ifdef __cplusplus
} }
#endif #endif
......
source/dnode/mnode/impl/src/mndSubscribe.c
浏览文件 @ f2bc0004
...@@ -377,9 +377,9 @@ static int32_t mndProcessDoRebalanceMsg(SMnodeMsg *pMsg) { ...@@ -377,9 +377,9 @@ static int32_t mndProcessDoRebalanceMsg(SMnodeMsg *pMsg) {
// send msg to vnode // send msg to vnode
// log rebalance statistics // log rebalance statistics
/*SSdbRaw *pSubRaw = mndSubscribeActionEncode(pSub);*/ SSdbRaw *pSubRaw = mndSubActionEncode(pSub);
/*sdbSetRawStatus(pSubRaw, SDB_STATUS_READY);*/ sdbSetRawStatus(pSubRaw, SDB_STATUS_READY);
/*mndTransAppendRedolog(pTrans, pSubRaw);*/ mndTransAppendRedolog(pTrans, pSubRaw);
} }
mndReleaseSubscribe(pMnode, pSub); mndReleaseSubscribe(pMnode, pSub);
} }
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或