FsfBarrier.h

Go to the documentation of this file.

/*
  FSF: Flow Scheduling Framework library
  
  Version 1.0 Copyright (C) 2010 Alexandre R.J. Francois

  Previous versions Copyright (C) 2001-2005 University of Southern California

  Author: Alexandre R.J. Francois - alexandrefrancois@yahoo.com
  www.alexandrefrancois.org
  
  Modular Flow Scheduling Middleware
  mfsm.sourceForge.net
  
  This library is free software; you can redistribute it and/or
  modify it under the terms of the GNU Lesser General Public
  License as published by the Free Software Foundation; either
  version 2.1 of the License, or (at your option) any later version.
  
  This library is distributed in the hope that it will be useful,
  but WITHOUT ANY WARRANTY; without even the implied warranty of
  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  Lesser General Public License for more details.
  
  You should have received a copy of the GNU Lesser General Public
  License along with this library; if not, write to the Free Software
  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
*/

#ifndef FSF_BARRIER_H
#define FSF_BARRIER_H

#include "FsfNode.h"
#include "FsfCell.h"
#include "FsfFilter.h"
#include "FsfPulse.h"

namespace fsf{


    class CBarrier : public CNode {
    private:
        static const Time DEFAULT_TIME_OUT=100000000.0; // .1s
        CMutex m_csFilter; 
        CActiveFilterBase *m_pFilter; 
        Time m_tTimeOut; 
    public:


        CBarrier()
            : CNode(), m_pFilter(NULL) {}
        CBarrier(CNode *pParent, Time tTime=0)
            : CNode(pParent,tTime), m_pFilter(NULL), m_tTimeOut(DEFAULT_TIME_OUT) {}
        CBarrier(const std::string &strName, CNode *pParent=NULL, Time tTime=0)
            : CNode(strName,pParent,tTime), m_pFilter(NULL), m_tTimeOut(DEFAULT_TIME_OUT) {}
        CBarrier(CActiveFilterBase *pFilter, Time tTimeOut=DEFAULT_TIME_OUT, CNode *pParent=NULL, Time tTime=0);
        CBarrier(const std::string &strName, CActiveFilterBase *pFilter=NULL, Time tTimeOut=DEFAULT_TIME_OUT, CNode *pParent=NULL, Time tTime=0);
        CBarrier(const CBarrier& rhs);
        virtual ~CBarrier();
        virtual CNode *clone() const { return new CBarrier(*this); }



        CBarrier& operator=(const CBarrier& rhs);
        void setFilter(CActiveFilterBase *pFilter);
        void setTimeOut(Time tTime) { m_tTimeOut=tTime; }
        bool filter(CActivePulse *pPulse);

        CActiveFilterBase *getFilter();



        virtual void getTypeID(std::string &str) const { str.assign("FSF_BARRIER"); }
        Time getTimeOut() const { return m_tTimeOut; }
    };

    
    class CSync : public CCell {
    public:


        CSync();



        virtual void GetTypeID(std::string &str) const { str.assign("FSF_SYNC"); }







        virtual void Process(CPassiveHandle *pPassiveHandle, CActiveHandle *pActiveHandle, CActivePulse *pActivePulse);
    };

} // namespace fsf

#endif // FSF_BARRIER_H

---