Skip to content
Snippets Groups Projects
Commit 5d22a1d8 authored by Corné Lukken's avatar Corné Lukken
Browse files

L2SS-340: Clean up for event loop

parent 5241984a
No related branches found
No related tags found
1 merge request!117create TCPReplicator for StatisticsClient
...@@ -140,8 +140,8 @@ class TCPReplicator(Thread, StatisticsClientThread): ...@@ -140,8 +140,8 @@ class TCPReplicator(Thread, StatisticsClientThread):
# Create the event loop, must be done in the new thread # Create the event loop, must be done in the new thread
self._loop = asyncio.new_event_loop() self._loop = asyncio.new_event_loop()
# TODO(Corne): REMOVE ME # When wanting to debug event loop behavior, uncomment this
self._loop.set_debug(True) # self._loop.set_debug(True)
# Schedule the task to create the server # Schedule the task to create the server
self._loop.create_task(TCPReplicator._run_server( self._loop.create_task(TCPReplicator._run_server(
......
...@@ -16,8 +16,6 @@ from clients.tcp_replicator import TCPReplicator ...@@ -16,8 +16,6 @@ from clients.tcp_replicator import TCPReplicator
from integration_test import base from integration_test import base
import timeout_decorator
logger = logging.getLogger() logger = logging.getLogger()
...@@ -36,9 +34,6 @@ class TestTCPReplicator(base.IntegrationTestCase): ...@@ -36,9 +34,6 @@ class TestTCPReplicator(base.IntegrationTestCase):
replicator = TCPReplicator(test_options) replicator = TCPReplicator(test_options)
def test_start_except(self):
def test_start_transmit_empty_stop(self): def test_start_transmit_empty_stop(self):
"""Test transmitting without clients""" """Test transmitting without clients"""
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment