tahoe-lafs/tahoe-lafs
tahoe-lafs
/
tahoe-lafs
2
0
Fork 0
Code Issues Pull Requests 23 Packages Projects Releases 1 Wiki Activity

exarkun wants a helper

This commit is contained in:
meejah 2022-12-01 17:05:58 -07:00
parent 36ed554627
commit 20b3594d12
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/allmydata/test/test_runner.py
View File

@ -630,6 +630,15 @@ class RunNode(common_util.SignalMixin, unittest.TestCase, pollmixin.PollMixin):
yield client_running
def _simulate_windows_stdin_close(stdio):
"""
on Unix we can just close all the readers, correctly "simulating"
a stdin close .. of course, Windows has to be difficult
"""
stdio.writeConnectionLost()
stdio.readConnectionLost()
class OnStdinCloseTests(SyncTestCase):
"""
Tests for on_stdin_close
@ -647,12 +656,8 @@ class OnStdinCloseTests(SyncTestCase):
transport = on_stdin_close(reactor, onclose)
self.assertEqual(called, [])
# on Unix we can just close all the readers, correctly
# "simulating" a stdin close .. of course, Windows has to be
# difficult
if platform.isWindows():
transport.writeConnectionLost()
transport.readConnectionLost()
_simulate_windows_stdin_close(transport)
else:
for reader in reactor.getReaders():
reader.loseConnection()
@ -674,8 +679,7 @@ class OnStdinCloseTests(SyncTestCase):
self.assertEqual(called, [])
if platform.isWindows():
transport.writeConnectionLost()
transport.readConnectionLost()
_simulate_windows_stdin_close(transport)
else:
for reader in reactor.getReaders():
reader.loseConnection()