Skip to content

Commit 67e6631

Browse files
committed
Fix shutdown paths exposed by the test.
1 parent 54cbba6 commit 67e6631

1 file changed

Lines changed: 4 additions & 3 deletions

File tree

‎python/TCPProxy.py‎

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -200,6 +200,7 @@ def spawn_forwarder(self, newsock):
200200
forwarders.append(fwd)
201201
else:
202202
self.dprint(lambda: f'joinning forwarder: {fwd.describe()}')
203+
fwd.shutdown()
203204
fwd.join()
204205
self.dprint(lambda: f'joinning forwarder done: {fwd.describe()}')
205206
self.forwarders = forwarders
@@ -209,8 +210,8 @@ def shutdown(self):
209210
while len(self.forwarders) > 0:
210211
forwarder = self.forwarders.pop()
211212
self.dprint(lambda: f'shutting down forwarder: {forwarder.describe()}')
212-
if forwarder.isAlive():
213-
forwarder.shutdown()
213+
forwarder.shutdown()
214214
forwarder.join()
215215
self.sock.close()
216-
self.join()
216+
if self.ident is not None:
217+
self.join()

0 commit comments

Comments
 (0)