summaryrefslogtreecommitdiff
path: root/src/AbstractProxyRequestCommand.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2010-06-09 12:43:44 +0000
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2010-06-09 12:43:44 +0000
commit970e7f95a65b1b8940c9131a76372b7d7abffdf1 (patch)
treec3a9b7b51a97a01160a7b37989406b78041d9115 /src/AbstractProxyRequestCommand.cc
parent9afc36152a1ce428243a3ace608d0508716a2efb (diff)
2010-06-09 Tatsuhiro Tsujikawa <t-tujikawa@users.sourceforge.net>
Made protected member variable private. Added accessor funcs. * src/AbstractCommand.cc * src/AbstractCommand.h * src/AbstractProxyRequestCommand.cc * src/AbstractProxyRequestCommand.h * src/AbstractProxyResponseCommand.cc * src/AbstractProxyResponseCommand.h * src/CreateRequestCommand.cc * src/DownloadCommand.cc * src/DownloadCommand.h * src/FtpDownloadCommand.cc * src/FtpDownloadCommand.h * src/FtpFinishDownloadCommand.cc * src/FtpInitiateConnectionCommand.cc * src/FtpNegotiationCommand.cc * src/FtpNegotiationCommand.h * src/FtpTunnelRequestCommand.cc * src/FtpTunnelResponseCommand.cc * src/HttpDownloadCommand.cc * src/HttpInitiateConnectionCommand.cc * src/HttpProxyRequestCommand.cc * src/HttpProxyResponseCommand.cc * src/HttpRequestCommand.cc * src/HttpResponseCommand.cc * src/HttpResponseCommand.h * src/HttpSkipResponseCommand.cc * src/InitiateConnectionCommand.cc
Diffstat (limited to 'src/AbstractProxyRequestCommand.cc')
-rw-r--r--src/AbstractProxyRequestCommand.cc22
1 files changed, 11 insertions, 11 deletions
diff --git a/src/AbstractProxyRequestCommand.cc b/src/AbstractProxyRequestCommand.cc
index d15d9dfc..02b1850f 100644
--- a/src/AbstractProxyRequestCommand.cc
+++ b/src/AbstractProxyRequestCommand.cc
@@ -64,37 +64,37 @@ AbstractProxyRequestCommand::AbstractProxyRequestCommand
:
AbstractCommand(cuid, req, fileEntry, requestGroup, e, s),
_proxyRequest(proxyRequest),
- httpConnection(new HttpConnection(cuid, s, getOption().get()))
+ _httpConnection(new HttpConnection(cuid, s, getOption().get()))
{
setTimeout(getOption()->getAsInt(PREF_CONNECT_TIMEOUT));
disableReadCheckSocket();
- setWriteCheckSocket(socket);
+ setWriteCheckSocket(getSocket());
}
AbstractProxyRequestCommand::~AbstractProxyRequestCommand() {}
bool AbstractProxyRequestCommand::executeInternal() {
//socket->setBlockingMode();
- if(httpConnection->sendBufferIsEmpty()) {
+ if(_httpConnection->sendBufferIsEmpty()) {
if(!checkIfConnectionEstablished
- (socket, _connectedHostname, _connectedAddr, _connectedPort)) {
+ (getSocket(), _connectedHostname, _connectedAddr, _connectedPort)) {
return true;
}
SharedHandle<HttpRequest> httpRequest(new HttpRequest());
httpRequest->setUserAgent(getOption()->get(PREF_USER_AGENT));
- httpRequest->setRequest(req);
+ httpRequest->setRequest(getRequest());
httpRequest->setProxyRequest(_proxyRequest);
- httpConnection->sendProxyRequest(httpRequest);
+ _httpConnection->sendProxyRequest(httpRequest);
} else {
- httpConnection->sendPendingData();
+ _httpConnection->sendPendingData();
}
- if(httpConnection->sendBufferIsEmpty()) {
- e->addCommand(getNextCommand());
+ if(_httpConnection->sendBufferIsEmpty()) {
+ getDownloadEngine()->addCommand(getNextCommand());
return true;
} else {
- setWriteCheckSocket(socket);
- e->addCommand(this);
+ setWriteCheckSocket(getSocket());
+ getDownloadEngine()->addCommand(this);
return false;
}
}