fergalmoran/picard
1
0
Fork 0
mirror of https://github.com/fergalmoran/picard.git synced 2026-01-06 08:34:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make pipe tests more robust on error

Browse Source
This commit is contained in:
Philipp Wolfer
2023-08-15 14:25:34 +02:00
parent c2639c4d29
commit df81f4e48a
1 changed files with 12 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
test/test_util_pipe.py
View File

@@ -62,18 +62,19 @@ class TestPipe(PicardTestCase):
for message in to_send:
__pool = concurrent.futures.ThreadPoolExecutor()
pipe_handler = pipe.Pipe(self.NAME, self.VERSION)
plistener = __pool.submit(pipe_listener, pipe_handler)
res = ""
# handle the write/read processes
try:
pipe_handler.send_to_pipe(message)
res = plistener.result(timeout=6)
except concurrent.futures._base.TimeoutError:
pass
plistener = __pool.submit(pipe_listener, pipe_handler)
res = ""
# handle the write/read processes
try:
pipe_handler.send_to_pipe(message)
res = plistener.result(timeout=6)
except concurrent.futures._base.TimeoutError:
pass
self.assertEqual(res, message,
"Data is sent and read correctly")
finally:
pipe_handler.stop()
__pool.shutdown()
self.assertEqual(res, message,
"Data is sent and read correctly")