JournalSynchronizer

Undocumented in source.

@safe

class JournalSynchronizer : StdSynchronizer {

BlockFile journalfile;

void record(RecordFactory.Recorder recorder);

void finish();

}

Members

Functions

finish void finish(): Should be called when the synchronization has finished
record void record(RecordFactory.Recorder recorder): Update and adds the recorder to the journal and store it

Variables

index Index index;: Current block index
journalfile BlockFile journalfile;: The actives is stored in this journal file. Which later can be run via the replay function

Inherited Members

From StdSynchronizer

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, DART.SynchronizationFiber fiber, HiRPC hirpc)
timeout void timeout(): Should be call on timeout timeout
empty bool empty(): Checks if synchronization has ended

tagion dart synchronizer classes

interfaces

Synchronizer