Commit edce42f0 authored by Wei Shoulin's avatar Wei Shoulin
Browse files

gz

parent 92631fa5
...@@ -8,7 +8,7 @@ class ServiceProxy: ...@@ -8,7 +8,7 @@ class ServiceProxy:
def channel(self): def channel(self):
options = (('grpc.max_send_message_length', 1000 * 1024 * 1024), options = (('grpc.max_send_message_length', 1000 * 1024 * 1024),
('grpc.max_receive_message_length', 1000 * 1024 * 1024)) ('grpc.max_receive_message_length', 1000 * 1024 * 1024))
channel = grpc.insecure_channel(self.gateway, options = options) channel = grpc.insecure_channel(self.gateway, options = options, compression = grpc.Compression.Gzip)
try: try:
grpc.channel_ready_future(channel).result(timeout=10) grpc.channel_ready_future(channel).result(timeout=10)
except grpc.FutureTimeoutError: except grpc.FutureTimeoutError:
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment