vpr::BarrierSGI Class Reference

Barrier wrapper for SGI. More...

#include <vpr/Sync/Barrier.h>

Collaboration diagram for vpr::BarrierSGI:

[legend]List of all members.

Public Member Functions
	BarrierSGI (int count)
	Initializes the barrier to synchronize count threads.
	~BarrierSGI ()
int	wait (int numProcs)
	Blocks the caller until all numProcs threads have called wait() and then allows all the caller threads to continue in parallel.
int	wait ()
void	addProcess ()
	Tells the barrier to increase the count of the number of threads to syncronize.
void	removeProcess ()
	Tells the barrier to decrease the count of the number of threads to syncronize.
void	setProcesses (int procs)
Protected Member Functions
void	operator= (const BarrierSGI &)
	BarrierSGI (const BarrierSGI &)
Protected Attributes
Mutex	mutex
int	syncCount
barrier_t *	theBarrier
Static Protected Attributes
static MemPoolSGI *	barrierPool
static int *	attachedCounter

---

Detailed Description

Barrier wrapper for SGI.

A barrier is a primitive that allows several processes to wait at a sync point. This is typedef'd to vpr::Barrier.

Date:

January 30, 1997

Definition at line 63 of file BarrierSGI.h.

---

Constructor & Destructor Documentation

vpr::BarrierSGI::BarrierSGI

(

int

count

)

[inline]

Initializes the barrier to synchronize count threads.

Definition at line 69 of file BarrierSGI.h.

References vpr::MemPoolSGI::allocate(), attachedCounter, barrierPool, vpr::MemPoolSGI::getArena(), and theBarrier.

                         : syncCount(count)
   {
      if (barrierPool == NULL)
      {
         barrierPool = new MemPoolSGI(65536, 32,
                                      "/var/tmp/memBarrierPoolSGIXXXXXX");
         attachedCounter = static_cast<int*>(barrierPool->allocate(sizeof(int)));
         *attachedCounter = 0;
      }
      *attachedCounter = *attachedCounter + 1;      // Track how many mutexes are allocated
      //vprDEBUG << "BarrierSGI::BarrierSGI: attachedCounter: " << *attachedCounter << std::endl << vprDEBUG_FLUSH;

      // ----- Allocate the mutex ----- //
      theBarrier = new_barrier(barrierPool->getArena());
   }

vpr::BarrierSGI::~BarrierSGI

(

)

[inline]

Definition at line 85 of file BarrierSGI.h.

References attachedCounter, barrierPool, vpr::MemPoolSGI::deallocate(), and theBarrier.

   {
      // ---- Delete the barrier --- //
      free_barrier(theBarrier);

      // ---- Deal with the pool --- //
      *attachedCounter = *attachedCounter - 1;     // Track how many mutexes are allocated

      //vprDEBUG << "BarrierSGI::~BarrierSGI: attachedCounter: " << *attachedCounter << std::endl << vprDEBUG_FLUSH;

      if (*attachedCounter == 0)
      {
         barrierPool->deallocate(attachedCounter);
         attachedCounter = NULL;
         delete barrierPool;
         barrierPool = NULL;
      }
   }

vpr::BarrierSGI::BarrierSGI

(

const BarrierSGI &

)

[inline, protected]

Definition at line 153 of file BarrierSGI.h.

{;}

---

Member Function Documentation

int vpr::BarrierSGI::wait

(

int

numProcs

)

[inline]

Blocks the caller until all numProcs threads have called wait() and then allows all the caller threads to continue in parallel.

Definition at line 108 of file BarrierSGI.h.

   {
      return -1;
   }

int vpr::BarrierSGI::wait

(

)

[inline]

Definition at line 113 of file BarrierSGI.h.

References syncCount, and theBarrier.

   {
      barrier(theBarrier, syncCount);
      //init_barrier(theBarrier);       // -- How do I reset the barrier -- //
      return 0;
   }

void vpr::BarrierSGI::addProcess

(

)

[inline]

Tells the barrier to increase the count of the number of threads to syncronize.

Definition at line 124 of file BarrierSGI.h.

References mutex, and syncCount.

   {
      Guard<Mutex> guard(mutex);
      syncCount++;
   }

void vpr::BarrierSGI::removeProcess

(

)

[inline]

Tells the barrier to decrease the count of the number of threads to syncronize.

Definition at line 134 of file BarrierSGI.h.

References mutex, and syncCount.

   {
      Guard<Mutex> guard(mutex);
      syncCount--;
   }

void vpr::BarrierSGI::setProcesses

(

int

procs

)

[inline]

Definition at line 140 of file BarrierSGI.h.

References mutex, and syncCount.

   {
      Guard<Mutex> guard(mutex);
      syncCount = procs;
   }

void vpr::BarrierSGI::operator=

(

const BarrierSGI &

)

[inline, protected]

Definition at line 152 of file BarrierSGI.h.

{;}

---

Member Data Documentation

Mutex vpr::BarrierSGI::mutex [protected]

Definition at line 147 of file BarrierSGI.h.

Referenced by addProcess(), removeProcess(), and setProcesses().

int vpr::BarrierSGI::syncCount [protected]

Definition at line 148 of file BarrierSGI.h.

Referenced by addProcess(), removeProcess(), setProcesses(), and wait().

barrier_t* vpr::BarrierSGI::theBarrier [protected]

Definition at line 149 of file BarrierSGI.h.

Referenced by BarrierSGI(), wait(), and ~BarrierSGI().

vpr::MemPoolSGI * vpr::BarrierSGI::barrierPool [static, protected]

Definition at line 155 of file BarrierSGI.h.

Referenced by BarrierSGI(), and ~BarrierSGI().

int * vpr::BarrierSGI::attachedCounter [static, protected]

Definition at line 156 of file BarrierSGI.h.

Referenced by BarrierSGI(), and ~BarrierSGI().

---

The documentation for this class was generated from the following files:

• BarrierSGI.h
• BarrierSGI.cpp

---