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

src/os/inc/osSocket.h

@@ -33,14 +33,14 @@ extern "C" {
   #define taosReadSocket(fd, buf, len) read(fd, buf, len)
   #define taosWriteSocket(fd, buf, len) write(fd, buf, len)
   #define taosCloseSocketNoCheck(x) close(x)
-#define taosCloseSocket(x) \
-  {                        \
-    if (FD_VALID(x)) {     \
-      close(x);            \
-      x = FD_INITIALIZER;  \
-    }                      \
-  }
-#endif
+  #define taosCloseSocket(x) \
+    {                        \
+      if (FD_VALID(x)) {     \
+        close(x);            \
+        x = FD_INITIALIZER;  \
+      }                      \
+    }
+  #endif
 
 #if defined(_TD_WINDOWS_64) || defined(_TD_WINDOWS_32)
   #define TAOS_EPOLL_WAIT_TIME 100

src/sync/src/syncMain.c

@@ -1502,7 +1502,11 @@ 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) {
       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);