Search  

---

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

Go to the documentation of this file.

#ifndef __J2K__Message_CPP__
#define __J2K__Message_CPP__

#include <j2k/Fred/Standard.hpp>
#include <j2k/nto/Message.hpp>   

Message::Message( int number0 = 0 )
{
  memset( &msg, 0, sizeof( fred_msg_data_t ) );
  msg.number = number0;


}

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 ) );
}

Message::~Message()
{
}

/*
struct _pulse {
        _uint16                                         type;
        _uint16                                         subtype;
        _int8                                           code;
        _uint8                                          zero[3];
        union sigval                            value;
        _int32                                          scoid;
};
*/

int Message::handleHeader( int rcvid )
{
  /* Pulse received */
  if ( rcvid == 0 )
  {
    switch ( (int)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 );
       return 1;
       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.
       */
       return 2;
       break;

      default:
      /*
       * A pulse sent by one of your processes or a
       * _PULSE_CODE_COIDDEATH or _PULSE_CODE_THREADDEATH 
       * from the kernel?
       */
       break;
    }
  }
  
  /* A QNX IO message received, reject */
  if ( type >= _IO_BASE  &&  type <= _IO_MAX ) 
  {
    MsgError( rcvid, ENOSYS );
    return -1;
  }

  return 0;
}

#endif // End of Meesage.cpp

---