TShareRun.h

Go to the documentation of this file.

// Copyright (C) 2013-2024 CEA/DES
//
// This program 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 3 of the License, or any 
// later version.
//
// This program 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 program.  If not, see <http://www.gnu.org/licenses/>.
// $Id$
// $Author$
// $Date$
// $Revision 1.4 $
// $State$

#ifndef __SHARE_RUN__
#define __SHARE_RUN__

//ROOT
#include "Rtypes.h"

// Uranie
#include "TRun.h"
#include "TEval.h"

#include <queue>

namespace URANIE
{
namespace Relauncher
{


#define SINGL 11
#define GRAD 12
#define UENTR 13

struct element
{
    long id, calcnb;
    vector<URANIE::DataServer::UEntry*> *inv, *outv;
};
struct relement
{
    long id;
    int stat;
};

class TShareRun: public TRun
{
protected:
    TEval *_fun;

public:
    TShareRun(TEval *fun);
    virtual ~TShareRun();

    virtual TEval *getEval()
    {
        return _fun;
    }
    virtual void put(long, vector<URANIE::DataServer::UEntry*> *in, vector<URANIE::DataServer::UEntry*> *out, int icalc)=0;
    
    ClassDef(URANIE::Relauncher::TShareRun, ID_RELAUNCHER)
};

class TSimpleRun: public TShareRun
{
protected:

    std::queue<struct element> _qin;


public:
    TSimpleRun(TEval *fun);
    virtual ~TSimpleRun();

    virtual Bool_t onMaster(void);

    virtual void put(long, vector<URANIE::DataServer::UEntry*> *in, vector<URANIE::DataServer::UEntry*> *out, int icalc=0);

    virtual Bool_t readyToGet();
        
    ClassDef(URANIE::Relauncher::TSimpleRun, ID_RELAUNCHER)
};

class TDecoratorRun: public TRun
{
protected:
    TRun *_subrun;

public:
    TDecoratorRun(TRun *run);
    virtual ~TDecoratorRun();

    virtual TEval *getEval();
    virtual void startSlave();
    virtual Bool_t onMaster();
    virtual void stopSlave();    
    
    ClassDef(URANIE::Relauncher::TDecoratorRun, ID_RELAUNCHER)
};

}
} //namespace

#endif