提交 98a7e88c 编写于 作者: 陶建辉(Jeff)'s avatar 陶建辉(Jeff)

releaseRef

上级 f7ad45fe
...@@ -137,6 +137,7 @@ void syncCleanUp() { ...@@ -137,6 +137,7 @@ void syncCleanUp() {
} }
taosCloseRef(tsSyncRefId); taosCloseRef(tsSyncRefId);
tsSyncRefId = -1;
sInfo("sync module is cleaned up"); sInfo("sync module is cleaned up");
} }
...@@ -1205,6 +1206,8 @@ static void syncMonitorFwdInfos(void *param, void *tmrId) { ...@@ -1205,6 +1206,8 @@ static void syncMonitorFwdInfos(void *param, void *tmrId) {
pNode->pFwdTimer = taosTmrStart(syncMonitorFwdInfos, 300, pNode, syncTmrCtrl); pNode->pFwdTimer = taosTmrStart(syncMonitorFwdInfos, 300, pNode, syncTmrCtrl);
} }
taosReleaseRef(tsSyncRefId, pNode);
} }
static int32_t syncForwardToPeerImpl(SSyncNode *pNode, void *data, void *mhandle, int qtype) { static int32_t syncForwardToPeerImpl(SSyncNode *pNode, void *data, void *mhandle, int qtype) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册