Search  

---

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

Go to the documentation of this file.

#ifndef __J2K__MsgThread_HPP__
#define __J2K__MsgThread_HPP__

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

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

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

class MsgThread : public Basic_PThread 
{ 
protected:
  int fd;
  int connected;
  NameSpace* n;
  Message*   message;
  Message*   replyMsg;
  MsgThreadType_t user;

public:
  MsgThread( NameSpace* n0, MsgThreadType_t user0 = client );
  virtual ~MsgThread();

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

#endif  // MsgThread.hpp

---