NQMessagePool.h

Go to the documentation of this file.

// MessageBuffers.h: interface for the CNQMessageBuffers class.
//

#ifndef __NQMESSAGEPOOL_H_INCLUDED__SW__
#define __NQMESSAGEPOOL_H_INCLUDED__SW__

class CNQMessagePool : public CNQLockMechanism 
{
    friend class CNetworkQueue; // (-!-)

public:
    CNQMessagePool();
    virtual ~CNQMessagePool();

    //  initialize 'numbuffers' empty CNQMessage objects
    bool Initialize( UINT32 numbuffers );
    
    //  free memory, clean up anything
    bool Deinitialize();


protected:
    // (-!-)
    //  obtain a free (refcount 0) CNQMessage object
    CNQMessage *acquire_reference();
    
    //  put reference back (decrement reference count and clear CNQMessage if refcount is zero)
    bool putback_reference( CNQMessage *ref );
    
    //  increment reference count by 1 for a already taken CNQMessage (by get_reference())
    bool increment_referencecount( CNQMessage *buffer_ref );
    // (-!-)

private:
    bool    m_bInitialized;
    
    UINT32  m_iSharedReferences;

    UINT32  m_iNumBuffers;
    
    CNQMessage *m_pCMessages;
    
    UINT32  *m_pTakenBuffer;

};

#endif // __NQMESSAGEPOOL_H_INCLUDED__SW__

---