commit
d9844fbf9e
|
@ -159,7 +159,7 @@ static void uvStartSendResp(SSvrMsg* msg);
|
|||
|
||||
static void uvNotifyLinkBrokenToApp(SSvrConn* conn);
|
||||
|
||||
static FORCE_INLINE void destroySmsg(SSvrMsg* smsg);
|
||||
static FORCE_INLINE void destroySmsg(SSvrMsg* smsg);
|
||||
static FORCE_INLINE SSvrConn* createConn(void* hThrd);
|
||||
static FORCE_INLINE void destroyConn(SSvrConn* conn, bool clear /*clear handle or not*/);
|
||||
static FORCE_INLINE void destroyConnRegArg(SSvrConn* conn);
|
||||
|
@ -1498,8 +1498,11 @@ int transSendResponse(const STransMsg* msg) {
|
|||
return 0;
|
||||
}
|
||||
SExHandle* exh = msg->info.handle;
|
||||
|
||||
if (exh == NULL) {
|
||||
return 0;
|
||||
rpcFreeCont(msg->pCont);
|
||||
tTrace("msg handle already released");
|
||||
return -1;
|
||||
}
|
||||
int64_t refId = msg->info.refId;
|
||||
ASYNC_CHECK_HANDLE(exh, refId);
|
||||
|
|
Loading…
Reference in New Issue