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 TypeSupportImpl &ts) const
template<typename T >
bool	eval (const T &sample, const DDS::StringSeq &params) const
bool	eval (ACE_Message_Block *serializedSample, Encoding encoding, const TypeSupportImpl &typeSupport, const DDS::StringSeq &params) const
Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual	~RcObject ()
virtual void	_add_ref ()
virtual void	_remove_ref ()
long	ref_count () const
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 91 of file FilterEvaluator.h.

Constructor & Destructor Documentation

FilterEvaluator() [1/3]

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

Definition at line 43 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 68 of file FilterEvaluator.cpp.

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

~FilterEvaluator()

OpenDDS::DCPS::FilterEvaluator::~FilterEvaluator

(

)

Definition at line 165 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 116 of file FilterEvaluator.h.

Referenced by OpenDDS::DCPS::DataReaderImpl_T< DynamicSample >::contains_sample_filtered(), OpenDDS::XTypes::DynamicSample::eval(), 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, Encoding  encoding, const TypeSupportImpl &  typeSupport, const DDS::StringSeq &  params  ) const

inline

Returns true if the serialized sample matches the filter.

Definition at line 125 of file FilterEvaluator.h.

  {
    SerializedForEval data(serializedSample, typeSupport, params, encoding);
    return eval_i(data);
  }

eval_i()

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

private

Definition at line 564 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 TypeSupportImpl &

ts

)

const

Definition at line 170 of file FilterEvaluator.cpp.

References eval(), fieldName_, filter_root_, OpenDDS::DCPS::FilterEvaluator::EvalNode::has_non_key_fields(), OpenDDS::DCPS::TypeSupportImpl::is_dcps_key(), 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 (!ts.is_dcps_key(i->c_str())) {
      return true;
    }
  }

  return filter_root_->has_non_key_fields(ts);
}

hasFilter()

bool OpenDDS::DCPS::FilterEvaluator::hasFilter

(

)

const

Definition at line 576 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 108 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 106 of file FilterEvaluator.h.

{ return extended_grammar_; }

walkAst()

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

private

Definition at line 492 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 528 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 parameters 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