diff --git a/src/os/inc/osSocket.h b/src/os/inc/osSocket.h index 2c1121ae0727bfa106ad8ec03d78348991d5f72f..a172c0bf3465257fe5590ae0a7552cf699a61c10 100644 --- a/src/os/inc/osSocket.h +++ b/src/os/inc/osSocket.h @@ -40,7 +40,7 @@ extern "C" { x = FD_INITIALIZER; \ } \ } - #endif +#endif #if defined(_TD_WINDOWS_64) || defined(_TD_WINDOWS_32) #define TAOS_EPOLL_WAIT_TIME 100 diff --git a/src/sync/src/syncMain.c b/src/sync/src/syncMain.c index 96a2716f5a1944588539351ac8bebf6005c99da8..34fa13b279ba7baf25b2fb08ebfe31b15a2bc032 100644 --- a/src/sync/src/syncMain.c +++ b/src/sync/src/syncMain.c @@ -1506,7 +1506,6 @@ static int32_t syncForwardToPeerImpl(SSyncNode *pNode, void *data, void *mhandle 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);