StdSynchronizer

Standards DART Synchronization object

@safe abstract

class StdSynchronizer : Synchronizer {

DART.SynchronizationFiber fiber;

uint chunk_size;

bool _finished;

bool _timeout;

protected

DART owner;

protected

HiRPC hirpc;

void removeRecursive(Rims selected_rims);

void finish();

void set(DART owner, DART.SynchronizationFiber fiber, HiRPC hirpc);

void timeout();

bool empty();

}

Members

Functions

empty bool empty(): Checks if synchronization has ended
finish void finish(): Should be called when the synchronization has finished
removeRecursive void removeRecursive(Rims selected_rims): Remove all archive at selected rim path
set void set(DART owner, DART.SynchronizationFiber fiber, HiRPC hirpc)
timeout void timeout(): Should be call on timeout timeout

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 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, DART.SynchronizationFiber fiber, HiRPC hirpc): Called in by the SynchronizationFiber constructor which enable the query function to yield the run function in SynchronizationFiber
empty bool empty(): Checks if the syncronizer is empty

tagion dart synchronizer classes

interfaces

Synchronizer