CObjectManager Class Reference

#include <ObjectManager.h>

Public Member Functions
	CObjectManager (CRioTCP *TCPconnection)
	~CObjectManager ()
HRESULT	Close (const ObjectHandle Handle)
HRESULT	GetSize (const ObjectHandle Handle, RioObjectSize *Size)
HRESULT	SetSize (const ObjectHandle Handle, const RioObjectSize Size, char *md5sum)
HRESULT	GetType (const ObjectHandle Handle, short *Type)
HRESULT	GetnBlocks (const ObjectHandle Handle, RioBlock *nBlocks)
HRESULT	NextObject (ObjectHandle Handle, int *IsDirectory, int BufferSize, signed char *ObjectName)
HRESULT	GetVideoRate (const ObjectHandle Handle, unsigned int *VideoRate)
	GetVideoRate retorna a taxa de transmissao (em Kbps) do video.
HRESULT	SetVideoRate (const ObjectHandle Handle, const unsigned int VideoRate)
	SetVideoRate altera a taxa de transmissao (em Kbps) do video.
HRESULT	ReallocBlocks (const ObjectHandle Handle, const RioBlock Block)
	Funcao usada para realocar os blocos fisicos do bloco logico passado como parametro.
	CObjectManager ()
	~CObjectManager ()
int	Reset ()
int	Stop ()
int	Start ()
int	Format ()
int	GetBlockMap (ObjectHandle Handle, RioBlock First, RioBlock nBlocks, RioDiskBlock *blocks)
int	GetnBlocks (ObjectHandle Handle, RioBlock *nBlocks)
int	GetType (ObjectHandle Handle, short *Type)
int	GetSize (ObjectHandle Handle, RioObjectSize *Size)
int	SetSize (ObjectHandle Handle, RioObjectSize Size)
int	Close (ObjectHandle Handle)
int	Open (char *ObjectPath, RioAccess Access, RioObject **Object)
int	Delete (char *ObjectPath)
int	Rename (char *OldPath, char *NewPath)
int	Create (char *Path, short Type)
int	Initialize (ObjectManagerConfig *Config)
int	GetBlockSize (unsigned int *BlockSize)
int	GetObjectInfo (char *ObjectName, ObjectInfo *ObjectInfo)
int	ExistDirectory (char *Path)
int	FirstObject (char *DirectoryPath, RioDirectory **Directory, int *IsDirectory, int BufferSize, char *ObjectName)
Static Public Member Functions
static int	StrToPath (const char *Str, char *PathName, const int MaxSize)
Private Member Functions
int	createdirectory (char *name)
int	RemoveDirectory (char *DirectoryName)
int	RemoveObject (char *ObjectName)
int	SetDefaultPermissions (char *name)
int	PathToFile (const char *Path, char *FileName, const int MaxSize)
Private Attributes
CRioTCP *	m_TCPconnection
ofstream	m_log
int	m_MaxReplications
int	m_UseReplications
bool	m_initialized
bool	m_started
char *	m_FileRoot
unsigned int	m_BlockSize
ObjMapMgr *	m_ObjMapMgr
DiskMgr *	m_DiskMgr
CUserManager *	m_UserManager
Friends
class	RioDirectory

---

Detailed Description

Definition at line 25 of file interface/ObjectManager.h.

---

Constructor & Destructor Documentation

CObjectManager::CObjectManager

(

CRioTCP *

TCPconnection

)

Definition at line 45 of file interface/ObjectManager.cpp.

{
    m_TCPconnection = TCPconnection;
}

CObjectManager::~CObjectManager

(

)

Definition at line 50 of file interface/ObjectManager.cpp.

{
}

CObjectManager::CObjectManager

(

)

Definition at line 82 of file server/ObjectManager.cpp.

{
    // m_log does not need to be initialized.
    m_MaxReplications = 0;
    m_UseReplications = 0;
    m_initialized     = false;
    m_started         = false;
    m_FileRoot        = NULL;
    m_BlockSize       = 0;
    m_ObjMapMgr       = NULL;
    m_DiskMgr         = NULL;
    m_UserManager     = NULL;
    
    #ifdef USE_GRID
    // Cria��o dos mutexes usados para a implementa��o da cache.
    pthread_mutex_init( &m_mutex_filelist, NULL );
    pthread_mutex_init( &m_mutex_gridcopy, NULL );
    // Inicializa��o dos ponteiros para a lista de arquivos na cache.
    m_StartListFiles = NULL;
    m_NextSearchFile = NULL;
    #endif
   
}

CObjectManager::~CObjectManager

(

)

---

Member Function Documentation

int CObjectManager::Close

(

ObjectHandle

Handle

)

HRESULT CObjectManager::Close

(

const ObjectHandle

Handle

)

Definition at line 55 of file interface/ObjectManager.cpp.

{
    char          *Parameter = (char*) malloc( MaxTCPDataSize*sizeof(char) );
    char          *Result;
    unsigned int  ParameterSize;
    unsigned int  ResultSize;
    HRESULT        status;

    if( Parameter == NULL )
    {
        RioErr << "malloc error Close:" << strerror(errno) << endl;
        free( Parameter );

        return ERROR_RIOPROXY + ERROR_MEMORY;
    }

    memset( Parameter, 0, MaxTCPDataSize*sizeof( char ) );

    ParameterSize = 2*MAX_LONG_STRING_SIZE;
    // Check if Parameter buffer is large enough
    if( ParameterSize > ( unsigned int ) MaxTCPDataSize )
    {
        free( Parameter );

        return ERROR_RIOPROXY + ERROR_CALL_MESSAGE_OVERFLOW;
    }

    int offset = 0;

    // Set parameters on asii buffer
    // Set Object Handle
    SetLong( Parameter, Handle.Version, &offset );
    SetLong( Parameter, Handle.Index, &offset );

    // Update Parameter size to actual size (previously was maximum
    //possible size)
    ParameterSize = offset;

    // Call remote method
    status = m_TCPconnection->Call( RioClassObjectManager,
                                    RioMethodObjectManagerClose,
                                    ParameterSize,
                                    Parameter,
                                    &ResultSize,
                                    &Result );

    // check if call failed
    if( FAILED( status ))
    {
        if( ( unsigned int ) status == ( ERROR_RIOTCP + ERROR_MEMORY ) )
            status = ERROR_RIOPROXY + ERROR_MEMORY;
        if( Result != NULL )
            free( Result );
        free( Parameter );

        return status;
    }

    offset = 0;
    // Get results from result buffer
    // Get method return value
    if( !GetLong( Result, ResultSize, &status, &offset ) )
    {
        free( Parameter );
        free( Result );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }

    free( Parameter );
    free( Result );

    return status;
}

int CObjectManager::Create	(	char *	Path,
		short	Type
	)

Definition at line 290 of file server/ObjectManager.cpp.

{
    int  rc;
    char name[ 2*MaxPathSize+1 ];

    #ifdef USE_GRID
    // Estrutura usada para obter o tempo de �ltimo acesso do arquivo.
    struct stat FileStat;
    #endif

    *name = '\0';

    if( ( rc = PathToFile( Path, name, sizeof( name ) ) ) )
        return rc;

    switch( Type )
    {
        case ObjectInfo::FILE_TYPE_DIRECTORY:
            rc = createdirectory( name );
            if( rc )
                return rc;
            break;

        case ObjectInfo::FILE_TYPE_DATA:
            rc = m_ObjMapMgr->createobject( name );

            if( rc )
                return rc;

            #ifdef USE_GRID
            // Obs: o que fazer se o arquivo for criado, e a coloca��o deste
            // arquivo na lista falhar?

            // Remove a refer�ncia anterior ao arquivo (caso estejamos
            // sobreescrevendo o arquivo). Ignoramos o erro, se este ocorrer,
            // pois o �nico erro poss�vel � o do arquivo n�o estar na lista (n�o
            // estamos fazendo uma sobreescri��o do arquivo).
            RemoveFile( Path );
            // Adiciona o novo arquivo criado � lista de arquivos.
            rc = stat( name, &FileStat );

            if( rc )
            {
                // Devemos remover o arquivo se o stat falhar? Ou devemos
                // colocar um tempo qualquer (como o tempo atual)?
                unlink( name );
                return ERROR_OBJECTMANAGER + ERROR_UNEXPECTED;
            }

            // Insere o arquivo na lista com os arquivos da cache.
            rc = InsertFile( Path, FileStat.st_atime );

            if( rc )
            {
                // Devemos remover o arquivo se o InsertFile falhar? Se n�o
                // fizermos isso, o arquivo somente poder� ser removido da
                // cache se reiniciarmos o servidor.
                unlink( name );
                return ERROR_OBJECTMANAGER + ERROR_UNEXPECTED;
            }

            // Usada para depurar o c�digo.
            PrintFileList();

            #endif

            break;

        default:
            return ERROR_OBJECTMANAGER + ERROR_INVALID_OBJECT_TYPE;
    }

    // ### set default permissions here (if needed)
    return S_OK;
}

int CObjectManager::createdirectory

(

char *

name

)

[private]

Definition at line 368 of file server/ObjectManager.cpp.

{
    int  error = 0;
    int status;

    status = mkdir( name, 0700 );

    if( status )
        error = errno;

    if( status )
    {
        switch( error )
        {
            case EEXIST:
                return ERROR_OBJECTMANAGER + ERROR_OBJECT_EXISTS;

            case ENOENT:
            case ENAMETOOLONG:
            case ENOTDIR:
                return ERROR_OBJECTMANAGER + ERROR_INVALID_OBJECTNAME;
        }
    }

    return S_OK;
}

int CObjectManager::Delete

(

char *

ObjectPath

)

Definition at line 460 of file server/ObjectManager.cpp.

{
    int         rc;
    struct stat mystat;
    char        name[ 2 *MaxPathSize+1 ];

    *name = '\0';

    if( ( rc = PathToFile( ObjectPath, name, sizeof( name ) ) ) )
        return rc;

    rc = stat( name, &mystat );
    if( rc )
    {
        #ifdef RIO_DEBUG2
        if( m_log.is_open() )
            m_log << "Could not find file " << name << endl;
        #endif

        return ERROR_OBJECTMANAGER + ERROR_INVALID_OBJECTNAME;
    }

    if( S_ISDIR( mystat.st_mode ) )
    {
        #ifdef RIO_DEBUG2
        if( m_log.is_open() )
            m_log << "Delete directory " << name << endl;
        #endif

        return RemoveDirectory( name );
    }
    else
        if( S_ISREG( mystat.st_mode ) )
        {
            #ifdef RIO_DEBUG2
            if( m_log.is_open() )
                m_log << "Delete object " << name << endl;
            #endif

            #ifdef USE_GRID
            // Implementa��o para renover os arquivos na cache.
            rc = RemoveObject( name );

            if( rc ) 
                return rc; // O que devemos fazer se o arquivo foi deletado? 
                           // Teremos um arquivo na lista inexistente na cache.

            // Remove o arquivo da lista com os arquivos da cache.
            rc = RemoveFile( ObjectPath );

            if( rc )
                return rc; // O �nico erro � o arquivo n�o estar na lista.

            // Usada para depurar o c�digo.
            PrintFileList();
            return S_OK;
            #else 
            return RemoveObject( name );
            #endif
        }

    return ERROR_OBJECTMANAGER + ERROR_INVALID_OBJECTNAME;
}

int CObjectManager::ExistDirectory

(

char *

Path

)

Definition at line 814 of file server/ObjectManager.cpp.

{
    int rc;
    struct stat mystat;
    char name[ 2*MaxPathSize+1 ];
    *name = '\0';

    if( ( rc = PathToFile( ObjectName, name, sizeof( name ) ) ) )
        return rc;

    rc = stat( name, &mystat );
    if( ( rc == 0 ) && ( S_ISDIR( mystat.st_mode ) ) )
        return S_OK;

    return ERROR_OBJECTMANAGER + ERROR_INVALID_OBJECTNAME;
}

int CObjectManager::FirstObject	(	char *	DirectoryPath,
		RioDirectory **	Directory,
		int *	IsDirectory,
		int	BufferSize,
		char *	ObjectName
	)

Definition at line 945 of file server/ObjectManager.cpp.

{
    int rc = 0;

    RioDirectory *op = new RioDirectory( this );
    if( op == 0 )
        return ERROR_OBJECTMANAGER + ERROR_MEMORY;

    if( ( rc = PathToFile( DirectoryPath, op->o_DirectoryName,
                           sizeof( op->o_DirectoryName ) ) ) )
        return rc;

    // ### Mutex to lock changes to RIO directories?? (future).
    // {would be inside of opendir/readdir routines?}.

    // Get first file.
    op->o_dir = opendir( op->o_DirectoryName );
    if( op->o_dir == NULL )
    {
        // Error on opendir (as directory can't be empty!).
        int error = errno;
        delete op;
        if( error == ENOENT )
            return ERROR_OBJECTMANAGER + ERROR_INVALID_DIRECTORYNAME;
    }

    *Directory = op;

    // Now just use NextObject to get 1st entry in directory.
    return op->NextObject( IsDirectory, BufferSize, ObjectName );
}

int CObjectManager::Format

(

)

int CObjectManager::GetBlockMap	(	ObjectHandle	Handle,
		RioBlock	First,
		RioBlock	nBlocks,
		RioDiskBlock *	blocks
	)

int CObjectManager::GetBlockSize

(

unsigned int *

BlockSize

)

int CObjectManager::GetnBlocks	(	ObjectHandle	Handle,
		RioBlock *	nBlocks
	)

HRESULT CObjectManager::GetnBlocks	(	const ObjectHandle	Handle,
		RioBlock *	nBlocks
	)

Definition at line 409 of file interface/ObjectManager.cpp.

{
    char          *Parameter = (char*) malloc( MaxTCPDataSize*sizeof(char) );
    char          *Result;
    unsigned int  ParameterSize;
    unsigned int  ResultSize;
    HRESULT        status;

    if( Parameter == NULL )
    {
        RioErr << "malloc error GetnBlocks:" << strerror(errno) << endl;
        free( Parameter );

        return ERROR_RIOPROXY + ERROR_MEMORY;
    }

    memset( Parameter, 0, MaxTCPDataSize*sizeof( char ) );

    ParameterSize = 2*MAX_LONG_STRING_SIZE;
    // Check if Parameter buffer is large enough
    if( ParameterSize > (unsigned int) MaxTCPDataSize )
    {
        free( Parameter );

        return ERROR_RIOPROXY + ERROR_CALL_MESSAGE_OVERFLOW;
    }

    int offset = 0;

    // Set parameters on asii buffer
    // Set Object Handle
    SetLong(Parameter,Handle.Version,&offset);
    SetLong(Parameter,Handle.Index,&offset);

    // Update Parameter size to actual size
    // (previously was maximum possible size)
    ParameterSize = offset;

    // Call remote method
    status = m_TCPconnection->Call( RioClassObjectManager,
                                    RioMethodObjectManagerGetnBlocks,
                                    ParameterSize,
                                    Parameter,
                                    &ResultSize,
                                    &Result );

    // check if call failed
    if( FAILED( status ) )
    {
        if( ( unsigned int ) status == ( ERROR_RIOTCP + ERROR_MEMORY ) )
            status = ERROR_RIOPROXY + ERROR_MEMORY;
        if( Result != NULL )
            free( Result );
        free( Parameter );

        return status;
    }

    offset = 0;
    // Get results from result buffer
    // Get method return value
    if( !GetLong( Result, ResultSize, &status, &offset ) )
    {
        free( Parameter );
        free( Result );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }
    // Get number of blocks
    if( !GetULong( Result, ResultSize, nBlocks, &offset ) )
    {
        free( Parameter );
        free( Result );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }

    free( Parameter );
    free( Result );

    return status;
}

int CObjectManager::GetObjectInfo	(	char *	ObjectName,
		ObjectInfo *	ObjectInfo
	)

Definition at line 801 of file server/ObjectManager.cpp.

{
    int rc;
    char name [ 2*MaxPathSize+1 ];
    *name = '\0';

    if( ( rc = PathToFile( ObjectName, name, sizeof( name ) ) ) )
        return rc;

    return m_ObjMapMgr->GetObjectInfo( name, ObjectInfo );
}

int CObjectManager::GetSize	(	ObjectHandle	Handle,
		RioObjectSize *	Size
	)

HRESULT CObjectManager::GetSize	(	const ObjectHandle	Handle,
		RioObjectSize *	Size
	)

Definition at line 131 of file interface/ObjectManager.cpp.

{
    char          *Parameter = (char*) malloc( MaxTCPDataSize*sizeof(char) );
    char          *Result;
    unsigned int  ParameterSize;
    unsigned int  ResultSize;
    HRESULT        status;

    if( Parameter == NULL )
    {
        RioErr << "malloc error GetSize:" << strerror(errno) << endl;
        free( Parameter );

        return ERROR_RIOPROXY + ERROR_MEMORY;
    }

    memset( Parameter, 0, MaxTCPDataSize*sizeof( char ) );

    ParameterSize = 2*MAX_LONG_STRING_SIZE;
    // Check if Parameter buffer is large enough
    if( ParameterSize > ( unsigned int ) MaxTCPDataSize )
    {
        free( Parameter );

        return ERROR_RIOPROXY + ERROR_CALL_MESSAGE_OVERFLOW;
    }

    int offset = 0;

    // Set parameters on asii buffer
    // Set Object Handle
    SetLong( Parameter, Handle.Version, &offset );
    SetLong( Parameter, Handle.Index, &offset );

    // Update Parameter size to actual size
    // (previously was maximum possible size)
    ParameterSize = offset;

    // Set Maximum result size (Size of buffer)
    // Call remote method
    status = m_TCPconnection->Call( RioClassObjectManager,
                                    RioMethodObjectManagerGetSize,
                                    ParameterSize,
                                    Parameter,
                                    &ResultSize,
                                    &Result );

    // check if call failed
    if( FAILED( status ) )
    {
        if( ( unsigned int ) status == ( ERROR_RIOTCP + ERROR_MEMORY ) )
            status = ERROR_RIOPROXY + ERROR_MEMORY;
        if( Result != NULL )
            free( Result );
        free( Parameter );

        return status;
    }

    offset = 0;
    // Get results from result buffer
    // Get method return value
    if( !GetLong( Result, ResultSize, &status, &offset ) )
    {
        free( Parameter );
        free( Result );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }
    // Get Object Size
    unsigned int highpart;
    unsigned int lowpart;
    if( !GetULong( Result, ResultSize, &highpart, &offset ) )
    {
        free( Parameter );
        free( Result );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }
    if( !GetULong( Result, ResultSize, &lowpart, &offset ) )
    {
        free( Parameter );
        free( Result );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }
    *Size = ((( RioObjectSize ) highpart ) << 32 ) | lowpart ;

    free( Parameter );
    free( Result );

    return status;
}

int CObjectManager::GetType	(	ObjectHandle	Handle,
		short *	Type
	)

HRESULT CObjectManager::GetType	(	const ObjectHandle	Handle,
		short *	Type
	)

Definition at line 321 of file interface/ObjectManager.cpp.

{
    char          *Parameter = (char*) malloc( MaxTCPDataSize*sizeof(char) );
    char          *Result;
    unsigned int  ParameterSize;
    unsigned int  ResultSize;
    HRESULT        status;

    if( Parameter == NULL )
    {
        RioErr << "malloc error GetType:" << strerror(errno) << endl;
        free( Parameter );

        return ERROR_RIOPROXY + ERROR_MEMORY;
    }

    memset( Parameter, 0, MaxTCPDataSize*sizeof( char ) );

    ParameterSize = 2*MAX_LONG_STRING_SIZE;
    // Check if Parameter buffer is large enough
    if( ParameterSize > (unsigned int) MaxTCPDataSize )
    {
        free( Parameter );

        return ERROR_RIOPROXY + ERROR_CALL_MESSAGE_OVERFLOW;
    }

    int offset = 0;

    // Set parameters on asii buffer
    // Set Object Handle
    SetLong( Parameter, Handle.Version, &offset );
    SetLong( Parameter, Handle.Index, &offset );

    // Update Parameter size to actual size
    // (previously was maximum possible size)
    ParameterSize = offset;

    // Call remote method
    status = m_TCPconnection->Call( RioClassObjectManager,
                                    RioMethodObjectManagerGetType,
                                    ParameterSize,
                                    Parameter,
                                    &ResultSize,
                                    &Result );

    // check if call failed
    if( FAILED( status ) )
    {
        if( ( unsigned int ) status == ( ERROR_RIOTCP + ERROR_MEMORY ) )
            status = ERROR_RIOPROXY + ERROR_MEMORY;
        if( Result != NULL )
            free( Result );
        free( Parameter );

        return status;
    }

    offset = 0;
    // Get results from result buffer
    // Get method return value
    if( !GetLong( Result, ResultSize, &status, &offset ) )
    {
        free( Parameter );
        free( Result );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }
    // Get Type
    short shortvalue;
    if( !GetShort( Result, ResultSize, &shortvalue, &offset ) )
    {
        free( Parameter );
        free( Result );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }

    *Type = shortvalue ;

    free( Parameter );
    free( Result );

    return status;
}

HRESULT CObjectManager::GetVideoRate	(	const ObjectHandle	Handle,
		unsigned int *	VideoRate
	)

GetVideoRate retorna a taxa de transmissao (em Kbps) do video.

Parameters:

	Handle	identificador do objeto cuja taxa de transmissao desejamos obter.
	VideoRate	ponteiro para o inteiro nao sinalizado que armazenara a taxa de transmissao do video.

Returns:

erro se nao foi possivel chamar o metodo ou se algum erro ocorreu ao executar o metodo.

Definition at line 604 of file interface/ObjectManager.cpp.

{
    char          *Parameter = (char*) malloc( MaxTCPDataSize*sizeof(char) );
    char          *Result;
    unsigned int  ParameterSize;
    unsigned int  ResultSize;
    HRESULT        status;

    if( Parameter == NULL )
    {
        RioErr << "malloc error GetVideoRate:" << strerror(errno) << endl;
        free( Parameter );

        return ERROR_RIOPROXY + ERROR_MEMORY;
    }

    memset( Parameter, 0, MaxTCPDataSize*sizeof( char ) );

    ParameterSize = 2*MAX_LONG_STRING_SIZE;
    // Check if Parameter buffer is large enough
    if( ParameterSize > ( unsigned int ) MaxTCPDataSize )
    {
        free( Parameter );

        return ERROR_RIOPROXY + ERROR_CALL_MESSAGE_OVERFLOW;
    }

    int offset = 0;

    // Set parameters on asii buffer
    // Set Object Handle
    SetLong( Parameter, Handle.Version, &offset );
    SetLong( Parameter, Handle.Index, &offset );

    // Update Parameter size to actual size
    // (previously was maximum possible size)
    ParameterSize = offset;

    // Call remote method
    status = m_TCPconnection->Call( RioClassObjectManager,
                                    RioMethodObjectManagerGetVideoRate,
                                    ParameterSize,
                                    Parameter,
                                    &ResultSize,
                                    &Result );

    // check if call failed
    if( FAILED( status ) )
    {
        if( ( unsigned int ) status == ( ERROR_RIOTCP + ERROR_MEMORY ) )
            status = ERROR_RIOPROXY + ERROR_MEMORY;
        if( Result != NULL )
            free( Result );
        free( Parameter );

        return status;
    }

    offset = 0;
    // Get results from result buffer
    // Get method return value
    if( !GetLong( Result, ResultSize, &status, &offset ) )
    {
        free( Parameter );
        free( Result );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }
    if( !GetULong( Result, ResultSize, VideoRate, &offset ) )
    {
        free( Parameter );
        free( Result );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }

    free( Parameter );
    free( Result );

    return status;
}

int CObjectManager::Initialize

(

ObjectManagerConfig *

Config

)

Definition at line 148 of file server/ObjectManager.cpp.

{
    int result;

    if( Config->GenerateLogs )
    {
        // Variavel usada para compor os nome do arquivo com o log.
        char LogFileName[ MaxPathSize ];
        // Compoe o nome do arquivo com o log.
        strcpy( LogFileName, Config->LogsDirectory );
        strcat( LogFileName, LOGFILE );
        m_log.open( LogFileName );
        if( !m_log.is_open() )
            return ERROR_OBJECTMANAGER + ERROR_LOGFILE ;
    }

    if( m_initialized )
    {
        if( m_log.is_open() )
            m_log << "Initialize(): Tried to initialize component "
                  << " already initialized" << endl;
        return ERROR_OBJECTMANAGER + ERROR_INITIALIZED;
    }

    if( ( strlen( Config->FileRoot ) + 1 ) > MaxPathSize )
    {
        if( m_log.is_open() )
            m_log << "CObjectManager::Initialize(). FileRoot name size too "
                  << "large: " << Config->FileRoot << " ("
                  << strlen( Config->FileRoot ) << ")" << endl;
        return ERROR_OBJECTMANAGER + ERROR_LARGE_ROOTNAME;
    }

    m_FileRoot = new char[ strlen( Config->FileRoot ) + 1 ];
    strcpy( m_FileRoot, Config->FileRoot );

    m_BlockSize       = Config->BlockSize;
    m_MaxReplications = Config->MaxReplications;
    m_UseReplications = Config->UseReplications;
    m_DiskMgr         = Config->c_DiskMgr;
    m_UserManager     = Config->UserManager;

    m_ObjMapMgr = new ObjMapMgr;
    if( m_ObjMapMgr == 0 )
    {
        if( m_log.is_open() ) 
            m_log << "CObjectManager::Initialize() new ObjMapMgr failed." 
                  << endl;
        return ERROR_OBJECTMANAGER + ERROR_MEMORY;
    }

    // Intialize Object Map Manager.
    result = m_ObjMapMgr->Initialize( Config->MaxNhandle, m_BlockSize,
                                      m_MaxReplications, m_UseReplications,
                                      m_DiskMgr, &m_log );
    if( FAILED( result ) )
        return result;

    #ifdef USE_GRID
    // Cria a lista com os arquivos do servidor, ordenada pelo tempo do �ltimo
    // acesso (usada pela funcionalidade de cache).
    result = CreateFileList();

    if( result != 0 )
    {
        if( m_log.is_open() )
            m_log << "CObjectManager::Initialize() CreateFileList failed."
                  << endl;
        return result;
    }

    // Usada para depurar o c�digo.
    PrintFileList();
    #endif

    m_initialized = true;

    return S_OK;
}

HRESULT CObjectManager::NextObject	(	ObjectHandle	Handle,
		int *	IsDirectory,
		int	BufferSize,
		signed char *	ObjectName
	)

Definition at line 494 of file interface/ObjectManager.cpp.

{
    char          *Parameter = (char*) malloc( MaxTCPDataSize*sizeof(char) );
    char          *Result;
    unsigned int  ParameterSize;
    unsigned int  ResultSize;
    HRESULT        status;

    if( Parameter == NULL )
    {
        RioErr << "malloc error NextObject:" << strerror(errno) << endl;
        free( Parameter );

        return ERROR_RIOPROXY + ERROR_MEMORY;
    }

    memset( Parameter, 0, MaxTCPDataSize*sizeof( char ) );

    ParameterSize = 3*MAX_LONG_STRING_SIZE;

    // Check if Parameter buffer is large enough
    if( ParameterSize > (unsigned int) MaxTCPDataSize )
    {
        free( Parameter );

        return ERROR_RIOPROXY + ERROR_CALL_MESSAGE_OVERFLOW;
    }

    int          offset = 0;
    // Set parameters on asii buffer
    // Set Object Handle
    SetLong( Parameter, Handle.Version, &offset );
    SetLong( Parameter, Handle.Index, &offset );
    // Set Buffer size
    SetLong( Parameter, BufferSize, &offset );

    // Update Parameter size to actual size
    // (previously was maximum possible size)
    ParameterSize = offset;

    // Call remote method
    status = m_TCPconnection->Call( RioClassObjectManager,
                                    RioMethodObjectManagerNextObject,
                                    ParameterSize,
                                    Parameter,
                                    &ResultSize,
                                    &Result );

    // check if call failed
    if( FAILED (status) )
    {
        if( ( unsigned int ) status == ( ERROR_RIOTCP + ERROR_MEMORY ) )
            status = ERROR_RIOPROXY + ERROR_MEMORY;
        if( Result != NULL )
            free( Result );
        free( Parameter );

        return status;
    }

    offset = 0;
    // Get results from result buffer
    // Get method return value
    if( !GetLong( Result, ResultSize, &status, &offset ) )
    {
        free( Parameter );
        free( Result );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }

    // Get Directory flag
    if( !GetLong( Result, ResultSize, IsDirectory, &offset ) )
    {
        free( Parameter );
        free( Result );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }

    // Get Object name
    char* str;
    if( !GetString( Result, ResultSize, &str, &offset ) )
    {
        free( Parameter );
        free( Result );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }

    if(status == S_OK)
    {
        strcpy( (char *)ObjectName, str );
    }

    free( Parameter );
    free( Result );

    return status;
}

int CObjectManager::Open	(	char *	ObjectPath,
		RioAccess	Access,
		RioObject **	Object
	)

Definition at line 572 of file server/ObjectManager.cpp.

{
    int  rc;
    char name[ 2*MaxPathSize+1 ];

    #ifdef USE_GRID
    // Vari�veis usadas pela implementa��o da GRID (cache).
    // Vari�vel usada para determinar os nomes dos outros arquivos associados a
    // um arquivo .mpg (nome no sistema de arquivos do Servidor RIO).
    char AuxObjectName[ 2*MaxPathSize+1 ]; 
    // Vari�vel usada para determinar os nomes dos outros arquivos associados a
    // um arquivo .mpg (nome no sistema de arquivos do sistema operacional, a
    // partir do diret�rio do Servidor RIO. Em geral, � o nome anterior com o
    // prefixo ''FileRoot/'').
    char AuxName[ 2*MaxPathSize+1 ];
    // Extens�es dos arquivos associados a um arquivo mpg (isto �, um arquivo
    // com um video de uma aula.
    // Obs: todas as extens�es est�o presentes? Ou alguma est� faltando?
    char *ObjectExtensions[ MAX_OBJECT_EXTENSIONS ] = { ".tgif", ".zip",
                                                        ".index", ".keyword",
                                                        ".xml"};
    RioObject    *AuxObject = NULL;
    unsigned int  rca;
    unsigned int  i;
    #endif

    *name = '\0';

    if( ( rc = PathToFile( ObjectName, name, sizeof( name ) ) ) )
        return rc;

    #ifdef USE_GRID
    // Obt�m o mutex para bloquear o acesso � lista com os arquivos da cache.
    pthread_mutex_lock( &m_mutex_filelist );

    rc = m_ObjMapMgr->Open( name, Access, Object );

    if( rc )
    {
        // Libera o acesso exclusivo � lista com os arquivos da cache.
        pthread_mutex_unlock( &m_mutex_filelist );

        // Obt�m o mutex para garantir que somente um arquivo � copiado da
        // GRID por vez.
        pthread_mutex_lock( &m_mutex_gridcopy );

        // Verifica se o arquivo j� foi copiado (pois a thread pode ter ficado
        // bloqueada no mutex esperando para poder fazer a copia, e uma outra
        // thread j� poderia ter copiado este arquivo para a cache).
        rc = m_ObjMapMgr->Open( name, Access, Object );

        if( rc )
        {
            // Tenta copiar o arquivo da GRID. Se o arquivo n�o foi copiado
            // com sucesso, o erro ocorrer� ao tentarmos reabrir o arquivo.
            CopyGridFile( ObjectName );
            // Tenta abrir o arquivo .mpg que acabou de ser copiado.
            // Obt�m novamente o acesso exclusivo � lista com os arquivos da
            // cache.
            pthread_mutex_lock( &m_mutex_filelist );

            // Tenta primeiramente abrir o objeto.
            if( m_log.is_open() )
                m_log << "CObjectManager::Open tentando abrir o arquivo "
                      << name << " associado ao objeto " << ObjectName << endl;
            rc = m_ObjMapMgr->Open( name, Access, Object );

            if( rc )
            {   
                // Se isso ocorrer, houve algum erro ao copiar o arquivo da
                // GRID.
                pthread_mutex_unlock( &m_mutex_filelist );
                pthread_mutex_unlock( &m_mutex_gridcopy );
                return rc;
            }

            // Incrementa o contador de refer�ncias ao arquivo que foi aberto
            // na lista com os arquivos que est�o na cache.
            rc = IncrementOpenFileCounter( ObjectName );
            // Libera o acesso exclusivo � lista  com os arquivos da cache.
            pthread_mutex_unlock( &m_mutex_filelist );
            // Imprime a nova lista (depura��o).
            PrintFileList();

            if( rc )
            {
                // O que devemos fazer neste caso? O nome do arquivo n�o existe
                // na lista. Optei por retornar um c�digo de erro e destruir o
                // objeto criado.
                delete Object;
                pthread_mutex_unlock( &m_mutex_gridcopy );
                return rc;
            }

            // Verifica o tipo do arquivo, e se for um v�deo (sufixo .mpg),
            // tenta copiar os arquivos associados a este video.
            if( ( strlen( ObjectName ) >= 4 ) && 
                ( strcmp( &ObjectName[ strlen( ObjectName )-4 ], ".mpg" ) 
                          == 0) )
            {

                if( m_log.is_open() )
                    m_log << "CObjectManager:: o arquivo " << ObjectName
                          << " e .mpg. Baixando os arquivos relacionados a "
                          << "ele." << endl;

                // Se for um arquivo terminado em .mpg.
                for( i = 0; i < MAX_OBJECT_EXTENSIONS; i++ )
                {
                    // Obt�m os nomes dos objetos.
                    strncpy( AuxObjectName, ObjectName,
                             strlen( ObjectName )-4 );

                    // Adiciona o caractere nulo ao final da string (o strncpy)
                    // n�o faz isso.
                    AuxObjectName[ strlen( ObjectName )-4 ] = 0;

                    strcat( AuxObjectName, ObjectExtensions[ i ] );
                    *AuxName = '\0'; // Cria uma string vazia 

                    if( (rca = PathToFile( AuxObjectName, AuxName,
                                           sizeof( AuxName ) ) ) )
                    {

                        if( m_log.is_open() )
                            m_log << "CObjectManager::Open nao foi possivel "
                                  << "converter o nome " << AuxObjectName 
                                  << " (erro " << rca << ")" << endl;
                    }
                    else // else do if( (rca = PathToFile( AuxObjectName, Au...
                    {

                        // Tenta primeiramente abrir o objeto.
                        if( m_log.is_open() )
                            m_log << "CObjectManager::Open tentando abrir o "
                                  << "arquivo " << AuxName << " associado ao "
                                  << "arquivo " << name << endl;

                        rca = m_ObjMapMgr->Open( AuxName, Access, &AuxObject );

                        if( rca )
                        {
                            // Se n�o tivermos sucesso, supomos que o arquivo
                            // n�o esta na cache, e o copiamos da GRID.
                            CopyGridFile( AuxObjectName );
                        }
                        else
                        {
                            // Se conseguimos abrir o arquivo, devemos
                            // simplesmente deletar o objeto temporario.
                            delete AuxObject;
                        }

                    } // fim do else do if( (rca = PathToFile( AuxObjectNam..

                } // fim do for (i = 0; i < MAX_OBJECT_EXTENSIONS; i++)

            }
            else // else do if ((strlen(ObjectName) >= 4) && ...
            {

                if( m_log.is_open() )
                    m_log << "CObjectManager:: o arquivo " << ObjectName
                          << " nao e um .mpg. " << endl;

            }

            // Libera o mutex para garantir que somente um arquivo � copiado da
            // GRID por vez.
            pthread_mutex_unlock( &m_mutex_gridcopy );
        }
        else // else do segundo comando if( rc )
        { 
            // Como o arquivo j� foi copiado, devemos simplesmente liberar o
            // mutex de c�pia.
            pthread_mutex_unlock( &m_mutex_gridcopy );
            // Obt�m novamente o acesso exclusivo � lista com os arquivos da
            // cache.
            pthread_mutex_lock( &m_mutex_filelist );
            // Incrementa o contador de refer�ncias ao arquivo que foi aberto
            // na lista com os arquivos que est�o na cache.
            rc = IncrementOpenFileCounter( ObjectName );
            // Libera o acesso exclusivo � lista  lista com os arquivos da
            // cache.
            pthread_mutex_unlock( &m_mutex_filelist );
            // Imprime a nova lista (depura��o).
            PrintFileList();

            if( rc )
            {
                // O que devemos fazer neste caso? O nome do arquivo n�o existe
                // na lista. Optei por retornar um c�digo de erro e destruir o
                // objeto criado.
                delete Object;
                return rc;
            }

        } // fim do else do segundo comando if( rc )

    }
    else // else do primeiro comando if( rc )
    {
        // Incrementa o contador de refer�ncias ao arquivo que foi aberto na
        // lista com os arquivos que est�o na cache.
        rc = IncrementOpenFileCounter( ObjectName );
        // Libera o acesso exclusivo � lista com os arquivos da cache.
        pthread_mutex_unlock( &m_mutex_filelist );
        // Imprime a nova lista (depura��o).
        PrintFileList();

        if( rc )
        {
            // O que devemos fazer neste caso? O nome do arquivo n�o existe na
            // lista. Optei por retornar um c�digo de erro e destruir o objeto
            // criado.
            delete Object;
            return rc;
        }

    } // fim do else do primeiro comando if( rc )

    return S_OK;
    #else
    return m_ObjMapMgr->Open( name, Access, Object );
    #endif
}

int CObjectManager::PathToFile	(	const char *	Path,
		char *	FileName,
		const int	MaxSize
	)			[private]

Definition at line 837 of file server/ObjectManager.cpp.

{
    int len = strlen( Path );

    if( ( len + strlen( m_FileRoot ) + 2 )  > ( unsigned ) MaxSize )
        return ERROR_PATHNAME_TOOLARGE;

    if( len == 0 )
    {
        strcpy( FileName, m_FileRoot );
        return S_OK;
    }

    strcpy( FileName, m_FileRoot );
    strcat( FileName, "/" );
    strcat( FileName, Path );

    return S_OK;
}

HRESULT CObjectManager::ReallocBlocks	(	const ObjectHandle	Handle,
		const RioBlock	Block
	)

Funcao usada para realocar os blocos fisicos do bloco logico passado como parametro.

Parameters:

Block

identificadao do bloco logico.

Returns:

S_OK se a realocacao foi feita com sucesso ou um valor diferente de S_OK se algum erro ocorreu.

Definition at line 776 of file interface/ObjectManager.cpp.

{
    char          *Parameter = (char*) malloc( MaxTCPDataSize*sizeof(char) );
    char          *Result;
    unsigned int  ParameterSize;
    unsigned int  ResultSize;
    HRESULT        status;

    if( Parameter == NULL )
    {
        RioErr << "malloc error ReallocBlocks:" << strerror(errno) << endl;
        free( Parameter );

        return ERROR_RIOPROXY + ERROR_MEMORY;
    }

    memset( Parameter, 0, MaxTCPDataSize*sizeof( char ) );

    ParameterSize = 2 * MAX_LONG_STRING_SIZE + MAX_ULONG_STRING_SIZE;
    // Check if Parameter buffer is large enough
    if( ParameterSize > (unsigned int) MaxTCPDataSize )
    {
        free( Parameter );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }

    int offset = 0;

    // Set parameters on asii buffer
    // Set Object Handle
    SetLong( Parameter, Handle.Version, &offset );
    SetLong( Parameter, Handle.Index, &offset );
    // Set Block
    SetULong( Parameter, ( unsigned int ) Block, &offset );

    // Update Parameter size to actual size
    // (previously was maximum possible size)
    ParameterSize = offset;

    // Call remote method
    status = m_TCPconnection->Call( RioClassObjectManager,
                                    RioMethodObjectManagerReallocBlocks,
                                    ParameterSize,
                                    Parameter,
                                    &ResultSize,
                                    &Result );

    // check if call failed
    if( FAILED( status ) )
    {
        if( ( unsigned int ) status == ( ERROR_RIOTCP + ERROR_MEMORY ) )
            status = ERROR_RIOPROXY + ERROR_MEMORY;
        if( Result != NULL )
            free( Result );
        free( Parameter );

        return status;
    }

    offset = 0;
    // Get results from result buffer
    // Get method return value
    if( !GetLong( Result, ResultSize, &status, &offset ) )
    {
        free( Parameter );
        free( Result );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }

    free( Parameter );
    free( Result );

    return status;
}

int CObjectManager::RemoveDirectory

(

char *

DirectoryName

)

[private]

Definition at line 525 of file server/ObjectManager.cpp.

{
    // ### Need some metadata mutex?
    int status;
    status = rmdir( DirectoryName );

    if( !status )
    {
        #ifdef RIO_DEBUG2
        if( m_log.is_open() )
            m_log << "Delete directory success"<< endl;
        #endif

        return S_OK;
    }
    else
    {
        #ifdef RIO_DEBUG2
        if( m_log.is_open() )
            m_log << "Delete directory failed"<< endl;
        #endif

        return ERROR_OBJECTMANAGER + ERROR_OBJECT_REMOVE_FAILED;
    }
}

int CObjectManager::RemoveObject

(

char *

ObjectName

)

[private]

Definition at line 552 of file server/ObjectManager.cpp.

{
    RioObject *Object;
    int        rc;

    // ### Need some metadata mutex?
    rc = m_ObjMapMgr->Open( ObjectName, RIO_READ_ACCESS | RIO_WRITE_ACCESS,
                            &Object );

    if( FAILED( rc ) )
        return rc;

    rc = Object->MarkDelete();

    delete Object;    // ### But don't get rc on delete.

    return rc;
}

int CObjectManager::Rename	(	char *	OldPath,
		char *	NewPath
	)

Definition at line 404 of file server/ObjectManager.cpp.

{
    int  rc;
    int  error;
    char oldname[ 2*MaxPathSize+1 ];
    char newname[ 2*MaxPathSize+1 ];

    *oldname = '\0';
    *newname = '\0';

    if( ( rc = PathToFile( OldPath, oldname, sizeof( oldname ) ) ) )
        return rc;

    if( ( rc = PathToFile( NewPath, newname, sizeof( newname ) ) ) )
        return rc;

    if( ( rc = rename( oldname, newname ) ) != 0 )
        error = errno;

    #ifdef USE_GRID
    // Implementa��o para renomear os arquivos na cache.
    if( !rc )
    {
        // Renomeia o arquivo na lista com os arquivos da cache.
        rc = RenameFile( OldPath, NewPath );
        
        if( rc )
        {
            // Devemos renomear novamente o arquivo, para garantir a
            // consist�ncia?
            rename( newname, oldname );
            // Este erro � o adequado?
            return ERROR_OBJECTMANAGER + ERROR_OBJECT_OPEN_FAILED; 
        }
        
        // Usada para depurar o c�digo.
        PrintFileList();
        return S_OK;
    }
    #else
    if( !rc )
        return S_OK;
    #endif
    else
    {
        //### Needs better error return values (?)
        //      if(error == ERROR_ALREADY_EXISTS)
        //       return ERROR_OBJECTMANAGER + ERROR_OBJECT_EXISTS;
        //      if(error == ERROR_INVALID_NAME)
        //       return ERROR_OBJECTMANAGER + ERROR_INVALID_OBJECTNAME;
        return ERROR_OBJECTMANAGER + ERROR_OBJECT_OPEN_FAILED;
    }
}

int CObjectManager::Reset

(

void

)

Definition at line 130 of file server/ObjectManager.cpp.

{
    m_BlockSize   = 0;
    m_initialized = false;
    m_started     = false;

    if( m_FileRoot != NULL ) 
        delete[] m_FileRoot;
    m_FileRoot = 0;

    // Remove o objeto m_ObjMapMgr.
    if( m_ObjMapMgr != NULL )
        delete m_ObjMapMgr;
    m_ObjMapMgr = NULL;

    return S_OK;
}

int CObjectManager::SetDefaultPermissions

(

char *

name

)

[private]

Definition at line 397 of file server/ObjectManager.cpp.

{
    return S_OK;
}

int CObjectManager::SetSize	(	ObjectHandle	Handle,
		RioObjectSize	Size
	)

HRESULT CObjectManager::SetSize	(	const ObjectHandle	Handle,
		const RioObjectSize	Size,
		char *	md5sum
	)

Definition at line 227 of file interface/ObjectManager.cpp.

{
    char          *Parameter = (char*) malloc( MaxTCPDataSize*sizeof(char) );
    char          *Result;
    unsigned int  ParameterSize;
    unsigned int  ResultSize;
    HRESULT        status;

    if( Parameter == NULL )
    {
        RioErr << "malloc error SetSize:" << strerror(errno) << endl;
        free( Parameter );

        return ERROR_RIOPROXY + ERROR_MEMORY;
    }

    memset( Parameter, 0, MaxTCPDataSize*sizeof( char ) );

    ParameterSize = 2*MAX_LONG_STRING_SIZE +
                    2*MAX_ULONG_STRING_SIZE +
                    strlen( md5sum );

    // Check if Parameter buffer is large enough
    if( ParameterSize > (unsigned int) MaxTCPDataSize )
    {
        free( Parameter );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }

    int offset = 0;

    // Set parameters on asii buffer

    // Set Object Handle
    SetLong( Parameter, Handle.Version, &offset );
    SetLong( Parameter, Handle.Index, &offset );
    // Set Object Size
    unsigned int highpart = (unsigned int) ((Size >> 32) & 0xffffffff);
    unsigned int lowpart = (unsigned int)(Size & 0xffffffff);
    SetULong( Parameter, highpart, &offset );
    SetULong( Parameter, lowpart, &offset );

    if( md5sum == NULL )
        SetString( Parameter, "0", &offset ); //NULL md5sum's are used for
                                              //directories, and represented by 
                                              //a single 0
    else 
        SetString( Parameter, md5sum, &offset );

    // Update Parameter size to actual size
    // (previously was maximum possible size)
    ParameterSize = offset;

    // Call remote method
    status = m_TCPconnection->Call( RioClassObjectManager,
                                    RioMethodObjectManagerSetSize,
                                    ParameterSize,
                                    Parameter,
                                    &ResultSize,
                                    &Result );

    // check if call failed
    if( FAILED( status ) )
    {
        if( Result != NULL )
            free( Result );
        if( ( unsigned int ) status == ( ERROR_RIOTCP + ERROR_MEMORY ) )
            status = ERROR_RIOPROXY + ERROR_MEMORY;
        free( Parameter );

        return status;
    }

    offset = 0;
    // Get results from result buffer
    // Get method return value
    if( !GetLong( Result, ResultSize, &status, &offset ) )
    {
        free( Parameter );
        free( Result );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }

    free( Parameter );
    free( Result );

    return status;
}

HRESULT CObjectManager::SetVideoRate	(	const ObjectHandle	Handle,
		const unsigned int	VideoRate
	)

SetVideoRate altera a taxa de transmissao (em Kbps) do video.

Parameters:

	Handle	identificador do objeto cuja taxa de transmissao desejamos alterar.
	VideoRate	nova taxa de transmissao do video.

Returns:

erro se nao foi possivel chamar o metodo ou se algum erro ocorreu ao executar o metodo.

Definition at line 691 of file interface/ObjectManager.cpp.

{
    char          *Parameter = (char*) malloc( MaxTCPDataSize*sizeof(char) );
    char          *Result;
    unsigned int  ParameterSize;
    unsigned int  ResultSize;
    HRESULT        status;

    if( Parameter == NULL )
    {
        RioErr << "malloc error SetVideoRate:" << strerror(errno) << endl;
        free( Parameter );

        return ERROR_RIOPROXY + ERROR_MEMORY;
    }

    memset( Parameter, 0, MaxTCPDataSize*sizeof( char ) );

    ParameterSize = 2*MAX_LONG_STRING_SIZE + MAX_ULONG_STRING_SIZE;
    // Check if Parameter buffer is large enough
    if( ParameterSize > (unsigned int) MaxTCPDataSize )
    {
        free( Parameter );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }

    int offset = 0;

    // Set parameters on asii buffer
    // Set Object Handle
    SetLong( Parameter, Handle.Version, &offset );
    SetLong( Parameter, Handle.Index, &offset );
    // Set Object transmission rate.
    SetULong( Parameter, VideoRate, &offset );

    // Update Parameter size to actual size
    // (previously was maximum possible size)
    ParameterSize = offset;

    // Call remote method
    status = m_TCPconnection->Call( RioClassObjectManager,
                                    RioMethodObjectManagerSetVideoRate,
                                    ParameterSize,
                                    Parameter,
                                    &ResultSize,
                                    &Result );

    // check if call failed
    if( FAILED( status ) )
    {
        if( ( unsigned int ) status == ( ERROR_RIOTCP + ERROR_MEMORY ) )
            status = ERROR_RIOPROXY + ERROR_MEMORY;
        if( Result != NULL )
            free( Result );
        free( Parameter );

        return status;
    }

    offset = 0;
    // Get results from result buffer
    // Get method return value
    if( !GetLong( Result, ResultSize, &status, &offset ) )
    {
        free( Parameter );
        free( Result );

        return ERROR_RIOPROXY + ERROR_MESSAGE_DATA_FORMAT;
    }

    free( Parameter );
    free( Result );

    return status;
}

int CObjectManager::Start

(

void

)

Definition at line 228 of file server/ObjectManager.cpp.

{
    HRESULT result;

    // Make sure we are initialized.
    if( !m_initialized )
    {
        if( m_log.is_open() )
            m_log << "Start(): Component not initiallized" << endl;

        return ERROR_OBJECTMANAGER + ERROR_NOT_INITIALIZED;
    }

    // Make sure we are not started.
    if( m_started )
    {
        if( m_log.is_open() )
            m_log << "Start(): Component already started" << endl;

        return( ERROR_OBJECTMANAGER + ERROR_STARTED );
    }

    // Start Object Map Manager.
    result = m_ObjMapMgr->Start();
    if( FAILED( result ) )
        return result;

    m_started = true;

    return S_OK;
}

int CObjectManager::Stop

(

void

)

Definition at line 261 of file server/ObjectManager.cpp.

{
    int result;

    // Make sure we are started.
    if( !m_started )
    {
        if( m_log.is_open() )
            m_log << "Stop(): Component not started" << endl;

        return( ERROR_OBJECTMANAGER + ERROR_NOT_STARTED );
    }

    // Handle table can fail to stop if the table is still in use.
    result = m_ObjMapMgr->Stop();
    if( FAILED( result ) )
        return result;

    m_started = false;

    return S_OK;
}

int CObjectManager::StrToPath	(	const char *	Str,
		char *	PathName,
		const int	MaxSize
	)			[static]

Definition at line 860 of file server/ObjectManager.cpp.

{
    const char *si;
    const char *dirs;
    char       *so;
    char       *sl;
    int         len;
    char        FullPathName[ MaxPathSize + 10 ];
    *FullPathName = '\0';

    *PathName = '\0'; // Default if return false.

    //if( *Str == '\0' ) // Empty path
   //   return ERROR_OBJECTMANAGER + ERROR_PATHNAME_BADSYNTAX;

    dirs = Str;
    so = FullPathName;
    sl = so + MaxPathSize; // String limit.
    while( *dirs != '\0' )
    {
        while( *dirs == '/' )
            dirs++; // Eat "/"s before name.
        // Find end of this directory in input string.
        for( si = dirs; *si != '\0' && *si != '/'; si++ )
            ;
        // Check if this is "." or "..".
        len = si - dirs;

        if( len == 0 )
        {
            dirs = si; // Nao copia nenhum subcaminho neste caso.
        }
        else
            if( ( len == 1 ) && ( *dirs == '.' ) )
                dirs = si; // Eat "." directory.
            else
                if( ( len == 2 ) && ( dirs[ 0 ] == '.' ) && 
                    ( dirs[ 1 ] == '.' ) )
                {
                    dirs = si; // Will process ..
                    // Back up output one directory
                    if( so <= FullPathName )
                        // Less than null path
                        return ERROR_OBJECTMANAGER + ERROR_PATHNAME_BADSYNTAX;
                    do
                    {
                        so--;
                    }while( ( so >= FullPathName ) && ( *so != '/' ) );

                    // Se o cd .. for feito no home deve voltar para o "/".
                    if( so < FullPathName )
                    {
                        so++;
                        if( strcmp( so, FullPathName ) == 0 )
                        {
                            FullPathName[ 0 ] = '\0';
                        }
                        so--;
                    }
                }
                else
                {
                    // Copy directory to output string.
                    if( so != FullPathName )
                        *so++ = '/';
                    if( ( so+len ) > sl )
                        return ERROR_OBJECTMANAGER + ERROR_PATHNAME_TOOLARGE;
                    memcpy( so, dirs, len );
                    so += len;
                    dirs += len;
                }
    }
    *so++ = '\0';

    if( ( so - FullPathName ) > MaxSize )
        return ERROR_OBJECTMANAGER + ERROR_PATHNAME_TOOLARGE;

    strcpy( PathName, FullPathName );

    return S_OK;
}

---

Friends And Related Function Documentation

friend class RioDirectory [friend]

Definition at line 369 of file server/ObjectManager.h.

---

Field Documentation

unsigned int CObjectManager::m_BlockSize [private]

Definition at line 134 of file server/ObjectManager.h.

DiskMgr* CObjectManager::m_DiskMgr [private]

Definition at line 136 of file server/ObjectManager.h.

char* CObjectManager::m_FileRoot [private]

Definition at line 133 of file server/ObjectManager.h.

bool CObjectManager::m_initialized [private]

Definition at line 131 of file server/ObjectManager.h.

ofstream CObjectManager::m_log [private]

Definition at line 128 of file server/ObjectManager.h.

int CObjectManager::m_MaxReplications [private]

Definition at line 129 of file server/ObjectManager.h.

ObjMapMgr* CObjectManager::m_ObjMapMgr [private]

Definition at line 135 of file server/ObjectManager.h.

bool CObjectManager::m_started [private]

Definition at line 132 of file server/ObjectManager.h.

CRioTCP* CObjectManager::m_TCPconnection [private]

Definition at line 80 of file interface/ObjectManager.h.

int CObjectManager::m_UseReplications [private]

Definition at line 130 of file server/ObjectManager.h.

CUserManager* CObjectManager::m_UserManager [private]

Definition at line 137 of file server/ObjectManager.h.

---

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

• interface/ObjectManager.h
• server/ObjectManager.h
• interface/ObjectManager.cpp
• server/ObjectManager.cpp