From 899c21302a84bed1902a3f6357f3922f23e37519 Mon Sep 17 00:00:00 2001 From: lichuang Date: Thu, 10 Jun 2021 15:19:24 +0800 Subject: [PATCH] [TD-3963]fix alter vgroup rsp handle --- src/mnode/src/mnodeVgroup.c | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) diff --git a/src/mnode/src/mnodeVgroup.c b/src/mnode/src/mnodeVgroup.c index 593b094dc2..af816d7ae7 100644 --- a/src/mnode/src/mnodeVgroup.c +++ b/src/mnode/src/mnodeVgroup.c @@ -1044,14 +1044,10 @@ static void mnodeProcessAlterVnodeRsp(SRpcMsg *rpcMsg) { mnodeMsg->rpcMsg.handle, rpcMsg->ahandle); if (mnodeMsg->received != mnodeMsg->expected) return; - uint8_t msgType = mnodeMsg->rpcMsg.msgType; - if (msgType == TSDB_MSG_TYPE_CM_ALTER_DB || msgType == TSDB_MSG_TYPE_CM_CREATE_TP || msgType == TSDB_MSG_TYPE_CM_ALTER_TP) { - int32_t code = mnodeInsertAlterDbRow(pVgroup->pDb, mnodeMsg); - if (code != TSDB_CODE_SUCCESS && code != TSDB_CODE_MND_ACTION_IN_PROGRESS) { - dnodeSendRpcMWriteRsp(mnodeMsg, code); - } - } else { - dnodeSendRpcMWriteRsp(mnodeMsg, TSDB_CODE_SUCCESS); + + int32_t code = mnodeInsertAlterDbRow(pVgroup->pDb, mnodeMsg); + if (code != TSDB_CODE_SUCCESS && code != TSDB_CODE_MND_ACTION_IN_PROGRESS) { + dnodeSendRpcMWriteRsp(mnodeMsg, code); } } -- GitLab