Search  

---

C:/temp/src/j2k/nto/bakJuly/MsgThreadTest.cpp

Go to the documentation of this file.

#include <j2k/Fred/Standard.hpp>
#include <j2k/nto/Message.hpp>
#include <j2k/nto/Namespace.hpp>
#include <j2k/nto/MsgThread.hpp>

#include <j2k/nto/TimerPulse.hpp>

#include <j2k/nto/Basic_PThread.cpp>
#include <j2k/nto/Message.cpp>
#include <j2k/nto/Namespace.cpp>
#include <j2k/nto/MsgThread.cpp>

#include <j2k/nto/TimerPulse.cpp>

class TimerPulseTest : public TimerPulse {
public:

 TimerPulseTest( ULONG clk = WAITING )
  : TimerPulse( clk ), loop( 0 ), avg( 0 ) 
 { 
 }

 virtual void tick( int signo )
 {
    loop++;
    printf( "#" );
    fflush( stdout );
    if ( loop > 100 )
    {
      exit( 0 );
    }
 }

 int loop;
 virtual ~TimerPulseTest() { }
};

class Client : public MsgThread
{
public:

  int id;
  pid_t p;

  Client( MsgNameSpace* n0 ) : MsgThread( client, n0 ) 
  { 
    p = pid;
  }

  virtual void run()
  {
    printf( "Client start\n" );
    setprio( pid, 8 );
    sched_yield();
    int i = 20;
    while( i < 30 )
    {
      printf( "C[%d]", i );
      MsgThread::send( i++ );
    }
  }
};

class Server : public MsgThread
{
public:
  pid_t p;
  int   id;

  Server( MsgNameSpace* n0, const char* name ) : MsgThread( server, n0, name ) 
  { 
    p = pid;    
  }

  virtual void run()
  {
    printf( "Server start\n" );
    setprio( pid, 8 );
    sched_yield();

    int i = 10000;
    while( i < 10030 )
    {
      printf( "S" );
      int rcvid = MsgThread::receive();

      if ( rcvid == -1 ) break;

      int r = MsgThread::handleReceive( rcvid );

      if ( r != 0 ) continue;

      printf( "S[%d][%d]", m->getMessageNumber(), i );

      MsgThread::reply( rcvid, i++ );
    }
  }
};

int main()
{
  MsgNameSpace* nn = new MsgNameSpace();

  Server a( nn, "fred" );
  Client b( nn );

  a.start();
  b.start();

  a.id = (int)b.p;
  b.id = (int)a.p;

  a.join();
  b.join();

  TimerPulseTest t;
  t.start();

  for( int k = 0; k < 100; k++ ) 
  { 
   printf( "M" );
   setprio( pthread_self(), 9 );
   sched_yield();
  } 

return 0;
}

---