Skip to content

Commit 0b9bac8

Browse files
author
SOHAN TIRPUDE
committed
added support to pass value to GRPC message_length options
1 parent b71eedb commit 0b9bac8

File tree

1 file changed

+7
-3
lines changed
  • connector/src/yang/connector

1 file changed

+7
-3
lines changed

connector/src/yang/connector/gnmi.py

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,9 @@ def to_plaintext(string):
3232
return string
3333

3434

35+
GRPC_MAX_RECEIVE_MESSAGE_LENGTH = 1000000000
36+
GRPC_MAX_SEND_MESSAGE_LENGTH = 1000000000
37+
3538
# create a logger for this module
3639
log = logging.getLogger(__name__)
3740

@@ -304,9 +307,10 @@ def connect(self):
304307
port = str(dev_args.get('port'))
305308
target = '{0}:{1}'.format(host, port)
306309

307-
options = [('grpc.max_receive_message_length', 1000000000),
308-
('grpc.max_send_message_length', 1000000000)
309-
]
310+
options = [('grpc.max_receive_message_length',
311+
getattr(self.device.settings, 'GRPC_MAX_RECEIVE_MESSAGE_LENGTH', GRPC_MAX_RECEIVE_MESSAGE_LENGTH)),
312+
('grpc.max_send_message_length',
313+
getattr(self.device.settings, 'GRPC_MAX_SEND_MESSAGE_LENGTH', GRPC_MAX_SEND_MESSAGE_LENGTH))]
310314

311315
# Gather certificate settings
312316
root = dev_args.get('root_certificate')

0 commit comments

Comments
 (0)