Search  

---

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

Go to the documentation of this file.

#ifndef __J2K__TFTP_DataAck_CPP__
#define __J2K__TFTP_DataAck_CPP__

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

TFTP_DataAck::TFTP_DataAck( ULONG blk )  // , Basic_PThread()
 : packet( NULL )
{
  blockNo = blk;
   
  //  Basic_PThread::start();
}

void TFTP_DataAck::run() 
{
  option.rwlock6_wait_queue.write();
  option.waitingAck_queue->setFirst();
  long rc = 0;
  while ( rc >= 0 ) {

    // Not Found = -1, Empty = -50, Invalid = -100 - position
    rc = option.waitingAck_queue->findID( blockNo );
    if ( rc >= 0 ) {
      packet = NULL;
      packet = option.waitingAck_queue->remove();
      //      option.windowsizeLeft++;
      if ( packet != NULL ) delete packet;
      packet = NULL;
    }
  }

  option.rwlock6_wait_queue.releaseWrite();

  // Thread loop exited anyway.
}

TFTP_DataAck::~TFTP_DataAck() 
{
  if ( this == NULL ) return;
  if ( packet != NULL )  delete packet;
}

#endif

---