Merge pull request #4812 from taosdata/fix/TD-2648

[TD-2648]<fix>: enlarge dnode peer sessions from 2K to 32K

src/dnode/src/dnodeMWrite.c

@@ -188,8 +188,8 @@ void dnodeReprocessMWriteMsg(void *pMsg) {
       ++pWrite->pBatchMasterMsg->received;
       if (pWrite->pBatchMasterMsg->successed + pWrite->pBatchMasterMsg->received
 	  >= pWrite->pBatchMasterMsg->expected) {
-	dnodeSendRedirectMsg(&pWrite->rpcMsg, true);
-	dnodeFreeMWriteMsg(pWrite);
+        dnodeSendRedirectMsg(&pWrite->pBatchMasterMsg->rpcMsg, true);
+        dnodeFreeMWriteMsg(pWrite->pBatchMasterMsg);
       }
 
       mnodeDestroySubMsg(pWrite);

src/dnode/src/dnodePeer.c

@@ -60,7 +60,7 @@ int32_t dnodeInitServer() {
   rpcInit.label        = "DND-S";
   rpcInit.numOfThreads = 1;
   rpcInit.cfp          = dnodeProcessReqMsgFromDnode;
-  rpcInit.sessions     = TSDB_MAX_VNODES;
+  rpcInit.sessions     = TSDB_MAX_VNODES << 4;
   rpcInit.connType     = TAOS_CONN_SERVER;
   rpcInit.idleTime     = tsShellActivityTimer * 1000;
 
@@ -123,7 +123,7 @@ int32_t dnodeInitClient() {
   rpcInit.label        = "DND-C";
   rpcInit.numOfThreads = 1;
   rpcInit.cfp          = dnodeProcessRspFromDnode;
-  rpcInit.sessions     = TSDB_MAX_VNODES;
+  rpcInit.sessions     = TSDB_MAX_VNODES << 4;
   rpcInit.connType     = TAOS_CONN_CLIENT;
   rpcInit.idleTime     = tsShellActivityTimer * 1000;
   rpcInit.user         = "t";