Method ReceiveData

deps/FtpClient/FTPClient.cpp:1108–1149

Receives data over a socket from the server. @param[in] Observer Object for observing the execution of the command. @param[in] sckDataConnection Socket which is used for receiving the data.

/// @param[in] Observer Object for observing the execution of the command.
/// @param[in] sckDataConnection Socket which is used for receiving the data.
bool CFTPClient::ReceiveData(ITransferNotification& Observer, IBlockingSocket& sckDataConnection) const
{
  try
  {
    m_fTransferInProgress = true;

    for( TObserverSet::const_iterator it=m_setObserver.begin(); it!=m_setObserver.end(); it++ )
      (*it)->OnBeginReceivingData();

    int iNumRead=sckDataConnection.Receive(&(*m_vBuffer.begin()), static_cast<int>(m_vBuffer.size()), mc_uiTimeout);
    long lTotalBytes = iNumRead;
    while( !m_fAbortTransfer && iNumRead!=0 )
    {
      for( TObserverSet::const_iterator it=m_setObserver.begin(); it!=m_setObserver.end(); it++ )
        (*it)->OnBytesReceived(m_vBuffer, iNumRead);

      Observer.OnBytesReceived(m_vBuffer, iNumRead);

      iNumRead=sckDataConnection.Receive(&(*m_vBuffer.begin()), static_cast<int>(m_vBuffer.size()), mc_uiTimeout);
      lTotalBytes += iNumRead;
    }

    for( TObserverSet::const_iterator it2=m_setObserver.begin(); it2!=m_setObserver.end(); it2++ )
      (*it2)->OnEndReceivingData(lTotalBytes);

    m_fTransferInProgress=false;
    if( m_fAbortTransfer )
    {
      Abort();
      return false;
    }
  }
  catch(CBlockingSocketException& blockingException)
  {
    m_fTransferInProgress=false;
    ReportError(blockingException.GetErrorMessage(), CCnv::ConvertToTString(__FILE__), __LINE__);
    sckDataConnection.Cleanup();
    return false;
  }

  return true;
}

/// Sends a command to the server.
/// @param[in] Command Command to send.