set compressMsg range

8cc54650 · dengyihao · 71587df6 · 8cc54650
隐藏空白更改
内联并排

Showing with 4 addition and 0 deletion

source/libs/transport/src/trans.c source/libs/transport/src/trans.c +4 -0

未找到文件。
--- a/source/libs/transport/src/trans.c
+++ b/source/libs/transport/src/trans.c
@@ -47,6 +47,10 @@ void* rpcOpen(const SRpcInit* pInit) {
  }

  pRpc->compressSize = pInit->compressSize;
+  if (pRpc->compressSize < 0) {
+    pRpc->compressSize = -1;
+  }
+
  pRpc->encryption = pInit->encryption;
  pRpc->retryLimit = pInit->retryLimit;
  pRpc->retryInterval = pInit->retryInterval;