xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

enh: grant notify optimize

This commit is contained in:
kailixu 2023-09-23 18:10:08 +08:00
parent 8f828e052b
commit a4b92760f0
2 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
source/common/src/tmsg.c
View File

@ -1076,9 +1076,10 @@ int32_t tDeserializeSNotifyReq(void *buf, int32_t bufLen, SNotifyReq *pReq) {
goto _exit; goto _exit;
} }
for (int32_t i = 0; i < nVgroup; ++i) { for (int32_t i = 0; i < nVgroup; ++i) {
SVnodeLoadLite *vload = TARRAY_GET_ELEM(pReq->pVloads, i); SVnodeLoadLite vload;
if (tDecodeI32(&decoder, &(vload->vgId)) < 0) goto _exit; if (tDecodeI32(&decoder, &(vload.vgId)) < 0) goto _exit;
if (tDecodeI64(&decoder, &(vload->nTimeSeries)) < 0) goto _exit; if (tDecodeI64(&decoder, &(vload.nTimeSeries)) < 0) goto _exit;
taosArrayPush(pReq->pVloads, &vload);
} }
} }

14
source/dnode/mnode/impl/src/mndDnode.c
View File

@ -697,13 +697,13 @@ static int32_t mndProcessNotifyReq(SRpcMsg *pReq) {
goto _OVER; goto _OVER;
} }
// int64_t clusterid = mndGetClusterId(pMnode); int64_t clusterid = mndGetClusterId(pMnode);
// if (notifyReq.clusterId != 0 && notifyReq.clusterId != clusterid) { if (notifyReq.clusterId != 0 && notifyReq.clusterId != clusterid) {
// code = TSDB_CODE_MND_DNODE_DIFF_CLUSTER; code = TSDB_CODE_MND_DNODE_DIFF_CLUSTER;
// mWarn("dnode:%d, its clusterid:%" PRId64 " differ from current cluster:%" PRId64 " since %s", notifyReq.dnodeId, mWarn("dnode:%d, its clusterid:%" PRId64 " differ from current cluster:%" PRId64 " since %s", notifyReq.dnodeId,
// notifyReq.clusterId, clusterid, tstrerror(code)); notifyReq.clusterId, clusterid, tstrerror(code));
// goto _OVER; goto _OVER;
// } }
int32_t nVgroup = taosArrayGetSize(notifyReq.pVloads); int32_t nVgroup = taosArrayGetSize(notifyReq.pVloads);
for (int32_t v = 0; v < nVgroup; ++v) { for (int32_t v = 0; v < nVgroup; ++v) {