tomwer.core.process.control.datalistener.datalistener.DataListener

class tomwer.core.process.control.datalistener.datalistener.DataListener

class able to connect with a redis database. During an acquisition at esrf the redis database expose the scan under acquisition. This allow use to know when a scan is finished.

In order to insure connection the machine need to know where is located the ‘bacon server’ (see https://bliss.gitlab-pages.esrf.fr/bliss/master/bliss_data_life.html). This is why the ‘BEACON_HOST’ environment variable should be defined.

For example for id19 - lbs 191 we have: export BEACON_HOST=”europa” On id19 - europa we would have export BEACON_HOST=”localhost”

SWMR_MODE = None

The bliss writer is not using the swmr mode. This class has independant behavior regarding the tomoscan / nxotmo get_swmr_mode which is dedicated to the internal tomotools behavior

TIMOUT_READ_FILE = 30

When the event ‘scan_ended’ is received all data might not have been write yet

activate(activate=True)

activate or deactivate the thread. When deactivate call join and delete the thread

Parameters:

activate (bool) –

convert(bliss_file, entry)

Parameters:

• bliss_file (str) – file to be converted

• entry (str) – entry in the tango .h5 file to be converter

Return type:

tuple

Returns:

tuple (output file, output file entry). Both are set to None if conversion fails.

create_listening_thread()

Procedure to create the listening thread :return: listening thread

static definition()

definition of the process

delete_listening_thread()

Procedure to delete the listening thread

get_listening_thread()

return the listening thread to ear at tango server

static get_master_sample_file(process_file, entry)

Return the proposal file of the experimentation if registred by the data listener

static get_proposal_file(process_file, entry)

Return the proposal file of the experimentation if registred by the data listener

static get_sample_file(process_file, entry)

Return the proposal file of the experimentation if registred by the data listener

static get_source_scans(process_file, entry)

Return the list of ‘bliss scan directory’ created for holding this specific sequence data

property host

is_active()

is_port_available()

Returns:

True if the port is available else False

property port

process_sample_file(sample_file, entry, proposal_file, master_sample_file)

Parameters:

• sample_file (str) – file to be converted

• entry (str) – entry in the tango .h5 file to be converter

Return type:

tuple

Returns:

tuple scan succeeded.

static program_name()

Name of the program used for this processing

static program_version()

version of the program used for this processing

run()

set_configuration(properties)