b.s.r.SmartServerRepositoryInsertStreamLocked(SmartServerRepositoryRequest) : class documentation

Part of bzrlib.smart.repository View In Hierarchy

Known subclasses: bzrlib.smart.repository.SmartServerRepositoryInsertStream, bzrlib.smart.repository.SmartServerRepositoryInsertStream_1_19

Insert a record stream from a RemoteSink into a repository.

This gets bytes pushed to it by the network infrastructure and turns that into a bytes iterator using a thread. That is then processed by _byte_stream_to_stream.

New in 1.14.

Method do_repository_request StreamSink.insert_stream for a remote repository.
Method do_insert_stream_request Undocumented
Method do_chunk Called with each body chunk if the request has a streamed body.
Method blocking_byte_stream Undocumented
Method do_end Called when the end of the request has been received.
Method _inserter_thread Undocumented

Inherited from SmartServerRepositoryRequest:

Method do Execute a repository request.
Method recreate_search Recreate a search from its serialised form.
Method recreate_search_from_recipe Recreate a specific revision search (vs a from-tip search).

Inherited from SmartServerRequest (via SmartServerRepositoryRequest):

Method __init__ Constructor.
Method execute Public entry point to execute this request.
Method do_body Called if the client sends a body with the request.
Method setup_jail Undocumented
Method teardown_jail Undocumented
Method translate_client_path Translate a path received from a network client into a local
Method transport_from_client_path Get a backing transport corresponding to the location referred to by
Method _check_enabled Raises DisabledMethod if this method is disabled.
def do_repository_request(self, repository, resume_tokens, lock_token):
StreamSink.insert_stream for a remote repository.
def do_insert_stream_request(self, repository, resume_tokens):
Undocumented
def do_chunk(self, body_stream_chunk):
Called with each body chunk if the request has a streamed body.

The do() method is still called, and must have returned None.

def _inserter_thread(self):
Undocumented
def blocking_byte_stream(self):
Undocumented
def do_end(self):
Called when the end of the request has been received.
API Documentation for Bazaar, generated by pydoctor at 2022-06-16 00:25:16.