From 5d22a1d8d0b859e4eecefb21d2f56e0660d45f50 Mon Sep 17 00:00:00 2001
From: lukken <lukken@astron.nl>
Date: Tue, 21 Sep 2021 11:09:03 +0000
Subject: [PATCH] L2SS-340: Clean up for event loop
---
devices/clients/tcp_replicator.py | 4 ++--
devices/integration_test/client/test_tcp_replicator.py | 5 -----
2 files changed, 2 insertions(+), 7 deletions(-)
diff --git a/devices/clients/tcp_replicator.py b/devices/clients/tcp_replicator.py
index ce3ba0d3b..b9738ee26 100644
--- a/devices/clients/tcp_replicator.py
+++ b/devices/clients/tcp_replicator.py
@@ -140,8 +140,8 @@ class TCPReplicator(Thread, StatisticsClientThread):
# Create the event loop, must be done in the new thread
self._loop = asyncio.new_event_loop()
- # TODO(Corne): REMOVE ME
- self._loop.set_debug(True)
+ # When wanting to debug event loop behavior, uncomment this
+ # self._loop.set_debug(True)
# Schedule the task to create the server
self._loop.create_task(TCPReplicator._run_server(
diff --git a/devices/integration_test/client/test_tcp_replicator.py b/devices/integration_test/client/test_tcp_replicator.py
index 2bac9356a..440aa43f5 100644
--- a/devices/integration_test/client/test_tcp_replicator.py
+++ b/devices/integration_test/client/test_tcp_replicator.py
@@ -16,8 +16,6 @@ from clients.tcp_replicator import TCPReplicator
from integration_test import base
-import timeout_decorator
-
logger = logging.getLogger()
@@ -36,9 +34,6 @@ class TestTCPReplicator(base.IntegrationTestCase):
replicator = TCPReplicator(test_options)
- def test_start_except(self):
-
-
def test_start_transmit_empty_stop(self):
"""Test transmitting without clients"""
--
GitLab