Search  

---

C:/temp/src/j2k/nto/bakJuly/Message.hpp

Go to the documentation of this file.

#ifndef __J2K__Message_HPP__
#define __J2K__Message_HPP__

#include <j2k/Fred/Standard.hpp>
#include <errno.h>
#include <sys/neutrino.h>
#include <sys/dispatch.h>

#ifndef __FRED_MSG_DATA_T__
#define __FRED_MSG_DATA_T__

enum MsgQueryInfo_t
{
///////////////////////////////////////////////////////////////////////////////////////////////////
//   Query Request   __OR__   Status State                                                       //
///////////////////////////////////////////////////////////////////////////////////////////////////
  MQI_PING          = 0x0000,   // Ping the server:  Server exist ?!
  MQI_STATUS        = 0x0001,   // Retrieve status:  Get current server status. 
  MQI_GET           = 0x0002,   // Get an element:   Return some element from current storage
  MQI_PUT           = 0x0004,   // Put an element:   Store some element in current storage
  MQI_CLEAR         = 0x0008,   // Clear element:    Clear element from current storage
  MQI_QUIT          = 0x0010,   // Quit Request:     Caller should quit
  MQI_ADD_CONSUMER  = 0x0020,   // Add one consumer slot
  MQI_ADD_PRODUCER  = 0x0040,   // Add one producer slot
  MQI_IS_EXPIRED    = 0x0080,   // Does my request is expired ?  __OR__  You are expired
  MQI_IS_EMPTY      = 0x0100,   // Does the buffer is empty ?    __OR__  Buffer is empty
  MQI_IS_FULL       = 0x0200,   // Does the buffer is filled ?   __OR__  Buffer is full
  MQI_EXIST         = 0x0400,   // Do you exist ?                __OR__  Server exist
  MQI_SUICIDE       = 0x0800,   // Should I suicide ?            __OR__  Please suicide !
  MQI_TIMEOUT       = 0x0D90,   // MQI_IS_EXPIRED | MQI_EXIST | MQI_SUICIDE | MQI_QUIT;
  MQI_CONSUMER      = 0x0402,   // MQI_EXIST | MQI_GET
  MQI_PRODUCER      = 0x0404    // MQI_EXIST | MQI_PUT
///////////////////////////////////////////////////////////////////////////////////////////////////
};

/* We specify the header as being at least a pulse */
typedef struct _pulse    msg_header_t;

/* Our real data comes after the header */
typedef struct _fred_msg_data_t
{
  msg_header_t  hdr;
  int           request;
  int           status;
  int           index;
  int           number;
  void*         data;
} fred_msg_data_t;

#endif // __FRED_MSG_DATA_T__

class Message 
{
protected:
  fred_msg_data_t  msg;

public:
  Message( int number0 = 0, int request0 = 0, int status0 = 0, int index0 = 0, void* data0 = NULL );

  Message( const Message& src );
  const Message& operator= ( const Message& src );

  virtual ~Message();

  void handleHeader();

  int checkHeader( int rcvid );

  inline int isIO();
  inline int receive( int channel );
  inline int send( int fd, Message* rm );
  inline void reply( int rcvid, int number, int state = EOK );

  // Message functions:
  inline fred_msg_data_t  getMessage();
  inline void*            getMessageAddr();
  inline size_t           getMessageSize();
  inline int              getNumber();
  inline void             setNumber( int nb );
  inline int              getRequest();
  inline void             setRequest( int r );
  inline int              getStatus();
  inline void             setStatus( int s );
  inline int              getIndex();
  inline void             setIndex( int i );
  inline void*            getData();
  inline void             setData( void* ptr );

  // Header functions:
  inline msg_header_t     getHeader();
  inline int              getHeaderCode();
  inline int              getHeaderScoid();
};

#include <j2k/nto/Message.inl>

#endif // End of Message.hpp

---