diff --git a/src/rpc/src/rpcMain.c b/src/rpc/src/rpcMain.c index fa46c3a0f35aaa8076815bf6f7de6d8f802f590b..87790c5683aa269bfc73f8d1d0721873cb20e036 100644 --- a/src/rpc/src/rpcMain.c +++ b/src/rpc/src/rpcMain.c @@ -124,7 +124,6 @@ typedef struct SRpcConn { } SRpcConn; int tsRpcMaxUdpSize = 15000; // bytes -int tsRpcProgressTime = 10; // milliseocnds // not configurable int tsRpcMaxRetry; @@ -204,7 +203,7 @@ static void rpcUnlockConn(SRpcConn *pConn); void *rpcOpen(const SRpcInit *pInit) { SRpcInfo *pRpc; - tsRpcMaxRetry = tsRpcMaxTime * 1000 / tsRpcProgressTime; + tsRpcMaxRetry = tsRpcMaxTime * 1000 * 2 / tsRpcTimer; tsRpcHeadSize = RPC_MSG_OVERHEAD; tsRpcOverhead = sizeof(SRpcReqContext);