CRioMMMp3 Class Reference

#include <RioMMMp3.h>

Inherits CRioMMObject.

Public Member Functions
	CRioMMMp3 (char *, unsigned int, RioBlock, struct timeval RTT_average, RioMMInterface *)
	~CRioMMMp3 ()
void	PlayBlock (int, int)
void	FastForward (void)
void	FastRewind (void)
void	GoTo (RioBlock)
void	Play (void)
void	Pause (void)
void	Stop (void)
int	init (void)
void	WaitEndOfVideo (void)
RioBlock	GetCurrentPosition (void)
RioBlock	GetTotalPositions (void)
Private Member Functions
void	StartMpg123 (void)
bool	ReadNextBlock (unsigned int)
Static Private Member Functions
static void *	PlayThread (void *)
static void	PlayThreadCleanup (void *)
Private Attributes
int	pipe_mpg123 [2]
pid_t	pid
RioBlock	NextRequestBlock
unsigned int	PlayBuffer
pthread_t	PlayThreadID
bool	Paused
pthread_mutex_t	PlayPause
RioMMInterface *	riomminterface

---

Detailed Description

Definition at line 27 of file RioMMMp3.h.

---

Constructor & Destructor Documentation

CRioMMMp3::CRioMMMp3	(	char *	mp3name,
		unsigned int	blocksize,
		RioBlock	numBuffers,
		struct timeval	RTT_average,
		RioMMInterface *	rio
	)

Definition at line 37 of file RioMMMp3.cpp.

          :CRioMMObject( mp3name, blocksize, numBuffers , RTT_average )
{
    pid              = 0;
    PlayBuffer       = 0;
    PlayThreadID     = 0;
    riomminterface   = rio;
    NextRequestBlock = numBuffers;
    Paused           = false;
    pthread_mutex_init( &PlayPause, NULL );
}

CRioMMMp3::~CRioMMMp3

(

)

Definition at line 51 of file RioMMMp3.cpp.

{
    if( PlayThreadID != 0 )
        pthread_cancel( PlayThreadID );
}

---

Member Function Documentation

void CRioMMMp3::FastForward

(

void

)

[virtual]

Implements CRioMMObject.

Definition at line 99 of file RioMMMp3.cpp.

{
    NextRequestBlock += 10;
}

void CRioMMMp3::FastRewind

(

void

)

[virtual]

Implements CRioMMObject.

Definition at line 105 of file RioMMMp3.cpp.

{
    NextRequestBlock -= 10;
}

RioBlock CRioMMMp3::GetCurrentPosition

(

void

)

[virtual]

Implements CRioMMObject.

Definition at line 179 of file RioMMMp3.cpp.

{
    return( CurrentBlock );
}

RioBlock CRioMMMp3::GetTotalPositions

(

void

)

[virtual]

Implements CRioMMObject.

Definition at line 185 of file RioMMMp3.cpp.

{
    return( TotalBlocks );
}

void CRioMMMp3::GoTo

(

RioBlock

block

)

[virtual]

Implements CRioMMObject.

Definition at line 111 of file RioMMMp3.cpp.

{
    NextRequestBlock = (int) block;
}

int CRioMMMp3::init

(

void

)

[virtual]

Implements CRioMMObject.

Definition at line 58 of file RioMMMp3.cpp.

{
    return 0;
}

void CRioMMMp3::Pause

(

void

)

[virtual]

Implements CRioMMObject.

Definition at line 133 of file RioMMMp3.cpp.

{
    if( PlayThreadID != 0 )
    {
        if( Paused )
        {
            pthread_mutex_unlock( &PlayPause );
            Paused = false;
        }
        else
        {
            pthread_mutex_lock( &PlayPause );
            Paused = true;
        }
    }
}

void CRioMMMp3::Play

(

void

)

[virtual]

Implements CRioMMObject.

Definition at line 151 of file RioMMMp3.cpp.

{
    if( PlayThreadID == 0 )
    {
        if( pthread_create( &PlayThreadID, NULL, &PlayThread, this ) )
        {
            RioErr << "Could not create play thread" << endl;
            return;
        }
    }
    else
    {
        if( Paused )
        {
            pthread_mutex_unlock( &PlayPause );
            Paused = false;
        }
    }
}

void CRioMMMp3::PlayBlock	(	int	buf,
		int	size
	)

Definition at line 64 of file RioMMMp3.cpp.

{
    int sent;
    int n, nwrite;

    char *buffer = (char *)Request[buf].Buffer;

    sent = 0;
    while( sent < size )
    {
        n = size - sent;
        if( n > MaxPipeDataSize )
            n = MaxPipeDataSize;

        pthread_mutex_lock( &PlayPause );
        nwrite = write( pipe_mpg123[1], (void*)buffer, n );
        pthread_mutex_unlock( &PlayPause );

        if( nwrite < 0 )
        {
            Rioperror("write: pipe mpg123");
        }

        sent   += nwrite;
        buffer += nwrite;
    }

    if( riomminterface )
    {
        QCustomEvent *event = new QCustomEvent( QEvent::User , &Request[buf].Block );
        QApplication::postEvent( (QObject*)riomminterface, event );
    }
}

void * CRioMMMp3::PlayThread

(

void *

param

)

[static, private]

Definition at line 192 of file RioMMMp3.cpp.

{
    int  curBlockSize;
    bool EOM;         //End of Media
    CRioMMMp3 *Mp3;
    unsigned int curpos;
    unsigned int n_requests;

    pthread_setcancelstate( PTHREAD_CANCEL_ENABLE, NULL );
    pthread_cleanup_push( CRioMMMp3::PlayThreadCleanup, param );

    Mp3 = (CRioMMMp3 *)param;

    Mp3->StartMpg123();
    Mp3->Prefetch();
    Mp3->WaitPrefetch();

    EOM = false;
    while( !EOM )
    {
        // Sets current position
        curpos     = Mp3->PlayBuffer;
        n_requests = 0;

        // While current position is empty (current block hasn't arrived)
        if( Mp3->GetBufferStatus( curpos ) == BUFFEREMPTY )
        {
            usleep( 700000 );
        }
        else
        {
            if( Mp3->Request[curpos].Block < Mp3->TotalBlocks-1 )
                curBlockSize = Mp3->BlockSize;
            else
            {
                if( Mp3->Request[curpos].Block == Mp3->TotalBlocks-1 )
                    curBlockSize = Mp3->ObjSize % Mp3->BlockSize;
                else
                {
                    RioErr << "Unbounded streams are not supported yet!" << endl;
                    exit( -1 );
                }
            }

            Mp3->PlayBlock( curpos, curBlockSize );
            Mp3->SetBufferStatus( Mp3->PlayBuffer, BUFFEREMPTY );

            Mp3->SyncMedia( (void *)Mp3->Request[curpos].Block );
        }

        Mp3->ReadNextBlock( Mp3->PlayBuffer );

        Mp3->PlayBuffer   = (curpos + 1 ) % Mp3->nBuffers;
        Mp3->CurrentBlock = Mp3->Request[curpos].Block;
        if( Mp3->CurrentBlock == Mp3->TotalBlocks - 1 )
            EOM = true;
    }
    sleep( 2 ); //wait for mpg123 to play the last block
    pthread_cleanup_pop( 0 );
    pthread_exit( NULL );
}

void CRioMMMp3::PlayThreadCleanup

(

void *

param

)

[static, private]

Definition at line 255 of file RioMMMp3.cpp.

{
    CRioMMMp3 *Mp3;

    Mp3 = (CRioMMMp3 *)param;
    kill( Mp3->pid, SIGKILL );
    pthread_mutex_unlock( &Mp3->PlayPause );
    pthread_mutex_unlock( &Mp3->PlayThreadMutex );
    waitpid( Mp3->pid, NULL, 0 );
    Mp3->PlayThreadID = 0;
    Mp3->Stop();
}

bool CRioMMMp3::ReadNextBlock

(

unsigned int

index

)

[private]

Definition at line 268 of file RioMMMp3.cpp.

{
    bool status;

    status = true;
    if( NextRequestBlock < TotalBlocks )
        Read( index, NextRequestBlock++ );
    else
        status = false;

    return( status );
}

void CRioMMMp3::StartMpg123

(

void

)

[private]

Definition at line 282 of file RioMMMp3.cpp.

{
    // create pipe to send data to mtv
    if( pipe( pipe_mpg123 ) < 0 )
    {
        Rioperror("pipe(). Failed to create pipe to mpg123.");
        return;
    }

    // associate pipe input to stdin
    if( dup2( pipe_mpg123[0], 0 ) == -1 )
    {
        Rioperror("dup2(). Failed to associate pipe to stdin.");
        return;
    }

    // start program mpg123
    if( (pid = fork()) != 0 )
    {
        if( pid < 0 )
        {
            Rioperror("fork(). Failed to fork process.");
            return;
        }
    }
    else
    {
        //run mpg123
        if( execlp( "mpg123","mpg123", "-", NULL ) == -1 )
        {
            Rioperror( "execlp(): Failed to execute mpg123." );
            exit( 1 );
        }
    }
}

void CRioMMMp3::Stop

(

void

)

[virtual]

Implements CRioMMObject.

Definition at line 117 of file RioMMMp3.cpp.

{
    if( PlayThreadID != 0 )
    {
        pthread_cancel( PlayThreadID );
        if( Paused )
            pthread_mutex_unlock( &PlayPause );
    }
    PlayBuffer       = 0;
    PlayThreadID     = 0;
    NextRequestBlock = nBuffers;

    CRioMMObject::Stop();
}

void CRioMMMp3::WaitEndOfVideo

(

void

)

Definition at line 172 of file RioMMMp3.cpp.

{
    pthread_join( PlayThreadID, NULL );
    PlayThreadID = 0;
}

---

Field Documentation

RioBlock CRioMMMp3::NextRequestBlock [private]

Definition at line 31 of file RioMMMp3.h.

bool CRioMMMp3::Paused [private]

Definition at line 34 of file RioMMMp3.h.

pid_t CRioMMMp3::pid [private]

Definition at line 30 of file RioMMMp3.h.

int CRioMMMp3::pipe_mpg123[2] [private]

Definition at line 29 of file RioMMMp3.h.

unsigned int CRioMMMp3::PlayBuffer [private]

Definition at line 32 of file RioMMMp3.h.

pthread_mutex_t CRioMMMp3::PlayPause [private]

Definition at line 35 of file RioMMMp3.h.

pthread_t CRioMMMp3::PlayThreadID [private]

Definition at line 33 of file RioMMMp3.h.

RioMMInterface* CRioMMMp3::riomminterface [private]

Definition at line 36 of file RioMMMp3.h.

---

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

• RioMMMp3.h
• RioMMMp3.cpp