lsmp/lsmp_con.hh

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

#include "lsmp.hh"

// #define COLDREAD

class LSMP_CON : public LSMP {

  //------------------------------------  Public data and methods
  public:
    LSMP_CON(void);

    LSMP_CON(const char *part, int nbuf=0, int mask=-1);

    ~LSMP_CON(void);

    const char* getBuffAddr(void) const;

    eventid_type getEvtID(void) const;

    int getLength(void) const;

    int getMask(void) const;

    int getNBuffer(void) const;

    int getNSkip(void) const;

    bool isConnected(void) const;

    bool latest_buffer(void) const;

    bool operator!(void) const;

    void setNBuffer(int nbuf);

    void setNSkip(int nskip);

    const char* get_buffer(int flags=0);

    const char* find_dataID(eventid_type ID);

    bool free_buffer();

  private:
    //------------------------------------  Private methods
    void get_consumer(int nbuf, int mask);

    int  free_consumer(void);

    int  get_by_ID(eventid_type dataID);

    //------------------------------------  Private data members.
    int icon;

    int ibuf;
};

//--------------------------------------  Inline functions
inline const char* 
LSMP_CON::getBuffAddr(void) const {
    return buffer_addr(ibuf);
}

inline int 
LSMP_CON::getLength(void) const {
    return buffer_length(ibuf);
}

inline bool
LSMP_CON::isConnected(void) const {
    return (valid() && icon >= 0);
}

inline bool
LSMP_CON::operator!(void) const {
    return (!valid() || icon < 0);
}

#endif  // LSMP_CON_HH

---