Search  

---

C:/temp/src/j2k/QNX4/MsgThread.hpp

Go to the documentation of this file.

#ifndef __J2K__MsgThread_HPP__
#define __J2K__MsgThread_HPP__

#include <j2k/Fred/QNX/Thread.hpp>
#include <j2k/Fred/QNX/MsgData.hpp>

// Increase this if a message is bigger than 1 KB !
#define MSG_BUFFER_MAX  1024

/*  Example of Sorting and dispatching function:
MsgData* SortMsg( MsgData* msg, MsgThread* mySelf, pid_t myPid ) {
   void* ( MsgThreadChild::*Table[] )( void* ) = { 
      MsgThreadChild::fn1, 
      MsgThreadChild::fn2 
   };
}
*/

// A Thread that deals with basic Message stuff
class MsgThread : public Thread
{
private:
   serial_t  Serialization;   // SHOULDN'T BE MODIFIED ELSE WHERE.

public:
   MsgThread() : Serialization( MSG_THREAD_SERIAL ) { }

   virtual ~MsgThread() { MsgThread::Stop(); }

   // Implemented.
   virtual void Run();

   virtual MsgData* SortMsg(  MsgData* msg, MsgThread* mySelf, pid_t myPid ) = 0;
   virtual MsgData* Dispatch( MsgData* msg, MsgThread* mySelf, pid_t myPid ) = 0;

   // The only thing that should be implemented in MsgThreadChild
   virtual void* MsgDispatcher( void* msg, pid_t replyPid ) = 0;

   void Stop();

   // Simpler Send(...) command
   void SendMsg( void* incomming, void* reply );
};

#endif

---