StdSynchronizer

Standards DART Synchronization object

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