lsmp/lsmp.hh

/* -*- mode: c++; c-basic-offset: 4; -*- */
//
//   LSMP is the Ligo Shared Memory Partition object class
//
#ifndef LSMP_HH
#define LSMP_HH

#include <sys/types.h>
#include <string>
#include <iosfwd>

#define LSMP_LNAME  16                      // maximum partition name length

//--------------------------------------- Error code enumerator
enum LSMP_error {
    NoError = 0,
    NotAttached,
    IncompatiblePartition,
    CantGetSem,
    NoFreeID,
    CantAttach,
    CantCreate,
    CantCreateSem,
    NoPriviledge,
    BadVersion
};

//---------------------------------------  Consumer flags.
#define READALL  0x0001
#define EVWAIT   0x0002
#define NOWAIT   0x0004
#define SHOWALL  0x0008

class LSMP {
  public:
    typedef int eventid_type;

  public:
    LSMP_error error;

    bool valid() const {
         return accessed;}

    bool found() const {
         return attached;}

    void dump(int flg=0xff) const;

    void dump(std::ostream& Out, int flg=0xff) const;

    void rqsynch(bool on);

    void bufmode(int mode);

    void keep(bool flag=true);


    void lock(bool flag=true);

    const char *Error(void) const;

    int getBufferLength(void) const {return NByte;}

    int getBufferCount(void) const {return NBuff;}

    LSMP(void);

    LSMP(LSMP& copy);

    LSMP(const char* name);

    LSMP(const char* name, int nbuf, int size);

    ~LSMP(void);

     std::string getStat(const std::string& par) const;

     bool testFlag(int x) const;

     int getLockCount(void) const {return mLockCount;}

     void clrLockCount(void) {mLockCount=0;}

  protected:
    struct LSMP_global* pointer;

    struct LSMP_consbk* conptr;

    struct LSMP_buffer* bufptr;

    char* buffer_addr(int ibuf) const;

    int buffer_length(int ibuf) const;

    bool gate(bool close) const;

    void Zeuss(const char* name);

  private:
    bool access();

    void deaccess();

    bool find(const char *name);

    bool make(const char *name, int nbuf, int size);

    void release();

  private:
    bool attached;

    bool accessed;

    bool kpflg;

    int NByte;

    int NBuff;

    int ident;

    static LSMP* base;

    LSMP* link;

    mutable int  mLockCount;
};


class LSMP_ACCESS : public LSMP {

  //------------------------------------  Public data and methods
  public:
    LSMP_ACCESS();

    LSMP_ACCESS(const char *part);

    ~LSMP_ACCESS();

    void Repair(int ID=-1);

    void Spew(int jBuf, std::ostream& Out, int length=0);

  private:
    int free_consumer(int icon);
};

#endif // LSMP_HH

---