ClusterBarrier.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 __CLUSTERBARRIER_H__
#define __CLUSTERBARRIER_H__

#include <time.h>

class  SimpleSHMEM;
class  IPC_SimpleSemaphore;

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

namespace IS3D {

class ClusterBarrier
{
public:
  
  virtual bool init() = 0;  
  
  virtual void stop() = 0;
};

class SpinLockBarrier : public ClusterBarrier
{
public: 
  enum {      READY_FLAG = 0,
          ALL_READY_FLAG,
          HAS_RENDERING_ATTACHED, 
          SHMEM_NUM_FLAGS 
  };

protected:
  // Syncing operations
  void setReady(); 
  void setAllReady();
  void setNotReady();
  void setNotAllReady();
  void waitForReady();
  void waitForAllReady();
  
  // Keeping track of rendering process
  bool hasRenderingAttached();
  bool isRenderingAttached();
  bool hasRenderingQuit();

  // Generic operations
  void setFlag    ( int flag, bool val );
  bool getFlag    ( int flag );
  void waitForFlag( int flag );

  SpinLockBarrier();

  SimpleSHMEM     *_shmem;
  struct timespec  _delay_time, _delay_time_result;
};

class SemaphoreBarrier : public ClusterBarrier
{
protected:
  SemaphoreBarrier();
  IPC_SimpleSemaphore *_enterGate, *_exitGate;
};

}

#endif

#endif

#endif

---