Search  

---

C:/temp/src/j2k/nto/bak2/MsgThreadClient.cpp

Go to the documentation of this file.

#ifndef __J2K__MsgThread_CPP__
#define __J2K__MsgThread_CPP__

#include <j2k/nto/MsgThread.hpp>

MsgThread::MsgThread( MsgNameSpaceUserType_t user0, MsgNameSpace* n0, const char* name = NULL )
  : Basic_PThread(), user( user0 )
{
  n = n0;
  m = new Message();

  if ( n == NULL ) 
  {
    printf( "Invalid NameSpace. The NameSpace provided is NULL.  \n" );
    exit( 1 );
  }

  if ( user == client )
  {
    printf( "Client \n" );
    fd = n->Nopen();
  }
  else if ( user == server )
  {
    printf( "Server \n" );

    if ( name == NULL )
    {
      printf( "Using default NameSpace Attach Point alias name. \n " );
      fd = n->Nattach();
    }
    else
    {
      fd = n->Nattach( name );
    }
  }
  else
  {
    printf( "Unknown NameSpace User type. \n " );
    exit( 1 );
  }
}


MsgThread::~MsgThread() 
{
  if ( m != NULL ) 
  {
    delete m;
  }

  if ( n != NULL ) 
  {
    if ( user == client )
    {
      n->Nclose( fd );
    }
    else if ( user == server )
    { 
      n->Ndetach();
    }
  }
}

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

  register int r = m->handleHeader( rcvid );

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

  return 0;
}

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

void MsgThread::send( int data )
{
  m->setMessageNumber( data );
  register int err = MsgSend( fd, m->getMessageAddr(), m->getMessageSize(), NULL );

  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. 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 )
{
  m->setMessageNumber( data );

  register int err = MsgReply( rcvid, EOK, m->getMessageAddr(), m->getMessageSize() );
  if ( err == -1 )
  {
    switch( error )
    {
      case EFAULT:
        printf( "A fault occurred in the sender's address space 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, or is no longer REPLY-blocked on the channel, 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;
    }
    exit( 1 );
  }
} 

#endif

---