StdSynchronizer

Standards DART Synchronization object

@safe abstract

class StdSynchronizer : Synchronizer {

DART.SynchronizationFiber fiber;

uint chunck_size;

bool _finished;

bool _timeout;

this(uint chunck_size);

void removeRecursive(Rims selected_rims);

void finish();

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

void timeout();

bool empty();

bool timeout();

}

Constructors

this this(uint chunck_size): Undocumented in source.

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
timeout bool timeout(): Undocumented in source. Be warned that the author may not have intended to support it.

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
chunck_size uint chunck_size;: Max number of archives operates in one recorder action
fiber DART.SynchronizationFiber fiber;: Contains the reference to SynchronizationFiber
hirpc HiRPC hirpc;: Undocumented in source.
owner DART owner;: Undocumented in source.

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

Meta

Source

See Implementation

tagion dart synchronizer aliases

classes

interfaces

Synchronizer