Search  

---

C:/temp/src/j2k/nto/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;
  pthread_t     pid;
} fred_msg_data_t;

#endif // __FRED_MSG_DATA_T__

class Message 
{
protected:
  fred_msg_data_t  msg;

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

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

  // Reset with default message
  inline void reset();
   
  // Copy a message content from the source
  inline void copy( const Message* src );

  virtual ~Message();

  // Normal Message handling
  void handleHeader();

  // Check for Kernel Message
  int checkHeader( int rcvid );

  inline int isIO();
  inline int receive( int channel );
  inline int send( int fd, Message* rm );
  inline void reply( int rcvid );
  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 );

  inline pthread_t        getPThread();
  inline void             setPThread( pthread_t tid );

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

  // Query recognition:
  inline BOOL  Message::isStatus();
  inline BOOL  Message::isGet();
  inline BOOL  Message::isPut();
  inline BOOL  Message::isClear();
  inline BOOL  Message::isQuit();
  inline BOOL  Message::isAddConsumer();
  inline BOOL  Message::isAddProducer();
  inline BOOL  Message::isExpired();
  inline BOOL  Message::isEmpty();
  inline BOOL  Message::isFull();
  inline BOOL  Message::isExist();
  inline BOOL  Message::isSuicide();
  inline BOOL  Message::isTimeout();
  inline BOOL  Message::isConsumer();
  inline BOOL  Message::isProducer();


  void print()
  {
    printf( "===================================== \n" );
    printf( "Message: \n" );
    printf( "===================================== \n" );

    printf( " - Request: [%d]  ", msg.request );
    printInfo( msg.request );

    printf( " - Status:  [%d]  ", msg.status  );
    printInfo( msg.status  );

    printf( " - Index:   [%d] \n", msg.index   );
    printf( " - Number:  [%d] \n", msg.number  );

    printf( "===================================== \n" );
    fflush( stdout );
  }

  void printInfo( int info )
  {
    register int backup = msg.status;

    msg.status = info;
    if ( isStatus()        ) { printf( " STATUS      " ); }
    if ( isGet()           ) { printf( " GET         " ); }
    if ( isPut()           ) { printf( " PUT         " ); }
    if ( isClear()         ) { printf( " CLEAR       " ); }
    if ( isQuit()          ) { printf( " QUIT        " ); }
    if ( isAddConsumer()   ) { printf( " ADD_CONSUMER " ); }
    if ( isAddProducer()   ) { printf( " ADD_PRODUCER " ); }
    if ( isExpired()       ) { printf( " EXPIRED     " ); }
    if ( isEmpty()         ) { printf( " EMPTY       " ); }
    if ( isFull()          ) { printf( " FULL        " ); }
    if ( isExist()         ) { printf( " EXIST       " ); }
    if ( isSuicide()       ) { printf( " SUICIDE     " ); }
    if ( isTimeout()       ) { printf( " TIMEOUT     " ); }
    if ( isConsumer()      ) { printf( " CONSUMER    " ); }
    if ( isProducer()      ) { printf( " PRODUCER    " ); }

    msg.status = backup;
    printf( "\n" );
    fflush( stdout );
  }
};

#include <j2k/nto/Message.inl>

#endif // End of Message.hpp

---