Search  

---

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

Go to the documentation of this file.

// Sending Factory

#ifndef __J2K__TFTP_Sender_CPP__
#define __J2K__TFTP_Sender_CPP__

#include <j2k/Net/TFTP/TFTP_Sender.hpp>

// Finish the Windows size modulo crapt and also in DataFactory
// This class send data packet created by the Data Factory 
// until the queue is empty or that the window Size is reached
// the window size shall be incremented by the ACK function
// in TFTP_Parser.

TFTP_Sender::TFTP_Sender() : Basic_PThread() 
{
   timeout = (double)option.getTimeOutValue();
   packet  = NULL;
   currentDataNo = 0;

   // Incremented by Acknowledge packet
   option.windowsizeLeft = option.getWindowSizeValue();

   printf("Creating Sender...\n");
   fflush( stdout );
}

void TFTP_Sender::sendData() 
{
    option.rwlock5_data_queue.read();
    packet = option.data_queue->dequeue();
    option.rwlock5_data_queue.releaseRead();

    packet->send();

    option.rwlock6_wait_queue.write();
    packet->setTimeStamp( option.currentTime + timeout );

    // First time sent.
    packet->resent = 0;
    //printf("The windowsizeLeft is %d\n",option.windowsizeLeft);
    option.rwlock1_global.write();
    option.windowsizeLeft--;
    option.rwlock1_global.releaseWrite();

    option.waitingAck_queue->enqueue( packet );
    option.rwlock6_wait_queue.releaseWrite();
}

void TFTP_Sender::run() 
{
    printf("Starting Sender...\n");
    fflush( stdout );
    

  for( currentDataNo = 1;
       currentDataNo <= option.LastData; //  && option.Done == FALSE;
       currentDataNo++ )
  {

      
    // If there is nothing then let other folks run.
    while( option.data_queue->isEmpty() ) {
      sched_yield();
    }

    //If the there window size is 0, then wait till it get's bigger
    while( option.windowsizeLeft < 1  )
    {
       sched_yield();             
    }    
      
    sendData();    
    sched_yield();
    
  }
  
   printf("Ending Sender...\n");
   exit(1);

   fflush( stdout );
}

#endif

---