BIE Overview Quick Start Theoretical overview Available methods Parallel chains Computation engine Command Line Interface Graphical User Interface Assigning Output Visualization tool Data handling Software technology Parallel debugging Results to date Recent developments Links User guide Future features Project goals Project Team Copyright and license

/home/weinberg/src/BIE/include/RecordStreamFilter.h // This is really -*- C++ -*- #ifndef RecordStreamFilter_h #define RecordStreamFilter_h #include <string> #include <vector> using namespace std; #include "RecordStream.h" #include "RecordType.h" #include "RecordBuffer.h" #include "BasicType.h" #include "Serializable.h" namespace BIE { class filterIn: public Serializable { public: filterIn() : inputtype(0), isset(0) {} filterIn(string i, BasicType* t, bool b) : inputname(i), inputtype(t), isset(b) {} string inputname; BasicType * inputtype; bool isset; bool isarray; // AUTO GENERATED BY ../persistence/autopersist.py private: friend class boost::serialization::access; template<class Archive> void serialize(Archive & ar, const unsigned int version) { this->pre_serialize(ar, version); try { ar & BOOST_SERIALIZATION_BASE_OBJECT_NVP(Serializable); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(inputname); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(inputtype); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(isset); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(isarray); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } this->post_serialize(ar, version); } }; class filterOut: public Serializable { public: filterOut() : outputtype(0) {} filterOut(string i, BasicType* t) : outputname(i), outputtype(t) {} string outputname; BasicType * outputtype; bool isarray; // AUTO GENERATED BY ../persistence/autopersist.py private: friend class boost::serialization::access; template<class Archive> void serialize(Archive & ar, const unsigned int version) { this->pre_serialize(ar, version); try { ar & BOOST_SERIALIZATION_BASE_OBJECT_NVP(Serializable); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(outputname); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(outputtype); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(isarray); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } this->post_serialize(ar, version); } }; //+ CLICLASS RecordStreamFilter class RecordStreamFilter: public Serializable { public: virtual ~RecordStreamFilter() {} //+ CLIMETHOD void connect string string void connect(string streamfieldname, string inputname); //+ CLIMETHOD void connect int string void connect(int streamfieldindex, string inputname); //+ CLIMETHOD void connect string int void connect(string streamfieldname, int inputindex); //+ CLIMETHOD void connect int int void connect(int streamfieldindex, int inputindex); //+ CLIMETHOD void disconnect string string void disconnect(string streamfieldname, string inputname); //+ CLIMETHOD void disconnect int string void disconnect(int streamfieldindex, string inputname); //+ CLIMETHOD void disconnect string int void disconnect(string streamfieldname, int inputindex); //+ CLIMETHOD void disconnect int int void disconnect(int streamfieldindex, int inputindex); //+ CLIMETHOD void disconnect string void disconnect(string inputname); //+ CLIMETHOD void disconnect int void disconnect(int inputindex); //+ CLIMETHOD void disconnect void disconnect(); //+ CLIMETHOD void renameOutputField int string void renameOutputField(int fieldindex, string newname); //+ CLIMETHOD void renameOutputField string string void renameOutputField(string fieldname, string newname); //+ CLIMETHOD bool isConnected bool isConnected(); //+ CLIMETHOD bool isConnected int bool isConnected(int inputindex); //+ CLIMETHOD bool isConnected string bool isConnected(string inputname); //+ CLIMETHOD int getInputCardinality string int getInputCardinality(string inputname); //+ CLIMETHOD int getInputCardinality string int getInputCardinality(int inputindex); //+ CLIMETHOD bool isAttached bool isAttached(); //+ CLIMETHOD bool nameClash bool nameClash(); //+ CLIMETHOD bool isUseable virtual bool isUseable(); //+ CLIMETHOD RecordBuffer* getBuffer RecordBuffer * getBuffer(); //+ CLIMETHOD RecordType* getOutputType RecordType * getOutputType(); //+ CLIMETHOD RecordType* getStreamType RecordType * getStreamType(); //+ CLIMETHOD int numInputs int numInputs(); //+ CLIMETHOD int getInputIndex string int getInputIndex(string inputname); //+ CLIMETHOD string getInputName int string getInputName(int inputindex); //+ CLIMETHOD bool isValidInputName string bool isValidInputName(string inputname); //+ CLIMETHOD bool isValidInputIndex int bool isValidInputIndex(int inputindex); //+ CLIMETHOD string toString string toString(); /******************************************************************************* * These are called only by input and output streams. perhaps * they should be protected, and accessed by "friends" only *******************************************************************************/ virtual void compute() = 0; void attachToStream(RecordStream * stream); protected: void initialize(const filterIn * input, const filterOut * output, RecordStream * stream); string getDefaultOutputName(int outputindex); int getDefaultOutputIndex(string outputname); bool isValidDefaultOutputName(string outputname); bool isValidOutputIndex(int outputindex); int getIntInput (string inputname); int getIntInput (int inputindex); double getRealInput (string inputname); double getRealInput (int inputindex); bool getBoolInput (string inputname); bool getBoolInput (int inputindex); string getStringInput(string inputname); string getStringInput(int inputindex); vector<int> getIntArrayInput(int inputindex); vector<double> getRealArrayInput(int inputindex); vector<bool> getBoolArrayInput(int inputindex); int getIntInput (string inputname, int setindex); int getIntInput (int inputindex, int setindex); double getRealInput (string inputname, int setindex); double getRealInput (int inputindex, int setindex); bool getBoolInput (string inputname, int setindex); bool getBoolInput (int inputindex, int setindex); string getStringInput(string inputname, int setindex); string getStringInput(int inputindex, int setindex); void setIntOutput (string inputname, int value); void setIntOutput (int inputindex, int value); void setRealOutput (string inputname, double value); void setRealOutput (int inputindex, double value); void setBoolOutput (string inputname, bool value); void setBoolOutput (int inputindex, bool value); void setStringOutput(string inputname, string value); void setStringOutput(int inputindex, string value); void setIntArrayOutput(int outputindex, vector<int> vint); void setRealArrayOutput(int outputindex, vector<double> vdbl); void setBoolArrayOutput(int outputindex, vector<bool> vbln); bool isArray(int inputindex); private: RecordBuffer * filter_outputbuffer; RecordType * filter_streamtype; RecordStream * filter_stream; bool filter_isattached; filterIn * filter_input; filterOut * filter_output; int filter_numinputs; int filter_numoutputs; vector< vector<int> > filter_connections; vector <int> filter_inputcardinality; // AUTO GENERATED BY ../persistence/autopersist.py protected: RecordStreamFilter() {} private: friend class boost::serialization::access; template<class Archive> void serialize(Archive & ar, const unsigned int version) { this->pre_serialize(ar, version); try { ar & BOOST_SERIALIZATION_BASE_OBJECT_NVP(Serializable); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(filter_outputbuffer); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(filter_streamtype); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(filter_stream); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(filter_isattached); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(filter_input); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(filter_output); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(filter_numinputs); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(filter_numoutputs); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(filter_connections); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(filter_inputcardinality); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } this->post_serialize(ar, version); } }; } #if BOOST_VERSION <= 103500 BOOST_IS_ABSTRACT(BIE::RecordStreamFilter) #else BOOST_SERIALIZATION_ASSUME_ABSTRACT(RecordStreamFilter) #endif BIE_CLASS_TYPE_INFO(BIE::filterIn) BIE_CLASS_TYPE_INFO(BIE::filterOut) BIE_CLASS_EXPORT_KEY(BIE::filterIn) BIE_CLASS_EXPORT_KEY(BIE::filterOut) BIE_CLASS_EXPORT_KEY(BIE::RecordStreamFilter) #endif