OpenDDS::DCPS::FilterEvaluator Class Reference

#include <FilterEvaluator.h>

Inheritance diagram for OpenDDS::DCPS::FilterEvaluator:

Collaboration diagram for OpenDDS::DCPS::FilterEvaluator:

Classes
struct	AstNodeWrapper
	keeps the details of yard out of the FilterEvaluator header file More...
struct	DataForEval
struct	DeserializedForEval
class	EvalNode
class	Operand
struct	SerializedForEval

Public Member Functions
	FilterEvaluator (const char *filter, bool allowOrderBy)
	FilterEvaluator (const AstNodeWrapper &yardNode)
	~FilterEvaluator ()
	OPENDDS_VECTOR (OPENDDS_STRING) getOrderBys() const
bool	hasFilter () const
bool	usesExtendedGrammar () const
size_t	number_parameters () const
bool	has_non_key_fields (const MetaStruct &meta) const
template<typename T >
bool	eval (const T &sample, const DDS::StringSeq &params) const
bool	eval (ACE_Message_Block *serializedSample, bool swap_bytes, bool cdr_encap, const MetaStruct &meta, const DDS::StringSeq &params, Extensibility exten) const
Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual	~RcObject ()
virtual void	_add_ref ()
virtual void	_remove_ref ()
long	ref_count () const
	This accessor is purely for debugging purposes. More...
WeakObject *	_get_weak_object () const

Private Member Functions
	FilterEvaluator (const FilterEvaluator &)
FilterEvaluator &	operator= (const FilterEvaluator &)
EvalNode *	walkAst (const AstNodeWrapper &node)
Operand *	walkOperand (const AstNodeWrapper &node)
bool	eval_i (DataForEval &data) const
	OPENDDS_VECTOR (OPENDDS_STRING) order_bys_

Private Attributes
bool	extended_grammar_
EvalNode *	filter_root_
size_t	number_parameters_

Additional Inherited Members
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Detailed Description

Definition at line 90 of file FilterEvaluator.h.

Constructor & Destructor Documentation

FilterEvaluator() [1/3]

OpenDDS::DCPS::FilterEvaluator::FilterEvaluator	(	const char *	filter,
		bool	allowOrderBy
	)

Definition at line 42 of file FilterEvaluator.cpp.

References filter_root_, OpenDDS::DCPS::reportErrors(), OpenDDS::DCPS::toString(), and walkAst().

  : extended_grammar_(false)
  , filter_root_(0)
  , number_parameters_(0)
{
  const char* out = filter + std::strlen(filter);
  yard::SimpleTextParser parser(filter, out);
  if (!(allowOrderBy ? parser.Parse<QueryCompleteInput>()
      : parser.Parse<FilterCompleteInput>())) {
    reportErrors(parser, filter);
  }

  bool found_order_by = false;
  for (AstNode* iter = parser.GetAstRoot()->GetFirstChild(); iter;
      iter = iter->GetSibling()) {
    if (iter->TypeMatches<ORDERBY>()) {
      found_order_by = true;
    } else if (found_order_by && iter->TypeMatches<FieldName>()) {
      order_bys_.push_back(toString(iter));
    } else {
      filter_root_ = walkAst(iter);
    }
  }
}

FilterEvaluator() [2/3]

OpenDDS::DCPS::FilterEvaluator::FilterEvaluator ( const AstNodeWrapper &  yardNode )

explicit

Definition at line 67 of file FilterEvaluator.cpp.

  : extended_grammar_(false)
  , filter_root_(walkAst(yardNode))
  , number_parameters_(0)
{
}

~FilterEvaluator()

OpenDDS::DCPS::FilterEvaluator::~FilterEvaluator

(

)

Definition at line 153 of file FilterEvaluator.cpp.

References filter_root_.

{
  delete filter_root_;
}

FilterEvaluator() [3/3]

OpenDDS::DCPS::FilterEvaluator::FilterEvaluator ( const FilterEvaluator &  )

private

Member Function Documentation

eval() [1/2]

template<typename T >

bool OpenDDS::DCPS::FilterEvaluator::eval ( const T &  sample, const DDS::StringSeq &  params  ) const

inline

Returns true if the unserialized sample matches the filter.

Definition at line 115 of file FilterEvaluator.h.

Referenced by OpenDDS::DCPS::DataReaderImpl_T< DynamicSample >::contains_sample_filtered(), OpenDDS::DCPS::Sample_T< NativeType >::eval(), OpenDDS::DCPS::DataWriterImpl::filter_out(), OpenDDS::DCPS::FilterEvaluator::EvalNode::has_non_key_fields(), and has_non_key_fields().

  {
    DeserializedForEval data(&sample, getMetaStruct<T>(), params);
    return eval_i(data);
  }

eval() [2/2]

bool OpenDDS::DCPS::FilterEvaluator::eval ( ACE_Message_Block *  serializedSample, bool  swap_bytes, bool  cdr_encap, const MetaStruct &  meta, const DDS::StringSeq &  params, Extensibility  exten  ) const

inline

Returns true if the serialized sample matches the filter.

Definition at line 124 of file FilterEvaluator.h.

  {
    SerializedForEval data(serializedSample, meta, params,
                           swap_bytes, cdr_encap, exten);
    return eval_i(data);
  }

eval_i()

bool OpenDDS::DCPS::FilterEvaluator::eval_i ( DataForEval &  data ) const

private

Definition at line 552 of file FilterEvaluator.cpp.

References OpenDDS::DCPS::Value::b_, OpenDDS::DCPS::FilterEvaluator::EvalNode::eval(), filter_root_, OPENDDS_STRING, and OPENDDS_VECTOR().

{
  return filter_root_->eval(data).b_;
}

has_non_key_fields()

bool OpenDDS::DCPS::FilterEvaluator::has_non_key_fields

(

const MetaStruct &

meta

)

const

Definition at line 158 of file FilterEvaluator.cpp.

References eval(), fieldName_, filter_root_, OpenDDS::DCPS::FilterEvaluator::EvalNode::has_non_key_fields(), OpenDDS::DCPS::MetaStruct::isDcpsKey(), OpenDDS::DCPS::FilterEvaluator::DataForEval::lookup(), OPENDDS_STRING, OPENDDS_VECTOR(), and OpenDDS::DCPS::toString().

Referenced by OpenDDS::DCPS::DataReaderImpl_T< DynamicSample >::contains_sample_filtered(), and OpenDDS::DCPS::DataWriterImpl::filter_out().

{
  for (OPENDDS_VECTOR(OPENDDS_STRING)::const_iterator i = order_bys_.begin(); i != order_bys_.end(); ++i) {
    if (!meta.isDcpsKey(i->c_str())) {
      return true;
    }
  }

  return filter_root_->has_non_key_fields(meta);
}

hasFilter()

bool OpenDDS::DCPS::FilterEvaluator::hasFilter

(

)

const

Definition at line 564 of file FilterEvaluator.cpp.

References filter_root_.

Referenced by OpenDDS::DCPS::QueryConditionImpl::hasFilter().

{
  return filter_root_ != 0;
}

number_parameters()

size_t OpenDDS::DCPS::FilterEvaluator::number_parameters ( ) const

inline

Definition at line 107 of file FilterEvaluator.h.

Referenced by OpenDDS::DCPS::ContentFilteredTopicImpl::ContentFilteredTopicImpl(), OpenDDS::DCPS::QueryConditionImpl::QueryConditionImpl(), OpenDDS::DCPS::ContentFilteredTopicImpl::set_expression_parameters(), and OpenDDS::DCPS::QueryConditionImpl::set_query_parameters().

{ return number_parameters_; }

OPENDDS_VECTOR() [1/2]

OpenDDS::DCPS::FilterEvaluator::OPENDDS_VECTOR

(

OPENDDS_STRING

)

const

Referenced by OpenDDS::DCPS::FilterEvaluator::EvalNode::deleteChild(), eval_i(), OpenDDS::DCPS::FilterEvaluator::EvalNode::has_non_key_fields(), and has_non_key_fields().

OPENDDS_VECTOR() [2/2]

OpenDDS::DCPS::FilterEvaluator::OPENDDS_VECTOR ( OPENDDS_STRING  )

private

operator=()

FilterEvaluator& OpenDDS::DCPS::FilterEvaluator::operator= ( const FilterEvaluator &  )

private

usesExtendedGrammar()

bool OpenDDS::DCPS::FilterEvaluator::usesExtendedGrammar ( ) const

inline

Definition at line 105 of file FilterEvaluator.h.

{ return extended_grammar_; }

walkAst()

FilterEvaluator::EvalNode * OpenDDS::DCPS::FilterEvaluator::walkAst ( const AstNodeWrapper &  node )

private

Definition at line 480 of file FilterEvaluator.cpp.

References OpenDDS::DCPS::arity(), OpenDDS::DCPS::child(), extended_grammar_, OpenDDS::DCPS::FilterEvaluator::Operand::isParameter(), OPENDDS_ASSERT, and walkOperand().

Referenced by FilterEvaluator().

{
  if (node->TypeMatches<CompPredDef>()) {
    Operand* left = walkOperand(child(node, 0));
    const FilterEvaluator::AstNodeWrapper& op = child(node, 1);
    Operand* right = walkOperand(child(node, 2));
    if (left->isParameter() && right->isParameter()) {
      extended_grammar_ = true;
    }
    return new Comparison(op, left, right);
  } else if (node->TypeMatches<BetweenPredDef>()) {
    Operand* field = walkOperand(child(node, 0));
    const FilterEvaluator::AstNodeWrapper& op = child(node, 1);
    Operand* low = walkOperand(child(node, 2));
    Operand* high = walkOperand(child(node, 3));
    return new Between(field, op, low, high);
  } else if (node->TypeMatches<CondDef>() || node->TypeMatches<Cond>()) {
    size_t a = arity(node);
    if (a == 1) {
      return walkAst(child(node, 0));
    } else if (a == 2) {
      OPENDDS_ASSERT(child(node, 0)->TypeMatches<NOT>());
      return new Logical(walkAst(child(node, 1)));
    } else if (a == 3) {
      EvalNode* left = walkAst(child(node, 0));
      const FilterEvaluator::AstNodeWrapper& op = child(node, 1);
      EvalNode* right = walkAst(child(node, 2));
      return new Logical(op, left, right);
    }
  }

  OPENDDS_ASSERT(0);
  return 0;
}

walkOperand()

FilterEvaluator::Operand * OpenDDS::DCPS::FilterEvaluator::walkOperand ( const AstNodeWrapper &  node )

private

Definition at line 516 of file FilterEvaluator.cpp.

References OpenDDS::DCPS::arity(), OpenDDS::DCPS::child(), extended_grammar_, number_parameters_, OPENDDS_ASSERT, and OpenDDS::DCPS::toString().

Referenced by walkAst().

{
  if (node->TypeMatches<FieldName>()) {
    return new FieldLookup(node);
  } else if (node->TypeMatches<IntVal>()) {
    return new LiteralInt(node);
  } else if (node->TypeMatches<CharVal>()) {
    return new LiteralChar(node);
  } else if (node->TypeMatches<FloatVal>()) {
    return new LiteralFloat(node);
  } else if (node->TypeMatches<StrVal>()) {
    return new LiteralString(node);
  } else if (node->TypeMatches<ParamVal>()) {
    Parameter* retval = new Parameter(node);
    // Keep track of the highest parameter number
    if (retval->param() + 1 > number_parameters_) {
      number_parameters_ = retval->param() + 1;
    }
    return retval;
  } else if (node->TypeMatches<CallDef>()) {
    if (arity(node) == 1) {
      return walkOperand(child(node, 0));
    } else {
      extended_grammar_ = true;
      Call* call = new Call(toString(child(node, 0)));
      for (AstNode* iter = child(node, 1); iter != 0; iter = iter->GetSibling()) {
        call->addChild(walkOperand(iter));
      }
      return call;
    }
  }
  OPENDDS_ASSERT(0);
  return 0;
}

Member Data Documentation

extended_grammar_

bool OpenDDS::DCPS::FilterEvaluator::extended_grammar_

private

Definition at line 177 of file FilterEvaluator.h.

Referenced by walkAst(), and walkOperand().

filter_root_

EvalNode* OpenDDS::DCPS::FilterEvaluator::filter_root_

private

Definition at line 178 of file FilterEvaluator.h.

Referenced by eval_i(), FilterEvaluator(), has_non_key_fields(), hasFilter(), and ~FilterEvaluator().

number_parameters_

size_t OpenDDS::DCPS::FilterEvaluator::number_parameters_

private

Number of parameter used in the filter, this should match the number of values passed when evaluating the filter

Definition at line 182 of file FilterEvaluator.h.

Referenced by walkOperand().

---

The documentation for this class was generated from the following files:

• FilterEvaluator.h
• FilterEvaluator.cpp