|
@@ -32,7 +32,11 @@ class GRPCPeerHandle(PeerHandle):
|
|
|
|
|
|
async def connect(self):
|
|
|
if self.channel is None:
|
|
|
- self.channel = grpc.aio.insecure_channel(self.address, options=[("grpc.max_metadata_size", 32*1024*1024)])
|
|
|
+ self.channel = grpc.aio.insecure_channel(self.address, options=[
|
|
|
+ ("grpc.max_metadata_size", 32*1024*1024),
|
|
|
+ ('grpc.max_receive_message_length', 32*1024*1024),
|
|
|
+ ('grpc.max_send_message_length', 32*1024*1024)
|
|
|
+ ])
|
|
|
self.stub = node_service_pb2_grpc.NodeServiceStub(self.channel)
|
|
|
await self.channel.channel_ready()
|
|
|
|