diff --git a/src/device/service/drivers/gnmi_openconfig/GnmiSessionHandler.py b/src/device/service/drivers/gnmi_openconfig/GnmiSessionHandler.py
index f0ef6520d33f48dc10fd8619d8daaa7a5485357f..671182b1c8c78de5269116c7fbef34acd2423bdd 100644
--- a/src/device/service/drivers/gnmi_openconfig/GnmiSessionHandler.py
+++ b/src/device/service/drivers/gnmi_openconfig/GnmiSessionHandler.py
@@ -168,6 +168,7 @@ class GnmiSessionHandler:
set_request = SetRequest()
#for resource_key in resource_keys:
+ resources_requested = list()
for resource_key, resource_value in resources:
#self._logger.info('---1')
#self._logger.info(str(resource_key))
@@ -177,6 +178,7 @@ class GnmiSessionHandler:
#_, value, exists, operation_done = resource_tuple
if isinstance(resource_value, str): resource_value = json.loads(resource_value)
str_path, str_data = compose(resource_key, resource_value, self._yang_handler, delete=False)
+ if str_path is None: continue # nothing to set
#self._logger.info('---3')
#self._logger.info(str(str_path))
#self._logger.info(str(str_data))
@@ -184,6 +186,7 @@ class GnmiSessionHandler:
set_request_entry = set_request_list.add()
set_request_entry.path.CopyFrom(path_from_string(str_path))
set_request_entry.val.json_val = str_data.encode('UTF-8')
+ resources_requested.append((resource_key, resource_value))
self._logger.info('set_request={:s}'.format(grpc_message_to_json_string(set_request)))
metadata = [('username', self._username), ('password', self._password)]
@@ -192,7 +195,7 @@ class GnmiSessionHandler:
self._logger.info('set_reply={:s}'.format(grpc_message_to_json_string(set_reply)))
results = []
- for (resource_key, resource_value), update_result in zip(resources, set_reply.response):
+ for (resource_key, resource_value), update_result in zip(resources_requested, set_reply.response):
operation = update_result.op
if operation == UpdateResult.UPDATE:
results.append((resource_key, True))
@@ -237,6 +240,7 @@ class GnmiSessionHandler:
set_request = SetRequest()
#for resource_key in resource_keys:
+ resources_requested = list()
for resource_key, resource_value in resources:
#self._logger.info('---1')
#self._logger.info(str(resource_key))
@@ -248,11 +252,13 @@ class GnmiSessionHandler:
if isinstance(resource_value, str): resource_value = json.loads(resource_value)
# pylint: disable=unused-variable
str_path, str_data = compose(resource_key, resource_value, self._yang_handler, delete=True)
+ if str_path is None: continue # nothing to do with this resource_key
#self._logger.info('---3')
#self._logger.info(str(str_path))
#self._logger.info(str(str_data))
set_request_entry = set_request.delete.add()
set_request_entry.CopyFrom(path_from_string(str_path))
+ resources_requested.append((resource_key, resource_value))
self._logger.info('set_request={:s}'.format(grpc_message_to_json_string(set_request)))
metadata = [('username', self._username), ('password', self._password)]
@@ -261,7 +267,7 @@ class GnmiSessionHandler:
self._logger.info('set_reply={:s}'.format(grpc_message_to_json_string(set_reply)))
results = []
- for (resource_key, resource_value), update_result in zip(resources, set_reply.response):
+ for (resource_key, resource_value), update_result in zip(resources_requested, set_reply.response):
operation = update_result.op
if operation == UpdateResult.DELETE:
results.append((resource_key, True))
diff --git a/src/device/service/drivers/gnmi_openconfig/MonitoringThread.py b/src/device/service/drivers/gnmi_openconfig/MonitoringThread.py
index 1910c167186a4e9b3424b44c6c6ed203f55c1e18..78bf6d8fbb2ad4e13414e4ebff7f65f577162f2d 100644
--- a/src/device/service/drivers/gnmi_openconfig/MonitoringThread.py
+++ b/src/device/service/drivers/gnmi_openconfig/MonitoringThread.py
@@ -94,9 +94,14 @@ class MonitoringThread(threading.Thread):
subscriptions = []
while not self._terminate.is_set():
try:
- subscription = self._in_subscriptions.get(block=True, timeout=0.1)
+ # Some devices do not support to process multiple
+ # SubscriptionList requests in a bidirectional channel.
+ # Increased timeout to 5 seconds assuming it should
+ # bring enough time to receive all the subscriptions in
+ # the queue and process them in bulk.
+ subscription = self._in_subscriptions.get(block=True, timeout=5.0)
operation, resource_key, sampling_duration, sampling_interval = subscription # pylint: disable=unused-variable
- if operation != 'subscribe': continue # Unsubscribe not supported by gNM, needs to cancel entire connection
+ if operation != 'subscribe': continue # Unsubscribe not supported by gNMI, needs to cancel entire connection
# options.timeout = int(sampling_duration)
#_path = parse_xpath(resource_key)
path = path_from_string(resource_key)
@@ -145,8 +150,12 @@ class MonitoringThread(threading.Thread):
else:
# might be clocks are not synchronized, use local timestamp
timestamp = timestamp_local
+ str_prefix = path_to_string(update.prefix) if len(update.prefix.elem) > 0 else ''
for update_entry in update.update:
str_path = path_to_string(update_entry.path)
+ if len(str_prefix) > 0:
+ str_path = '{:s}/{:s}'.format(str_prefix, str_path)
+ str_path = str_path.replace('//', '/')
if str_path.startswith('/interfaces/'):
# Add namespace, if missing
str_path_parts = str_path.split('/')
diff --git a/src/device/service/drivers/gnmi_openconfig/handlers/NetworkInstanceInterface.py b/src/device/service/drivers/gnmi_openconfig/handlers/NetworkInstanceInterface.py
index ed5e0408711fa54a25e1c2e2ca070f404465bdad..4cf0b275c1627edba0baac87929dbacdaf3beb63 100644
--- a/src/device/service/drivers/gnmi_openconfig/handlers/NetworkInstanceInterface.py
+++ b/src/device/service/drivers/gnmi_openconfig/handlers/NetworkInstanceInterface.py
@@ -37,8 +37,9 @@ class NetworkInstanceInterfaceHandler(_Handler):
if IS_CEOS: ni_if_id = if_name
if delete:
- PATH_TMPL = '/network-instances/network-instance[name={:s}]/interfaces/interface[id={:s}]'
- str_path = PATH_TMPL.format(ni_name, ni_if_id)
+ #PATH_TMPL = '/network-instances/network-instance[name={:s}]/interfaces/interface[id={:s}]'
+ #str_path = PATH_TMPL.format(ni_name, ni_if_id)
+ str_path = None # nothing to delete
str_data = json.dumps({})
return str_path, str_data
diff --git a/src/device/service/drivers/gnmi_openconfig/handlers/NetworkInstanceProtocol.py b/src/device/service/drivers/gnmi_openconfig/handlers/NetworkInstanceProtocol.py
index f456461929bf80a04b96e2cf8cdda3070d94954c..a54c40b4a3fe9f77db883599880781b1cee19ec7 100644
--- a/src/device/service/drivers/gnmi_openconfig/handlers/NetworkInstanceProtocol.py
+++ b/src/device/service/drivers/gnmi_openconfig/handlers/NetworkInstanceProtocol.py
@@ -38,6 +38,7 @@ class NetworkInstanceProtocolHandler(_Handler):
str_path = PATH_TMPL.format(ni_name, identifier, proto_name)
if delete:
+ str_path = None # nothing to delete
str_data = json.dumps({})
return str_path, str_data
diff --git a/src/device/service/drivers/gnmi_openconfig/handlers/NetworkInstanceStaticRoute.py b/src/device/service/drivers/gnmi_openconfig/handlers/NetworkInstanceStaticRoute.py
index ad1ef8b700e022a3c3b55cbad1847ad989680bb0..3d1c240e37c0d66064b3c66d31ee62dcae7f6106 100644
--- a/src/device/service/drivers/gnmi_openconfig/handlers/NetworkInstanceStaticRoute.py
+++ b/src/device/service/drivers/gnmi_openconfig/handlers/NetworkInstanceStaticRoute.py
@@ -37,9 +37,10 @@ class NetworkInstanceStaticRouteHandler(_Handler):
identifier = 'openconfig-policy-types:{:s}'.format(identifier)
if delete:
- PATH_TMPL = '/network-instances/network-instance[name={:s}]/protocols'
- PATH_TMPL += '/protocol[identifier={:s}][name={:s}]/static-routes/static[prefix={:s}]'
- str_path = PATH_TMPL.format(ni_name, identifier, proto_name, prefix)
+ #PATH_TMPL = '/network-instances/network-instance[name={:s}]/protocols'
+ #PATH_TMPL += '/protocol[identifier={:s}][name={:s}]/static-routes/static[prefix={:s}]'
+ #str_path = PATH_TMPL.format(ni_name, identifier, proto_name, prefix)
+ str_path = None # nothing to delete
str_data = json.dumps({})
return str_path, str_data