MCPcopy Create free account
hub / github.com/OpenDDS/OpenDDS / add_reader

Method add_reader

dds/DCPS/ContentFilteredTopicImpl.cpp:123–131  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

121}
122
123void
124ContentFilteredTopicImpl::add_reader(DataReaderImpl& reader)
125{
126 // readers_ does not own or reference-count the reader because
127 // the readers reference this CFT and this CFT can't be removed
128 // until all readers are gone (DomainParticipant::delete_contentfilteredtopic)
129 ACE_GUARD(ACE_Recursive_Thread_Mutex, guard, lock_);
130 readers_.push_back(reader);
131}
132
133void
134ContentFilteredTopicImpl::remove_reader(DataReaderImpl& reader)

Callers 3

enable_filteringMethod · 0.45
connectMethod · 0.45
TESTFunction · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected