/home/kopmann/git-mirror/fdhwlib/fdhwlib/Hw/IRhandler.h

Go to the documentation of this file.

/***************************************************************************
    IRhandler.h  -  description

    begin                : Thu Jun 29 2000
    copyright            : (C) 2000 by Andreas Kopmann
    email                : kopmann@hpe.fzk.de
 ***************************************************************************/


#ifndef _INC_IR_HANDLER_38563E480220_INCLUDED
#define _INC_IR_HANDLER_38563E480220_INCLUDED

// IR dispatcher for the FD mirror electronic
// hpe, june 2000 (ak)
//
// Goal: There is only one IR + one IR vector, therefore
// we have to provide a master process, that reads the IR vector
// and informs all the other interested processes
//
// History:
// 20 june 2000 First version trying to emulate a real software
//              IR with a couple of semaphores...

#ifdef __linux__

#include <cstdio>
#include <cstdlib>
#include <climits>
#include <unistd.h>

#include <akutil/semaphore.h>
#include <akutil/sharedMemory.h>
#include <akutil/procDuration.h>

#include <Pbus/Pbus.h>

//#  define INT_MAX     2147483647 // from limits.h


#define IR_TEST_MODE  // use this switch to enable the test mode
#define IR_SINGLE_CLIENT_ACK // use this switch to let the IRdispatcher
                         // wait for an acknoledge from the client

#ifdef IR_TEST_MODE
//#define IR_REQUESTS_MAX 8 // maxmal number of requests that
//                       // that can be invoked (only for extented test mode)
#endif // __linux__

#define IR_NXPG_MAX 2   // at least two are necessary
#define IR_ERROR_MAX 2  // buffer = IR_SEMA_MAX -2

#define SEM_NXPG 0
#define SEM_ERROR 1


#define IR_HANDLER_MASTER 0
#define IR_HANDLER_CLIENT 1
#define IR_HANDLER_CLIENT_NXPG 2

#ifndef IR_TEST_MODE

typedef struct {
   int masterActive;        // 0 no master, 1 master started
   int page[IR_NXPG_MAX];  // corresp. pages for the IRs
}  IRdata;

#else

typedef struct {
   int masterActive;        // 0 no master, 1 master started
   int page[IR_NXPG_MAX];  // corresp. pages for the IRs
   // simple test: do all the registered clients got the NxPg message?
   int nrNxPgClients; // number of registered clients
   int countNxPgRequests[IR_NXPG_MAX];  // number of requests
   //int reqMap[IR_NXPG_MAX,IR_REQUESTS_MAX] // detailed list for all procs
                                        // (extended test mode)
   // same for all errors ?!
}  IRdata;
#endif


//##ModelId=3991397D0290
class IRhandler : public Pbus {

public:

        //##ModelId=3991397D0346
   void dispatcher();

        //##ModelId=3991397D0345
   int waitForNxPg();

   // this is only a template for others
        //##ModelId=3991397D0344
   void waitForError(); // in fact there are more than one sources...


        //##ModelId=3991397D033A
   void displayParameters();
        

        //##ModelId=3991397D0330
   IRhandler(int mode); // 0 master =dispatcher
                        // 1 client (set bits to indicate
                        // which IRs will be requested - only
                        // for testing. )

        //##ModelId=3991397D0326
   ~IRhandler();

private:

        //##ModelId=3991397D031E
   sharedMemory shm;
        //##ModelId=3991397D0312
   IRdata *parameter;
        //##ModelId=3991397D02FE
   int mode;

        //##ModelId=3991397D02F6
   semaphore s_nxpg;
#ifdef IR_SINGLE_CLIENT_ACK     
        //##ModelId=3991397D02EC
   semaphore s_nxpg_ack;
#endif
        //##ModelId=3991397D02E2
   semaphore s_error;

   // indicates the next sema to wait for
        //##ModelId=3991397D02A4
   int w_nxpg;
        //##ModelId=3991397D029B
   int w_error;

};

#endif


#endif