Search  

---

C:/temp/src/j2k/nto/MsgContainer.hpp

Go to the documentation of this file.

#ifndef __J2K__MsgContainer_HPP__
#define __J2K__MsgContainer_HPP__

#include <stdio.h>
#include <errno.h>
#include <stdlib.h>
#include <sys/dispatch.h>

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

enum MsgContainerType_t
{
  server = 0,
  client = 1
};

class MsgContainer
{ 
protected:
  MsgContainerType_t user;
  NameSpace* n;

  int fd;
  int connected;

  Message*   message;
  Message*   replyMsg;

public:
  MsgContainer( NameSpace* n0, MsgContainerType_t user0 = client );
  virtual ~MsgContainer();

  void connect( const char* name = NULL );

  void disconnect();

  int handleReceive( int rcvid, int replyData = 0 );
  int receive();
  void send( int data );
  void reply( int rcvid, int data );
  virtual void run() = 0;

  inline void copy( const Message* src );

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

  inline void MsgContainer::copy( const Message* src )
  {
    message->copy( src );
  }

  // Query recognition:
  inline BOOL  MsgContainer::isStatus()       { return  message->isStatus();       }
  inline BOOL  MsgContainer::isGet()          { return  message->isGet();          }
  inline BOOL  MsgContainer::isPut()          { return  message->isPut();          }
  inline BOOL  MsgContainer::isClear()        { return  message->isClear();        }
  inline BOOL  MsgContainer::isQuit()         { return  message->isQuit();         }
  inline BOOL  MsgContainer::isAddConsumer()  { return  message->isAddConsumer();  }
  inline BOOL  MsgContainer::isAddProducer()  { return  message->isAddProducer();  }
  inline BOOL  MsgContainer::isExpired()      { return  message->isExpired();      }
  inline BOOL  MsgContainer::isEmpty()        { return  message->isEmpty();        }
  inline BOOL  MsgContainer::isFull()         { return  message->isFull();         }
  inline BOOL  MsgContainer::isExist()        { return  message->isExist();        }
  inline BOOL  MsgContainer::isSuicide()      { return  message->isSuicide();      }
  inline BOOL  MsgContainer::isTimeout()      { return  message->isTimeout();      }
  inline BOOL  MsgContainer::isConsumer()     { return  message->isConsumer();     }
  inline BOOL  MsgContainer::isProducer()     { return  message->isProducer();     }

#endif  // MsgContainer.hpp

---