timerQueueActiveMgr Class Reference

#include "timerPrivate.h"

Public Types
typedef epicsSingleton< timerQueueActiveMgr >::reference	RefThis

Public Member Functions
	timerQueueActiveMgr ()
	~timerQueueActiveMgr ()
epicsTimerQueueActiveForC &	allocate (RefThis &, bool okToShare, unsigned threadPriority=epicsThreadPriorityMin+10)
void	release (epicsTimerQueueActiveForC &)

Detailed Description

Definition at line 163 of file timerPrivate.h.

Member Typedef Documentation

typedef epicsSingleton< timerQueueActiveMgr >:: reference timerQueueActiveMgr::RefThis

Definition at line 165 of file timerPrivate.h.

Constructor & Destructor Documentation

timerQueueActiveMgr::timerQueueActiveMgr

(

)

Definition at line 21 of file timerQueueActiveMgr.cpp.

    :mutex(__FILE__, __LINE__)
{
}

timerQueueActiveMgr::~timerQueueActiveMgr

(

)

Definition at line 26 of file timerQueueActiveMgr.cpp.

{
    epicsGuard < epicsMutex > locker ( this->mutex );
}

Member Function Documentation

epicsTimerQueueActiveForC & timerQueueActiveMgr::allocate	(	RefThis &	refThis,
		bool	okToShare,
		unsigned	threadPriority = epicsThreadPriorityMin + 10
	)

Definition at line 32 of file timerQueueActiveMgr.cpp.

{
    epicsGuard < epicsMutex > locker ( this->mutex );
    if ( okToShare ) {
        tsDLIter < epicsTimerQueueActiveForC > iter = this->sharedQueueList.firstIter ();
        while ( iter.valid () ) {
            if ( iter->threadPriority () == threadPriority ) {
                assert ( iter->timerQueueActiveMgrPrivate::referenceCount < UINT_MAX );
                iter->timerQueueActiveMgrPrivate::referenceCount++;
                return *iter;
            }
            iter++;
        }
    }

    epicsTimerQueueActiveForC & queue =
        * new epicsTimerQueueActiveForC ( refThis, okToShare, threadPriority );
    queue.timerQueueActiveMgrPrivate::referenceCount = 1u;
    if ( okToShare ) {
        this->sharedQueueList.add ( queue );
    }
    return queue;
}

void timerQueueActiveMgr::release

(

epicsTimerQueueActiveForC &

queue

)

Definition at line 57 of file timerQueueActiveMgr.cpp.

{
    {
        epicsGuard < epicsMutex > locker ( this->mutex );
        assert ( queue.timerQueueActiveMgrPrivate::referenceCount > 0u );
        queue.timerQueueActiveMgrPrivate::referenceCount--;
        if ( queue.timerQueueActiveMgrPrivate::referenceCount > 0u ) {
            return;
        }
        else if ( queue.sharingOK () ) {
            this->sharedQueueList.remove ( queue );
        }
    }
    // delete only after we release the guard in case the embedded
    // reference is the last one and this object is destroyed
    // as a side effect
    timerQueueActiveMgrPrivate * pPriv = & queue;
    delete pPriv;
}

---

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

• modules/libcom/src/timer/timerPrivate.h
• modules/libcom/src/timer/timerQueueActiveMgr.cpp