smstream/oSMbuf.hh

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

#if defined(OSMBUF_TRACE)
  #include <string>
  #include <iostream>
#endif

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

class LSMP_PROD;

class oSMbuf : public std::streambuf {
  public:
#if defined(__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

  public:

    oSMbuf();

    oSMbuf(const char *partition, openmode_type mode=std::ios::out);

    ~oSMbuf();

    oSMbuf* open(const char *partition, openmode_type mode=std::ios::out);

    void close(void);

    int doallocate(void);

    int overflow(int c);

    void set_id(int evtid);

    int underflow() {return EOF;}

    int underflow(int c) {return EOF;}

    std::streampos seekoff(std::streamoff off, seekdir_type dir, 
                           openmode_type mode);

    std::streampos seekpos(std::streampos pos, openmode_type mode);

    int sync(void);

#ifndef __GNU_STDC_OLD

  void setb(char* b, char* eb, int a=0) {}

  int out_waiting(void) {return pptr() - pbase();}
#endif

  private:
    LSMP_PROD *mProducer;
    char      *mBuffer;
    int        mLength;
#ifdef OSMBUF_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);
        long returns(long i);
        void pTrace(void) const;
        void clear(void);
    private:
        int nTrace;
        std::string mFuncName[maxTrace];
        long mArg1[maxTrace];
        long mArg2[maxTrace];
        long mRet[maxTrace];
    } mTrace;
#endif
};

#ifdef OSMBUF_TRACE
inline void 
oSMbuf::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 
oSMbuf::trace::clear(void) {
    nTrace = 0;
}

inline long 
oSMbuf::trace::returns(long ret) {
  int inx = (nTrace-1) % maxTrace;
  mRet[inx] = ret;
  return ret;
}
#endif

#endif  //  _OSMBUF_HH_

---