Method SendData

deps/FtpClient/FTPClient.cpp:1065–1103

Sends data over a socket to the server. @param[in] Observer Object for observing the execution of the command. @param[in] sckDataConnection Socket which is used for the send action.

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

    int iNumWrite = 0;
    size_t bytesRead = 0;

    Observer.OnPreBytesSend(&m_vBuffer.front(), m_vBuffer.size(), bytesRead);

    while( !m_fAbortTransfer && bytesRead!=0 )
    {
      iNumWrite = sckDataConnection.Write(&(*m_vBuffer.begin()), static_cast<int>(bytesRead), mc_uiTimeout);
      ASSERT( iNumWrite == static_cast<int>(bytesRead) );

      for( TObserverSet::const_iterator it=m_setObserver.begin(); it!=m_setObserver.end(); it++ )
        (*it)->OnBytesSent(m_vBuffer, iNumWrite);

      Observer.OnPreBytesSend(&m_vBuffer.front(), m_vBuffer.size(), bytesRead);
    }

    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;
}

/// Receives data over a socket from the server.
/// @param[in] Observer Object for observing the execution of the command.