CRequestManager Class Reference

#include <request.h>

Public Member Functions
	CRequestManager ()
	~CRequestManager ()
int	Initialize (const unsigned int nRequests, const unsigned int BufferSize)
void	Free (StrRequest *Request)
StrRequest *	New ()
StrRequest *	Get (const u32 ReqId)
Private Attributes
unsigned int	m_n
CRioFreeList	m_FreeList
StrRequest *	m_Request
CBufferManager	m_BufferManager

---

Detailed Description

Definition at line 96 of file request.h.

---

Constructor & Destructor Documentation

CRequestManager::CRequestManager

(

)

Definition at line 64 of file request.cpp.

{
    m_Request = NULL;
    m_n       = 0;
}

CRequestManager::~CRequestManager

(

)

Definition at line 70 of file request.cpp.

{
    if(m_Request != 0)
    {
        delete[] m_Request;
    }
}

---

Member Function Documentation

void CRequestManager::Free

(

StrRequest *

Request

)

Definition at line 131 of file request.cpp.

{
    // Higher order 16 bits are version number, incremented every time
    // request is free. Lower order 16 bits are index to
    // vector m_Request

    //RioErr << "Free request: (before): " << (void *) Request->Id << endl;

    u32 Version = ((Request->Id & 0xffff0000) >> 16 );
    Version ++;
    u32 Ind     = Request->Id & 0xffff;
    Request->Id = Ind | (Version << 16);
    Request->Status = RequestStatusFree;


    //RioErr << "Version: " << (void*) Version << endl;
    //RioErr << "Free request: (after): " << (void*) Request->Id << endl;

    m_FreeList.Free( (RioQueueEle*)Request);
}

StrRequest * CRequestManager::Get

(

const u32

ReqId

)

Definition at line 166 of file request.cpp.

{
    StrRequest* rp;

    // lower 16 bits are index to vector m_Request;
    unsigned int ind = ReqId & 0xffff;

    if(ind >= m_n)
        return 0;

    rp = &m_Request[ind];

    // Request must be in use and Request Id version must match
    if( (rp->Status != RequestStatusFree) && (rp->Id == ReqId) )
        return rp;
    else
        return 0;
}

int CRequestManager::Initialize	(	const unsigned int	nRequests,
		const unsigned int	BufferSize
	)

Definition at line 79 of file request.cpp.

{

    // debug -----------------------------------------------
    RioErr << "RequestManager: Max number = " << 0xffff << endl;
    RioErr << "RequestManager: Using = "<< nRequest << endl;
    // ------------------------------------------------------------------------

    // Request index has to fit in 16 bits
    if( ( nRequest <= 0 ) || ( nRequest > 0xffff ))
    {
        return ERROR_SS_PROGRAM_ERROR;
    }

    // In case was initialized before
    if(m_Request != 0)
    {
        delete[] m_Request;
        m_n = 0;
    }

    m_Request = new StrRequest[nRequest];

    if( m_Request == 0 )
        return ERROR_SS_MEMORY;

    m_n = nRequest;

    int stat = m_BufferManager.Initialize( nRequest,BufferSize );

    if(stat < 0)
    {
        delete[] m_Request;
        return stat;
    }

    for( int i= ((int)(nRequest))-1; i>=0; i-- )
    {
        m_Request[i].Status = RequestStatusFree;
        m_Request[i].Id = i;
        m_Request[i].Buffer = m_BufferManager.New();
        m_Request[i].Data = m_Request[i].Buffer->Data;
        m_FreeList.Free((RioQueueEle*)&m_Request[i]);
    }

    return (0);

}

StrRequest * CRequestManager::New

(

)

Definition at line 155 of file request.cpp.

{
    StrRequest* rp;

    rp = (StrRequest*) m_FreeList.GetNB();

    return rp;
}

---

Field Documentation

CBufferManager CRequestManager::m_BufferManager [private]

Definition at line 113 of file request.h.

CRioFreeList CRequestManager::m_FreeList [private]

Definition at line 111 of file request.h.

unsigned int CRequestManager::m_n [private]

Definition at line 110 of file request.h.

StrRequest* CRequestManager::m_Request [private]

Definition at line 112 of file request.h.

---

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

• request.h
• request.cpp