Search  

---

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

Go to the documentation of this file.

// Runs the message loop and dispatches to the proper child function.
void MsgThread::Run()
{
   char*  buf = new char[ MSG_BUFFER_MAX ];
   void*  feedback;
   pid_t  rpid;
   int    runme = 1;

   while ( runme ) {

      printf("\nReceive-Blocked,");
      rpid = Receive( 0, buf, sizeof(buf) );
      printf("\tMessage Received [%d],", rpid );

          if (  rpid > 0  ) 
      {

        if ( *((int*)buf) == MSG_KILL_THREAD ) {
         printf("\nMsgThread.cc: MSG_KILL_THREAD as *((int*)buf received,");
         runme = 0;
        } else {
         // Dispatch message into the children array of local function
         printf("\tLaunch Dispatcher,");
         feedback = MsgDispatcher( buf, rpid );

         printf("\tReply,");
            Reply( rpid, feedback, sizeof(feedback) );
         }
        printf("!");
      }  
        printf("!");
   }
   printf("\tBreak,");
// Line 26
    // Send confirmation for destruction
   delete [] buf;

   printf( "\tReply NULL,");
    Reply( rpid, NULL, 0 );
}

// Stops the current thread (if running)
void MsgThread::Stop()
{
   printf("\nEntering MsgThread Stop,");
   int Kill_Msg = MSG_KILL_THREAD;

    if ( pid < 0 ) { return; }

    // Try to send  MSG_KILL_THREAD  message...
   printf("\tTry to send  MSG_KILL_THREAD  message...,");
    Send( pid, &Kill_Msg, NULL, sizeof( Kill_Msg ), 0 );

   printf("End Thread");
    _endthread();

    pid = -1;
}

---