diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2013-06-22 01:10:38 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2013-06-22 01:10:38 +0900 |
| commit | 07d270c87e6f9184aea4ca17eb26e466712e8db2 (patch) | |
| tree | 2dfbaa2e0d2ad0f38cb73098608f7d67a64320f8 /src/HttpConnection.cc | |
| parent | 126a4bde612eb0e6c48cf2f13ebe3eac45cc71a8 (diff) | |
Require -std=c++11 and use std::shared_ptr instead of SharedHandle
Diffstat (limited to 'src/HttpConnection.cc')
| -rw-r--r-- | src/HttpConnection.cc | 32 |
1 files changed, 16 insertions, 16 deletions
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>& httpRequest) +(const std::shared_ptr<HttpRequest>& httpRequest) : httpRequest_(httpRequest), proc_(new HttpHeaderProcessor(HttpHeaderProcessor::CLIENT_PARSER)) {} @@ -71,8 +71,8 @@ HttpRequestEntry::~HttpRequestEntry() {} HttpConnection::HttpConnection (cuid_t cuid, - const SharedHandle<SocketCore>& socket, - const SharedHandle<SocketRecvBuffer>& socketRecvBuffer) + const std::shared_ptr<SocketCore>& socket, + const std::shared_ptr<SocketRecvBuffer>& 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>& httpRequest) +void HttpConnection::sendRequest(const std::shared_ptr<HttpRequest>& httpRequest) { std::string request = httpRequest->createRequest(); A2_LOG_INFO(fmt(MSG_SENDING_REQUEST, @@ -107,12 +107,12 @@ void HttpConnection::sendRequest(const SharedHandle<HttpRequest>& httpRequest) eraseConfidentialInfo(request).c_str())); socketBuffer_.pushStr(request); socketBuffer_.send(); - SharedHandle<HttpRequestEntry> entry(new HttpRequestEntry(httpRequest)); + std::shared_ptr<HttpRequestEntry> entry(new HttpRequestEntry(httpRequest)); outstandingHttpRequests_.push_back(entry); } void HttpConnection::sendProxyRequest -(const SharedHandle<HttpRequest>& httpRequest) +(const std::shared_ptr<HttpRequest>& 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<HttpRequestEntry> entry(new HttpRequestEntry(httpRequest)); + std::shared_ptr<HttpRequestEntry> entry(new HttpRequestEntry(httpRequest)); outstandingHttpRequests_.push_back(entry); } -SharedHandle<HttpResponse> HttpConnection::receiveResponse() +std::shared_ptr<HttpResponse> HttpConnection::receiveResponse() { if(outstandingHttpRequests_.empty()) { throw DL_ABORT_EX(EX_NO_HTTP_REQUEST_ENTRY_FOUND); } - SharedHandle<HttpRequestEntry> entry = outstandingHttpRequests_.front(); - const SharedHandle<HttpHeaderProcessor>& proc = + std::shared_ptr<HttpRequestEntry> entry = outstandingHttpRequests_.front(); + const std::shared_ptr<HttpHeaderProcessor>& proc = entry->getHttpHeaderProcessor(); if(socketRecvBuffer_->bufferEmpty()) { if(socketRecvBuffer_->recv() == 0 && @@ -138,10 +138,10 @@ SharedHandle<HttpResponse> HttpConnection::receiveResponse() throw DL_RETRY_EX(EX_GOT_EOF); } } - SharedHandle<HttpResponse> httpResponse; + std::shared_ptr<HttpResponse> httpResponse; if(proc->parse(socketRecvBuffer_->getBuffer(), socketRecvBuffer_->getBufferLength())) { - const SharedHandle<HttpHeader>& httpHeader = proc->getResult(); + const std::shared_ptr<HttpHeader>& httpHeader = proc->getResult(); A2_LOG_INFO(fmt(MSG_RECEIVE_RESPONSE, cuid_, proc->getHeaderString().c_str())); @@ -155,11 +155,11 @@ SharedHandle<HttpResponse> HttpConnection::receiveResponse() return httpResponse; } -bool HttpConnection::isIssued(const SharedHandle<Segment>& segment) const +bool HttpConnection::isIssued(const std::shared_ptr<Segment>& segment) const { for(HttpRequestEntries::const_iterator itr = outstandingHttpRequests_.begin(), eoi = outstandingHttpRequests_.end(); itr != eoi; ++itr) { - SharedHandle<HttpRequest> httpRequest = (*itr)->getHttpRequest(); + std::shared_ptr<HttpRequest> httpRequest = (*itr)->getHttpRequest(); if(*httpRequest->getSegment() == *segment) { return true; } @@ -167,10 +167,10 @@ bool HttpConnection::isIssued(const SharedHandle<Segment>& segment) const return false; } -SharedHandle<HttpRequest> HttpConnection::getFirstHttpRequest() const +std::shared_ptr<HttpRequest> HttpConnection::getFirstHttpRequest() const { if(outstandingHttpRequests_.empty()) { - return SharedHandle<HttpRequest>(); + return std::shared_ptr<HttpRequest>(); } else { return outstandingHttpRequests_.front()->getHttpRequest(); } |
