put tsRpcMaxUdpSize as an configurable parameter

src/inc/trpc.h

@@ -27,7 +27,6 @@ extern "C" {
 #define TAOS_CONN_CLIENT   1
 
 extern int tsRpcHeadSize;
-extern int tsRpcMaxUdpSize;
 
 typedef struct {
   int8_t    inUse; 

src/rpc/inc/tsched.h

-/*
- * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
- *
- * This program is free software: you can use, redistribute, and/or modify
- * it under the terms of the GNU Affero General Public License, version 3
- * or later ("AGPL"), as published by the Free Software Foundation.
- *
- * This program is distributed in the hope that it will be useful, but WITHOUT
- * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
- * FITNESS FOR A PARTICULAR PURPOSE.
- *
- * You should have received a copy of the GNU Affero General Public License
- * along with this program. If not, see <http://www.gnu.org/licenses/>.
- */
-
-#ifndef TDENGINE_TSCHED_H
-#define TDENGINE_TSCHED_H
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-
-typedef struct _sched_msg {
-  void    *msg;
-  int      msgLen;
-  int8_t   type;
-  int32_t  code 
-  void     handle;
-} SRpcMsg;
-
-void *rpcInitMsgQueue(int queueSize, void (*fp)(int num, SRpcQueue *),const char *label);
-int   rpcPutIntoMsgQueue(void *qhandle, SRpcMsg *pMsg);
-void  rpcCleanUpMsgQueue(void *param);
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif  // TDENGINE_TSCHED_H

src/rpc/src/rpcMain.c

@@ -122,7 +122,6 @@ typedef struct _RpcConn {
 } SRpcConn;
 
 int tsRpcProgressTime = 10;  // milliseocnds
-int tsRpcMaxUdpSize = 15000; // bytes;
 
 // not configurable
 int tsRpcMaxRetry;

src/util/inc/tglobalcfg.h

@@ -178,6 +178,7 @@ extern uint32_t taosMaxTmrCtrl;
 
 extern int  tsRpcTimer;
 extern int  tsRpcMaxTime;
+extern int  tsRpcMaxUdpSize;
 extern int  tsUdpDelay;
 extern char version[];
 extern char compatible_version[];

src/util/src/tglobalcfg.c

@@ -199,6 +199,7 @@ int   tsIsCluster = 0;
 
 int tsRpcTimer = 300;
 int tsRpcMaxTime = 600;      // seconds;
+int tsRpcMaxUdpSize = 15000;  // bytes
 
 char tsMonitorDbName[TSDB_DB_NAME_LEN] = "log";
 int  tsMonitorInterval = 30;  // seconds