00001 #ifndef __J2K__MsgThread_HPP__
00002 #define __J2K__MsgThread_HPP__
00003
00004 #include <stdio.h>
00005 #include <errno.h>
00006 #include <stdlib.h>
00007 #include <sys/dispatch.h>
00008
00009 #include <j2k/Fred/Standard.hpp>
00010 #include <j2k/nto/Basic_PThread.hpp>
00011 #include <j2k/nto/Message.hpp>
00012 #include <j2k/nto/Namespace.hpp>
00013
00014 class MsgThread : public Basic_PThread
00015 {
00016 protected:
00017 int fd;
00018 MsgNameSpaceUserType_t user;
00019 MsgNameSpace* n;
00020 Message* m;
00021
00022 public:
00023 MsgThread( MsgNameSpaceUserType_t user0, MsgNameSpace* n0, const char* name = NULL );
00024 virtual ~MsgThread();
00025 int handleReceive( int rcvid );
00026 int receive();
00027 void send( int data );
00028 void reply( int rcvid, int data );
00029 };
00030
00031 #endif
