Search  

---

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

Go to the documentation of this file.

#include "MsgThread.hh"

// Default Constructor
MsgThread::MsgThread() : Thread() {}

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

// Runs the message loop and dispatches to the proper child function.
void MsgThread::Run()
{
   unsigned char   buf[ MSG_BUFFER_MAX ];
   MsgData*    msg;
   MsgData*    feedback;
   pid_t    rpid;

   while( 1 ) {

          if( (  rpid = Receive( 0, buf, sizeof(buf) )  )  < 0  ) {
            continue;           // Try again

       if ( (*buf) == MSG_KILL_THREAD ) 
      break;
   
       if ( (*buf) == MSG_DATA_ID ) {  // Got a good message of type (MsgData*)

          // convert message
             msg = (MsgData*)buf;
   
               // Destroy MsgThread, if index equal MSG_KILL_THREAD
          if( msg->index == MSG_KILL_THREAD )
         break;


          // Dispatch message into the children array of local function
          feedback = Dispatch( msg, this, rpid );

               Reply( rpid, &feedback, sizeof(feedback) );

       } else {  // Not a known type message, so reply the same message

               Reply( rpid, buf, sizeof(buf) );
       }
    }

    // Send confirmation for destruction
    Reply( rpid, NULL, 0 );
}

// Send a message to this MsgThread
void MsgThread::SendMsg( void* buffer, void* reply )
{
    if ( pid < 0 ) { return; }
    Send( pid, buffer, reply, sizeof(buffer), sizeof(reply) );
}

// Stops the current thread (if running)
void MsgThread::Stop()
{
//  static const unsigned char Kill_Msg[1] = MSG_KILL_THREAD;

    MsgData* Kill_Msg = new MsgData();

    if ( pid < 0 ) { return; }

    // Try to send  MSG_KILL_THREAD  message...
    Send( pid, Kill_Msg, NULL, sizeof( Kill_Msg ), 0 );

    _endthread();

    pid = -1;
}

---