From eee2ea2d14dfd6ea4ba0d8c77fad24b041e3bac7 Mon Sep 17 00:00:00 2001
From: Tao He <linzhu.ht@alibaba-inc.com>
Date: Mon, 2 Nov 2020 20:23:09 +0800
Subject: [PATCH] Set maximum message bytes for send/recv for larger initial
 etcd machine.

---
 src/Client.cpp | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/Client.cpp b/src/Client.cpp
index c8e354f..aa1cb3a 100644
--- a/src/Client.cpp
+++ b/src/Client.cpp
@@ -4,6 +4,7 @@
 #include <sys/socket.h>
 #include <netdb.h>
 
+#include <limits>
 #include <memory>
 #include "etcd/Client.hpp"
 #include "etcd/v3/action_constants.hpp"
@@ -108,6 +109,8 @@ etcd::Client::Client(std::string const & address,
   // create channels
   std::string const addresses = etcd::detail::strip_and_resolve_addresses(address);
   grpc::ChannelArguments grpc_args;
+  grpc_args.SetMaxSendMessageSize(std::numeric_limits<int>::max());
+  grpc_args.SetMaxReceiveMessageSize(std::numeric_limits<int>::max());
   std::shared_ptr<grpc::ChannelCredentials> creds = grpc::InsecureChannelCredentials();
   grpc_args.SetLoadBalancingPolicyName(load_balancer);
   this->channel = grpc::CreateCustomChannel(addresses, creds, grpc_args);
@@ -127,6 +130,8 @@ etcd::Client::Client(std::string const & address,
   // create channels
   std::string const addresses = etcd::detail::strip_and_resolve_addresses(address);
   grpc::ChannelArguments grpc_args;
+  grpc_args.SetMaxSendMessageSize(std::numeric_limits<int>::max());
+  grpc_args.SetMaxReceiveMessageSize(std::numeric_limits<int>::max());
   std::shared_ptr<grpc::ChannelCredentials> creds = grpc::InsecureChannelCredentials();
   grpc_args.SetLoadBalancingPolicyName(load_balancer);
   this->channel = grpc::CreateCustomChannel(addresses, creds, grpc_args);