aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authormarcoagner <marco@agner.io>2018-07-19 12:14:05 +0100
committermarcoagner <marco@agner.io>2018-07-19 12:24:31 +0100
commitea5340c9d24b5b59b178c06e7cb25495a282fdd0 (patch)
tree6992387bfefd974d599c335679d184c2ad4a812e
parent4a3e8c5aa6a5d8dda15a76d644b2a9f0f40cdec7 (diff)
tests: fixes mininode's P2PConnection sending messages on closing transport
- checks if _transport.is_closing() (added in python3.4.4/python3.5.1) before attempting to send messages on P2PConnection's send_message method.
-rwxr-xr-xtest/functional/test_framework/mininode.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/test/functional/test_framework/mininode.py b/test/functional/test_framework/mininode.py
index 29bf33fa5b..d5b1a90687 100755
--- a/test/functional/test_framework/mininode.py
+++ b/test/functional/test_framework/mininode.py
@@ -179,7 +179,7 @@ class P2PConnection(asyncio.Protocol):
raise IOError('Not connected')
self._log_message("send", message)
tmsg = self._build_message(message)
- NetworkThread.network_event_loop.call_soon_threadsafe(lambda: self._transport and self._transport.write(tmsg))
+ NetworkThread.network_event_loop.call_soon_threadsafe(lambda: self._transport and not self._transport.is_closing() and self._transport.write(tmsg))
# Class utility methods