FsfTypeCellBase.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_TYPE_CELL_BASE_H
#define FSF_TYPE_CELL_BASE_H

#include "FsfCell.h"

namespace fsf {
    
    class CTypeCellBase : public CCell {
    protected:
    public:


        CTypeCellBase() : CCell() {}



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

                


        virtual void process(CPassiveHandle *pPassiveHandle, CActiveHandle *pActiveHandle, CActivePulse *pActivePulse) {}




        inline void startActiveThread(CActivePulse *pPulse=NULL);

        // Calls Process if needed
        // Process incoming active pulse.
        // The semantics are slightly modified for the type cell
        // to handle Get and Set value operations.
        virtual void activeThread(CActivePulse *pPulse=NULL){
            lockPassiveHandle();
            if(getPassiveHandle()!=NULL){
                // make a copy of passive handle
                CPassiveHandle *pPassiveHandle=new CPassiveHandle(*getPassiveHandle());
                unlockPassiveHandle();
                
                // filter active pulse to get active node
                std::list<CActiveHandle*> listHandles;
                lockActiveFilter();
                bool bMatch=getActiveFilter()->filter(listHandles,pPulse);
                unlockActiveFilter();
                if(bMatch){
                    // no multiple matches allowed: only process first match
                    // input found: SET value
                    std::list<CActiveHandle*>::iterator it=listHandles.begin();
                    // make both nodes interact
                    process(pPassiveHandle,*it,pPulse);
                    // trigger update on passive loop
                    getRepository()->notifyPulseUpdate();
                    // delete handles
                    while(it!=listHandles.end()){
                        delete *it;
                        ++it;
                    }
                }
                else{
                    // no input found: GET value
                    process(pPassiveHandle,NULL,pPulse);
                }
                delete pPassiveHandle;
            }
            else{
                unlockPassiveHandle();
            }
            
            // Complete routing of active pulse
            lockDownstream();
            if(!getListDownstream().empty()){
                pPulse->incNbPaths(getListDownstream().size()-1);
                std::list<CCell*>::iterator it;
                for(it=getListDownstream().begin();it!=getListDownstream().end();++it){
                    (*it)->startActiveThread(pPulse);
                }
                unlockDownstream();
            }
            else{
                unlockDownstream();
                // release the Pulse and delete if no longer needed
                if(pPulse->decNbPaths()==0)
                    delete pPulse;
            }
        }


    };
    
} // namespace fsf

#endif // FSF_TYPE_CELL_BASE_H

---