Search  

---

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

Go to the documentation of this file.

#ifndef __J2K__Message_INL__
#define __J2K__Message_INL__

inline int Message::receive( int channel )
{
  int rcvid = MsgReceive( channel, &msg, sizeof( msg ), NULL );
  return rcvid;
}

inline int Message::isIO()
{
  return ( msg.hdr.type >= _IO_BASE  &&  msg.hdr.type <= _IO_MAX );
}

inline void Message::reply( int rcvid )
{
  MsgReply( rcvid, EOK, &msg, sizeof( msg ) );
}

inline void Message::reply( int rcvid, int number, int state = EOK )
{
  msg.number = number;
  MsgReply( rcvid, state, &msg, sizeof( msg ) );
}

inline int Message::send( int fd, Message* replyMsg )
{
  register int rc = MsgSend( fd, &msg, sizeof(msg), &replyMsg->msg, sizeof(msg) );
  return rc;
}

inline void Message::reset()
{
  memset( &msg, 0, sizeof( fred_msg_data_t )  );
  msg.number  = -1;
}

inline void Message::copy( const Message* src )
{
  memcpy( &msg, &src->msg, sizeof( fred_msg_data_t )  );
}

// Message functions:
inline fred_msg_data_t  Message::getMessage()         { return msg;              }
inline void*            Message::getMessageAddr()     { return (void*)&msg;      }
inline size_t           Message::getMessageSize()     { return sizeof( msg_t );  }
inline int              Message::getNumber()          { return msg.number;       }
inline void             Message::setNumber( int nb )  { msg.number  = nb;        }
inline int              Message::getRequest()         { return msg.request;      }
inline void             Message::setRequest( int r )  { msg.request = r;         }
inline int              Message::getStatus()          { return msg.status;       }
inline void             Message::setStatus( int s )   { msg.status  = s;         }
inline int              Message::getIndex()           { return msg.index;        }
inline void             Message::setIndex( int i )    { msg.index   = i;         }
inline void*            Message::getData()            { return msg.data;         }
inline void             Message::setData( void* ptr ) { msg.data    = ptr;       }
inline pthread_t        Message::getPThread()         { return msg.pid;          }
inline void             Message::setPThread( pthread_t tid ) {  msg.pid = tid;   }

// Header functions:
inline msg_header_t     Message::getHeader()          { return msg.hdr;          }
inline int              Message::getHeaderCode()      { return msg.hdr.code;     }
inline int              Message::getHeaderScoid()     { return msg.hdr.scoid;    }

// Query recognition:
inline BOOL  Message::isStatus()       { return ( ( msg.status & MQI_STATUS       ) == MQI_STATUS       ); }
inline BOOL  Message::isGet()          { return ( ( msg.status & MQI_GET          ) == MQI_GET          ); }
inline BOOL  Message::isPut()          { return ( ( msg.status & MQI_PUT          ) == MQI_PUT          ); }
inline BOOL  Message::isClear()        { return ( ( msg.status & MQI_CLEAR        ) == MQI_CLEAR        ); }
inline BOOL  Message::isQuit()         { return ( ( msg.status & MQI_QUIT         ) == MQI_QUIT         ); }
inline BOOL  Message::isAddConsumer()  { return ( ( msg.status & MQI_ADD_CONSUMER ) == MQI_ADD_CONSUMER ); }
inline BOOL  Message::isAddProducer()  { return ( ( msg.status & MQI_ADD_PRODUCER ) == MQI_ADD_PRODUCER ); }
inline BOOL  Message::isExpired()      { return ( ( msg.status & MQI_IS_EXPIRED   ) == MQI_IS_EXPIRED   ); }
inline BOOL  Message::isEmpty()        { return ( ( msg.status & MQI_IS_EMPTY     ) == MQI_IS_EMPTY     ); }
inline BOOL  Message::isFull()         { return ( ( msg.status & MQI_IS_FULL      ) == MQI_IS_FULL      ); }
inline BOOL  Message::isExist()        { return ( ( msg.status & MQI_EXIST        ) == MQI_EXIST        ); }
inline BOOL  Message::isSuicide()      { return ( ( msg.status & MQI_SUICIDE      ) == MQI_SUICIDE      ); }
inline BOOL  Message::isTimeout()      { return ( ( msg.status & MQI_TIMEOUT      ) == MQI_TIMEOUT      ); }
inline BOOL  Message::isConsumer()     { return ( ( msg.status & MQI_CONSUMER     ) == MQI_CONSUMER     ); }
inline BOOL  Message::isProducer()     { return ( ( msg.status & MQI_PRODUCER     ) == MQI_PRODUCER     ); }

#endif // End of Meesage.inl

---