text: /* <!-- copyright */
  /*
   * aria2 - The high speed download utility
   *
   * Copyright (C) 2006 Tatsuhiro Tsujikawa
   *
   * This program is free software; you can redistribute it and/or modify
   * it under the terms of the GNU General Public License as published by
   * the Free Software Foundation; either version 2 of the License, or
   * (at your option) any later version.
   *
   * This program is distributed in the hope that it will be useful,
   * but WITHOUT ANY WARRANTY; without even the implied warranty of
   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   * GNU General Public License for more details.
   *
   * You should have received a copy of the GNU General Public License
   * along with this program; if not, write to the Free Software
   * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
   *
   * In addition, as a special exception, the copyright holders give
   * permission to link the code of portions of this program with the
   * OpenSSL library under certain conditions as described in each
   * individual source file, and distribute linked combinations
   * including the two.
   * You must obey the GNU General Public License in all respects
   * for all of the code used other than OpenSSL.  If you modify
   * file(s) with this exception, you may extend this exception to your
   * version of the file(s), but you are not obligated to do so.  If you
   * do not wish to do so, delete this exception statement from your
   * version.  If you delete this exception statement from all source
   * files in the program, then also delete it here.
   */
  /* copyright --> */
  #include "AbstractProxyRequestCommand.h"
  #include "DownloadEngine.h"
  #include "RequestGroup.h"
  #include "Request.h"
  #include "HttpConnection.h"
  #include "HttpRequest.h"
  #include "Segment.h"
  #include "Option.h"
  #include "prefs.h"
  #include "SocketCore.h"
  #include "DownloadContext.h"
  #include "SocketRecvBuffer.h"
  #include "fmt.h"
  #include "LogFactory.h"
  
  namespace aria2 {
  
  AbstractProxyRequestCommand::AbstractProxyRequestCommand
  (cuid_t cuid,
   const SharedHandle<Request>& req,
   const SharedHandle<FileEntry>& fileEntry,
   RequestGroup* requestGroup,
   DownloadEngine* e,
   const SharedHandle<Request>& proxyRequest,
   const SharedHandle<SocketCore>& s)
    :
    AbstractCommand(cuid, req, fileEntry, requestGroup, e, s),
    proxyRequest_(proxyRequest),
    httpConnection_
    (new HttpConnection
     (cuid, s, SharedHandle<SocketRecvBuffer>(new SocketRecvBuffer(s))))
  {
    setTimeout(getOption()->getAsInt(PREF_CONNECT_TIMEOUT));
    disableReadCheckSocket();
    setWriteCheckSocket(getSocket());
  }
  
  AbstractProxyRequestCommand::~AbstractProxyRequestCommand() {}
  
  bool AbstractProxyRequestCommand::executeInternal() {
    //socket->setBlockingMode();
    if(httpConnection_->sendBufferIsEmpty()) {
      SharedHandle<HttpRequest> httpRequest(new HttpRequest());
      httpRequest->setUserAgent(getOption()->get(PREF_USER_AGENT));
      httpRequest->setRequest(getRequest());
      httpRequest->setProxyRequest(proxyRequest_);
  
      httpConnection_->sendProxyRequest(httpRequest);
    } else {
      httpConnection_->sendPendingData();
    }
    if(httpConnection_->sendBufferIsEmpty()) {
      getDownloadEngine()->addCommand(getNextCommand());
      return true;
    } else {
      setWriteCheckSocket(getSocket());
      getDownloadEngine()->addCommand(this);
      return false;
    }
  }
  
  } // namespace aria2
  