commit 34b7dd7cb54caa8d9bded98a38c50658e2635eca
author Rouzbahan Rashidi-Tabrizi <rrashidi@ciena.com> Mon Mar 13 17:45:20 2017 -0400
committer khenaidoo Nursimulu <knursimu@ciena.com> Tue Mar 14 07:35:40 2017 -0700
tree 8ff7540849f2abba865240156e746dcb116a2633
parent c60afa1b4221702ed12f4a04c9f164cf9f6685d1

[3200] fix for stability issue in ofagent connection manager

Change-Id: I8993eaafb7363fa9433c55b4cdec0c93450472d8

ofagent/connection_mgr.py

diff --git a/ofagent/connection_mgr.py b/ofagent/connection_mgr.py
index 9ccf115..11bc0c0 100644
--- a/ofagent/connection_mgr.py
+++ b/ofagent/connection_mgr.py
@@ -24,6 +24,8 @@
 from common.utils.consulhelpers import get_endpoint_from_consul
 from structlog import get_logger
 import grpc
+from grpc import StatusCode
+from grpc._channel import _Rendezvous
 from ofagent.protos import third_party
 from protos import voltha_pb2
 from grpc_client import GrpcClient
@@ -131,6 +133,10 @@
                                                        device.datapath_id))
                 returnValue(devices)
 
+            except _Rendezvous, e:
+                if e.code() == StatusCode.UNAVAILABLE:
+                    os.system("kill -15 {}".format(os.getpid()))
+
             except Exception as e:
                 log.error('Failure to retrieve devices from '
                                'voltha: {}'.format(repr(e)))