From 07d270c87e6f9184aea4ca17eb26e466712e8db2 Mon Sep 17 00:00:00 2001 From: Tatsuhiro Tsujikawa Date: Sat, 22 Jun 2013 01:10:38 +0900 Subject: Require -std=c++11 and use std::shared_ptr instead of SharedHandle --- src/HttpConnection.cc | 32 ++++++++++++++++---------------- 1 file changed, 16 insertions(+), 16 deletions(-) (limited to 'src/HttpConnection.cc') diff --git a/src/HttpConnection.cc b/src/HttpConnection.cc index 84e3461f..78fe8164 100644 --- a/src/HttpConnection.cc +++ b/src/HttpConnection.cc @@ -62,7 +62,7 @@ namespace aria2 { HttpRequestEntry::HttpRequestEntry -(const SharedHandle& httpRequest) +(const std::shared_ptr& httpRequest) : httpRequest_(httpRequest), proc_(new HttpHeaderProcessor(HttpHeaderProcessor::CLIENT_PARSER)) {} @@ -71,8 +71,8 @@ HttpRequestEntry::~HttpRequestEntry() {} HttpConnection::HttpConnection (cuid_t cuid, - const SharedHandle& socket, - const SharedHandle& socketRecvBuffer) + const std::shared_ptr& socket, + const std::shared_ptr& socketRecvBuffer) : cuid_(cuid), socket_(socket), socketRecvBuffer_(socketRecvBuffer), @@ -99,7 +99,7 @@ std::string HttpConnection::eraseConfidentialInfo(const std::string& request) return result; } -void HttpConnection::sendRequest(const SharedHandle& httpRequest) +void HttpConnection::sendRequest(const std::shared_ptr& httpRequest) { std::string request = httpRequest->createRequest(); A2_LOG_INFO(fmt(MSG_SENDING_REQUEST, @@ -107,12 +107,12 @@ void HttpConnection::sendRequest(const SharedHandle& httpRequest) eraseConfidentialInfo(request).c_str())); socketBuffer_.pushStr(request); socketBuffer_.send(); - SharedHandle entry(new HttpRequestEntry(httpRequest)); + std::shared_ptr entry(new HttpRequestEntry(httpRequest)); outstandingHttpRequests_.push_back(entry); } void HttpConnection::sendProxyRequest -(const SharedHandle& httpRequest) +(const std::shared_ptr& httpRequest) { std::string request = httpRequest->createProxyRequest(); A2_LOG_INFO(fmt(MSG_SENDING_REQUEST, @@ -120,17 +120,17 @@ void HttpConnection::sendProxyRequest eraseConfidentialInfo(request).c_str())); socketBuffer_.pushStr(request); socketBuffer_.send(); - SharedHandle entry(new HttpRequestEntry(httpRequest)); + std::shared_ptr entry(new HttpRequestEntry(httpRequest)); outstandingHttpRequests_.push_back(entry); } -SharedHandle HttpConnection::receiveResponse() +std::shared_ptr HttpConnection::receiveResponse() { if(outstandingHttpRequests_.empty()) { throw DL_ABORT_EX(EX_NO_HTTP_REQUEST_ENTRY_FOUND); } - SharedHandle entry = outstandingHttpRequests_.front(); - const SharedHandle& proc = + std::shared_ptr entry = outstandingHttpRequests_.front(); + const std::shared_ptr& proc = entry->getHttpHeaderProcessor(); if(socketRecvBuffer_->bufferEmpty()) { if(socketRecvBuffer_->recv() == 0 && @@ -138,10 +138,10 @@ SharedHandle HttpConnection::receiveResponse() throw DL_RETRY_EX(EX_GOT_EOF); } } - SharedHandle httpResponse; + std::shared_ptr httpResponse; if(proc->parse(socketRecvBuffer_->getBuffer(), socketRecvBuffer_->getBufferLength())) { - const SharedHandle& httpHeader = proc->getResult(); + const std::shared_ptr& httpHeader = proc->getResult(); A2_LOG_INFO(fmt(MSG_RECEIVE_RESPONSE, cuid_, proc->getHeaderString().c_str())); @@ -155,11 +155,11 @@ SharedHandle HttpConnection::receiveResponse() return httpResponse; } -bool HttpConnection::isIssued(const SharedHandle& segment) const +bool HttpConnection::isIssued(const std::shared_ptr& segment) const { for(HttpRequestEntries::const_iterator itr = outstandingHttpRequests_.begin(), eoi = outstandingHttpRequests_.end(); itr != eoi; ++itr) { - SharedHandle httpRequest = (*itr)->getHttpRequest(); + std::shared_ptr httpRequest = (*itr)->getHttpRequest(); if(*httpRequest->getSegment() == *segment) { return true; } @@ -167,10 +167,10 @@ bool HttpConnection::isIssued(const SharedHandle& segment) const return false; } -SharedHandle HttpConnection::getFirstHttpRequest() const +std::shared_ptr HttpConnection::getFirstHttpRequest() const { if(outstandingHttpRequests_.empty()) { - return SharedHandle(); + return std::shared_ptr(); } else { return outstandingHttpRequests_.front()->getHttpRequest(); } -- cgit