未验证 提交 0d7de8f4 编写于 作者: guanshengliang's avatar guanshengliang 提交者: GitHub

Revert "TD-1843"

上级 001e09a8
......@@ -55,6 +55,7 @@ typedef struct {
} SMnodeComponent;
void *tsMnodeTmr = NULL;
static bool tsMgmtIsRunning = false;
static EMndStatus tsMgmtStatus = TSDB_MND_STATUS_NOT_RUNNING;
static const SMnodeComponent tsMnodeComponents[] = {
......@@ -138,7 +139,7 @@ int32_t mnodeInitSystem() {
}
void mnodeCleanupSystem() {
if (mnodeIsRunning()) {
if (tsMgmtIsRunning) {
mInfo("starting to clean up mnode");
tsMgmtStatus = TSDB_MND_STATUS_CLEANING;
......
......@@ -1559,18 +1559,13 @@ static int rpcCheckAuthentication(SRpcConn *pConn, char *msg, int msgLen) {
if ( !rpcIsReq(pHead->msgType) ) {
// for response, if code is auth failure, it shall bypass the auth process
code = htonl(pHead->code);
#if 0
if (code != 0) {
#else
if (code == TSDB_CODE_RPC_INVALID_TIME_STAMP || code == TSDB_CODE_RPC_AUTH_FAILURE ||
code == TSDB_CODE_RPC_AUTH_REQUIRED || code == TSDB_CODE_MND_INVALID_USER || code == TSDB_CODE_RPC_NOT_READY) {
#endif
// tTrace("%s, dont check authentication since code is:0x%x", pConn->info, code);
pHead->msgLen = (int32_t)htonl((uint32_t)pHead->msgLen);
return 0;
}
if (code != 0) {
// tTrace("%s, dont check authentication since code is:0x%x", pConn->info, code);
pHead->msgLen = (int32_t)htonl((uint32_t)pHead->msgLen);
return 0;
}
}
code = 0;
if (pHead->spi == pConn->spi) {
// authentication
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册