tomwer.synctools.datalistener.DataListenerQThread#

class tomwer.synctools.datalistener.DataListenerQThread(host, port, acquisitions)#

Implementation of the _BaseDataListenerThread with a QThread.

As jsonrpc is using gevent we want to limit the ‘crossover’ of gevent and qt. So the server is launch in another process and bot processes are sharing list of acquisitions (added, ended…).

join(timeout=None)#
run(self)#
scan_added(acquisition, scan_number)#
Return type:

None

sequence_ended(acquisition)#

callback when a sequence end (with success)

Return type:

None

sequence_failed(acquisition)#

callback when a sequence fails (probably canceled)

sequence_started(acquisition)#
Return type:

None

sigAcquisitionEnded#

Signal emitted when an acquisition is ended. Tuple is (master_file, master_entry, succeed)

sigAcquisitionStarted#

Signal emitted when an acquisition is started. Tuple is: (master_file, master_entry)

sigScanAdded#

Signal emitted when a scan is added to an acquisition. Tuple is (master_file, master_entry, scan_entry)

sigServerStop#

Signal if the rpc-server have been turn off

start(self, priority: QThread.Priority = QThread.InheritPriority)#
stop()#