Search  

---

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

Go to the documentation of this file.

#ifndef __J2K__Message_CPP__
#define __J2K__Message_CPP__

#include <j2k/nto/Message.hpp>   

Message::Message( int number0 = -1, int request0 = 0, int status0 = 0, int index0 = 0, void* data0 = NULL )
{
  memset(  &msg, 0, sizeof( fred_msg_data_t )  );
  msg.number  = number0;
  msg.request = request0;
  msg.index   = index0;
  msg.status  = status0;
  msg.data    = data0;
}

Message::Message( const Message& src )
{
  memcpy(  &msg, &src.msg, sizeof( fred_msg_data_t )  );
}

const Message& Message::operator=( const Message& src )
{
  memcpy(  &msg, &src.msg, sizeof( fred_msg_data_t )   );
  return *this;
}

Message::~Message()
{
}

// Normal handling of message
void Message::handleHeader()
{
   switch( msg.hdr.code ) 
   {
      case _PULSE_CODE_DISCONNECT:
        /*
         * A client disconnected all its connections (called
         * name_close() for each name_open() of our name) or
         * terminated
         */
        ConnectDetach(msg.hdr.scoid);
      break;

      case _PULSE_CODE_UNBLOCK:
        /*
         * REPLY blocked client wants to unblock (was hit by
         * a signal or timed out).  It's up to you if you
         * reply now or later.
         */
      break;

      default:
        /*
         * A pulse sent by one of your processes or a
         * _PULSE_CODE_COIDDEATH or _PULSE_CODE_THREADDEATH 
         * from the kernel?
         */
       break;
   }
}

// Check for Kernel message
int Message::checkHeader( int rcvid )
{
  if ( rcvid == 0 )  /* Pulse received */
  {
    handleHeader();
    return 1;
  }

  /* A QNX IO message received, reject */
  if (  isIO()  ) 
  {
    MsgError( rcvid, ENOSYS );
    return 1;
  }

  return 0;
}

#endif // End of Meesage.cpp

---