Search  

---

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

Go to the documentation of this file.

#ifndef __J2K__Producer_CPP__
#define __J2K__Producer_CPP__

#include <j2k/nto/Producer.hpp>

/*** Producer Side of the code ***/
  Producer::Producer( NameSpace* n0, int idx0 = 0 )
    : Basic_PThread(),
      MsgContainer( n0, client ),
      idx( idx0 )
  { 
    message->setRequest( MQI_PRODUCER );
    message->setIndex( idx );
  }

  void Producer::setPThread( pthread_t tid )
  {
    printf( "Producer PID[%d] \n", (int)tid );
    fflush( stdout );

    message->setPThread( tid );
  }

  /*** Producer Side of the code ***/
  void Producer::run()
  {
    printf( "Producer %d run \n", idx );
    fflush( stdout );

    connect();

    printf( "Producer %d opened a connection \n", idx );
    fflush( stdout );
    n->waitForThreads();

    /* Do whatever work you wanted with server connection */
    register int i = 0;
  
    // Producing 5 messages
    for ( i = 0; i < 5; i++ ) 
    {
      sched_yield();
      
      // Random Sleeping feature 
      unsigned seed = time( NULL );
      srand( seed );
      int sec1 = rand()/100%3 + 1;

      unsigned seed2 = time( NULL );
      srand( seed2 );
      int sec2 = ( rand()/100%1 + 1 ) * sec1;
      
      printf( "Sleep for %d seconds.\n", sec2 );  
      sleep( sec2 );
      
       
        // Sending a Message
        register int data = 100 * idx + i;
        printf("Producer %d sending %d \n", idx, data );
        fflush( stdout );

        message->setNumber( data );

        if ( message->send( fd, replyMsg ) < 0 )
        {
          perror( "Couldn't send Message ! \n" );
        }

        // Suicide if Server decided to timeout a producer (not the case)
        if ( replyMsg->isSuicide() )
        {
          printf( "Producer %d SUICIDE ! \n", idx );
          fflush( stdout );
          i = 100;
        }

        printf( "Producer loop end for %d \n", data );
        fflush( stdout );

    } // End of for

    if ( replyMsg->isEmpty() )
    {
      printf( "Producer %d was consumed by %d \n", idx, replyMsg->getNumber() );
      fflush( stdout );
    }

    // Producer disconnect from the Producer-Server-Consumer channel
    printf( "Producer disconnect \n" );
    disconnect();
  }

#endif // End of Producer.cpp

---