提交 b472511e 编写于 作者: A Alex Duan

feat(rpc): windows build error

上级 2ea367eb
......@@ -82,7 +82,7 @@ typedef struct SSendInfo {
void *pContext;
void *pConn;
void *pFdObj;
int32_t fd;
SOCKET fd;
} SSendInfo;
int32_t rpcInit();
......
......@@ -32,7 +32,7 @@ void *taosOpenTcpClientConnection(void *shandle, void *thandle, uint32_t ip, uin
void taosCloseTcpConnection(void *chandle);
int taosSendTcpData(uint32_t ip, uint16_t port, void *data, int len, void *chandle);
int32_t taosGetFdID(void *chandle);
SOCKET taosGetFdID(void *chandle);
#ifdef __cplusplus
}
......
......@@ -86,8 +86,8 @@ typedef struct {
SRpcMsg *pRsp; // for synchronous API
tsem_t *pSem; // for synchronous API
SRpcEpSet *pSet; // for synchronous API
char msg[0]; // RpcHead starts from here
SSendInfo sendInfo; // save last send information
char msg[0]; // RpcHead starts from here
} SRpcReqContext;
typedef struct SRpcConn {
......@@ -1840,7 +1840,7 @@ bool rpcSendProbe(int64_t rpcRid, void* pPrevContext) {
}
// fd same
int32_t fd = taosGetFdID(pContext->pConn->chandle);
SOCKET fd = taosGetFdID(pContext->pConn->chandle);
if (fd != pContext->sendInfo.fd) {
tInfo("PROBE rpcRid=0x%" PRIx64 " connect fd diff.fd=%d prevFd=%d", rpcRid, fd, pContext->sendInfo.fd);
goto _END;
......
......@@ -675,7 +675,7 @@ static void taosFreeFdObj(SFdObj *pFdObj) {
tfree(pFdObj);
}
int32_t taosGetFdID(void *chandle) {
SOCKET taosGetFdID(void *chandle) {
SFdObj * pFdObj = chandle;
if(pFdObj == NULL)
return -1;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册