avoid invalid vgroup id
This commit is contained in:
parent
e15d8875ad
commit
42e6f59e49
|
@ -398,7 +398,7 @@ static int uvPrepareSendData(SSvrMsg* smsg, uv_buf_t* wb) {
|
||||||
pHead->magicNum = htonl(TRANS_MAGIC_NUM);
|
pHead->magicNum = htonl(TRANS_MAGIC_NUM);
|
||||||
|
|
||||||
// handle invalid drop_task resp, TD-20098
|
// handle invalid drop_task resp, TD-20098
|
||||||
if (pMsg->msgType == TDMT_SCH_DROP_TASK && pMsg->code == TSDB_CODE_VND_INVALID_VGROUP_ID) {
|
if (pConn->inType == TDMT_SCH_DROP_TASK && pMsg->code == TSDB_CODE_VND_INVALID_VGROUP_ID) {
|
||||||
transQueuePop(&pConn->srvMsgs);
|
transQueuePop(&pConn->srvMsgs);
|
||||||
destroySmsg(smsg);
|
destroySmsg(smsg);
|
||||||
return -1;
|
return -1;
|
||||||
|
|
Loading…
Reference in New Issue