Search  

---

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

Go to the documentation of this file.

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

#include <j2k/Fred/QNX/Board.hpp>
#include <j2k/Fred/QNX/Reader.hpp>
#include <j2k/Fred/QNX/Writer.hpp>

#include <j2k/Fred/QNX/Board.cpp>
#include <j2k/Fred/QNX/Thread.cpp>
#include <j2k/Fred/QNX/Reader.cpp>
#include <j2k/Fred/QNX/Writer.cpp>

Board*  b1;
Reader* r1;
Writer* w1;

Reader*  r2;
MsgData* m1;

int test1() {
  b1 = new Board();
  r1 = new Reader();
  w1 = new Writer();
   
  printf("MAIN=[ (%d) (%d) ]\n\r", b1->Read(1), b1->Read() );

  printf("MAIN: Start Read\n\r");
  r1->Start();

  printf("MAIN: Start Write\n\r");
  w1->Start();

  Msg_t m;
  m.type = MSG_DO;

  printf("MAIN: Send Msg Read\n\r");
  Send( r1->Pid(), &m, &m, sizeof(m), sizeof(m) );

  for(;;) {  
    printf(".");
  }

  printf("MAIN: Done!\n\r");

  delete b1;
  delete r1;
  delete w1;

  return 0;
}

int test2() {
  int i = 0;

  r1 = new Reader(12);
  r2 = new Reader(26);
  m1 = new MsgData(MSG_FUNCTION_CALL, 5);
  m1->valid = 1;
  m1->Show();

  printf("\nMAIN: Start Read\n\r");
  r1->Start();
  r2->Start();

  printf("\nMAIN: Send Msg Read0\n\r");
  r1->SendMsg( m1, NULL );

  printf("\nMAIN: Send Msg Read1\n\r");
  r2->SendMsg( m1, NULL );

  printf("\nMAIN: Done!\n\r");
  for(i = 0; i < 50; i++ ) {
    printf("D");
  }

  r1->Stop();

  for(i = 0; i < 50; i++ ) {
    printf("#1");
  }

  r2->Stop();

  for(i = 0; i < 50; i++ ) {
    printf(".2");
  }

  delete r1;
  delay( 100 );
  delete r2;
  delay( 100 );
  delete m1;
  return 0;
}

void main() {
  test1();
}

---