diff --git a/source/client/src/clientMsgHandler.c b/source/client/src/clientMsgHandler.c index d46ff7fe5bda783cf09c7709d4121b1d46a8ecae..e17e7e79c6546109cf95a675f9818349aa590336 100644 --- a/source/client/src/clientMsgHandler.c +++ b/source/client/src/clientMsgHandler.c @@ -220,6 +220,15 @@ int32_t processUseDbRsp(void* param, SDataBuf* pMsg, int32_t code) { } } + tscTrace("db:%s, usedbRsp received, numOfVgroups:%d", usedbRsp.db, usedbRsp.vgNum); + for (int32_t i = 0; i < usedbRsp.vgNum; ++i) { + SVgroupInfo* pInfo = taosArrayGet(usedbRsp.pVgroupInfos, i); + tscTrace("vgId:%d, numOfEps:%d inUse:%d ", pInfo->vgId, pInfo->epSet.numOfEps, pInfo->epSet.inUse); + for (int32_t j = 0; j < pInfo->epSet.numOfEps; ++j) { + tscTrace("vgId:%d, index:%d epset:%s:%u", pInfo->vgId, j, pInfo->epSet.eps[j].fqdn, pInfo->epSet.eps[j].port); + } + } + SName name = {0}; tNameFromString(&name, usedbRsp.db, T_NAME_ACCT | T_NAME_DB); diff --git a/source/dnode/mnode/impl/src/mndDnode.c b/source/dnode/mnode/impl/src/mndDnode.c index 04f340b0ff1bde94a3a84fc2dce3af4a4d3ca1f0..75ae6f467b8187ad4ce69426b9ad8f787985a7ba 100644 --- a/source/dnode/mnode/impl/src/mndDnode.c +++ b/source/dnode/mnode/impl/src/mndDnode.c @@ -376,6 +376,9 @@ static int32_t mndProcessStatusReq(SRpcMsg *pReq) { if (pVgroup->vnodeGid[vg].dnodeId == statusReq.dnodeId) { if (pVgroup->vnodeGid[vg].syncState != pVload->syncState || pVgroup->vnodeGid[vg].syncRestore != pVload->syncRestore) { + mTrace("vgId:%d, role changed, old state:%s restored:%d new state:%s restored:%d", pVgroup->vgId, + syncStr(pVgroup->vnodeGid[vg].syncState), pVgroup->vnodeGid[vg].syncRestore, + syncStr(pVload->syncState), pVload->syncRestore); pVgroup->vnodeGid[vg].syncState = pVload->syncState; pVgroup->vnodeGid[vg].syncRestore = pVload->syncRestore; roleChanged = true; diff --git a/source/libs/qcom/src/querymsg.c b/source/libs/qcom/src/querymsg.c index 953abd595695a3616e3cf89fa89994f3306283d0..181abc2247be09dd9d2f0a66b4782c674a2264be 100644 --- a/source/libs/qcom/src/querymsg.c +++ b/source/libs/qcom/src/querymsg.c @@ -306,6 +306,15 @@ int32_t queryProcessUseDBRsp(void *output, char *msg, int32_t msgSize) { goto PROCESS_USEDB_OVER; } + qTrace("db:%s, usedbRsp received, numOfVgroups:%d", usedbRsp.db, usedbRsp.vgNum); + for (int32_t i = 0; i < usedbRsp.vgNum; ++i) { + SVgroupInfo *pInfo = taosArrayGet(usedbRsp.pVgroupInfos, i); + qTrace("vgId:%d, numOfEps:%d inUse:%d ", pInfo->vgId, pInfo->epSet.numOfEps, pInfo->epSet.inUse); + for (int32_t j = 0; j < pInfo->epSet.numOfEps; ++j) { + qTrace("vgId:%d, index:%d epset:%s:%u", pInfo->vgId, j, pInfo->epSet.eps[j].fqdn, pInfo->epSet.eps[j].port); + } + } + code = queryBuildUseDbOutput(pOut, &usedbRsp); PROCESS_USEDB_OVER: