From df17d3c686458deb2814f1f19a91a2c2124ea9f3 Mon Sep 17 00:00:00 2001 From: Cary Xu Date: Mon, 6 Dec 2021 10:18:31 +0800 Subject: [PATCH] update --- src/os/inc/osSocket.h | 2 +- src/sync/src/syncMain.c | 4 ++-- src/sync/src/syncTcp.c | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/os/inc/osSocket.h b/src/os/inc/osSocket.h index 7dabd161b4..6349859611 100644 --- a/src/os/inc/osSocket.h +++ b/src/os/inc/osSocket.h @@ -39,7 +39,7 @@ static FORCE_INLINE int32_t taosCloseSocket(int x) { x = ((int32_t)-1); } if (ret != 0) { - exit(10); + assert(false); } return ret; } diff --git a/src/sync/src/syncMain.c b/src/sync/src/syncMain.c index 565a84f21c..10cff04494 100644 --- a/src/sync/src/syncMain.c +++ b/src/sync/src/syncMain.c @@ -568,7 +568,7 @@ static void syncClosePeerConn(SSyncPeer *pPeer) { taosTmrStopA(&pPeer->timer); if (taosCloseSocket(pPeer->syncFd) != 0) { - exit(4); + exit(false); } if (pPeer->peerFd >= 0) { pPeer->peerFd = -1; @@ -896,7 +896,7 @@ static void syncRestartPeer(SSyncPeer *pPeer) { if (pPeer->nodeId == 0 || ret > 0 || (ret == 0 && pPeer->port > tsSyncPort)) { sDebug("%s, check peer connection in 1000 ms", pPeer->id); if (!taosTmrReset(syncCheckPeerConnection, SYNC_CHECK_INTERVAL, (void *)pPeer->rid, tsSyncTmrCtrl, &pPeer->timer)) { - exit(3); + assert(false); } } } diff --git a/src/sync/src/syncTcp.c b/src/sync/src/syncTcp.c index f69c7e137a..8ca5b63ba1 100644 --- a/src/sync/src/syncTcp.c +++ b/src/sync/src/syncTcp.c @@ -169,7 +169,7 @@ void syncFreeTcpConn(void *param) { sDebug("%p TCP connection will be closed, fd:%d", pThread, pConn->fd); pConn->closedByApp = 1; if (shutdown(pConn->fd, SHUT_WR) != 0) { - exit(2); + ASSERT(false); } } -- GitLab