Class Interface#

Defined in File thermal_interface.h

Nested Relationships#

Nested Types#

Struct Interface::thermal_info_t

Class Documentation#

class Interface#

interface class for a thermal device

This class defines the interface for each temperature controller and contains the functions used to communicate with it.

Public Functions

inline Interface()#

inline long init_pubsub(const std::initializer_list<std::string> &topics = {})#

inline void start_subscriber_thread()#

inline void stop_subscriber_thread()#

void handletopic_snapshot(const nlohmann::json &jmessage)#: respond to a snapshot request

void handletopic_acamd(const nlohmann::json &jmessage)#: stash acam CCD temperature into externaldata

void handletopic_slicecamd(const nlohmann::json &jmessage)#: stash slicecam CCD temperatures into externaldata

void publish_status()#: publish thermalinfo on Topic::THERMALD

void request_snapshot()#: ask subscribed daemons to publish their status

void process_external_data(const nlohmann::json &jmessage)#

apply DB-bound JSON keys from a pub/sub message to externaldata

Iterates DbColumnDefs::ExternalDataColumns; for each entry whose jkey appears in the message with a non-null value, stores the value into externaldata under the bound column name.

Parameters:: jmessage – [in] json message received via pub/sub

long reconnect(std::string args, std::string &retstring)#: close,open all hardware devices

long open_campbell()#: Campbell functions

long close_campbell()#

long open_lakeshores()#: Lakeshore functions

long close_lakeshores()#

long parse_unit_chan(std::string args, int &unit, std::string &chan)#

long lakeshore_readall()#: read all Lakeshores into memory

long get(std::string args, std::string &retstring)#: read specified channel from specified LKS unit

long print_labels(std::string args, std::string &retstring)#: print lakeshore channel labels

long show_telemdata(std::string args, std::string &retstring)#

long native(std::string cmd, std::string &retstring)#: send Lakeshore-native command to specified unit

long setpoint(std::string args, std::string &retstring)#: set or get setpoint for specified output

Public Members

std::unique_ptr<Common::PubSub> publisher#: publisher object

std::string publisher_address#: publish socket endpoint

std::string publisher_topic#: my default topic for publishing

std::unique_ptr<Common::PubSub> subscriber#: subscriber object

std::string subscriber_address#: subscribe socket endpoint

std::vector<std::string> subscriber_topics#: list of topics I subscribe to

std::atomic<bool> is_subscriber_thread_running#: is my subscriber thread running?

std::atomic<bool> should_subscriber_thread_run#: should my subscriber thread run?

std::unordered_map<std::string, std::function<void(const nlohmann::json&)>> topic_handlers#: maps a handler function to each topic

Common::Queue async#

std::map<int, Thermal::Lakeshore> lakeshore#: STL map of all Lakeshores indexed by LKS#.

Thermal::Campbell campbell#: Campbell object for datalogger.

std::mutex lakeshoredata_mtx#

std::mutex telemdata_mtx#

std::mutex externaldata_mtx#

std::map<std::string, mysqlx::Value> lakeshoredata#: map of Lakeshore readings indexed by label

std::map<std::string, mysqlx::Value> campbelldata#: map of Campbell readings indexed by label

std::map<std::string, mysqlx::Value> telemdata#: map of all readings (merge lakeshore+campbell)

std::map<std::string, mysqlx::Value> externaldata#: map of telemetry received from other daemons

std::map<std::string, thermal_info_t> thermal_info#: thermal info database, indexed by channel label

struct thermal_info_t#

Public Members

std::string device#: device type e.g. LKS, CAMP, etc.

int unit#: user-assigned unit number

std::string name#: user-assigned name

std::string chan#: channel number e.g. A, B, C1, H1, 1, etc.

std::string label#: channel label (must be unique for indexing by label)