CRioMMIntSimul Class Reference

#include <RioMMIntSimul.h>

Inherits CRioMMObject.

Public Member Functions
	CRioMMIntSimul (char *, unsigned int, RioBlock)
	~CRioMMIntSimul (void)
int	init (void)
void	Stop (void)
void	Pause (void)
void	Play (void)
void	SyncMedia (void *)
Private Member Functions
void	StartTgif (void)
int	ConnectTgif (void)
Private Attributes
char	BaseName [MAXPATHSIZE]
int	pid
int	pipe_tgif [2]
unsigned int	BlockOffset
RioBlock	NextBlock

---

Detailed Description

Definition at line 21 of file RioMMIntSimul.h.

---

Constructor & Destructor Documentation

CRioMMIntSimul::CRioMMIntSimul	(	char *	ModelName,
		unsigned int	blocksize,
		RioBlock	numBuffers
	)

Definition at line 35 of file RioMMIntSimul.cpp.

                 :CRioMMObject( ModelName, blocksize, numBuffers )
{
    char *ext;

    NextBlock   = 0;
    BlockOffset = 0;
    pid         = 0;

    /* Extract objname from simulation file name */
    strcpy( BaseName, ModelName );
    ext = strrchr( BaseName, '.' );
    if( strcmp( ext, ".simul" ) == 0 )
        *ext = 0;
}

CRioMMIntSimul::~CRioMMIntSimul

(

void

)

Definition at line 52 of file RioMMIntSimul.cpp.

{
}

---

Member Function Documentation

int CRioMMIntSimul::ConnectTgif

(

void

)

[private]

Definition at line 159 of file RioMMIntSimul.cpp.

{
    struct hostent    *phe;
    struct servent    *pse;
    struct protoent   *ppe;
    struct sockaddr_in sin;
    int s;
    int type;
    char buffer[sizeof(T_Packet)];
    fd_set soc_pool;
    int    max_desc;
    struct timeval timeout;
    char *host     = "localhost";
    char *protocol = "udp";

    bzero( (char *)&sin, sizeof( sin ) );
    sin.sin_family = AF_INET;

    if( (pse = getservbyname( service, protocol )) != NULL )
        sin.sin_port = pse->s_port;
    else
        if( (sin.sin_port = htons( (u_short)atoi( service ) )) == 0 )
        {
            RioErr << "Can't get \"" << service << "\" service entry" << endl;
            return( -1 );
        }

    if( (phe = gethostbyname( host )) != NULL )
        bcopy(phe->h_addr,(char *)&sin.sin_addr, phe->h_length);
    else
        if( (sin.sin_addr.s_addr = inet_addr( host )) == INADDR_NONE )
        {
            RioErr << "Can't get \"" << host << "\" host entry" << endl;
            return( -1 );
        }

    if( (ppe = getprotobyname( protocol )) == NULL )
    {
        RioErr << "Can't get \"" << protocol << "\" protocol entry" << endl;
        return( -1 );
    }

    if( strcmp( protocol, "udp" ) == 0 )
        type = SOCK_DGRAM;
    else
        type = SOCK_STREAM;

    s = socket( PF_INET, type, ppe->p_proto );
    if( s < 0 )
    {
        RioErr << "Can't create socket!" << endl;
        return( -1 );
    }

    if( connect( s, (struct sockaddr *)&sin, sizeof( sin ) ) < 0 )
    {
        RioErr << "Can't connect to " << host << "." << service << endl;
        return( -1 );
    }

    /* send a fake packet to the interface */
    if( send( s, buffer, sizeof( T_Packet ), 0 ) < 0 )
    {
        Rioperror( "send" );
        return( -1 );
    }

    /* zero the pool and set the bits corresponding to the socket  */
    FD_ZERO( &soc_pool );
    FD_SET( s, &soc_pool );
    max_desc        = s + 1;
    timeout.tv_sec  = 3;
    timeout.tv_usec = 0;

    if( select( max_desc, &soc_pool, NULL, NULL, &timeout ) < 0 )
    {
        Rioperror( "select" );
        return( -1 );
    }

    if( FD_ISSET(s, &soc_pool))
    {
        /* receive fake packet from tgif */
        if( recv( s, buffer, sizeof( T_Packet ), MSG_WAITALL ) < 0 )
        {
            Rioperror( "recv" );
            return( -1 );
        }
    }
    else
    {
        RioErr << "Simulator Timeout expired!" << endl;
        return( -1 );
    }

    RioErr << "Simulator connected." << endl;
    return s;
}

int CRioMMIntSimul::init

(

void

)

[virtual]

Implements CRioMMObject.

Definition at line 57 of file RioMMIntSimul.cpp.

{
    return( 1 );
}

void CRioMMIntSimul::Pause

(

void

)

[virtual]

Implements CRioMMObject.

Definition at line 87 of file RioMMIntSimul.cpp.

{
    #ifdef RIO_DEBUG2
    RioErr << "[IntSimul]: Entrei na Plause" << endl;
    #endif
}

void CRioMMIntSimul::Play

(

void

)

[virtual]

Implements CRioMMObject.

Definition at line 94 of file RioMMIntSimul.cpp.

{
    int soc;
    char msg[ 150 ];
    T_Packet pack_in, pack_out;
    
    #ifdef RIO_DEBUG2
    RioErr << "[IntSimul]: Entrei na Play" << endl;
    #endif
    
    StartTgif();
    sleep( 3 );
    strcpy( msg, "call_one_arg_shortcut(Tangram2StartSimulator,\"0;0;/dev/null;0;ANY;0;0;I;0;OFF;0;0;\")" );
    write( pipe_tgif[1], msg, strlen( msg ) );
    soc = ConnectTgif();
    while( 1 )
    {
        recv_packet( soc, &pack_in );
        unmount_packet( pack_in );
        mount_packet( pack_in, &pack_out );
        send_packet( soc, pack_out );
    }
}

void CRioMMIntSimul::StartTgif

(

void

)

[private]

Definition at line 119 of file RioMMIntSimul.cpp.

{
    char path[ 200 ];

    // create pipe to send data to tgif
    if( pipe( pipe_tgif ) < 0 )
    {
        Rioperror("pipe(). Failed to create pipe to tgif.");
        return;
    }

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

    // start program tgif
    if( (pid = fork()) != 0 )
    {
        if( pid < 0 )
        {
            Rioperror("fork(). Failed to fork process.");
            return;
        }
    }
    else
    {
        //run tgif
        sprintf( path, "/tmp/%s", BaseName );
        if( execlp( "tgif", "tgif", path, "-exec", "-", NULL ) == -1 )
        {
            Rioperror( "execlp(): Failed to execute tgif." );
            exit( 1 );
        }
    }
}

void CRioMMIntSimul::Stop

(

void

)

[virtual]

Implements CRioMMObject.

Definition at line 75 of file RioMMIntSimul.cpp.

{
    #ifdef RIO_DEBUG2
    RioErr << "[IntSimul]: Entrei na Stop" << endl;
    #endif
    
    NextBlock      = 0;
    BlockOffset    = 0;

    CRioMMObject::Stop();
}

void CRioMMIntSimul::SyncMedia

(

void *

param

)

[virtual]

Reimplemented from CRioMMObject.

Definition at line 63 of file RioMMIntSimul.cpp.

{
    RioErr << "[IntSimul]: Entrei na SyncMedia(" << (RioBlock)param << ")" 
           << NextBlock << endl;
    if( (RioBlock)param >= NextBlock )
    {
        SendPcktToTgif();
        GetNextPckt();
    }
    CRioMMObject::SyncMedia( param );
}

---

Field Documentation

char CRioMMIntSimul::BaseName[MAXPATHSIZE] [private]

Definition at line 24 of file RioMMIntSimul.h.

unsigned int CRioMMIntSimul::BlockOffset [private]

Definition at line 27 of file RioMMIntSimul.h.

RioBlock CRioMMIntSimul::NextBlock [private]

Definition at line 28 of file RioMMIntSimul.h.

int CRioMMIntSimul::pid [private]

Definition at line 25 of file RioMMIntSimul.h.

int CRioMMIntSimul::pipe_tgif[2] [private]

Definition at line 26 of file RioMMIntSimul.h.

---

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

• RioMMIntSimul.h
• RioMMIntSimul.cpp