Search  

---

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

Go to the documentation of this file.

#ifndef __J2K__CS6_CPP__
#define __J2K__CS6_CPP__

#include <j2k/nto/cs_def.hpp>
#include <j2k/nto/Server.hpp>
#include <j2k/nto/Producer.hpp>
#include <j2k/nto/Consumer.hpp>

#include <j2k/nto/Server.cpp>
#include <j2k/nto/Producer.cpp>
#include <j2k/nto/Consumer.cpp>

int nbConsumers = 2;
int nbProducers = 1;
int nbServers   = 1;

int main( int argc, char **argv ) 
{
  if ( argc >= 2 )
  {
    nbConsumers = (int)strtoull( argv[ 1 ], NULL, 10 );
    printf( "Loading %d consumers [%s] \n", nbConsumers, argv[1] );
  }

  if ( argc >= 3 )
  {
    nbProducers = (int)strtoull( argv[ 2 ], NULL, 10 );
    printf( "Loading %d producers [%s] \n", nbProducers, argv[2] );
  }

  NameSpace* n = new NameSpace( "coen320_fred", nbConsumers, nbProducers, nbServers  );
  Server s( n );

  Producer* p[ nbProducers ];
  Consumer* c[ nbConsumers ];

  s.start();
  setprio( s.getPID(), 20 );

  n->waitForServer();

  setprio( pthread_self(), 19 );

  register int i = 0;
  for( i = 0; i < nbProducers; i++ )
  {
    p[i] = new Producer( n, i+100 );
    p[i]->start();
    p[i]->setPThread( p[i]->getPID() );
    setprio( p[i]->getPID(), 18 );
  }

  for( i = 0; i < nbConsumers; i++ )
  {
    c[i] = new Consumer( n, i+100 );
    c[i]->start();
    c[i]->setPThread( c[i]->getPID() );
    setprio( c[i]->getPID(), 18 );
  }

  n->waitForThreads();

//  pthread_join( c.getPID(), NULL );

  n->waitForClient();

  printf( "Main Done \n" );
  fflush( stdout );

  // Shut down the READ-Blocked server
  printf( "Shut down the READ-Blocked server... \n" );
  fflush( stdout );

  pthread_kill( s.getPID(), SIGKILL );

  if ( n != NULL ) delete n;

  return 0;
}

#endif // End of CS6.cpp

---