Search  

---

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

Go to the documentation of this file.

#ifndef __J2K__Consumer_CPP__
#define __J2K__Consumer_CPP__

#include <j2k/nto/Consumer.hpp>

  Consumer::Consumer( NameSpace* n0, int idx0 = 0 ) 
    : Basic_PThread(), 
      MsgContainer( n0, client ),
      idx( idx0 )
  { 
    message->setRequest( MQI_CONSUMER );
    message->setIndex( idx );
  }

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

    message->setPThread( tid );
  }

  void Consumer::run()
  {
    printf( "Consumer %d run \n", idx );
    fflush( stdout );

    connect();

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

    /* Do whatever work you wanted with server connection */
    register int i = 0;

    // Consuming 5 messages     
    for ( i = 0; i < 5; i++ ) 
    {
      sched_yield();

        register int data = 1000 * idx + i;
        printf("Consumer %d sending %d \n", idx, data );
        fflush( stdout );

        // Set the message number
        message->setNumber( data );

        if ( message->send( fd, replyMsg ) < 0 )
        {
          perror( "Couldn't send Message ! \n" );
        }
  
        // What is the status of the request ?
        register int status = replyMsg->getStatus();

        printf( "Status[%d] \n", status );
        fflush( stdout );

        // Did I timeout ?
        if ( replyMsg->isSuicide() )
        {
          printf( "Consumer %d SUICIDE ! \n", idx );
          fflush( stdout );
          i = 100;
        }

        if ( replyMsg->isFull() && replyMsg->isGet() )
        {
          printf( "Consumer %d retrieved %d \n", idx, replyMsg->getNumber() );
          fflush( stdout );
        }

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

    } // End of for

    printf( "Consumer disconnect \n" );
    disconnect();
  }

#endif // End of Consumer.cpp

---