/home/kopmann/git-mirror/fdhwlib/fdhwlib/akutil/semaphore.h

Go to the documentation of this file.

/***************************************************************************
    semaphore.h  -  description

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




#ifndef _INC_SEMAPHORE_1234_INCLUDED
#define _INC_SEMAPHORE_1234_INCLUDED

//#define SEM_DEBUG // turn on debug information

#ifdef __GNUC__
#define USE_SYSV_SYNC
#endif

// Do not realy work for Windows
// Use the appropriate MFC commands directly!!!
//#define USE_MFC_SYNC

#include <cstdio>
#include <stdexcept>

#ifdef USE_SYSV_SYNC
// Semaphore für Linux
// Sys V style
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>

#ifdef __linux__
//#include <linux/sem.h>
// from linux/sem.h  don't know how to handle it. You can't invoke
// both sys/sem.h and linux/sem.h !?

/* arg for semctl system calls. */
union semun {
        int val;                        /* value for SETVAL */
        struct semid_ds *buf;           /* buffer for IPC_STAT & IPC_SET */
        unsigned short *array;          /* array for GETALL & SETALL */
        struct seminfo *__buf;          /* buffer for IPC_INFO */
        void *__pad;
};
#endif

#define SEM_NUMBER_MAX 16  // Number of Semas in the array
#define SEM_RESOURCE_MAX 1 //Initial value of all semaphores
#endif

#ifdef USE_MFC_SYNC
#include <afxwin.h>
#include <afxmt.h>
#endif

class semaphore
{
public:
   //semaphore();
   //semaphore(int mid);
   semaphore(int mid=0, const char *dir="/");

   //void request();
   //void release();
   void request(int nr=0);
   void release(int nr=0);

   int number();

#ifdef USE_SYSV_SYNC
   key_t getKey();
#endif

private:

   int memid;

#ifdef USE_SYSV_SYNC
   key_t key;

   int sid;
   int max;

   void init(int mid, const char *dir);
#endif

#ifdef USE_MFC_SYNC
   CMutex *mutex0;
   CMutex *mutex1;

   CSingleLock *lock0;
   CSingleLock *lock1;
#endif

};

#ifdef USE_SYSV_SYNC

class semaControl
{
public:
   semaControl();

   semaControl(const char *dir);

   int number();

   int value(int nr);

   void markForDelete();


   void open();

   void create(int members);

   void lock(int nr);

   void unlock(int nr);

#ifdef USE_SYSV_SYNC
   key_t getKey();
#endif

private:
   int sid;
   int memid;
   int max;

   key_t key;

   void init(const char *dir);
};
#endif

#endif