RSB
0.19.0
|
Instances of this class publish information about the local host, the current process and its participants for consumption by introspection receivers. More...
#include <IntrospectionSender.h>
Public Member Functions | |
IntrospectionSender (boost::shared_ptr< std::string > processDisplayName, const ParticipantConfig &listenerConfig=getFactory().getDefaultParticipantConfig(), const ParticipantConfig &informerConfig=getFactory().getDefaultParticipantConfig()) | |
void | addParticipant (ParticipantPtr participant, ParticipantPtr parent) |
bool | removeParticipant (const Participant &participant) |
Private Types | |
typedef std::vector< ParticipantInfo > | ParticipantList |
Private Member Functions | |
void | sendHello (const ParticipantInfo &participant, EventPtr query=EventPtr()) |
void | sendBye (const ParticipantInfo &participant) |
Private Attributes | |
rsc::logging::LoggerPtr | logger |
boost::mutex | mutex |
boost::shared_ptr< std::string > | processDisplayName |
ParticipantList | participants |
ProcessInfo | process |
HostInfo | host |
ListenerPtr | listener |
InformerBasePtr | informer |
rsb::patterns::LocalServerPtr | server |
Friends | |
struct | QueryHandler |
Instances of this class publish information about the local host, the current process and its participants for consumption by introspection receivers.
Definition at line 57 of file IntrospectionSender.h.
|
private |
Definition at line 71 of file IntrospectionSender.h.
rsb::introspection::IntrospectionSender::IntrospectionSender | ( | boost::shared_ptr< std::string > | processDisplayName, |
const ParticipantConfig & | listenerConfig = getFactory().getDefaultParticipantConfig() , |
||
const ParticipantConfig & | informerConfig = getFactory().getDefaultParticipantConfig() |
||
) |
Definition at line 133 of file IntrospectionSender.cpp.
References listener, QueryHandler, and server.
void rsb::introspection::IntrospectionSender::addParticipant | ( | ParticipantPtr | participant, |
ParticipantPtr | parent | ||
) |
Definition at line 150 of file IntrospectionSender.cpp.
References logger, mutex, participants, and sendHello().
bool rsb::introspection::IntrospectionSender::removeParticipant | ( | const Participant & | participant | ) |
Definition at line 167 of file IntrospectionSender.cpp.
References rsb::Participant::getId(), logger, mutex, participants, sendBye(), and rsb::introspection::UNIX_EPOCH.
|
private |
Definition at line 268 of file IntrospectionSender.cpp.
References rsb::introspection::ParticipantInfo::getId(), and informer.
Referenced by removeParticipant().
|
private |
Definition at line 196 of file IntrospectionSender.cpp.
References rsb::introspection::ProcessInfo::getArguments(), rsb::introspection::ParticipantInfo::getId(), rsb::introspection::ParticipantInfo::getKind(), rsb::introspection::ParticipantInfo::getParentId(), rsb::introspection::ParticipantInfo::getScope(), rsb::introspection::ParticipantInfo::getTransportURLs(), host, informer, process, processDisplayName, rsb::Scope::toString(), and rsb::introspection::UNIX_EPOCH.
Referenced by addParticipant(), rsb::introspection::QueryHandler::handleRequest(), and rsb::introspection::QueryHandler::handleSurvey().
|
friend |
Definition at line 58 of file IntrospectionSender.h.
Referenced by IntrospectionSender().
|
private |
Definition at line 81 of file IntrospectionSender.h.
Referenced by sendHello().
|
private |
Definition at line 84 of file IntrospectionSender.h.
Referenced by sendBye(), sendHello(), and rsb::introspection::QueryHandler::sendPong().
|
private |
Definition at line 83 of file IntrospectionSender.h.
Referenced by IntrospectionSender().
|
private |
Definition at line 73 of file IntrospectionSender.h.
Referenced by addParticipant(), rsb::introspection::QueryHandler::handle(), and removeParticipant().
|
private |
Definition at line 75 of file IntrospectionSender.h.
Referenced by addParticipant(), rsb::introspection::QueryHandler::handle(), and removeParticipant().
|
private |
Definition at line 79 of file IntrospectionSender.h.
Referenced by addParticipant(), rsb::introspection::QueryHandler::handlePing(), rsb::introspection::QueryHandler::handleRequest(), rsb::introspection::QueryHandler::handleSurvey(), and removeParticipant().
|
private |
Definition at line 80 of file IntrospectionSender.h.
Referenced by sendHello().
|
private |
Definition at line 77 of file IntrospectionSender.h.
Referenced by sendHello().
|
private |
Definition at line 86 of file IntrospectionSender.h.
Referenced by IntrospectionSender().