Provider-specific classes and interfaces. More...
Classes | |
class | BufferedProviderListener |
class | DDSConnection |
class | DDSTopicReaderClass |
class | DDSTopicWriterClass |
class | DPSingleton |
class | EpicsConnection |
class | EpicsMessenger |
class | LocalhostConnection |
class | MessageAssembler |
class | MessageFragment |
class | MessageSplitter |
class | ProcessSignalHandler |
class | ProcessSignalHandlerDeleter |
class | ProviderListener |
class | RmsConnection |
class | RmsConnectionFactory |
class | SignalInhibitor |
Typedefs | |
typedef std::pair< std::string, std::vector< std::string > > | dds_topic_filter_t |
typedef boost::interprocess::unique_ptr< ProcessSignalHandler, ProcessSignalHandlerDeleter > | ProcessSignalHandler_t |
Functions | |
std::string | create_extended_topic_name_for (std::string const &type_name, std::string const &topic_name) |
std::string | create_content_filtered_topic_name_for (std::string const &type_name, std::string const &topic_name) |
dds_topic_filter_t & | create_topic_filter_for (dds_topic_filter_t &filter, std::string const &type_name, std::string const &topic_name) |
std::string | unique_topic_name_for (std::string const &extended_topic_name) |
bool | string2bool (std::string const &bool_string) |
void | dumpReceivedSamples (dds::SampleInfoSeq const &infoSeq, const unsigned int length, const int status) |
const char * | getErrorName (DDS::ReturnCode_t status) |
void | checkStatus (DDS::ReturnCode_t status, const char *info) |
void | checkHandle (void *handle, const char *info) |
static void | EpicsMessengerCallback (struct event_handler_args eventHandlerArgs) |
template<typename T > | |
bool | equal (T *first, T *second) |
Variables | |
const char * | RetCodeName [13] |
Provider-specific classes and interfaces.
This package contains classes and interfaces for interacting with third-party messaging providers.
typedef std::pair<std::string, std::vector<std::string> > gov::fnal::cd::rms::provider::dds_topic_filter_t |
typedef boost::interprocess::unique_ptr<ProcessSignalHandler, ProcessSignalHandlerDeleter> gov::fnal::cd::rms::provider::ProcessSignalHandler_t |
Definition at line 107 of file ProcessSignalHandler.h.
Check whether a valid handle has been returned. If not, then terminate.
Check whether a valid handle has been returned. If not, then throw a runtime exception.
Definition at line 78 of file CheckStatus.cpp.
References om::cerr, allTimeWatchdog::endl, and GENERATE_RMS_RUNTIME_EXCEPTION.
void gov::fnal::cd::rms::provider::checkStatus | ( | DDS::ReturnCode_t | status, |
const char * | info | ||
) |
Check the return status for errors. If there is an error, then terminate.
Check the return status for errors. If there is an error, then throw a runtime exception.
Definition at line 64 of file CheckStatus.cpp.
References om::cerr, allTimeWatchdog::endl, GENERATE_RMS_RUNTIME_EXCEPTION, and getErrorName().
Referenced by gov::fnal::cd::rms::provider::DPSingleton::connect_participant(), gov::fnal::cd::rms::provider::DDSTopicReaderClass< TT_ >::receiveMessage(), and gov::fnal::cd::rms::provider::DDSTopicWriterClass< TT_ >::write().
std::string gov::fnal::cd::rms::provider::create_content_filtered_topic_name_for | ( | std::string const & | type_name, |
std::string const & | topic_name | ||
) |
Definition at line 33 of file CETDDS.cpp.
References create_extended_topic_name_for().
Referenced by gov::fnal::cd::rms::provider::DDSTopicWriterClass< TT_ >::init(), gov::fnal::cd::rms::provider::DDSTopicReaderClass< TT_ >::init(), and gov::fnal::cd::rms::Deleter< D >::operator()().
std::string gov::fnal::cd::rms::provider::create_extended_topic_name_for | ( | std::string const & | type_name, |
std::string const & | topic_name | ||
) |
Definition at line 24 of file CETDDS.cpp.
References cet::replace_all(), and string.
Referenced by create_content_filtered_topic_name_for(), gov::fnal::cd::rms::provider::DDSTopicWriterClass< TT_ >::init(), gov::fnal::cd::rms::provider::DDSTopicReaderClass< TT_ >::init(), and gov::fnal::cd::rms::Deleter< D >::operator()().
dds_topic_filter_t & gov::fnal::cd::rms::provider::create_topic_filter_for | ( | dds_topic_filter_t & | filter, |
std::string const & | type_name, | ||
std::string const & | topic_name | ||
) |
Definition at line 39 of file CETDDS.cpp.
References cet::replace_all(), and string.
Referenced by gov::fnal::cd::rms::provider::DDSTopicReaderClass< TT_ >::init().
void gov::fnal::cd::rms::provider::dumpReceivedSamples | ( | dds::SampleInfoSeq const & | infoSeq, |
const unsigned int | length, | ||
const int | status | ||
) |
Definition at line 68 of file CETDDS.cpp.
References om::cout, allTimeWatchdog::endl, compare_h5_caf::idx, makeTrainCVSamples::int, and demo0::length.
Referenced by gov::fnal::cd::rms::provider::DDSTopicReaderClass< TT_ >::receiveMessage().
|
static |
Callback function for handling notifications from EPICS. Calls the monitorChanged() method on the messenger object that is interited in the PV that changed.
eventHandlerArgs | Parameters from EPICS |
Definition at line 21 of file EpicsMessenger.cpp.
References gov::fnal::cd::rms::provider::EpicsMessenger::monitorChanged().
Referenced by gov::fnal::cd::rms::provider::EpicsMessenger::addListener().
Definition at line 60 of file ProcessSignalHandler.cpp.
References ana::assert(), and moon_position_table_new3::second.
Referenced by genie::ELFormFactors::Compare(), genie::QELFormFactors::Compare(), genie::DISStructureFunc::Compare(), genie::InitialState::Compare(), genie::Target::Compare(), ana::LikelihoodCovMxExperiment::LikelihoodCovMxNewton(), stan::io::stan_csv_reader::read_metadata(), and slid::ParticleIDAlg::SetShower().
const char * gov::fnal::cd::rms::provider::getErrorName | ( | DDS::ReturnCode_t | status | ) |
Returns the name of an error code.
Definition at line 56 of file CheckStatus.cpp.
References fabricate::status.
Referenced by checkStatus().
bool gov::fnal::cd::rms::provider::string2bool | ( | std::string const & | bool_string | ) |
Definition at line 61 of file CETDDS.cpp.
Referenced by gov::fnal::cd::rms::provider::DDSTopicWriterClass< TT_ >::init(), and gov::fnal::cd::rms::provider::DDSTopicReaderClass< TT_ >::init().
std::string gov::fnal::cd::rms::provider::unique_topic_name_for | ( | std::string const & | extended_topic_name | ) |
Definition at line 53 of file CETDDS.cpp.
References central_limit::rand, and string.
Referenced by gov::fnal::cd::rms::provider::DDSTopicReaderClass< TT_ >::init().
const char* gov::fnal::cd::rms::provider::RetCodeName[13] |
Definition at line 38 of file CheckStatus.cpp.