Search  

---

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

Go to the documentation of this file.

#ifndef __J2K__QNX__Reader_CPP__
#define __J2K__QNX__Reader_CPP__

#include <j2k/Fred/QNX/Reader.hpp>
#include <j2k/Fred/QNX/Extern.hpp>

virtual void Reader::Run() {
  int r = 0;
  int o = 0;

  for(;;) {
    printf("Reader Receive(...)\n\r");
    rpid = Receive( 0, &msg, sizeof( msg ) );
    printf("Reader Received it! [%d]\n\r", rpid );

    r = b1->Read();
    if ( r != o ) { 
      o = r;
      printf("READ()   [%d] ", r );
      printf("READ(0)  [%d] ", b1->Read(0) );
      printf("READ(1)  [%d] ", b1->Read(1) );
    }

    printf("Send NULL message to Writer\n\r");
    Send( w1->Pid(), NULL, NULL, 0, 0 );
    printf("Returned from Send\n\r");
  }

  printf("Reader finished\n\r");
} 

#endif

---