OpenDDS::DCPS::ContentFilteredTopicImpl Class Reference

#include <ContentFilteredTopicImpl.h>

Inheritance diagram for OpenDDS::DCPS::ContentFilteredTopicImpl:

Inheritance graph
[legend]
Collaboration diagram for OpenDDS::DCPS::ContentFilteredTopicImpl:

Collaboration graph
[legend]
List of all members.

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 &parameters) throw (CORBA::SystemException)
DDS::ReturnCode_t set_expression_parameters (const DDS::StringSeq &parameters) 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_

Constructor & Destructor Documentation

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]


Member Function Documentation

void OpenDDS::DCPS::ContentFilteredTopicImpl::add_reader ( DataReaderImpl reader  ) 

template<typename Sample>
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)


Member Data Documentation

DDS::StringSeq OpenDDS::DCPS::ContentFilteredTopicImpl::expression_parameters_ [private]

FilterEvaluator OpenDDS::DCPS::ContentFilteredTopicImpl::filter_eval_ [private]

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]


The documentation for this class was generated from the following files:
Generated on Wed Nov 16 15:28:38 2011 for OpenDDS by  doxygen 1.4.7