diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c index 0d33bec38dad0dd1eccc0debf0e67b174e9a1df7..41c94bc4bdef18e74af2a3b66d1c0734164dba16 100644 --- a/src/client/src/tscServer.c +++ b/src/client/src/tscServer.c @@ -294,11 +294,6 @@ void tscProcessMsgFromServer(SRpcMsg *rpcMsg) { } } } - - if (pRes->code == TSDB_CODE_SUCCESS) { - tscTrace("%p reset retry counter to be 0 due to success rsp, old:%d", pSql, pSql->retry); - pSql->retry = 0; - } pRes->rspLen = 0; @@ -308,6 +303,11 @@ void tscProcessMsgFromServer(SRpcMsg *rpcMsg) { tscTrace("%p query is cancelled, code:%d", pSql, tstrerror(pRes->code)); } + if (pRes->code == TSDB_CODE_SUCCESS) { + tscTrace("%p reset retry counter to be 0 due to success rsp, old:%d", pSql, pSql->retry); + pSql->retry = 0; + } + if (pRes->code != TSDB_CODE_QUERY_CANCELLED) { assert(rpcMsg->msgType == pCmd->msgType + 1); pRes->code = rpcMsg->code; @@ -569,7 +569,7 @@ int tscBuildSubmitMsg(SSqlObj *pSql, SSqlInfo *pInfo) { pSql->cmd.msgType = TSDB_MSG_TYPE_SUBMIT; tscSetDnodeIpList(pSql, pTableMeta); - tscTrace("%p build submit msg, vgId:%d numOfVgroup:%d", pSql, vgId, htonl(pMsgDesc->numOfVnodes)); + tscTrace("%p build submit msg, vgId:%d numOfVgroup:%d numberOfIP:%d", pSql, vgId, htonl(pMsgDesc->numOfVnodes), pSql->ipList.numOfIps); return TSDB_CODE_SUCCESS; } diff --git a/src/plugins/http/src/httpSystem.c b/src/plugins/http/src/httpSystem.c index 355fdf2fd003f446b9ae66c1904f9946569d5e4e..07aa880a30d98feeb2671ea16cb75f7752d71092 100644 --- a/src/plugins/http/src/httpSystem.c +++ b/src/plugins/http/src/httpSystem.c @@ -117,7 +117,7 @@ void httpCleanUpSystem() { httpPrint("http service cleanup"); httpStopSystem(); -#if 1 +#if 0 if (httpServer == NULL) { return; } diff --git a/src/vnode/src/vnodeMain.c b/src/vnode/src/vnodeMain.c index 9ae05887714375148f8689acaba18f5f132665cb..57f0afbe8f35d40d817dde7502a0536b2c969337 100644 --- a/src/vnode/src/vnodeMain.c +++ b/src/vnode/src/vnodeMain.c @@ -667,7 +667,7 @@ static int32_t vnodeSaveVersion(SVnodeObj *pVnode) { fclose(fp); free(content); - dPrint("pVnode:%p vgId:%d, save vnode version successed", pVnode, pVnode->vgId); + dPrint("pVnode:%p vgId:%d, save vnode version:%" PRId64 " successed", pVnode, pVnode->vgId, pVnode->version); return 0; } @@ -675,7 +675,7 @@ static int32_t vnodeSaveVersion(SVnodeObj *pVnode) { static bool vnodeReadVersion(SVnodeObj *pVnode) { char versionFile[TSDB_FILENAME_LEN + 30] = {0}; sprintf(versionFile, "%s/vnode%d/version.json", tsVnodeDir, pVnode->vgId); - FILE *fp = fopen(versionFile, "w"); + FILE *fp = fopen(versionFile, "r"); if (!fp) { dError("pVnode:%p vgId:%d, failed to open vnode version file for write, error:%s", pVnode, pVnode->vgId, strerror(errno)); return false; diff --git a/tests/script/unique/db/replica_add12.sim b/tests/script/unique/db/replica_add12.sim index 969a2a209157df62549a593d75e85605a4f7f318..29f9fdbea8d9135604e43c2a2cb3f90d7e010472 100644 --- a/tests/script/unique/db/replica_add12.sim +++ b/tests/script/unique/db/replica_add12.sim @@ -145,7 +145,9 @@ if $rows != 2 then return -1 endi +sql reset query cache sleep 2000 + print ========= step5 system sh/exec_up.sh -n dnode2 -s stop -x SIGINT sleep 5000 @@ -155,7 +157,7 @@ if $rows != 2 then return -1 endi -sql select * from d2.t2 +sql select * from d2.t2 if $rows != 2 then return -1 endi @@ -172,11 +174,12 @@ endi print ===== insert data - sql insert into d1.t1 values(now, 3) -sql insert into d2.t2 values(now, 3) +# no master +sql_error insert into d2.t2 values(now, 3) sql insert into d3.t3 values(now, 3) -sql insert into d4.t4 values(now, 3) +# no master +sql_error insert into d4.t4 values(now, 3) sql select * from d1.t1 if $rows != 3 then @@ -184,7 +187,7 @@ if $rows != 3 then endi sql select * from d2.t2 -if $rows != 3 then +if $rows != 2 then return -1 endi @@ -194,32 +197,49 @@ if $rows != 3 then endi sql select * from d4.t4 -if $rows != 3 then +if $rows != 2 then return -1 endi print ========= step6 system sh/exec_up.sh -n dnode2 -s start -sleep 10000 -system sh/exec_up.sh -n dnode3 -s stop -x SIGINT -sleep 10000 - -sql insert into d1.t1 values(now, 4) -sql insert into d2.t2 values(now, 4) -sql insert into d3.t3 values(now, 4) -sql insert into d4.t4 values(now, 4) +sleep 5000 +sql insert into d2.t2 values(now, 3) +sql insert into d4.t4 values(now, 3) sql select * from d1.t1 -if $rows != 4 then +if $rows != 3 then return -1 endi sql select * from d2.t2 -if $rows != 4 then +if $rows != 3 then return -1 endi sql select * from d3.t3 +if $rows != 3 then + return -1 +endi + +sql select * from d4.t4 +if $rows != 3 then + return -1 +endi + +print ========= step61 + +system sh/exec_up.sh -n dnode3 -s stop -x SIGINT +sleep 5000 + +# no master +sql_error insert into d1.t1 values(now, 4) +sql insert into d2.t2 values(now, 4) +# no master +sql_error insert into d3.t3 values(now, 4) +sql insert into d4.t4 values(now, 4) + +sql select * from d2.t2 if $rows != 4 then return -1 endi @@ -231,9 +251,7 @@ endi print ========= step7 system sh/exec_up.sh -n dnode3 -s start -sleep 10000 -system sh/exec_up.sh -n dnode2 -s stop -x SIGINT -sleep 10000 +sleep 5000 sql insert into d1.t1 values(now, 5) sql insert into d2.t2 values(now, 5) @@ -241,7 +259,7 @@ sql insert into d3.t3 values(now, 5) sql insert into d4.t4 values(now, 5) sql select * from d1.t1 -if $rows != 5 then +if $rows != 4 then return -1 endi @@ -251,7 +269,7 @@ if $rows != 5 then endi sql select * from d3.t3 -if $rows != 5 then +if $rows != 4 then return -1 endi