gov::fnal::cd::rms::provider Namespace Reference

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]

Detailed Description

Provider-specific classes and interfaces.

This package contains classes and interfaces for interacting with third-party messaging providers.

Typedef Documentation

typedef std::pair<std::string, std::vector<std::string> > gov::fnal::cd::rms::provider::dds_topic_filter_t

Definition at line 63 of file CETDDS.h.

typedef boost::interprocess::unique_ptr<ProcessSignalHandler, ProcessSignalHandlerDeleter> gov::fnal::cd::rms::provider::ProcessSignalHandler_t

Definition at line 107 of file ProcessSignalHandler.h.

Function Documentation

void gov::fnal::cd::rms::provider::checkHandle	(	void *	handle,
		const char *	info
	)

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.

                       {
     
     if (!handle) {
        cerr << "Error in " << info << ": Creation failed: invalid handle" << endl;
        GENERATE_RMS_RUNTIME_EXCEPTION ("checkHandle failed");
     }
}

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().

                       { 
    

    if (status != DDS::RETCODE_OK && status != DDS::RETCODE_NO_DATA) {
        cerr << "Error in " << info << ": " << getErrorName(status) << endl;
        GENERATE_RMS_RUNTIME_EXCEPTION ("checkStatus failed");
    }
}

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()().

{
    return create_extended_topic_name_for(type_name,topic_name.substr(topic_name.find("_")+1));
}

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()().

{
    std::string extendedTopicName(topic_name);
    extendedTopicName.append( "_" );
    extendedTopicName.append( type_name );
    boost::replace_all( extendedTopicName, "::", "_" );
    return extendedTopicName;
}

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().

{
    filter.first="( header.target = %0 )";
    filter.second.clear();
    std::string topic_name_tmp(topic_name.substr(0,topic_name.rfind("_")));
    
    //restore dashes replaced in DDSConnection::registerSender
    boost::replace_all(topic_name_tmp,"_dash_","-");
    filter.second.push_back(topic_name_tmp);
        
    return filter;
}

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().

{
    std::cout << "++++++++++++++++++++++++++++++++++++++++" << std::endl;
    std::cout << "status=" << status << " topic_seq.length()=" << length << std::endl;

    for ( uint32_t idx = 0; idx < length; ++idx ) {
        std::cout << "sample state = " << infoSeq[idx].sample_state << std::endl;
        std::cout << "view state = " << infoSeq[idx].view_state << std::endl;
        std::cout << "instance state = " << infoSeq[idx].instance_state << std::endl;
        std::cout << "valid data = " << (( int ) infoSeq[idx].valid_data ) << std::endl;
        //std::cout << "source timestamp = " << infoSeq[idx].source_timestamp << std::endl;
        std::cout << "disposed generation count = " << infoSeq[idx].disposed_generation_count << std::endl;
        std::cout << "no writers generation count = " << infoSeq[idx].no_writers_generation_count << std::endl;
        std::cout << "sample rank = " << infoSeq[idx].sample_rank << std::endl;
        std::cout << "generation rank = " << infoSeq[idx].generation_rank << std::endl;
        std::cout << "absolute generation rank = " << infoSeq[idx].absolute_generation_rank << std::endl;
    }

    std::cout << "----------------------------------------" << std::endl;
}

static void gov::fnal::cd::rms::provider::EpicsMessengerCallback ( struct event_handler_args  eventHandlerArgs )

static

Callback function for handling notifications from EPICS. Calls the monitorChanged() method on the messenger object that is interited in the PV that changed.

Parameters

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().

                                                                   {
    EpicsMessenger *messengerObject;
    char *messengerData;

    messengerObject = (EpicsMessenger *)eventHandlerArgs.usr;
    messengerData = (char *)eventHandlerArgs.dbr;
    
    messengerObject->monitorChanged(messengerData);
}

template<typename T >

bool gov::fnal::cd::rms::provider::equal	(	T *	first,
		T *	second
	)

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().

{
    assert( first != NULL );
    assert( second != NULL );

    return first==second;
}

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().

{
    return RetCodeName[status];
}

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().

{
    return !bool_string.empty() && (
               strcasecmp(bool_string.c_str(),"true")==0
               || atoi(bool_string.c_str()) !=0);
}

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().

{
    static boost::mt19937 rand(static_cast<unsigned int>(std::time(0)));
    std::string unique_extended_topic_name(extended_topic_name);
    unique_extended_topic_name.append(boost::lexical_cast<std::string>(rand()));
    return  unique_extended_topic_name;
}

Variable Documentation

const char* gov::fnal::cd::rms::provider::RetCodeName[13]

Initial value:

= { 
    "DDS_RETCODE_OK",
    "DDS_RETCODE_ERROR",
    "DDS_RETCODE_UNSUPPORTED",
    "DDS_RETCODE_BAD_PARAMETER",
    "DDS_RETCODE_PRECONDITION_NOT_MET",
    "DDS_RETCODE_OUT_OF_RESOURCES",
    "DDS_RETCODE_NOT_ENABLED",
    "DDS_RETCODE_IMMUTABLE_POLICY",
    "DDS_RETCODE_INCONSISTENT_POLICY",
    "DDS_RETCODE_ALREADY_DELETED",
    "DDS_RETCODE_TIMEOUT",
    "DDS_RETCODE_NO_DATA",
    "DDS_RETCODE_ILLEGAL_OPERATION" }

Definition at line 38 of file CheckStatus.cpp.