Service_Participant.h File Reference

#include "Definitions.h"
#include "MonitorFactory.h"
#include "Discovery.h"
#include "PoolAllocator.h"
#include "DomainParticipantFactoryImpl.h"
#include "ConfigUtils.h"
#include "unique_ptr.h"
#include "ReactorTask.h"
#include "JobQueue.h"
#include "NetworkConfigMonitor.h"
#include "NetworkConfigModifier.h"
#include "Recorder.h"
#include "Replayer.h"
#include "TimeSource.h"
#include "AtomicBool.h"
#include <dds/DdsDcpsInfrastructureC.h>
#include <dds/DdsDcpsDomainC.h>
#include <dds/DdsDcpsInfoUtilsC.h>
#include <ace/Task.h>
#include <ace/Time_Value.h>
#include <ace/ARGV.h>
#include <ace/Barrier.h>
#include <memory>

Include dependency graph for Service_Participant.h:

Go to the source code of this file.

Classes
class	OpenDDS::DCPS::ShutdownListener
class	OpenDDS::DCPS::Service_Participant
	Service entrypoint. More...
struct	OpenDDS::DCPS::Service_Participant::DomainRange
struct	OpenDDS::DCPS::Service_Participant::DiscoveryInfo

Namespaces
	OpenDDS
	The Internal API and Implementation of OpenDDS.
	OpenDDS::DCPS

Macros
#define	TheServiceParticipant   OpenDDS::DCPS::Service_Participant::instance()
#define	TheParticipantFactory   TheServiceParticipant->get_domain_participant_factory()
#define	TheParticipantFactoryWithArgs(argc, argv)   TheServiceParticipant->get_domain_participant_factory(argc, argv)

Variables
const char	OpenDDS::DCPS::DEFAULT_ORB_NAME [] = "OpenDDS_DCPS"

Macro Definition Documentation

TheParticipantFactory

#define TheParticipantFactory   TheServiceParticipant->get_domain_participant_factory()

Definition at line 794 of file Service_Participant.h.

Referenced by OpenDDS::Federator::ManagerImpl::finalize(), OpenDDS::DCPS::DomainParticipantFactoryImpl::get_instance(), DCPS_IR_Domain::init_built_in_topics(), OpenDDS::Federator::ManagerImpl::initialize(), FACE::TS::Receive_Message(), and OpenDDS::DCPS::SPMonitorImpl::report().

TheParticipantFactoryWithArgs

#define TheParticipantFactoryWithArgs	(		argc,
			argv
	)		TheServiceParticipant->get_domain_participant_factory(argc, argv)

Definition at line 796 of file Service_Participant.h.

Referenced by InfoRepo::init().

TheServiceParticipant

#define TheServiceParticipant   OpenDDS::DCPS::Service_Participant::instance()

Definition at line 792 of file Service_Participant.h.

Referenced by OpenDDS::DCPS::ReplayerImpl::add_association(), OpenDDS::DCPS::DataWriterImpl::add_association(), TAO_DDS_DCPSInfo_i::add_domain_participant(), OpenDDS::ICE::AgentImpl::add_endpoint(), OpenDDS::DCPS::TypeSupportImpl::add_types(), OpenDDS::ICE::AgentImpl::AgentImpl(), OpenDDS::DCPS::DomainParticipantImpl::await_handle(), OpenDDS::DCPS::TransportRegistry::bind_config(), OpenDDS::DCPS::InfoRepoDiscovery::bit_config(), OpenDDS::DCPS::BitSubscriber::bit_pub_listener_hack(), OpenDDS::DCPS::WriterInfo::check_end_historic_samples(), OpenDDS::DCPS::RecorderImpl::cleanup(), OpenDDS::DCPS::ReplayerImpl::cleanup(), OpenDDS::RTPS::Sedp::cleanup_reader_association(), OpenDDS::RTPS::Sedp::cleanup_writer_association(), OpenDDS::DCPS::ThreadPerConnectionSendTask::close(), OpenDDS::DCPS::QueueTaskBase< DataLink_rch >::close(), OpenDDS::RTPS::Spdp::SpdpTransport::close(), OpenDDS::DCPS::DataReaderImpl::coherent_changes_completed(), OpenDDS::DCPS::UdpTransport::configure_i(), OpenDDS::DCPS::MulticastTransport::configure_i(), OpenDDS::DCPS::RtpsUdpTransport::configure_i(), OpenDDS::DCPS::TcpTransport::configure_i(), OpenDDS::DCPS::TransportRegistry::create_new_transport_instance_for_participant(), OpenDDS::DCPS::DomainParticipantFactoryImpl::create_participant(), OpenDDS::DCPS::TransportImpl::create_reactor_task(), OpenDDS::DCPS::DomainParticipantImpl::create_recorder(), OpenDDS::DCPS::DomainParticipantImpl::create_replayer(), OpenDDS::DCPS::DataReaderImpl::DataReaderImpl(), OpenDDS::DCPS::DataWriterImpl::DataWriterImpl(), OpenDDS::DCPS::DataReaderImpl::deadline_task(), OpenDDS::Security::SecurityRegistry::default_config(), OpenDDS::DCPS::MonitorFactoryImpl::deinitialize(), OpenDDS::DCPS::PublisherImpl::delete_contained_entities(), OpenDDS::DCPS::DomainParticipantImpl::delete_contained_entities(), OpenDDS::DCPS::SubscriberImpl::delete_datareader(), OpenDDS::DCPS::PublisherImpl::delete_datawriter(), OpenDDS::DCPS::DomainParticipantFactoryImpl::delete_participant(), OpenDDS::DCPS::DomainParticipantImpl::delete_topic_i(), OpenDDS::DCPS::InfoRepoDiscovery::Config::discovery_config(), OpenDDS::RTPS::RtpsDiscovery::Config::discovery_config(), TAO_DDS_DCPSInfo_i::domain(), OpenDDS::DCPS::DomainParticipantImpl::DomainParticipantImpl(), OpenDDS::DCPS::TopicImpl::enable(), OpenDDS::DCPS::RecorderImpl::enable(), OpenDDS::DCPS::ReplayerImpl::enable(), OpenDDS::DCPS::DataWriterImpl::enable(), OpenDDS::DCPS::DomainParticipantImpl::enable(), OpenDDS::DCPS::DataReaderImpl::enable(), OpenDDS::RTPS::Spdp::SpdpTransport::enable_periodic_tasks(), OpenDDS::DCPS::NetworkInterfaceAddress::exclude_from_multicast(), OpenDDS::DCPS::DataReaderImpl_T< DynamicSample >::filter_delayed(), InfoRepo::finalize(), OpenDDS::DCPS::DomainParticipantImpl::find_topic(), OpenDDS::DCPS::DataReaderImpl_T< DynamicSample >::finish_store_instance_data(), OpenDDS::RTPS::ParameterListConverter::from_param_list(), OpenDDS::DCPS::InfoRepoDiscovery::get_dcps_info(), OpenDDS::DCPS::DomainParticipantImpl::get_dynamic_type(), OpenDDS::DCPS::DataReaderImpl::get_guid(), OpenDDS::DCPS::TcpConnection::handle_close(), OpenDDS::DCPS::DataLink::handle_close(), OpenDDS::DCPS::ScheduleOutputHandler::handle_exception(), InfoRepo::handle_exception(), OpenDDS::DCPS::ReactorInterceptor::handle_exception(), OpenDDS::DCPS::JobQueue::handle_exception(), OpenDDS::DCPS::DataLink::handle_exception(), OpenDDS::DCPS::DomainParticipantImpl::handle_exception(), OpenDDS::DCPS::MulticastReceiveStrategy::handle_input(), OpenDDS::DCPS::UdpReceiveStrategy::handle_input(), OpenDDS::DCPS::TcpConnection::handle_input(), OpenDDS::DCPS::RtpsUdpTransport::IceEndpoint::handle_input(), OpenDDS::RTPS::Spdp::SpdpTransport::handle_input(), OpenDDS::DCPS::TcpConnection::handle_output(), OpenDDS::DCPS::MultiTask::handle_timeout(), OpenDDS::DCPS::PeriodicTask::handle_timeout(), OpenDDS::DCPS::TcpConnection::handle_timeout(), OpenDDS::DCPS::InstanceState::handle_timeout(), OpenDDS::ICE::AgentImpl::handle_timeout(), OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::handle_timeout(), OpenDDS::DCPS::SporadicTask::handle_timeout(), OpenDDS::DCPS::DataLink::handle_timeout(), OpenDDS::DCPS::TransportClient::PendingAssoc::handle_timeout(), OpenDDS::DCPS::DataWriterImpl::handle_timeout(), OpenDDS::DCPS::LivenessTimer::handle_timeout(), OpenDDS::DCPS::DataReaderImpl::LivelinessTimer::handle_timeout(), OpenDDS::DCPS::DomainParticipantImpl::ignore_participant(), OpenDDS::DCPS::DomainParticipantImpl::ignore_publication(), OpenDDS::DCPS::DomainParticipantImpl::ignore_subscription(), OpenDDS::DCPS::DomainParticipantImpl::ignore_topic(), InfoRepo::init(), OpenDDS::DCPS::DataWriterImpl::init(), OpenDDS::DCPS::DataDurabilityCache::init(), OpenDDS::DCPS::InfoRepoDiscovery::init_bit(), OpenDDS::RTPS::RtpsDiscovery::init_bit(), OpenDDS::DCPS::StaticDiscovery::init_bit(), DCPS_IR_Domain::init_built_in_topics_datawriters(), OpenDDS::RTPS::Sedp::init_security(), OpenDDS::DCPS::MonitorFactoryImpl::initialize(), FACE::TS::Initialize(), OpenDDS::DCPS::instance_handle_to_bit_data(), OpenDDS::Federator::ManagerImpl::join_federation(), OpenDDS::DCPS::RtpsUdpInst::load(), OpenDDS::Security::AccessControlBuiltInImpl::make_task(), OpenDDS::DCPS::Marked_Default_Qos::marked_default_DataReader_Use_TopicQos(), OpenDDS::DCPS::Marked_Default_Qos::marked_default_DataReaderQos(), OpenDDS::DCPS::Marked_Default_Qos::marked_default_DataWriter_Use_TopicQos(), OpenDDS::DCPS::Marked_Default_Qos::marked_default_DataWriterQos(), OpenDDS::DCPS::Marked_Default_Qos::marked_default_DomainParticipantQos(), OpenDDS::DCPS::Marked_Default_Qos::marked_default_PublisherQos(), OpenDDS::DCPS::Marked_Default_Qos::marked_default_SubscriberQos(), OpenDDS::DCPS::Marked_Default_Qos::marked_default_TopicQos(), OpenDDS::DCPS::StaticEndpointManager::match_continue(), OpenDDS::RTPS::Sedp::match_continue(), OpenDDS::DCPS::SubscriberImpl::notify_datareaders(), OpenDDS::DCPS::WriteDataContainer::obtain_buffer(), OpenDDS::DCPS::FailoverListener::on_subscription_disconnected(), OpenDDS::DCPS::FailoverListener::on_subscription_lost(), OpenDDS::DCPS::DefaultNetworkConfigMonitor::open(), OpenDDS::DCPS::ThreadPerConnectionSendTask::open(), OpenDDS::DCPS::RtpsUdpDataLink::open(), OpenDDS::RTPS::Spdp::SpdpTransport::open(), OpenDDS::FaceTSS::config::Parser::parse(), OpenDDS::DCPS::StaticDiscovery::parse_datareaderqos(), OpenDDS::DCPS::StaticDiscovery::parse_datawriterqos(), OpenDDS::DCPS::StaticDiscovery::parse_endpoints(), OpenDDS::DCPS::StaticDiscovery::parse_publisherqos(), OpenDDS::DCPS::StaticDiscovery::parse_subscriberqos(), OpenDDS::DCPS::RtpsSampleHeader::populate_inline_qos(), OpenDDS::DCPS::PublisherImpl::PublisherImpl(), OpenDDS::ICE::AgentImpl::reactor_is_shut_down(), OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::reactor_is_shut_down(), OpenDDS::DCPS::InstanceState::reactor_is_shut_down(), OpenDDS::DCPS::TransportClient::PendingAssocTimer::reactor_is_shut_down(), OpenDDS::DCPS::DataReaderImpl::LivelinessTimer::reactor_is_shut_down(), TAO_DDS_DCPSInfo_i::receive_image(), FACE::TS::Receive_Message(), TAO_DDS_DCPSInfo_i::remove_domain_participant(), OpenDDS::ICE::AgentImpl::remove_endpoint(), OpenDDS::Federator::ManagerImpl::repository(), OpenDDS::DCPS::TransportSendListener::retrieve_inline_qos_data(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsUdpDataLink(), OpenDDS::DCPS::DispatchService::run_event_loop(), OpenDDS::DCPS::DataWriterImpl::send_liveliness(), OpenDDS::DCPS::TopicImpl::set_qos(), OpenDDS::DCPS::PublisherImpl::set_qos(), OpenDDS::DCPS::SubscriberImpl::set_qos(), OpenDDS::DCPS::ReplayerImpl::set_qos(), OpenDDS::DCPS::RecorderImpl::set_qos(), OpenDDS::DCPS::DataWriterImpl::set_qos(), OpenDDS::DCPS::DomainParticipantImpl::set_qos(), OpenDDS::DCPS::DataReaderImpl::set_qos(), OpenDDS::DCPS::DispatchService::shutdown(), OpenDDS::RTPS::Spdp::shutdown(), OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner::shutdown(), OpenDDS::DCPS::ShmemTransport::shutdown_i(), OpenDDS::DCPS::DomainParticipantImpl::signal_liveliness(), OpenDDS::DCPS::TransportSendStrategy::start(), OpenDDS::DCPS::StaticEndpointManager::StaticEndpointManager(), OpenDDS::DCPS::InfoRepoDiscovery::StaticInitializer::StaticInitializer(), OpenDDS::RTPS::RtpsDiscovery::StaticInitializer::StaticInitializer(), OpenDDS::DCPS::ShmemTransport::ReadTask::stop(), OpenDDS::DCPS::RtpsUdpDataLink::stop_i(), OpenDDS::DCPS::SubscriberImpl::SubscriberImpl(), OpenDDS::DCPS::DcpsUpcalls::svc(), OpenDDS::DCPS::PerConnectionSynch::svc(), OpenDDS::DCPS::ThreadPerConnectionSendTask::svc(), OpenDDS::DCPS::ShmemTransport::ReadTask::svc(), OpenDDS::DCPS::QueueTaskBase< DataLink_rch >::svc(), OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner::svc(), TAO_DDS_DCPSInfo_i::TAO_DDS_DCPSInfo_i(), OpenDDS::DCPS::DirectPriorityMapper::thread_priority(), OpenDDS::RTPS::Spdp::SpdpTransport::thread_status_task(), OpenDDS::DCPS::TypeSupportImpl::to_type_info_i(), OpenDDS::DCPS::TopicImpl::TopicImpl(), OpenDDS::DCPS::DataWriterImpl::transport_discovery_change(), OpenDDS::DCPS::DataReaderImpl::transport_discovery_change(), OpenDDS::DCPS::TransportImpl::TransportImpl(), OpenDDS::DCPS::TransportSendStrategy::TransportSendStrategy(), OpenDDS::RTPS::Sedp::type_lookup_init(), OpenDDS::DCPS::StaticEndpointManager::type_lookup_init(), OpenDDS::DCPS::PerConnectionSynch::unregister_worker_i(), OpenDDS::DCPS::DataWriterImpl::update_subscription_params(), OpenDDS::DCPS::DataReaderImpl::update_subscription_params(), OpenDDS::DCPS::TypeObjReqCond::wait(), DDS::WaitSet::wait(), OpenDDS::DCPS::WriteDataContainer::wait_ack_of_seq(), OpenDDS::DCPS::ReactorTask::wait_for_startup_i(), OpenDDS::DCPS::MessageTracker::wait_messages_pending(), OpenDDS::DCPS::WriteDataContainer::wait_pending(), OpenDDS::DCPS::DataWriterImpl::write_w_timestamp(), and OpenDDS::DCPS::DcpsUpcalls::writer_done().