DARTSynchronizer

branches DARTFile.Branches branches(const(ubyte[]) rim_path, Index* branch_index): Wrapper: Loads the branches from the DART at rim_path
load Document load(const(DARTFile.Branches) b, uint key): Wrapper: Reads the data at branch key
query const(HiRPC.Receiver) query(const(HiRPC.Sender) request): Query the remote DART for a response to a request.
record void record(RecordFactory.Recorder recorder): Update and adds the recorder to the journal and store it
recorder RecordFactory.Recorder recorder(): Wrapper: Creates a recorder factor
recorder RecordFactory.Recorder recorder(const(Document) doc): Wrapper: Creates a recorder factor from a document
updateJournalFile void updateJournalFile(File newJournalFile): Update the journal file for this synchronizer.

Inherited Members

fiber DARTSynchronizationFiber fiber;: Contains the reference to a dedicated DARTSynchronizationFiber
fiber DART.SynchronizationFiber fiber;: Contains the reference to SynchronizationFiber
chunk_size uint chunk_size;: Max number of archives operates in one recorder action
_finished bool _finished;: Finish flag set when the Fiber function returns
_timeout bool _timeout;: Set via the timeout method to indicate and network timeout
removeRecursive void removeRecursive(Rims selected_rims): Remove all archive at selected rim path
finish void finish(): Should be called when the synchronization has finished
set void set(DART owner, DARTSynchronizationFiber fiber, HiRPC hirpc)
timeout void timeout(): Should be call on timeout timeout
finished bool finished(): Checks if synchronization has ended