OSGBarrier.inl

Go to the documentation of this file.

/*---------------------------------------------------------------------------*\
 *                                OpenSG                                     *
 *                                                                           *
 *                                                                           *
 *           Copyright (C) 2003 by the OpenSG Forum                          *
 *                                                                           *
 *                            www.opensg.org                                 *
 *                                                                           *
 *   contact: dirk@opensg.org, gerrit.voss@vossg.org, jbehr@zgdv.de          *
 *                                                                           *
\*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*\
 *                                License                                    *
 *                                                                           *
 * This library is free software; you can redistribute it and/or modify it   *
 * under the terms of the GNU Library General Public License as published    *
 * by the Free Software Foundation, version 2.                               *
 *                                                                           *
 * This library is distributed in the hope that it will be useful, but       *
 * WITHOUT ANY WARRANTY; without even the implied warranty of                *
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU         *
 * Library General Public License for more details.                          *
 *                                                                           *
 * You should have received a copy of the GNU Library General Public         *
 * License along with this library; if not, write to the Free Software       *
 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.                 *
 *                                                                           *
\*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*\
 *                                Changes                                    *
 *                                                                           *
 *                                                                           *
 *                                                                           *
 *                                                                           *
 *                                                                           *
 *                                                                           *
\*---------------------------------------------------------------------------*/

OSG_BEGIN_NAMESPACE

inline
void BarrierCommonBase::setNumWaitFor(UInt32 uiNumWaitFor)
{
    _uiNumWaitFor = uiNumWaitFor;
}


#if defined (OSG_USE_PTHREADS)

/*------------------------------- Enter -----------------------------------*/

inline
void PThreadBarrierBase::enter(void)
{
    if(_uiNumWaitFor <= 1)
        return;

    pthread_mutex_lock(&(_pLockOne));

    _uiCount++;

    if(_uiCount < _uiNumWaitFor)
    {
        /* not enough threads are waiting => wait */

        pthread_cond_wait(&(_pWakeupCondition[_uiCurrentCond]), &(_pLockOne));
    }
    else
    {
        /* ok, enough threads are waiting
           => wake up all waiting threads
        */

        pthread_cond_broadcast(&(_pWakeupCondition[_uiCurrentCond]));

        _uiCount       = 0;
        _uiCurrentCond = 1 - _uiCurrentCond;
    }

    pthread_mutex_unlock(&(_pLockOne));
}

inline
void PThreadBarrierBase::enter(UInt32 uiNumWaitFor)
{
    _uiNumWaitFor = uiNumWaitFor;

    enter();
}

#endif /* OSG_USE_PTHREADS */



#if defined (OSG_USE_SPROC)

/*------------------------------ Enter ------------------------------------*/

inline
void SprocBarrierBase::enter(void)
{
    if(_pBarrier != NULL)
        barrier(_pBarrier, _uiNumWaitFor);
}

inline
void SprocBarrierBase::enter(UInt32 uiNumWaitFor)
{
    _uiNumWaitFor = uiNumWaitFor;

    enter();
}

#endif /* OSG_USE_SPROC */



#if defined (OSG_USE_WINTHREADS)

/*------------------------------ Enter ------------------------------------*/

inline
void WinThreadBarrierBase::enter(void)
{
    WaitForSingleObject(_pMutex1, INFINITE);

    ++_uiNumWaiters;

    if(_uiNumWaiters == _uiNumWaitFor) 
    {
        --_uiNumWaiters;

        ReleaseMutex(_pMutex1);

        ReleaseSemaphore(_pBarrierSema, _uiNumWaitFor - 1, NULL);

        return;
    }
    else
    {
        ReleaseMutex(_pMutex1);

        WaitForSingleObject(_pBarrierSema, INFINITE);
        
        WaitForSingleObject(_pMutex1, INFINITE);

        --_uiNumWaiters;

        ReleaseMutex(_pMutex1);
    }
}

inline
void WinThreadBarrierBase::enter(UInt32 uiNumWaitFor)
{
    _uiNumWaitFor = uiNumWaitFor;

    enter();
}

#endif /* OSG_USE_WINTHREADS */

inline
Barrier *Barrier::create(void)
{
    return Barrier::get(NULL);
}

inline
const MPBarrierType &Barrier::getClassType(void)
{
    return _type;
}

/*------------------------------- Enter -----------------------------------*/


inline
void Barrier::enter(void)
{
    Inherited::enter();
}

inline
void Barrier::enter(UInt32 uiNumWaitFor)
{
    Inherited::enter(uiNumWaitFor);
}


OSG_END_NAMESPACE

#define OSGBARRIER_INLINE_CVSID "@(#)$Id: $"

---