From 61bfa554892399b8302a25259482f020821597fb Mon Sep 17 00:00:00 2001 From: gifrerenom Date: Fri, 12 May 2023 15:16:53 +0000 Subject: [PATCH] All Microservices: - Updated wait loop time --- src/compute/service/__main__.py | 2 +- src/context/service/__main__.py | 2 +- src/device/service/__main__.py | 2 +- src/dlt/connector/service/__main__.py | 2 +- src/dlt/mock_blockchain/service/__main__.py | 2 +- src/interdomain/service/__main__.py | 2 +- src/l3_attackmitigator/service/__main__.py | 2 +- src/l3_centralizedattackdetector/service/__main__.py | 2 +- src/load_generator/service/__main__.py | 2 +- src/monitoring/service/__main__.py | 2 +- src/pathcomp/frontend/service/__main__.py | 2 +- src/service/service/__main__.py | 2 +- src/slice/service/__main__.py | 2 +- 13 files changed, 13 insertions(+), 13 deletions(-) diff --git a/src/compute/service/__main__.py b/src/compute/service/__main__.py index 19a04c4c8..6c744d0dc 100644 --- a/src/compute/service/__main__.py +++ b/src/compute/service/__main__.py @@ -65,7 +65,7 @@ def main(): rest_server.start() # Wait for Ctrl+C or termination signal - while not terminate.wait(timeout=0.1): pass + while not terminate.wait(timeout=1.0): pass LOGGER.info('Terminating...') grpc_service.stop() diff --git a/src/context/service/__main__.py b/src/context/service/__main__.py index 92d4c8827..8b39c0ded 100644 --- a/src/context/service/__main__.py +++ b/src/context/service/__main__.py @@ -57,7 +57,7 @@ def main(): grpc_service.start() # Wait for Ctrl+C or termination signal - while not terminate.wait(timeout=0.1): pass + while not terminate.wait(timeout=1.0): pass LOGGER.info('Terminating...') grpc_service.stop() diff --git a/src/device/service/__main__.py b/src/device/service/__main__.py index 35b548fe9..a07a2ab90 100644 --- a/src/device/service/__main__.py +++ b/src/device/service/__main__.py @@ -66,7 +66,7 @@ def main(): grpc_service.start() # Wait for Ctrl+C or termination signal - while not terminate.wait(timeout=0.1): pass + while not terminate.wait(timeout=1.0): pass LOGGER.info('Terminating...') grpc_service.stop() diff --git a/src/dlt/connector/service/__main__.py b/src/dlt/connector/service/__main__.py index c9812f90a..9d73ca9fc 100644 --- a/src/dlt/connector/service/__main__.py +++ b/src/dlt/connector/service/__main__.py @@ -58,7 +58,7 @@ def main(): grpc_service.start() # Wait for Ctrl+C or termination signal - while not terminate.wait(timeout=0.1): pass + while not terminate.wait(timeout=1.0): pass LOGGER.info('Terminating...') grpc_service.stop() diff --git a/src/dlt/mock_blockchain/service/__main__.py b/src/dlt/mock_blockchain/service/__main__.py index e4cffac51..65a80ed51 100644 --- a/src/dlt/mock_blockchain/service/__main__.py +++ b/src/dlt/mock_blockchain/service/__main__.py @@ -49,7 +49,7 @@ def main(): grpc_service.start() # Wait for Ctrl+C or termination signal - while not terminate.wait(timeout=0.1): pass + while not terminate.wait(timeout=1.0): pass LOGGER.info('Terminating...') grpc_service.stop() diff --git a/src/interdomain/service/__main__.py b/src/interdomain/service/__main__.py index f4bdbb7b8..73fa93539 100644 --- a/src/interdomain/service/__main__.py +++ b/src/interdomain/service/__main__.py @@ -72,7 +72,7 @@ def main(): #remote_domain_clients.add_peer('remote-teraflow', 'remote-teraflow', interdomain_service_port_grpc) # Wait for Ctrl+C or termination signal - while not terminate.wait(timeout=0.1): pass + while not terminate.wait(timeout=1.0): pass LOGGER.info('Terminating...') topology_abstractor.stop() diff --git a/src/l3_attackmitigator/service/__main__.py b/src/l3_attackmitigator/service/__main__.py index 1e91d5e97..aadccbdab 100644 --- a/src/l3_attackmitigator/service/__main__.py +++ b/src/l3_attackmitigator/service/__main__.py @@ -52,7 +52,7 @@ def main(): grpc_service.start() # Wait for Ctrl+C or termination signal - while not terminate.wait(timeout=0.1): pass + while not terminate.wait(timeout=1.0): pass logger.info('Terminating...') grpc_service.stop() diff --git a/src/l3_centralizedattackdetector/service/__main__.py b/src/l3_centralizedattackdetector/service/__main__.py index 340812724..5b8873afd 100644 --- a/src/l3_centralizedattackdetector/service/__main__.py +++ b/src/l3_centralizedattackdetector/service/__main__.py @@ -53,7 +53,7 @@ def main(): grpc_service.start() # Wait for Ctrl+C or termination signal - while not terminate.wait(timeout=0.1): pass + while not terminate.wait(timeout=1.0): pass logger.info('Terminating...') grpc_service.stop() diff --git a/src/load_generator/service/__main__.py b/src/load_generator/service/__main__.py index 7051a9a18..5f5fa97f9 100644 --- a/src/load_generator/service/__main__.py +++ b/src/load_generator/service/__main__.py @@ -53,7 +53,7 @@ def main(): grpc_service.start() # Wait for Ctrl+C or termination signal - while not terminate.wait(timeout=0.1): pass + while not terminate.wait(timeout=1.0): pass scheduler = grpc_service.load_generator_servicer._scheduler if scheduler is not None: scheduler.stop() diff --git a/src/monitoring/service/__main__.py b/src/monitoring/service/__main__.py index 14f560960..d0a132c70 100644 --- a/src/monitoring/service/__main__.py +++ b/src/monitoring/service/__main__.py @@ -91,7 +91,7 @@ def main(): start_monitoring(name_mapping) # Wait for Ctrl+C or termination signal - while not terminate.wait(timeout=0.1): pass + while not terminate.wait(timeout=1.0): pass LOGGER.info('Terminating...') grpc_service.stop() diff --git a/src/pathcomp/frontend/service/__main__.py b/src/pathcomp/frontend/service/__main__.py index e3f7d3619..00da64775 100644 --- a/src/pathcomp/frontend/service/__main__.py +++ b/src/pathcomp/frontend/service/__main__.py @@ -53,7 +53,7 @@ def main(): grpc_service.start() # Wait for Ctrl+C or termination signal - while not terminate.wait(timeout=0.1): pass + while not terminate.wait(timeout=1.0): pass LOGGER.info('Terminating...') grpc_service.stop() diff --git a/src/service/service/__main__.py b/src/service/service/__main__.py index d755348ad..f2b6e38d6 100644 --- a/src/service/service/__main__.py +++ b/src/service/service/__main__.py @@ -62,7 +62,7 @@ def main(): grpc_service.start() # Wait for Ctrl+C or termination signal - while not terminate.wait(timeout=0.1): pass + while not terminate.wait(timeout=1.0): pass LOGGER.info('Terminating...') grpc_service.stop() diff --git a/src/slice/service/__main__.py b/src/slice/service/__main__.py index aef1c4b82..4d581530a 100644 --- a/src/slice/service/__main__.py +++ b/src/slice/service/__main__.py @@ -55,7 +55,7 @@ def main(): grpc_service.start() # Wait for Ctrl+C or termination signal - while not terminate.wait(timeout=0.1): pass + while not terminate.wait(timeout=1.0): pass LOGGER.info('Terminating...') grpc_service.stop() -- GitLab