smstream/iSMbuf.hh

/* -*- mode: c++; c-basic-offset: 4; -*- */
#ifndef ISMBUF_HH_
#define ISMBUF_HH_
//
//   Shared memory stream input buffer class
//
#include "PConfig.h"
// #define ISMBUF_TRACE

#if defined(ISMBUF_TRACE)
  #include <string>
  #include <iostream>
#endif
#if defined(__GNU_STDC_OLD)
   #include <streambuf.h>
#else
   #include <iostream>
   #include <streambuf>
#endif

class LSMP_CON;

class iSMbuf : public std::streambuf {
public:

#ifdef __GNU_STDC_OLD
    typedef std::ios::open_mode openmode_type;
    typedef std::ios::seek_dir  seekdir_type;
#else
    typedef std::ios::openmode  openmode_type;
    typedef std::ios::seekdir   seekdir_type;
#endif

    typedef std::streamoff off_type;

    typedef std::streampos pos_type;

public:
    iSMbuf();

    iSMbuf(const char *partition, openmode_type mode=std::ios::in);

    ~iSMbuf();

    int eventid(void) const;

    bool latest(void) const;

    iSMbuf* open(const char *partition, openmode_type mode=std::ios::in);

    void setBCount(int nbuf);

    bool waitBuf(bool nowait=false);

    void relse(void);

    int doallocate(void);

    int overflow(int c) {return EOF;}

    int underflow(void);


    pos_type seekoff(off_type off, seekdir_type dir, openmode_type mode);

    pos_type seekpos(pos_type off, openmode_type mode);

    int sync(){return 0;}

  private:
    void setptrs(int ix=0);
#ifndef __GNUG__
  void setb(char* b, char*eb, int a=0) {}
#endif


  private:
    LSMP_CON*   mConsumer;
    const char* mBuffer;
    int         mLength;
#ifdef ISMBUF_TRACE
  public:
    void pTrace(void) const {mTrace.pTrace();}
  private:
    class trace {
    #define maxTrace 8
    public:
        trace() : nTrace(0) {}
        void tracepoint(const std::string& funct, int arg1=0, int arg2=0);
        void pTrace(void) const;
        void clear(void);
    private:
        int nTrace;
        std::string mFuncName[maxTrace];
        int mArg1[maxTrace];
        int mArg2[maxTrace];
    } mTrace;
#endif
};

//======================================  Inline implementation of seekoff
#ifndef __GNU_STDC_OLD
inline iSMbuf::pos_type
iSMbuf::seekpos(pos_type off, openmode_type mode) {
    return seekoff(off_type(off), std::ios::beg, mode);
}
#endif

//======================================  Trace point function
#ifdef ISMBUF_TRACE
inline void 
iSMbuf::trace::tracepoint(const std::string& funct, int arg1, int arg2) {
    int inx = nTrace % maxTrace;
    mFuncName[inx] = funct;
    mArg1[inx] = arg1;
    mArg2[inx] = arg2;
    nTrace++;
}

inline void 
iSMbuf::trace::clear(void) {
    nTrace = 0;
}
#endif

#endif  //  ISMBUF_HH_

---