DARTRemoteSynchronizer

Remote DART synchronizer.

@safe

class DARTRemoteSynchronizer : Synchronizer {

version(DEDICATED_DART_SYNC_FIBER)

DARTSynchronizationFiber fiber;

version(!DEDICATED_DART_SYNC_FIBER)

DART.SynchronizationFiber fiber;

bool _finished;

bool _timeout;

protected

Pubkey addr_pub_key;

protected

File journalfile;

uint chunk_size;

immutable(TaskNames) task_names;

ActorHandle dart_handle;

const

HiRPC _hirpc;

const

SecureNet net;

const(HiRPC.Receiver) query(const(HiRPC.Sender) request);

void updateJournalFile(File newJournalFile);

void record(RecordFactory.Recorder recorder);

bool finished();

void removeRecursive(Rims selected_rims);

DARTFile.Branches branches(immutable(ubyte[]) rim_path, Index* branch_index);

RecordFactory.Recorder recorder();

RecordFactory.Recorder recorder(const(Document) doc);

Document load(const(DARTFile.Branches) b, uint key);

}

Members

Functions

branches DARTFile.Branches branches(immutable(ubyte[]) rim_path, Index* branch_index): Wrapper: Loads the branches from the DART at rim_path
finished bool finished(): Checks if synchronization has ended
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
removeRecursive void removeRecursive(Rims selected_rims): Remove all archive at selected rim path
updateJournalFile void updateJournalFile(File newJournalFile): Update the journal file for this synchronizer.

Variables

_finished bool _finished;: Finish flag set when the Fiber function returns
_timeout bool _timeout;: Set via the timeout method to indicate and network timeout
chunk_size uint chunk_size;: Max number of archives operates in one recorder action
fiber DARTSynchronizationFiber fiber;: Contains the reference to a dedicated DARTSynchronizationFiber
fiber DART.SynchronizationFiber fiber;: Contains the reference to SynchronizationFiber

Inherited Members

From Synchronizer

query const(HiRPC.Receiver) query(const(HiRPC.Sender) request): Recommend to put a yield the SynchronizationFiber between send and receive between the DART's
record void record(RecordFactory.Recorder recorder): Stores the add and remove actions in the journal replay log file
removeRecursive void removeRecursive(Rims rims): This function is called when whole branches doesn't exist in the foreign DART and need to be removed in the local DART
finish void finish(): This function is called when the SynchronizationFiber run-function finishes
set void set(DART owner, DARTSynchronizationFiber fiber, HiRPC hirpc): Called in by the SynchronizationFiber constructor which enable the query function to yield the run function in SynchronizationFiber
set void set(DARTSynchronizationFiber fiber): Called in by the SynchronizationFiber constructor which enable the query function to yield the run function in SynchronizationFiber
finished bool finished(): Checks if the synchronizer is empty

tagion dart DARTRemoteSynchronizer classes

DARTRemoteSynchronizer