Search  

---

C:/temp/src/j2k/nto/cs2.cpp

Go to the documentation of this file.

#ifndef __J2K__CS_CPP__
#define __J2K__CS_CPP__

#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <string.h>
#include <pthread.h>
#include <sys/neutrino.h>
#include <sys/dispatch.h>
#include <sync.h>
#include <time.h>

#include <j2k/nto/Basic_PThread.hpp>
#include <j2k/nto/Namespace.hpp>
#include <j2k/nto/Message.hpp>

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

pthread_barrier_t barrier;
pthread_barrier_t barrier2;

#define ATTACH_POINT "myname"

class Server : public Basic_PThread
{
private:
  int rcvid;
  char* name;
  MsgNameSpace* n;
  Message* m;

public:
  Server() : Basic_PThread() 
  { 
    name = ATTACH_POINT;
    n = new MsgNameSpace( name );
    m = new Message();
  }

  virtual ~Server() 
  { 
    if ( n ) { delete[] n; }
    if ( m ) { delete[] m; }
  }

// Server Side of the code 
virtual void run()
{
  printf( "Server started \n" );
  n->Nattach( name );

  printf( "Server attached \n" );
  fflush( stdout );

  pthread_barrier_wait( &barrier  );

  /* Do your MsgReceive's here now with the chid */
  while (1) 
  {
    rcvid = m->receive( n->getChannel() );

    printf( "Received from %d \n", rcvid );
    fflush( stdout );

    if (rcvid == -1) { /* Error condition, exit */
      break;
    }

    if ( m->checkHeader( rcvid ) )
    {
      continue;
    }

    /* A message (presumable ours) received, handle */
    printf("Server receive %d \n", m->getNumber() );
    fflush( stdout );

    m->reply( rcvid, 100 );
  }

  n->Ndetach();
}

};

// Client Side of the code 
class Client : public Basic_PThread
{
  char* name;
  MsgNameSpace* n;
  Message* m;
  Message* rm;

public:
  Client() : Basic_PThread()
  { 
    name = ATTACH_POINT;
    n  = new MsgNameSpace( name );
    m  = new Message();
    rm = new Message();
  }

  virtual ~Client()
  { 
    if ( n  ) { delete[] n;  }
    if ( m  ) { delete[] m;  }
    if ( rm ) { delete[] rm; }
  } 

virtual void run()
{
  printf( "Client started \n" );
  int fd;

  fd = n->Nopen( name );

  printf( "Client opened a connection \n" );
  fflush( stdout );

  /* Do whatever work you wanted with server connection */
  for ( register int i = 20; i < 25; i++ )
  {
    printf("Client sending %d \n", i );
    fflush( stdout );

     m->setNumber( i );
    rm->setNumber( i );

    if ( m->send( fd, rm ) == -1 ) 
    {
      break;
    }

    printf("Reply: %d \n", rm->getNumber() );
    fflush( stdout );
  }

  printf( "Client closed the connection \n" );
  fflush( stdout );

  /* Close the connection */
  n->Nclose( fd );

  pthread_barrier_wait( &barrier2 );
}

};

int main( int argc, char **argv ) 
{
  pthread_barrier_init( &barrier,  NULL, 2 );
  pthread_barrier_init( &barrier2, NULL, 2 );
 
  Server s;
  Client c;

  s.start();
  s.join();

  pthread_barrier_wait( &barrier );

  c.start();
  c.join();

  printf( "Wait for barrier 2 \n" );

  pthread_barrier_wait( &barrier2 );

  printf( "done! \n" );

  exit( 0 );

  return 0;
}

#endif

---