#include <ContentFilteredTopicImpl.h>
Inheritance diagram for OpenDDS::DCPS::ContentFilteredTopicImpl:


Public Member Functions | |
| ContentFilteredTopicImpl (const char *name, DDS::Topic_ptr related_topic, const char *filter_expression, const DDS::StringSeq &expression_parameters, DomainParticipantImpl *participant) | |
| virtual | ~ContentFilteredTopicImpl () |
| char * | get_filter_expression () throw (CORBA::SystemException) |
| DDS::ReturnCode_t | get_expression_parameters (DDS::StringSeq ¶meters) throw (CORBA::SystemException) |
| DDS::ReturnCode_t | set_expression_parameters (const DDS::StringSeq ¶meters) throw (CORBA::SystemException) |
| DDS::Topic_ptr | get_related_topic () throw (CORBA::SystemException) |
| template<typename Sample> | |
| bool | filter (const Sample &s) const |
| void | add_reader (DataReaderImpl &reader) |
| void | remove_reader (DataReaderImpl &reader) |
Private Attributes | |
| std::string | filter_expression_ |
| FilterEvaluator | filter_eval_ |
| DDS::StringSeq | expression_parameters_ |
| DDS::Topic_var | related_topic_ |
| std::vector< DataReaderImpl * > | readers_ |
| ACE_Recursive_Thread_Mutex | lock_ |
| concurrent access to expression_parameters_ and readers_ | |
| OpenDDS::DCPS::ContentFilteredTopicImpl::ContentFilteredTopicImpl | ( | const char * | name, | |
| DDS::Topic_ptr | related_topic, | |||
| const char * | filter_expression, | |||
| const DDS::StringSeq & | expression_parameters, | |||
| DomainParticipantImpl * | participant | |||
| ) |
| virtual OpenDDS::DCPS::ContentFilteredTopicImpl::~ContentFilteredTopicImpl | ( | ) | [inline, virtual] |
| void OpenDDS::DCPS::ContentFilteredTopicImpl::add_reader | ( | DataReaderImpl & | reader | ) |
| bool OpenDDS::DCPS::ContentFilteredTopicImpl::filter | ( | const Sample & | s | ) | const [inline] |
| DDS::ReturnCode_t OpenDDS::DCPS::ContentFilteredTopicImpl::get_expression_parameters | ( | DDS::StringSeq & | parameters | ) | throw (CORBA::SystemException) |
| char * OpenDDS::DCPS::ContentFilteredTopicImpl::get_filter_expression | ( | ) | throw (CORBA::SystemException) |
Implements DDS::ContentFilteredTopic.
| DDS::Topic_ptr OpenDDS::DCPS::ContentFilteredTopicImpl::get_related_topic | ( | ) | throw (CORBA::SystemException) |
Implements DDS::ContentFilteredTopic.
| void OpenDDS::DCPS::ContentFilteredTopicImpl::remove_reader | ( | DataReaderImpl & | reader | ) |
| DDS::ReturnCode_t OpenDDS::DCPS::ContentFilteredTopicImpl::set_expression_parameters | ( | const DDS::StringSeq & | parameters | ) | throw (CORBA::SystemException) |
std::string OpenDDS::DCPS::ContentFilteredTopicImpl::filter_expression_ [private] |
ACE_Recursive_Thread_Mutex OpenDDS::DCPS::ContentFilteredTopicImpl::lock_ [mutable, private] |
concurrent access to expression_parameters_ and readers_
std::vector<DataReaderImpl*> OpenDDS::DCPS::ContentFilteredTopicImpl::readers_ [private] |
DDS::Topic_var OpenDDS::DCPS::ContentFilteredTopicImpl::related_topic_ [private] |
1.4.7