|
GammaWare
Head Version for release 0.9
|
|
|
GammaWare
Head Version for release 0.9
|
|
To get a buffer from a server. More...
#include <WatcherProducer.h>
Public Member Functions | |
| virtual Int_t | AttachInput (FrameBlock *, Int_t=-1) |
| Attach a block as input for a given slot number. More... | |
| virtual Int_t | AttachOutput (FrameBlock *block, Int_t slot=-1) |
| Attach a block as output for a given slot number. More... | |
| const std::string & | GetConfPath () |
| To get the algo path associated with the current actor. More... | |
| FrameIO & | GetFrameIO () |
| virtual Int_t | GetMaxInput () const |
| for this actor, it gives the max number of entry lines it can handle (max included). More... | |
| virtual Int_t | GetMaxOutput () const |
| for this actor, it gives the max number of output lines it can handle ==> Only one for a producer More... | |
| virtual Int_t | GetNbInput () const |
| for this actor, it gives the current number of entry lines attached. More... | |
| virtual Int_t | GetNbOutput () const |
| for this actor, it gives the current number of entry lines attached. More... | |
| UInt_t | GetPID () const |
| To get the ID number for that algorithm. More... | |
| virtual void | process_block (void *output_buffer, UInt_t size_of_output_buffer, UInt_t *used_size_of_output_buffer, UInt_t *error_code) |
| Ask the algorithm to process the data block. More... | |
| virtual void | process_initialise (UInt_t *) |
| TODO reads from a file the data to open the socket. More... | |
| virtual void | process_pause (UInt_t *error_code) |
| This method is called every time the system pauses data acquisition. More... | |
| virtual void | process_reset (UInt_t *) |
| TODO. More... | |
| virtual void | process_resume (UInt_t *error_code) |
| this method is called every time the system resumes data acquisition More... | |
| virtual void | process_start (UInt_t *error_code) |
| This method is called every time the daq starts. More... | |
| virtual void | process_stop (UInt_t *error_code) |
| This method is called every time the daq stops. More... | |
| virtual UInt_t | ProcessBlock (ADF::FrameBlock &) |
| load the next block More... | |
| virtual UInt_t | ProcessBlocks () |
| process blocks attached by AttachInput/AttachOutput. No need to overwrite it if ProcessBlock(FrameBlock &). Otherwise both are to be implemented. More... | |
| Bool_t | SetConnection (const Char_t *machine="localhost", UInt_t port=9090) |
| change the place where are picked data More... | |
| void | SetTimeout (Long_t timeout=10) |
| change timeout to try and get data from the socket More... | |
| WatcherProducer () | |
| virtual | ~WatcherProducer () |
Static Public Member Functions | |
| static std::string | GetGlobalConfPath () |
| global conf path keep since passed in static method and needed in init method More... | |
| static Int_t | GetGlobalParameter (const char *name, UShort_t &val) |
| to get from narval a parameter () ... IS IT mandatory to have there a static method ???? More... | |
| static Int_t | GetGlobalParameter (const char *name, Int_t &val) |
| static Int_t | GetGlobalParameter (const char *name, std::string &val) |
| static void | process_config (const Char_t *path, UInt_t *error_code) |
| static void | process_config (const Char_t *, UInt_t *, Short_t do_adf_conf=0) |
| Have to be overwritten and called in your implementation. More... | |
| static Int_t | SetGlobalParameter (const char *name, const UShort_t &) |
| static Int_t | SetGlobalParameter (const char *name, const std::string &) |
Protected Member Functions | |
| Bool_t | CloseSocket () |
| virtual ConfAgent * | GetConfAgent () const |
| Bool_t | OpenSocket () |
| true if a valid connection More... | |
Protected Attributes | |
| FrameIO | fFrameIO |
| Frame IO ... should be private ... More... | |
| Version | fVersion |
| Algo version (used to check determine suitable frame version ?) More... | |
| LogMessage | Log |
| to send messages to the log server More... | |
To get a buffer from a server.
Definition at line 22 of file WatcherProducer.h.
1.8.7