Search  

---

C:/temp/src/j2k/nto/MsgThread.cpp

Go to the documentation of this file.

#ifndef __J2K__MsgThread_CPP__
#define __J2K__MsgThread_CPP__

#include <j2k/nto/MsgThread.hpp>

MsgThread::MsgThread( NameSpace* n0, MsgThreadType_t user0 = client )
  : Basic_PThread(), user( user0 ), n( n0 ), fd( 0 ), connected( 0 )
{
  // Allocate memory for Message and Reply buffers
  message  = new Message();
  replyMsg = new Message();

  // Verify that the MsgThreadType is valid

  // Verify that the NameSpace exists.
  if ( n == NULL ) 
  {
    perror( "Invalid NameSpace. The NameSpace provided is NULL.  \n" );
    exit( 1 );
  }

  if ( user == client )      // Client MsgThread
  {
//    printf( "Client \n" );
  }
  else if ( user == server ) // Server MsgThread
  {
//    printf( "Server \n" );
  }
  else                       // Invalid MsgThread
  {
    perror( "Invalid MsgThread type. \n " );
    exit( 1 );
  }
}

void  MsgThread::connect( const char* name = NULL )
{
  if ( user == client )      // Client MsgThread
  {
    connected = 1;
    fd = n->Nopen( name );
  }
  else if ( user == server ) // Server MsgThread
  {
    connected = 1;
    n->Nattach( name );
  }
  else                       // Invalid MsgThread
  {
    perror( "Invalid MsgThread type. \n " );
    exit( 1 );
  }
}

void MsgThread::disconnect()
{
  if ( !connected ) return;

  // Close NameSpace connection that was opened.
  if ( n != NULL ) 
  {
    if ( user == client )
    {
      n->Nclose( fd );
    }
    else if ( user == server )
    { 
      n->Ndetach();
    }
  }
  connected = 0;
}

MsgThread::~MsgThread() 
{
  disconnect();

  // Release memory taken by Message and Reply buffers
  if ( message != NULL ) 
  {
    delete message;
  }

  if ( replyMsg != NULL ) 
  {
    delete replyMsg;
  }
}

int MsgThread::handleReceive( int rcvid, int replyData = 0 )
{
  if ( rcvid != -1 ) // Error case
  {
    return -10;
  }

  register int rc = message->checkHeader( rcvid );

  if ( rc != 0 ) return rc;
      
  /* A message (presumable ours) received, handle */
  printf( "Server receive %d \n", message->getNumber() );
  reply( rcvid, replyData );

  return 0;
}

int MsgThread::receive()
{
  register int rcvid = MsgReceive( n->getChannel(), message->getMessageAddr(), message->getMessageSize(), NULL );
  return rcvid;
}

void MsgThread::send( int data )
{
  message->setNumber( data );
  register int err = MsgSend( fd, 
      message->getMessageAddr(), 
      message->getMessageSize(), 
     replyMsg->getMessageAddr(), 
     replyMsg->getMessageSize() 
  );

  if ( err == -1 )
  {
    switch( errno )
    {
      case EBADF:
        printf( "The connection indicated by coid is no longer connected to a channel, \n" );
        printf( "or the connection indicated by coid doesn't exist. \n" );
        printf( "The channel may have been terminated by the server, \n" );
        printf( "or the network manager if it failed to respond to multiple polls. \n" );
        break;
      case EFAULT:
        printf( "A fault occurred when the kernel tried to access the buffers provided. \n" );
        printf( "This may have occurred on the receive or the reply. \n" );
        break;
      case EINTR:
        printf( "The call was interrupted by a signal. \n" );
        break;
      case ESRVRFAULT:
        printf( "A fault occurred in a server's address space when accessing the server's message buffers. \n" );
        break;
      case ETIMEDOUT:
        printf( "A kernel timeout unblocked the call. See TimerTimeout(). \n" );
        break;
      default:
        printf( "Unknown error %d: %s\n", errno, strerror( errno ) );
        break;
    }
  }
}

void MsgThread::reply( int rcvid, int data )
{
  replyMsg->setNumber( data );

  register int state = EOK;

  register int err = MsgReply( rcvid, state, replyMsg->getMessageAddr(), replyMsg->getMessageSize() );

  if ( err == -1 )
  {
    switch( errno )
    {
      case EFAULT:
        printf( "A fault occurred in the sender's address space \n" );
        printf( "when a server tried to access the sender's return message buffers. \n" );
      break;

      case ESRCH:
        printf( "The thread indicated by rcvid doesn't exist,  \n" );
        printf( "or is no longer REPLY-blocked on the channel, \n" );
        printf( "or the connection is detached. \n" );
      break;

      case ESRVRFAULT:
        printf( "A fault occurred when the kernel tried to access the buffers provided. \n" );
      break;

      default:
        printf( "Unknown error occured. \n" );
      break;
    }

    printf( "An error happened while replying to a message: MsgReply, code = %d, type = %s", 
            errno, strerror( errno ) 
    );

    exit( 1 );
  }
} 

#endif  // MsgThread.cpp

---