Search  

---

C:/temp/src/j2k/Net/TFTP/TFTP_Timeout.cpp

Go to the documentation of this file.

#ifndef __J2K__TFTP_Timeout_CPP__
#define __J2K__TFTP_Timeout_CPP__

#include <j2k/Net/TFTP/TFTP_Timeout.hpp>
#define  DEAD   4

// Must be straight forward in binary:
// 1/2, 1/4, 1/8, 1/16, else we got arithmetic problems !
// 250 ms
TFTP_Timeout::TFTP_Timeout() : Timer( 0000000, 10 ) 
{
  dataEmpty = 0;
  waitEmpty = 0;
  elapsed = 10.000;  // 1/4 sec
  packet  = NULL;
  timeout = option.getTimeOutValue();

  // This is logic time 0
  option.currentTime = 0;

  // Start the timer NOW !
  // Timer::start();
}

void TFTP_Timeout::timedRun( int signalNo ) 
{
  option.currentTime += elapsed;

  //  printf("Timer[%0.001f]\n", option.currentTime );

  option.rwlock6_wait_queue.write();
  option.waitingAck_queue->setFirst();
  long rc = 0;
  while ( rc >= 0 ) {
    //  printf("timedRun:  rc is equal to %d\n",rc);

    // Not Found = -1, Empty = -50, Invalid = -100 - position
      rc = option.waitingAck_queue->findTimeStamp( option.currentTime );

    // printf("timedRun: rc is returning %d after findTimeStamp\n", rc);

    if ( rc < 0 ) 
    {
        
        //option.waitingAck_queue->display();
    }
    
    if ( rc >= 0 ) {
      // TIMEOUT for packet on waitingAck_queue->curr
      packet = option.waitingAck_queue->remove();

      // Resend it, anything else to do ?!?!!?
      // Do we resent the hole thing ?!
      packet->resent++;

      // After 10 timeout on the same data packet
      if ( packet->resent > 10 ) 
      {
        SendNotDefinedError( "ERROR: 10 Timeouts. Connection closed.\n" );
        exit( 1 );
      }
      
      printf( "Resending Data, packet Timed out! \n" );
      fflush(stdout);
      packet->send();
      packet->setTimeStamp( option.currentTime + timeout );
      option.waitingAck_queue->enqueue( packet );
      fflush(stdout);
    }
  }

  if (  option.waitingAck_queue->isEmpty() ) 
  {
     waitEmpty++; 
  } else {
     waitEmpty = 0; 
  }
  
  option.rwlock6_wait_queue.releaseWrite();

  option.rwlock5_data_queue.read();
  if (  option.data_queue->isEmpty() ) 
  { 
    dataEmpty++;
  } else {
    dataEmpty = 0;
  }

  option.rwlock5_data_queue.releaseRead();
 
  if ( ( dataEmpty > DEAD || waitEmpty > DEAD ) && ( option.isReading() || option.isWriting() ) ) 
  {
    exit( 0 );
  } 
}

#endif

---