xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix compile

This commit is contained in:
Liu Jicong 2022-02-10 11:29:51 +08:00
parent 91a2d7c2a9
commit b59a82225e
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
source/dnode/mnode/impl/src/mndSubscribe.c
View File

@ -356,7 +356,7 @@ static int32_t mndProcessDoRebalanceMsg(SMnodeMsg *pMsg) {
SMqConsumerObj *pRebConsumer = mndAcquireConsumer(pMnode, pSubConsumer->consumerId); SMqConsumerObj *pRebConsumer = mndAcquireConsumer(pMnode, pSubConsumer->consumerId);
pRebConsumer->epoch++; pRebConsumer->epoch++;
SSdbRaw* pConsumerRaw = mndConsumerActionEncode(pRebConsumer); SSdbRaw* pConsumerRaw = mndConsumerActionEncode(pRebConsumer);
sdbSetRawStatus(pRebConsumer, SDB_STATUS_READY); sdbSetRawStatus(pConsumerRaw, SDB_STATUS_READY);
mndTransAppendRedolog(pTrans, pConsumerRaw); mndTransAppendRedolog(pTrans, pConsumerRaw);
} }
} }
@ -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 = mndSubscribeActionEncode(pSub);*/
sdbSetRawStatus(pSubRaw, SDB_STATUS_READY); /*sdbSetRawStatus(pSubRaw, SDB_STATUS_READY);*/
mndTransAppendRedolog(pTrans, pSubRaw); /*mndTransAppendRedolog(pTrans, pSubRaw);*/
} }
mndReleaseSubscribe(pMnode, pSub); mndReleaseSubscribe(pMnode, pSub);
} }