Search  

---

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

Go to the documentation of this file.

#ifndef __J2K__TIMEOUT_CPP__
#define __J2K__TIMEOUT_CPP__

#include <j2k/nto/Timeout.hpp>

Timeout::Timeout( NameSpace* n0, ULONG nsec0, ULONG sec0 )
  : TimerPulse( nsec0, sec0 ), 
    MsgContainer( n0, client ),
    delay_nsec( nsec0 ), 
    delay_sec(   sec0 ),
    rcvid( 0 )
{ 
  message->setRequest( MQI_TIMEOUT );
  message->setStatus(  MQI_TIMEOUT );
  message->setData(   (void*)this  );
//  printf( "Timeout built \n" );
//  fflush( stdout );
}

void Timeout::tick( int signo )
{
  const int time_out = 5;

  printf( "# Tick %d for %d #\n", (time_out - count ), message->getNumber() );
  fflush( stdout );

  count++;
  if ( count < time_out ) 
  {
    TimerPulse::set( delay_nsec, delay_sec );
    return;
  }

  TimerPulse::set( 0, 0 );
  printf( "DIRECT Reply \n" );
  message->setRequest( MQI_TIMEOUT );
  message->setStatus(  MQI_TIMEOUT );
  message->setData(   (void*)this  );

  // Shut down the READ-Blocked consumer
  printf( "Killing PID[%d] ID#%d \n", message->getPThread(), rcvid );
  fflush( stdout );


  message->reply( rcvid );
  message->print();

  printf( "Reply sent \n" );
  fflush( stdout );

//  setprio( message->getPThread(), 19 );
//  sched_yield();
//  pthread_kill( message->getPThread(), SIGKILL );

  return;

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

void Timeout::start()
{
//  printf( "Timer connecting... \n" );
  connect();

  printf( "Timer started.\n" );
  fflush( stdout ); 

  TimerPulse::start();
}

#endif // End of Timeout.cpp

---