ClusterEventBuffer.H

Go to the documentation of this file.

// only compile if USE_SHMEMDEV is defined
#ifdef USE_SHMEMDEV

// this code only works on linux
#ifdef linux

#ifndef __CLUSTEREVENTBUFFER_H__
#define __CLUSTEREVENTBUFFER_H__

class IPC_SimpleSemaphore;
class SimpleSHMEM;

#include "ipc.simple.sem.H"
#include "ipc.simple.shmem.H"

namespace IS3D {

class ClusterEventBuffer 
{
public:
  enum { TERM_FLAG = 0, RENDERER_ATTACHED_FLAG, SHMEM_NUM_FLAGS };

  virtual bool init() = 0; 

  void  setRenderingAttached();
  bool  hasRenderingAttached();
  bool  isRenderingAttached();
  void  lockBuffer();
  void  unlockBuffer();
  char* getBuffer();
  int   getBufferSize();
  void  clearBuffer();

protected:
  
  void  setFlag( int flag, bool val );
  bool  getFlag( int flag );
  
  int   shmemTotalSize();
  int   shmemDeviceSize();
  int   shmemFlagsSize();
  char* shmemDataAddr();
  char* shmemFlagsAddr();


  SimpleSHMEM         *_buffer;
  IPC_SimpleSemaphore *_bufferGate;

public:
  static const int BUFFER_SIZE = 102400; // 100k should be way too much 
  static const int SHORT_SLEEP = 5000;   // 5 ms if this is in microseconds

};

}

#endif

#endif

#endif

---