ipAddrToAsciiEnginePrivate Class Reference

Inheritance diagram for ipAddrToAsciiEnginePrivate:

Collaboration diagram for ipAddrToAsciiEnginePrivate:

Public Member Functions
	ipAddrToAsciiEnginePrivate ()
virtual	~ipAddrToAsciiEnginePrivate ()
void	show (unsigned level) const
ipAddrToAsciiTransaction &	createTransaction ()
void	release ()

Public Attributes
unsigned	refcount
bool	released

Static Public Attributes
static ipAddrToAsciiGlobal *	pEngine = 0

Additional Inherited Members
Static Public Member Functions inherited from ipAddrToAsciiEngine
static ipAddrToAsciiEngine &	allocate ()
Protected Member Functions inherited from ipAddrToAsciiEngine
virtual	~ipAddrToAsciiEngine ()=0

Detailed Description

Definition at line 106 of file ipAddrToAsciiAsynchronous.cpp.

Constructor & Destructor Documentation

ipAddrToAsciiEnginePrivate::ipAddrToAsciiEnginePrivate ( )

inline

Definition at line 109 of file ipAddrToAsciiAsynchronous.cpp.

:refcount(1u), released(false) {}

virtual ipAddrToAsciiEnginePrivate::~ipAddrToAsciiEnginePrivate ( )

inlinevirtual

Definition at line 110 of file ipAddrToAsciiAsynchronous.cpp.

{}

Member Function Documentation

ipAddrToAsciiTransaction & ipAddrToAsciiEnginePrivate::createTransaction ( )

virtual

Implements ipAddrToAsciiEngine.

Definition at line 283 of file ipAddrToAsciiAsynchronous.cpp.

{
    epicsGuard <epicsMutex> G(this->pEngine->mutex);
    if(this->released)
        throw std::logic_error("createTransaction() on release()'d ipAddrToAsciiEngine");

    assert(this->refcount>0);

    ipAddrToAsciiTransactionPrivate *ret = new ( this->pEngine->transactionFreeList ) ipAddrToAsciiTransactionPrivate ( *this );

    this->refcount++;

    return * ret;
}

void ipAddrToAsciiEnginePrivate::release ( )

virtual

Implements ipAddrToAsciiEngine.

Definition at line 184 of file ipAddrToAsciiAsynchronous.cpp.

{
    bool last;
    {
        epicsGuard < epicsMutex > guard ( this->pEngine->mutex );
        if(released)
            throw std::logic_error("Engine release() called again!");

        // released==true prevents new transactions
        released = true;

        {
            // cancel any pending transactions
            tsDLIter < ipAddrToAsciiTransactionPrivate > it(pEngine->labor.firstIter());
            while(it.valid()) {
                ipAddrToAsciiTransactionPrivate *trn = it.pointer();
                ++it;

                if(this==&trn->engine) {
                    trn->pending = false;
                    pEngine->labor.remove(*trn);
                }
            }

            // cancel transaction in lookup or callback
            if (pEngine->pCurrent && this==&pEngine->pCurrent->engine) {
                pEngine->pCurrent->pending = false;
                pEngine->pCurrent = 0;
            }

            // wait for completion of in-progress callback
            pEngine->cancelPendingCount++;
            while(pEngine->pActive && this==&pEngine->pActive->engine
                  && ! pEngine->thread.isCurrentThread()) {
                epicsGuardRelease < epicsMutex > unguard ( guard );
                pEngine->destructorBlockEvent.wait();
            }
            pEngine->cancelPendingCount--;
            if(pEngine->cancelPendingCount)
                pEngine->destructorBlockEvent.signal();
        }

        assert(refcount>0);
        last = 0==--refcount;
    }
    if(last) {
        delete this;
    }
}

void ipAddrToAsciiEnginePrivate::show ( unsigned  level ) const

virtual

Implements ipAddrToAsciiEngine.

Definition at line 234 of file ipAddrToAsciiAsynchronous.cpp.

{
    epicsGuard < epicsMutex > guard ( this->pEngine->mutex );
    printf ( "ipAddrToAsciiEngine at %p with %u requests pending\n",
        static_cast <const void *> (this), this->pEngine->labor.count () );
    if ( level > 0u ) {
        tsDLIter < ipAddrToAsciiTransactionPrivate >
            pItem = this->pEngine->labor.firstIter ();
        while ( pItem.valid () ) {
            pItem->show ( level - 1u );
            pItem++;
        }
    }
    if ( level > 1u ) {
        printf ( "mutex:\n" );
        this->pEngine->mutex.show ( level - 2u );
        printf ( "laborEvent:\n" );
        this->pEngine->laborEvent.show ( level - 2u );
        printf ( "exitFlag  boolean = %u\n", this->pEngine->exitFlag );
        printf ( "exit event:\n" );
    }
}

Member Data Documentation

ipAddrToAsciiGlobal * ipAddrToAsciiEnginePrivate::pEngine = 0

static

Definition at line 116 of file ipAddrToAsciiAsynchronous.cpp.

unsigned ipAddrToAsciiEnginePrivate::refcount

Definition at line 113 of file ipAddrToAsciiAsynchronous.cpp.

bool ipAddrToAsciiEnginePrivate::released

Definition at line 114 of file ipAddrToAsciiAsynchronous.cpp.

---

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

• modules/libcom/src/misc/ipAddrToAsciiAsynchronous.cpp