Search  

---

C:/temp/src/j2k/nto/bakJuly/MsgThreadServer.cpp

Go to the documentation of this file.

#ifndef __J2K__MsgThreadServer_CPP__
#define __J2K__MsgThreadServer_CPP__

#include <j2k/nto/MsgThreadServer.hpp>

MsgThreadServer::MsgThreadServer( const char* name0 )
 : Basic_PThread()
{
    name_len = strlen( name0 ) + 1;
    name     = new char[ name_len ];
    memcpy( name, name0, name_len );

    /* Create a local name (/dev/name/local/...) */

    attach = name_attach( NULL, name, 0 );
    assert( attach != NULL );
}

Message MsgThreadServer::receive( int who )
{
    int rcvid = -1;
    while( rcvid != who )
    {
      rcvid = MsgReceive( attach->chid, m.getMessageAddr(), m.getMessageSize(), NULL );

      if ( rcvid != -1 ) // Error case
      {
        break;
      }

      register int r = m.handleHeader( rcvid );

      if ( r != 0 ) continue;
      
      /* A message (presumable ours) received, handle */
      printf( "Server receive %d \n", m.getNumber() );
      MsgReply( rcvid, EOK, 0, 0 );

      return Message( m );

//      if ( rcvid == who ) return Message( m );
    }

    return Message( m );
}


MsgThreadServer::~MsgThreadServer() 
{
    /* Remove the name from the space */ 
    name_detach(attach, 0);
}

void MsgThreadServer::send( const char* dest0, Message msg_recv )
{
    int fd = name_open( dest0, 0);
    assert( fd != -1 );
 
    int r = MsgSend( fd, msg_recv.getMessageAddr(), msg_recv.getMessageSize(), NULL, 0 );
    assert( r != -1 );
 
    /* Close the connection */
    name_close( fd ); 
}

#endif

---