RevisionFilterQBox.h

Go to the documentation of this file.

#ifndef REVISION_FILTER_QBOX_H
#define REVISION_FILTER_QBOX_H

#include "QBox.h"
#include "Expression.h"
#include "CP.h"

BOREALIS_NAMESPACE_BEGIN;

class RevisionFilterQBox : public QBox {

private:
    EvalContext _ctxt;
    vector<ptr<Expression> > _expressions;

    bool _passOnFalsePort;
    unsigned int _output_tuple_size;

    unsigned int _expr_count; // _expressions.size()

    /****** Added on this box *******/
    int _revision_id_counter;
    map<int, const char*> _revision_tuple_store;

protected:
    void setupImpl() throw (AuroraException);
    void initImpl() throw (AuroraException);
    void runImpl(QBoxInvocation&) throw (AuroraException);
        
    /***** Added on this box *****/
    // If a CPView exists on my stream, then return it.
    CPView* getCPView(unsigned int port);


    AURORA_DECLARE_QBOX(RevisionFilterQBox, "revisionfilter");
};

BOREALIS_NAMESPACE_END;

#endif

---