summaryrefslogtreecommitdiff
path: root/src/FileEntry.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2011-08-10 01:17:28 +0900
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2011-08-10 01:17:28 +0900
commite8e3a6f259ab74c486aec9b5ea95d3e1f5068f6c (patch)
tree81530df222473d79cf39e007729b0d882441ebfb /src/FileEntry.cc
parent97f34ab6682d83d9a0265a4291b44eaf45703493 (diff)
wallclock is now retrieved using global::wallclock() call.
This is necessary to avoid global variable initialization order problem.
Diffstat (limited to 'src/FileEntry.cc')
-rw-r--r--src/FileEntry.cc14
1 files changed, 7 insertions, 7 deletions
diff --git a/src/FileEntry.cc b/src/FileEntry.cc
index 5ca1d23b..379be62a 100644
--- a/src/FileEntry.cc
+++ b/src/FileEntry.cc
@@ -174,13 +174,13 @@ FileEntry::getRequest
}
} else {
// Skip Request object if it is still
- // sleeping(Request::getWakeTime() < global::wallclock). If all
+ // sleeping(Request::getWakeTime() < global::wallclock()). If all
// pooled objects are sleeping, return first one. Caller should
// inspect returned object's getWakeTime().
std::deque<SharedHandle<Request> >::iterator i = requestPool_.begin();
std::deque<SharedHandle<Request> >::iterator eoi = requestPool_.end();
for(; i != eoi; ++i) {
- if((*i)->getWakeTime() <= global::wallclock) {
+ if((*i)->getWakeTime() <= global::wallclock()) {
break;
}
}
@@ -200,7 +200,7 @@ FileEntry::findFasterRequest(const SharedHandle<Request>& base)
{
const int startupIdleTime = 10;
if(requestPool_.empty() ||
- lastFasterReplace_.difference(global::wallclock) < startupIdleTime) {
+ lastFasterReplace_.difference(global::wallclock()) < startupIdleTime) {
return SharedHandle<Request>();
}
const SharedHandle<PeerStat>& fastest = requestPool_.front()->getPeerStat();
@@ -211,13 +211,13 @@ FileEntry::findFasterRequest(const SharedHandle<Request>& base)
// TODO hard coded value. See PREF_STARTUP_IDLE_TIME
if(!basestat ||
(basestat->getDownloadStartTime().
- difference(global::wallclock) >= startupIdleTime &&
+ difference(global::wallclock()) >= startupIdleTime &&
fastest->getAvgDownloadSpeed()*0.8 > basestat->calculateDownloadSpeed())){
// TODO we should consider that "fastest" is very slow.
SharedHandle<Request> fastestRequest = requestPool_.front();
requestPool_.pop_front();
inFlightRequests_.push_back(fastestRequest);
- lastFasterReplace_ = global::wallclock;
+ lastFasterReplace_ = global::wallclock();
return fastestRequest;
}
return SharedHandle<Request>();
@@ -231,7 +231,7 @@ FileEntry::findFasterRequest
{
const int startupIdleTime = 10;
const unsigned int SPEED_THRESHOLD = 20*1024;
- if(lastFasterReplace_.difference(global::wallclock) < startupIdleTime) {
+ if(lastFasterReplace_.difference(global::wallclock()) < startupIdleTime) {
return SharedHandle<Request>();
}
std::vector<std::string> inFlightHosts;
@@ -280,7 +280,7 @@ FileEntry::findFasterRequest
uris_.erase(std::find(uris_.begin(), uris_.end(), uri));
spentUris_.push_back(uri);
inFlightRequests_.push_back(fastestRequest);
- lastFasterReplace_ = global::wallclock;
+ lastFasterReplace_ = global::wallclock();
return fastestRequest;
}
A2_LOG_DEBUG("No faster server found.");