Changeset View
Changeset View
Standalone View
Standalone View
test/functional/test_framework/mininode.py
Show First 20 Lines • Show All 237 Lines • ▼ Show 20 Lines | def send_raw_message(self, tmsg): | ||||
This method adds a raw message to the send buffer to be sent over the | This method adds a raw message to the send buffer to be sent over the | ||||
socket.""" | socket.""" | ||||
if not self.is_connected: | if not self.is_connected: | ||||
raise IOError('Not connected') | raise IOError('Not connected') | ||||
def maybe_write(): | def maybe_write(): | ||||
if not self._transport: | if not self._transport: | ||||
return | return | ||||
# Python <3.4.4 does not have is_closing, so we have to check for | if self._transport.is_closing(): | ||||
# its existence explicitly as long as Bitcoin ABC supports all | |||||
# Python 3.4 versions. | |||||
if hasattr(self._transport, 'is_closing') and self._transport.is_closing(): | |||||
return | return | ||||
self._transport.write(tmsg) | self._transport.write(tmsg) | ||||
NetworkThread.network_event_loop.call_soon_threadsafe(maybe_write) | NetworkThread.network_event_loop.call_soon_threadsafe(maybe_write) | ||||
# Class utility methods | # Class utility methods | ||||
def _build_message(self, message): | def _build_message(self, message): | ||||
"""Build a serialized P2P message""" | """Build a serialized P2P message""" | ||||
▲ Show 20 Lines • Show All 376 Lines • Show Last 20 Lines |