BufferStream Class Reference

#include <BufferStream.h>

Public Member Functions
	BufferStream (char *fileName, unsigned int streamSize, unsigned int blockSize)
	~BufferStream ()
int	getNextBlock (unsigned int *block)
unsigned int	getBlockSize ()
void	setFileName (const char *fileName)
void	setFileName (const char *fileName, const char *localPath)
char *	getFileName ()
int	writeBlock (unsigned int n, unsigned char *block)
int	readBlock (unsigned int n, unsigned char *block)
int	exist (unsigned int n)
int	isUnicast (unsigned int n)
void	setUnicast (unsigned int n)
Protected Attributes
unsigned int	blockSize
StreamControl *	streamControl
unsigned int	streamSize
FILE *	streamFile
char	fileName [MAXLEN_FILE+MAXLEN_FILE+1]
int	offset
unsigned int	writePoint

---

Detailed Description

Definition at line 30 of file BufferStream.h.

---

Constructor & Destructor Documentation

BufferStream::BufferStream	(	char *	fileName,
		unsigned int	streamSize,
		unsigned int	blockSize
	)

Definition at line 29 of file BufferStream.cpp.

{
    #ifndef RIO_EMUL
    char  path[ MAXLEN_FILE + 1 ];
    #endif

    streamControl = new StreamControl [ streamSize ];

    for( int i = 0 ; i < (int)streamSize ; i++ )
    {
        streamControl[ i ].writePoint = 0;
        streamControl[ i ].unicastRequested = false;
    }

    #ifndef RIO_EMUL
    if( getcwd( path, MAXLEN_FILE ) == NULL ) 
    {
        RioErr << "[ Error ] Unable to get working directory " << endl;
    }
    setFileName( ( const char * ) fileName );
    #endif

    this->streamSize = streamSize;
    this->blockSize = blockSize;

    this->writePoint = 0;
    this->offset = 0;

    #ifndef RIO_EMUL
    char tempName[ MAXLEN_FILE +1];
    strcpy( tempName , "riommclientStream." );
    strncat( tempName , getFileName() , MAXLEN_FILE - 6 - 1 );
    strcat( tempName , ".XXXXXX" );
    int fd = mkstemp( tempName );
    if( fd )
        close( fd );

    setFileName( tempName, path );
    if( ( streamFile = fopen( getFileName() , "w+" ) ) == NULL ) {
        RioErr << "[ Error ] Unable to Open " << getFileName() << endl;
    }
    #ifdef RIO_DEBUG2
    else
        RioErr << "Creating cache at " << getFileName() << endl;
    #endif
    #endif // end ifndef RIO_EMUL

}

BufferStream::~BufferStream

(

)

Definition at line 79 of file BufferStream.cpp.

{
    #ifndef RIO_EMUL
    if( streamFile )
    {
        fclose( streamFile );
        remove( getFileName() );
    }
    #endif

    delete[] streamControl;
}

---

Member Function Documentation

int BufferStream::exist

(

unsigned int

n

)

Definition at line 274 of file BufferStream.cpp.

{
    if( n >= streamSize )
        return 0;

    if( streamControl[ n ].writePoint == 0 )
        return 0;
    else
        return 1;
}

unsigned int BufferStream::getBlockSize

(

)

Definition at line 92 of file BufferStream.cpp.

{
    return this->blockSize;
}

char * BufferStream::getFileName

(

void

)

Definition at line 131 of file BufferStream.cpp.

{
    return this->fileName;
}

int BufferStream::getNextBlock

(

unsigned int *

block

)

Definition at line 195 of file BufferStream.cpp.

{
    if( !block )
        return 1;

    if( *block > streamSize )
        return 2;

    while( exist( *block ) )
        (*block)++;

    return 0;
}

int BufferStream::isUnicast

(

unsigned int

n

)

Definition at line 297 of file BufferStream.cpp.

{
    if( n >= streamSize )
    {
        #ifdef RIO_DEBUG2
        RioErr << "[BufferStream - isUnicast] Erro tentando acessar posicao "
               << "inexistente da cache: " << n << "/" << streamSize << endl;
        #endif

        return -1;
    }

    return streamControl[n].unicastRequested;
}

int BufferStream::readBlock	(	unsigned int	n,
		unsigned char *	block
	)

Definition at line 209 of file BufferStream.cpp.

{
    #ifndef RIO_EMUL
    unsigned int readN;
    #endif

    int status;

    status = 5;

    #ifndef RIO_EMUL
    if( streamFile == NULL )
        status = 2;
    #endif

    if( status == 5 && n >= streamSize )
        status = 1;
    else if( status == 5 && streamControl[ n ].writePoint == 0 )
        status = 3;

    #ifndef RIO_EMUL
    {
        if( fseek( streamFile, ( streamControl[n].writePoint - 1 ) * blockSize,
            SEEK_SET ) == 0)
        {
            #ifdef RIO_DEBUG2
            RioErr << "[BufferStream] readBlock - Lendo bloco " << n
                   << " da cache... ";
            #endif

            if( ( readN = fread( block , 1 , blockSize , streamFile ) ) ==
                blockSize
              )
            {
                status = 0;
            }
            else
            {
                status = 4;
            }

            #ifdef RIO_DEBUG2
            RioErr << "lido " << (float) ( 100 * readN ) / (float) blockSize
                   << "%"<< endl;
            #endif

        }
        #ifdef RIO_DEBUG2
        else
            RioErr << "[BufferStream] readBlock - Bloco " << n
                   << " n�o est� na cache... " << endl;
        #endif
    }
    #else
    {
        if( status == 5 )
        {
            status = 0;
        }
    }
    #endif

    return status;
}

void BufferStream::setFileName	(	const char *	fileName,
		const char *	localPath
	)

Definition at line 119 of file BufferStream.cpp.

{
    char file[ MAXLEN_FILE + MAXLEN_FILE + 1 ];

    setFileName( fileName );
    if( localPath )
    {
        sprintf( file, "%s/%s", localPath, fileName );
        strcpy( this->fileName, file );
    }
}

void BufferStream::setFileName

(

const char *

fileName

)

Definition at line 97 of file BufferStream.cpp.

{
    if( fileName )
    {
        char file[ MAXLEN_FILE + 1 ];
        strncpy( file , fileName , MAXLEN_FILE );

        char *shortFileName;
        if( ( shortFileName = strrchr( file , '/' ) ) == NULL )
            shortFileName = file;
        else
            shortFileName++;

        snprintf( this->fileName , MAXLEN_FILE , "%s" , shortFileName );
        this->fileName[ MAXLEN_FILE ] = '\0';
    }
    else
    {
        strcpy( this->fileName , "" );
    }
}

void BufferStream::setUnicast

(

unsigned int

n

)

Definition at line 312 of file BufferStream.cpp.

{
    streamControl[n].unicastRequested = true;
}

int BufferStream::writeBlock	(	unsigned int	n,
		unsigned char *	block
	)

Definition at line 137 of file BufferStream.cpp.

{

    #ifdef RIO_EMUL
    bool simulacao = true;
    #endif

    #ifndef RIO_EMUL
    if( streamFile == NULL )
        return 2;
    #endif

    unsigned int writeN = 0;

    if( n >= streamSize )
        return 1;

    #ifdef RIO_EMUL
    if( simulacao )
    #else
    //IMPORTANT: Offset here is different of zero when occur an write error,
    //it avoid crashes
    if( fseek( streamFile , offset  , SEEK_END ) == 0 )
    {
        if( ( writeN = fwrite( block , 1 , blockSize , streamFile ) ) ==
            blockSize
          )
    #endif
        {
            offset = 0;
            writePoint++;
            streamControl[ n ].writePoint = writePoint;

            #ifdef RIO_DEBUG2
            RioErr << "[BufferStream] BUFFER GRAVADO (Bloco="<< n
                   << " & Posicao=" << streamControl[ n ].writePoint << ")" << endl;
            #endif

            return 0;
        }
        else
        {
            offset = -1 * writeN;

            #ifdef RIO_DEBUG2
            RioErr << "[BufferStream] Nao conseguiu gravar dados na cache."
                   << endl;
            #endif

            return 1;
        }
    #ifndef RIO_EMUL
    }
    #endif

    return 1;
}

---

Field Documentation

unsigned int BufferStream::blockSize [protected]

Definition at line 33 of file BufferStream.h.

char BufferStream::fileName[MAXLEN_FILE+MAXLEN_FILE+1] [protected]

Definition at line 37 of file BufferStream.h.

int BufferStream::offset [protected]

Definition at line 38 of file BufferStream.h.

StreamControl* BufferStream::streamControl [protected]

Definition at line 34 of file BufferStream.h.

FILE* BufferStream::streamFile [protected]

Definition at line 36 of file BufferStream.h.

unsigned int BufferStream::streamSize [protected]

Definition at line 35 of file BufferStream.h.

unsigned int BufferStream::writePoint [protected]

Definition at line 39 of file BufferStream.h.

---

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

• BufferStream.h
• BufferStream.cpp