Package conduit :: Module Synchronization :: Class SyncManager

Class SyncManager

source code

Given a dictionary of relationships this class synchronizes the relevant sinks and sources. If there is a conflict then this is handled by the conflictResolver

Instance Methods

[hide private]

__init__(self, typeConverter)
Constructor.

source code

_cancel_sync_thread(self, cond)

source code

_on_sync_completed(self, cond, abort, error, conflict, worker)

source code

_start_worker_thread(self, cond, worker)

source code

is_busy(self)
Returns true if any conduit is currently undergoing a sync

source code

sync_in_progress(self, cond)
Returns true if cond is currently undergoing sync, refresh etc

source code

cancel_all(self)
Cancels all threads and also joins() them.

source code

join_one(self, cond, timeout=None)
Blocks until the thread associated with the supplied conduit finishes

source code

join_all(self, timeout=None)
Joins all threads.

source code

run_blocking_dataprovider_function_calls(self, dataprovider, callback, *functions)

source code

refresh_dataprovider(self, cond, dataproviderWrapper)

source code

refresh_conduit(self, cond)

source code

sync_conduit(self, cond)

source code

did_sync_abort(self, cond)
Returns True if the supplied conduit aborted (the sync did not complete due to an unhandled exception, a SynchronizeFatalError or the conduit was unsyncable (source did not refresh, etc)

source code

did_sync_error(self, cond)
Returns True if the supplied conduit raised a non fatal SynchronizeError during sync

source code

did_sync_conflict(self, cond)
Returns True if the supplied conduit encountered a conflict during processing

source code

Method Details

[hide private]