bzrlib.smart.medium.SmartServerPipeStreamMedium : API documentation

Method	__init__	Construct new server.
Method	serve	See SmartServerStreamMedium.serve
Method	terminate_due_to_error	Called when an unhandled exception from the protocol occurs.
Method	_serve_one_request_unguarded	Undocumented
Method	_disconnect_client	Close the current connection. We stopped due to a timeout/etc.
Method	_wait_for_bytes_with_timeout	Wait for more bytes to be read, but timeout if none available.
Method	_read_bytes	Get some bytes from the medium.
Method	_write_out	Undocumented

Inherited from SmartServerStreamMedium:

Method	_stop_gracefully	When we finish this message, stop looking for more.
Method	_build_protocol	Identifies the version of the incoming request, and returns an
Method	_wait_on_descriptor	select() on a file descriptor, waiting for nonblocking read()
Method	_serve_one_request	Read one request from input, process, send back a response.

Inherited from SmartMedium (via SmartServerStreamMedium):

Method	read_bytes	Read some bytes from this medium.
Method	_push_back	Return unused bytes to the medium, because they belong to the next
Method	_get_push_back_buffer	Undocumented
Method	_get_line	Read bytes from this request's response until a newline byte.
Method	_report_activity	Notify that this medium has activity.

def __init__(self, in_file, out_file, backing_transport, timeout=None):

overrides bzrlib.smart.medium.SmartServerStreamMedium.__init__

Construct new server.

Parameters	in_file	Python file from which requests can be read.
	out_file	Python file to write responses.
	backing_transport	Transport for the directory served.

def _wait_for_bytes_with_timeout(self, timeout_seconds):

overrides bzrlib.smart.medium.SmartServerStreamMedium._wait_for_bytes_with_timeout

Wait for more bytes to be read, but timeout if none available.

This allows us to detect idle connections, and stop trying to read from them, without setting the socket itself to non-blocking. This also allows us to specify when we watch for idle timeouts.

Returns None, this will raise ConnectionTimeout if we time out before data is available.

b.s.m.SmartServerPipeStreamMedium(SmartServerStreamMedium) : class documentation