提交 0249e701 编写于 作者: C Cary Xu

[TS-787]<enhance>:release lock during write socket

上级 13ac7117
...@@ -1502,7 +1502,10 @@ static int32_t syncForwardToPeerImpl(SSyncNode *pNode, void *data, void *mhandle ...@@ -1502,7 +1502,10 @@ static int32_t syncForwardToPeerImpl(SSyncNode *pNode, void *data, void *mhandle
} }
} }
int32_t retLen = taosWriteMsg(pPeer->peerFd, pSyncHead, fwdLen); SOCKET peerFd = pPeer->peerFd;
pthread_mutex_unlock(&pNode->mutex);
int32_t retLen = taosWriteMsg(peerFd, pSyncHead, fwdLen);
pthread_mutex_lock(&pNode->mutex);
if (retLen == fwdLen) { if (retLen == fwdLen) {
sTrace("%s, forward is sent, role:%s sstatus:%s hver:%" PRIu64 " contLen:%d", pPeer->id, syncRole[pPeer->role], sTrace("%s, forward is sent, role:%s sstatus:%s hver:%" PRIu64 " contLen:%d", pPeer->id, syncRole[pPeer->role],
syncStatus[pPeer->sstatus], pWalHead->version, pWalHead->len); syncStatus[pPeer->sstatus], pWalHead->version, pWalHead->len);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册