Skip to content

Commit

Permalink
removed blocking test for HTTP server to make action complete
Browse files Browse the repository at this point in the history
  • Loading branch information
VigneshVSV committed Jul 20, 2024
1 parent 106ce72 commit f448461
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions tests/test_rpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ def setUpClass(self):
instance_name='test-rpc',
log_level=logging.WARN,
protocols=['IPC', 'TCP'],
tcp_socket_address='tcp://*:60000',
tcp_socket_address='tcp://*:58000',
http_server=True
)
self.thing_client = ObjectProxy('test-rpc') # type: TestThing
Expand Down Expand Up @@ -67,7 +67,7 @@ def test_5_http_client(self):
def test_6_tcp_client(self):
# Also, for sake, a TCP client
done_queue = multiprocessing.Queue()
start_client(done_queue, tcp_socket_address='tcp://localhost:60000')
start_client(done_queue, tcp_socket_address='tcp://localhost:58000')
self.assertEqual(done_queue.get(), True)


Expand All @@ -93,10 +93,10 @@ def test_7_multiple_clients(self):
start_client(done_queue_6, 'http')

done_queue_7 = multiprocessing.Queue()
start_client(done_queue_7, typ='threading', tcp_socket_address='tcp://localhost:60000')
start_client(done_queue_7, typ='threading', tcp_socket_address='tcp://localhost:58000')

done_queue_8 = multiprocessing.Queue()
start_client(done_queue_8, tcp_socket_address='tcp://localhost:60000')
start_client(done_queue_8, tcp_socket_address='tcp://localhost:58000')

self.assertEqual(done_queue_1.get(), True)
self.assertEqual(done_queue_2.get(), True)
Expand Down
File renamed without changes.

0 comments on commit f448461

Please sign in to comment.