xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

add log

This commit is contained in:
yihaoDeng 2023-08-23 11:45:01 +08:00
parent ab407c58b6
commit b1495a530d
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source/libs/transport/src/transCli.c
View File

@ -12,8 +12,8 @@
* along with this program. If not, see <http://www.gnu.org/licenses/>. * along with this program. If not, see <http://www.gnu.org/licenses/>.
*/ */
#include "transComm.h"
#include "tmisce.h" #include "tmisce.h"
#include "transComm.h"
typedef struct { typedef struct {
int32_t numOfConn; int32_t numOfConn;
@ -309,7 +309,6 @@ static void cliWalkCb(uv_handle_t* handle, void* arg);
} \ } \
} while (0) } while (0)
static void* cliWorkThread(void* arg); static void* cliWorkThread(void* arg);
static void cliReleaseUnfinishedMsg(SCliConn* conn) { static void cliReleaseUnfinishedMsg(SCliConn* conn) {
@ -1257,7 +1256,7 @@ static void cliHandleFastFail(SCliConn* pConn, int status) {
SCliThrd* pThrd = pConn->hostThrd; SCliThrd* pThrd = pConn->hostThrd;
STrans* pTransInst = pThrd->pTransInst; STrans* pTransInst = pThrd->pTransInst;
if (status == -1) status = ENETUNREACH; if (status == -1) status = UV_EADDRNOTAVAIL;
if (pConn->pBatch == NULL) { if (pConn->pBatch == NULL) {
SCliMsg* pMsg = transQueueGet(&pConn->cliMsgs, 0); SCliMsg* pMsg = transQueueGet(&pConn->cliMsgs, 0);