WatcherProducer.h

Go to the documentation of this file.

#ifndef Gw_WatcherProducer
#define Gw_WatcherProducer

// ADF includes
#ifndef ADF_NarvalInterface
#include "NarvalInterface.h"
#endif

// ROOT includes
#ifndef ROOT_TSocket
#include "TSocket.h"
#endif

namespace Gw {


class WatcherProducer : public ADF::NarvalProducer 
{
private:
        TString fMachine;
        UInt_t  fPort;
        
        TSocket *fSocket;
        Long_t fTimeout; 
        
private:
        ADF::BufferIO fBuffer;
        
protected:
        Bool_t  OpenSocket();
        Bool_t CloseSocket();   
public:
        WatcherProducer(): 
                ADF::NarvalProducer(), 
                fMachine("localhost"), 
                fPort(9090),
                fSocket(0x0),
                fTimeout(100),
                fBuffer(ADF::aByte)
                        {;}
        virtual ~WatcherProducer();
        
        void SetTimeout(Long_t timeout = 10); //*MENU* 
        
        static void process_config (const Char_t *path, UInt_t *error_code)
                { ADF::NarvalProducer::process_config(path,error_code); }
                
        virtual void process_initialise (UInt_t */*error_code*/)
                {;}
        virtual void process_reset (UInt_t */*error_code*/);    


        virtual UInt_t ProcessBlock (ADF::FrameBlock &);

        Bool_t SetConnection(const Char_t *machine ="localhost", UInt_t port = 9090);
};

} // end namespace

#endif