Skip to content
Snippets Groups Projects
Commit 786a54f3 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Device component:

- Added logs to identify issue
parent 9d2f3119
No related branches found
No related tags found
2 merge requests!235Release TeraFlowSDN 3.0,!216Resolve "Automate end-to-end tests and integrate them in CI/CD pipeline"
...@@ -88,10 +88,17 @@ class DeviceServiceServicerImpl(DeviceServiceServicer): ...@@ -88,10 +88,17 @@ class DeviceServiceServicerImpl(DeviceServiceServicer):
# update device_uuid to honor UUID provided by Context # update device_uuid to honor UUID provided by Context
device_uuid = device.device_id.device_uuid.uuid device_uuid = device.device_id.device_uuid.uuid
device_name = device.name
t2 = time.time() t2 = time.time()
LOGGER.warning('[AddDevice] before add_alias {:s} {:s}'.format(str(device_uuid), str(device_name)))
self.mutex_queues.add_alias(device_uuid, device_name)
LOGGER.warning('[AddDevice] after add_alias {:s} {:s}'.format(str(device_uuid), str(device_name)))
LOGGER.warning('[AddDevice] before wait_my_turn {:s}'.format(str(device_uuid)))
self.mutex_queues.wait_my_turn(device_uuid) self.mutex_queues.wait_my_turn(device_uuid)
LOGGER.warning('[AddDevice] after wait_my_turn {:s}'.format(str(device_uuid)))
t3 = time.time() t3 = time.time()
try: try:
driver : _Driver = get_driver(self.driver_instance_cache, device) driver : _Driver = get_driver(self.driver_instance_cache, device)
...@@ -202,7 +209,9 @@ class DeviceServiceServicerImpl(DeviceServiceServicer): ...@@ -202,7 +209,9 @@ class DeviceServiceServicerImpl(DeviceServiceServicer):
return device_id return device_id
finally: finally:
LOGGER.warning('[AddDevice] before signal_done {:s}'.format(str(device_uuid)))
self.mutex_queues.signal_done(device_uuid) self.mutex_queues.signal_done(device_uuid)
LOGGER.warning('[AddDevice] after signal_done {:s}'.format(str(device_uuid)))
@safe_and_metered_rpc_method(METRICS_POOL, LOGGER) @safe_and_metered_rpc_method(METRICS_POOL, LOGGER)
def ConfigureDevice(self, request : Device, context : grpc.ServicerContext) -> DeviceId: def ConfigureDevice(self, request : Device, context : grpc.ServicerContext) -> DeviceId:
...@@ -210,7 +219,9 @@ class DeviceServiceServicerImpl(DeviceServiceServicer): ...@@ -210,7 +219,9 @@ class DeviceServiceServicerImpl(DeviceServiceServicer):
device_id = request.device_id device_id = request.device_id
device_uuid = device_id.device_uuid.uuid device_uuid = device_id.device_uuid.uuid
LOGGER.warning('[ConfigureDevice] before wait_my_turn {:s}'.format(str(device_uuid)))
self.mutex_queues.wait_my_turn(device_uuid) self.mutex_queues.wait_my_turn(device_uuid)
LOGGER.warning('[ConfigureDevice] after wait_my_turn {:s}'.format(str(device_uuid)))
t1 = time.time() t1 = time.time()
try: try:
context_client = ContextClient() context_client = ContextClient()
...@@ -294,13 +305,17 @@ class DeviceServiceServicerImpl(DeviceServiceServicer): ...@@ -294,13 +305,17 @@ class DeviceServiceServicerImpl(DeviceServiceServicer):
return device_id return device_id
finally: finally:
LOGGER.warning('[ConfigureDevice] before signal_done {:s}'.format(str(device_uuid)))
self.mutex_queues.signal_done(device_uuid) self.mutex_queues.signal_done(device_uuid)
LOGGER.warning('[ConfigureDevice] after signal_done {:s}'.format(str(device_uuid)))
@safe_and_metered_rpc_method(METRICS_POOL, LOGGER) @safe_and_metered_rpc_method(METRICS_POOL, LOGGER)
def DeleteDevice(self, request : DeviceId, context : grpc.ServicerContext) -> Empty: def DeleteDevice(self, request : DeviceId, context : grpc.ServicerContext) -> Empty:
device_uuid = request.device_uuid.uuid device_uuid = request.device_uuid.uuid
LOGGER.warning('[DeleteDevice] before wait_my_turn {:s}'.format(str(device_uuid)))
self.mutex_queues.wait_my_turn(device_uuid) self.mutex_queues.wait_my_turn(device_uuid)
LOGGER.warning('[DeleteDevice] after wait_my_turn {:s}'.format(str(device_uuid)))
try: try:
context_client = ContextClient() context_client = ContextClient()
device = get_device( device = get_device(
...@@ -315,13 +330,17 @@ class DeviceServiceServicerImpl(DeviceServiceServicer): ...@@ -315,13 +330,17 @@ class DeviceServiceServicerImpl(DeviceServiceServicer):
context_client.RemoveDevice(request) context_client.RemoveDevice(request)
return Empty() return Empty()
finally: finally:
LOGGER.warning('[DeleteDevice] before signal_done {:s}'.format(str(device_uuid)))
self.mutex_queues.signal_done(device_uuid) self.mutex_queues.signal_done(device_uuid)
LOGGER.warning('[DeleteDevice] after signal_done {:s}'.format(str(device_uuid)))
@safe_and_metered_rpc_method(METRICS_POOL, LOGGER) @safe_and_metered_rpc_method(METRICS_POOL, LOGGER)
def GetInitialConfig(self, request : DeviceId, context : grpc.ServicerContext) -> DeviceConfig: def GetInitialConfig(self, request : DeviceId, context : grpc.ServicerContext) -> DeviceConfig:
device_uuid = request.device_uuid.uuid device_uuid = request.device_uuid.uuid
LOGGER.warning('[GetInitialConfig] before wait_my_turn {:s}'.format(str(device_uuid)))
self.mutex_queues.wait_my_turn(device_uuid) self.mutex_queues.wait_my_turn(device_uuid)
LOGGER.warning('[GetInitialConfig] after wait_my_turn {:s}'.format(str(device_uuid)))
try: try:
context_client = ContextClient() context_client = ContextClient()
device = get_device( device = get_device(
...@@ -344,7 +363,9 @@ class DeviceServiceServicerImpl(DeviceServiceServicer): ...@@ -344,7 +363,9 @@ class DeviceServiceServicerImpl(DeviceServiceServicer):
return device_config return device_config
finally: finally:
LOGGER.warning('[GetInitialConfig] before signal_done {:s}'.format(str(device_uuid)))
self.mutex_queues.signal_done(device_uuid) self.mutex_queues.signal_done(device_uuid)
LOGGER.warning('[GetInitialConfig] after signal_done {:s}'.format(str(device_uuid)))
@safe_and_metered_rpc_method(METRICS_POOL, LOGGER) @safe_and_metered_rpc_method(METRICS_POOL, LOGGER)
def MonitorDeviceKpi(self, request : MonitoringSettings, context : grpc.ServicerContext) -> Empty: def MonitorDeviceKpi(self, request : MonitoringSettings, context : grpc.ServicerContext) -> Empty:
...@@ -362,7 +383,9 @@ class DeviceServiceServicerImpl(DeviceServiceServicer): ...@@ -362,7 +383,9 @@ class DeviceServiceServicerImpl(DeviceServiceServicer):
raise OperationFailedException('MonitorDeviceKpi', extra_details=msg) raise OperationFailedException('MonitorDeviceKpi', extra_details=msg)
device_uuid = kpi_details[0] device_uuid = kpi_details[0]
LOGGER.warning('[MonitorDeviceKpi] before wait_my_turn {:s}'.format(str(device_uuid)))
self.mutex_queues.wait_my_turn(device_uuid) self.mutex_queues.wait_my_turn(device_uuid)
LOGGER.warning('[MonitorDeviceKpi] after wait_my_turn {:s}'.format(str(device_uuid)))
try: try:
context_client = ContextClient() context_client = ContextClient()
device = get_device( device = get_device(
...@@ -381,4 +404,6 @@ class DeviceServiceServicerImpl(DeviceServiceServicer): ...@@ -381,4 +404,6 @@ class DeviceServiceServicerImpl(DeviceServiceServicer):
return Empty() return Empty()
finally: finally:
LOGGER.warning('[MonitorDeviceKpi] before signal_done {:s}'.format(str(device_uuid)))
self.mutex_queues.signal_done(device_uuid) self.mutex_queues.signal_done(device_uuid)
LOGGER.warning('[MonitorDeviceKpi] after signal_done {:s}'.format(str(device_uuid)))
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment