Search  

---

C:/temp/src/j2k/QNX4/Test/Reader.hpp

Go to the documentation of this file.

#ifndef __J2K__QNX__Reader_HPP__
#define __J2K__QNX__Reader_HPP__

#include <j2k/Fred/QNX/Project.hpp>

class Reader
 : public MsgThread {

// : public Thread {

public:
// Reader() { }
// virtual void Run();

  Reader( int i = 0 ) : count( 0 ), idx( i ) { }
  virtual ~Reader() { }

  // The only thing that should be implemented in MsgThreadChild
  virtual void* MsgDispatcher( void* m, pid_t replyPid ) {
    void ( *Table[3] )( void ) = { 
      function1, 
      function2, 
      function3
    };

    serial_t id = *((serial_t*)m);
    printf("\nEntering MsgDispatcher,");

    if ( id & _IS_MSG_DATA ) {
      MsgData* msg = (MsgData*)m;
      printf("\tMsgDataType [%d],", msg->valid );
      
      if ( msg->valid == 0 ) {
        printf("\tExpired MsgData,");
        return m;
      }

      if ( msg->task < MSG_VALID ) {
        printf("\tInvalid Task,");
        return m;
      }
   
      if ( ( msg->task == MSG_KILL_THREAD ) || count > 5 ) {
        Stop();
      } else if ( msg->task == MSG_FUNCTION_CALL ) {
        printf("\tReader(%d){%u}[%d][%d]/5 \n", idx, id, msg->index, count );
        ( *Table[1] )();
        count++;
      }
    } else {
      printf("I have no clue what I am ! [%u]\n\n", id );
    }

    return m;
  }

  static void function1() {
    printf("\nFn1");
  }

  static void function2() {
    printf("\nFn2");
  }

  static void function3() {
    printf("\nFn3");
  }

private:
  int count;
  int idx;
};

#endif

---