summaryrefslogtreecommitdiff
path: root/src/FileEntry.cc
diff options
context:
space:
mode:
Diffstat (limited to 'src/FileEntry.cc')
-rw-r--r--src/FileEntry.cc74
1 files changed, 34 insertions, 40 deletions
diff --git a/src/FileEntry.cc b/src/FileEntry.cc
index 8ea635ad..2786619d 100644
--- a/src/FileEntry.cc
+++ b/src/FileEntry.cc
@@ -382,9 +382,8 @@ public:
void FileEntry::extractURIResult
(std::deque<URIResult>& res, error_code::Value r)
{
- std::deque<URIResult>::iterator i =
- std::stable_partition(uriResults_.begin(), uriResults_.end(),
- FindURIResultByResult(r));
+ auto i = std::stable_partition(uriResults_.begin(), uriResults_.end(),
+ FindURIResultByResult(r));
std::copy(uriResults_.begin(), i, std::back_inserter(res));
uriResults_.erase(uriResults_.begin(), i);
}
@@ -392,9 +391,8 @@ void FileEntry::extractURIResult
void FileEntry::reuseUri(const std::vector<std::string>& ignore)
{
if(A2_LOG_DEBUG_ENABLED) {
- for(std::vector<std::string>::const_iterator i = ignore.begin(),
- eoi = ignore.end(); i != eoi; ++i) {
- A2_LOG_DEBUG(fmt("ignore host=%s", (*i).c_str()));
+ for (const auto& i: ignore) {
+ A2_LOG_DEBUG(fmt("ignore host=%s", i.c_str()));
}
}
std::deque<std::string> uris = spentUris_;
@@ -417,8 +415,8 @@ void FileEntry::reuseUri(const std::vector<std::string>& ignore)
std::set_difference(uris.begin(), uris.end(),
errorUris.begin(), errorUris.end(),
std::back_inserter(reusableURIs));
- std::vector<std::string>::iterator insertionPoint = reusableURIs.begin();
- for(std::vector<std::string>::iterator i = reusableURIs.begin(),
+ auto insertionPoint = reusableURIs.begin();
+ for(auto i = reusableURIs.begin(),
eoi = reusableURIs.end(); i != eoi; ++i) {
uri_split_result us;
if(uri_split(&us, (*i).c_str()) == 0 &&
@@ -485,36 +483,32 @@ InputIterator findRequestByUri
bool FileEntry::removeUri(const std::string& uri)
{
- std::deque<std::string>::iterator itr =
- std::find(spentUris_.begin(), spentUris_.end(), uri);
+ auto itr = std::find(spentUris_.begin(), spentUris_.end(), uri);
if(itr == spentUris_.end()) {
itr = std::find(uris_.begin(), uris_.end(), uri);
if(itr == uris_.end()) {
return false;
- } else {
- uris_.erase(itr);
+ }
+ uris_.erase(itr);
+ return true;
+ }
+ spentUris_.erase(itr);
+ std::shared_ptr<Request> req;
+ InFlightRequestSet::iterator riter =
+ findRequestByUri(inFlightRequests_.begin(), inFlightRequests_.end(), uri);
+ if(riter == inFlightRequests_.end()) {
+ RequestPool::iterator riter = findRequestByUri(requestPool_.begin(),
+ requestPool_.end(), uri);
+ if(riter == requestPool_.end()) {
return true;
}
+ req = *riter;
+ requestPool_.erase(riter);
} else {
- spentUris_.erase(itr);
- std::shared_ptr<Request> req;
- InFlightRequestSet::iterator riter =
- findRequestByUri(inFlightRequests_.begin(), inFlightRequests_.end(), uri);
- if(riter == inFlightRequests_.end()) {
- RequestPool::iterator riter = findRequestByUri(requestPool_.begin(),
- requestPool_.end(), uri);
- if(riter == requestPool_.end()) {
- return true;
- } else {
- req = *riter;
- requestPool_.erase(riter);
- }
- } else {
- req = *riter;
- }
- req->requestRemoval();
- return true;
+ req = *riter;
}
+ req->requestRemoval();
+ return true;
}
std::string FileEntry::getBasename() const
@@ -547,13 +541,12 @@ bool FileEntry::addUri(const std::string& uri)
bool FileEntry::insertUri(const std::string& uri, size_t pos)
{
std::string peUri = util::percentEncodeMini(uri);
- if(uri_split(nullptr, peUri.c_str()) == 0) {
- pos = std::min(pos, uris_.size());
- uris_.insert(uris_.begin()+pos, peUri);
- return true;
- } else {
+ if(uri_split(nullptr, peUri.c_str()) != 0) {
return false;
}
+ pos = std::min(pos, uris_.size());
+ uris_.insert(uris_.begin()+pos, peUri);
+ return true;
}
void FileEntry::setPath(const std::string& path)
@@ -599,12 +592,13 @@ void writeFilePath
} else {
o << uris.front();
}
+ return;
+ }
+
+ if(memory) {
+ o << "[MEMORY]" << File(entry->getPath()).getBasename();
} else {
- if(memory) {
- o << "[MEMORY]" << File(entry->getPath()).getBasename();
- } else {
- o << entry->getPath();
- }
+ o << entry->getPath();
}
}