commit
83ba8bfe69
|
@ -310,7 +310,8 @@ static int32_t mnodeProcessConnectMsg(SMnodeMsg *pMsg) {
|
||||||
|
|
||||||
if (pDb->status != TSDB_DB_STATUS_READY) {
|
if (pDb->status != TSDB_DB_STATUS_READY) {
|
||||||
mError("db:%s, status:%d, in dropping", pDb->name, pDb->status);
|
mError("db:%s, status:%d, in dropping", pDb->name, pDb->status);
|
||||||
return TSDB_CODE_MND_DB_IN_DROPPING;
|
code = TSDB_CODE_MND_DB_IN_DROPPING;
|
||||||
|
goto connect_over;
|
||||||
}
|
}
|
||||||
mnodeDecDbRef(pDb);
|
mnodeDecDbRef(pDb);
|
||||||
}
|
}
|
||||||
|
@ -355,7 +356,7 @@ static int32_t mnodeProcessUseMsg(SMnodeMsg *pMsg) {
|
||||||
int32_t code = TSDB_CODE_SUCCESS;
|
int32_t code = TSDB_CODE_SUCCESS;
|
||||||
if (pMsg->pDb == NULL) pMsg->pDb = mnodeGetDb(pUseDbMsg->db);
|
if (pMsg->pDb == NULL) pMsg->pDb = mnodeGetDb(pUseDbMsg->db);
|
||||||
if (pMsg->pDb == NULL) {
|
if (pMsg->pDb == NULL) {
|
||||||
code = TSDB_CODE_MND_INVALID_DB;
|
return TSDB_CODE_MND_INVALID_DB;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (pMsg->pDb->status != TSDB_DB_STATUS_READY) {
|
if (pMsg->pDb->status != TSDB_DB_STATUS_READY) {
|
||||||
|
|
Loading…
Reference in New Issue