PLObjectManager Class Reference

#include <PLObjectManager.h>

Public Member Functions
	PLObjectManager (char *LogsDirectory)
	~PLObjectManager ()
HRESULT	Close (unsigned int *ResultSize, CRioObject *ObjectRioServer)
RioResult	PrefetchBlock (int block, unsigned int BlockSize, RioRequest *RequestRioServer, CRioObject *ObjectRioServer, int ip, RioStreamType traffic=UNICASTTRAFFIC, int port=0)
Private Member Functions
RioResult	Read (RioBlock Block, CRioObject *ObjectRioServer, RioRequest *Request, int ip, RioStreamType traffic=UNICASTTRAFFIC, int port=0)
Private Attributes
ofstream	m_log

---

Detailed Description

Definition at line 46 of file PLObjectManager.h.

---

Constructor & Destructor Documentation

PLObjectManager::PLObjectManager

(

char *

LogsDirectory

)

Definition at line 37 of file PLObjectManager.cpp.

{
    #ifdef RIO_DEBUG1
    RioErr << "### [PLObjectManager - Constructor] Start" << endl;
    #endif

    #if defined(RIO_DEBUG2) || defined(RIO_EMUL)
    // Variavel usada para compor o nome do arquivo com o log.
    char LogFileName[ MaxPathSize ];
    // Compoe o nome do arquivo com o log.
    strcpy( LogFileName, LogsDirectory );
    strcat( LogFileName, LOGFILE ); 
    m_log.open( LogFileName );
    #endif

    #ifdef RIO_DEBUG1
    RioErr << "### [PLObjectManager - Constructor] Finish" << endl;
    #endif
    
}

PLObjectManager::~PLObjectManager

(

)

Definition at line 59 of file PLObjectManager.cpp.

{
    #ifdef RIO_DEBUG1
    RioErr << "### [PLObjectManager - Destructor] Start" << endl;
    #endif

    #if defined(RIO_DEBUG2) || defined(RIO_EMUL)
    m_log.close();
    #endif

    #ifdef RIO_DEBUG1
    RioErr << "### [PLObjectManager - Destructor] Finish" << endl;
    #endif
}

---

Member Function Documentation

HRESULT PLObjectManager::Close	(	unsigned int *	ResultSize,
		CRioObject *	ObjectRioServer
	)

Definition at line 75 of file PLObjectManager.cpp.

{
    #ifdef RIO_DEBUG1
    RioErr << "### [PLObjectManager - Close] Start" << endl;
    #endif

    unsigned int Size;

    // Call method
    HRESULT hresult = ObjectRioServer->Close();

    // Check if Result Size is less than Result buffer
    Size = MAX_LONG_STRING_SIZE;
    if( Size > *ResultSize )
    {
        #ifdef RIO_DEBUG1
        RioErr << "### [PLObjectManager - Close] Finish 1" << endl;
        #endif

        return ERROR_CONNECTIONMANAGER + ERROR_RESULT_MESSAGE_OVERFLOW;
    }

    #ifdef RIO_DEBUG1
    RioErr << "### [PLObjectManager - Close] Finish 2" << endl;
    #endif

    return( hresult );
}

RioResult PLObjectManager::PrefetchBlock	(	int	block,
		unsigned int	BlockSize,
		RioRequest *	RequestRioServer,
		CRioObject *	ObjectRioServer,
		int	ip,
		RioStreamType	traffic = UNICASTTRAFFIC,
		int	port = 0
	)

Definition at line 106 of file PLObjectManager.cpp.

{
    #ifdef RIO_DEBUG1
    RioErr << "### [PLObjectManager - PrefetchBlock] Start" << endl;
    #endif

    RioResult hresult = 0;
    RioBlock Block    = block;

    RioObjectSize objectsize;

    ObjectRioServer->GetSize( &objectsize );

    RioBlock NumBlocks = (int) (( (objectsize - 1)/ BlockSize ) + 1);

//    ObjectRioServer->GetObjectStream()->SetCurPending( 0 );

    if( Block <= ( NumBlocks - 1 ) )
    {
        hresult = Read( Block,
                        ObjectRioServer,
                        RequestRioServer,
                        ip,
                        traffic,
                        port );

       if( FAILED( hresult ) )
       {
           RioErr << "[PLObjectManager]: Failed to read block: " << Block 
                  << endl;
       }
    }

    #ifdef RIO_DEBUG1
    RioErr << "### [PLObjectManager - Prefetch Block] Finish" << endl;
    #endif

    return( hresult );
}

RioResult PLObjectManager::Read	(	RioBlock	Block,
		CRioObject *	ObjectRioServer,
		RioRequest *	Request,
		int	ip,
		RioStreamType	traffic = UNICASTTRAFFIC,
		int	port = 0
	)			[private]

Definition at line 153 of file PLObjectManager.cpp.

{
    #ifdef RIO_DEBUG1
    RioErr << "### [PLObjectManager - Read] Start" << endl;
    #endif

    Request->Block        = Block;
    Request->Result       = S_OK;
    Request->Status       = RIO_REQUEST_FREE;
    Request->BufferStatus = 0;

    RioResult hResult = ObjectRioServer->StreamRead( Request, 0, traffic,
                                                     ip, port );

    if( FAILED( hResult ) )
    {
        RioErr << "[PLObjectManager]: Failed to read block: " << Block << endl;
    }

    #ifdef RIO_DEBUG1
    RioErr << "### [PLObjectManager - Read] Finish" << endl;
    #endif

    return( hResult );
}

---

Field Documentation

ofstream PLObjectManager::m_log [private]

Definition at line 68 of file PLObjectManager.h.

---

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

• PLObjectManager.h
• PLObjectManager.cpp