itkBarrier.h

Go to the documentation of this file.

/*=========================================================================

  Program:   Insight Segmentation & Registration Toolkit
  Module:    $RCSfile: itkBarrier.h,v $
  Language:  C++
  Date:      $Date: 2007-01-25 23:18:04 $
  Version:   $Revision: 1.10 $

  Copyright (c) Insight Software Consortium. All rights reserved.
  See ITKCopyright.txt or http://www.itk.org/HTML/Copyright.htm for details.

     This software is distributed WITHOUT ANY WARRANTY; without even 
     the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR 
     PURPOSE.  See the above copyright notices for more information.

=========================================================================*/
#ifndef __itkBarrier_h
#define __itkBarrier_h

#include "itkLightObject.h"
#include "itkConditionVariable.h"
#include "itkMutexLock.h"

#ifdef ITK_USE_FETCHOP_BARRIERS
extern "C" {
#include <sys/pmo.h>
#include <fetchop.h>
}
#endif

#ifdef ITK_USE_SPROC
extern "C" {
#include <ulocks.h>
}
#endif

namespace itk {

class ITKCommon_EXPORT Barrier : public LightObject
{
public:

  typedef Barrier                   Self;
  typedef LightObject               Superclass;
  typedef SmartPointer<Self>        Pointer;
  typedef SmartPointer<const Self>  ConstPointer;

  itkNewMacro(Self);

  itkTypeMacro(Barrier, Object);

  void Initialize(unsigned int);

  void Wait();

private:
  Barrier();
  ~Barrier();

#if defined ITK_USE_FETCHOP_BARRIERS
  static bool               m_ReservoirInitialized;
  static atomic_reservoir_t m_Reservoir;
  static int                m_MaxBarriers;
  atomic_var_t *            m_Pvar;

  char pad1[128];              // Attempt to put
  volatile int m_FetchopFlag;  // m_Fetchop on its
  char pad2[128];              // own cache line.

#elif defined ITK_USE_SPROC
  barrier_t *m_Barrier;

#else
  ConditionVariable::Pointer m_ConditionVariable;
  unsigned int               m_NumberArrived;
  SimpleMutexLock            m_Mutex;

#endif

  unsigned int m_NumberExpected;
};

} // end namespace itk

#endif