ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2025-04-27 14:30:19 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

proto -> transport

Browse Source
This commit is contained in:
meejah 2022-12-01 17:03:48 -07:00
parent 3d43cbccc9
commit 36ed554627
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -644,15 +644,15 @@ class OnStdinCloseTests(SyncTestCase):
def onclose(): def onclose():
called.append(True) called.append(True)
proto = on_stdin_close(reactor, onclose) transport = on_stdin_close(reactor, onclose)
self.assertEqual(called, []) self.assertEqual(called, [])
# on Unix we can just close all the readers, correctly # on Unix we can just close all the readers, correctly
# "simulating" a stdin close .. of course, Windows has to be # "simulating" a stdin close .. of course, Windows has to be
# difficult # difficult
if platform.isWindows(): if platform.isWindows():
proto.writeConnectionLost() transport.writeConnectionLost()
proto.readConnectionLost() transport.readConnectionLost()
else: else:
for reader in reactor.getReaders(): for reader in reactor.getReaders():
reader.loseConnection() reader.loseConnection()
@ -670,12 +670,12 @@ class OnStdinCloseTests(SyncTestCase):
def onclose(): def onclose():
called.append(True) called.append(True)
raise RuntimeError("unexpected error") raise RuntimeError("unexpected error")
proto = on_stdin_close(reactor, onclose) transport = on_stdin_close(reactor, onclose)
self.assertEqual(called, []) self.assertEqual(called, [])
if platform.isWindows(): if platform.isWindows():
proto.writeConnectionLost() transport.writeConnectionLost()
proto.readConnectionLost() transport.readConnectionLost()
else: else:
for reader in reactor.getReaders(): for reader in reactor.getReaders():
reader.loseConnection() reader.loseConnection()