Index: chrome/browser/media/router/discovery/dial/dial_registry.cc |
diff --git a/chrome/browser/media/router/discovery/dial/dial_registry.cc b/chrome/browser/media/router/discovery/dial/dial_registry.cc |
index f394945b5a37ca659178c64addb7078e9ce2c2cb..7d800eb49a9c9f8c669cbc5544fe6a593e0655ed 100644 |
--- a/chrome/browser/media/router/discovery/dial/dial_registry.cc |
+++ b/chrome/browser/media/router/discovery/dial/dial_registry.cc |
@@ -10,6 +10,7 @@ |
#include "base/memory/ptr_util.h" |
#include "base/stl_util.h" |
#include "base/strings/string_number_conversions.h" |
+#include "base/time/default_clock.h" |
#include "base/time/time.h" |
#include "base/values.h" |
#include "chrome/browser/browser_process.h" |
@@ -43,10 +44,10 @@ DialRegistry::DialRegistry() |
registry_generation_(0), |
last_event_registry_generation_(0), |
label_count_(0), |
- refresh_interval_delta_( |
- base::TimeDelta::FromSeconds(kDialRefreshIntervalSecs)), |
- expiration_delta_(base::TimeDelta::FromSeconds(kDialExpirationSecs)), |
- max_devices_(kDialMaxDevices) { |
+ refresh_interval_delta_(TimeDelta::FromSeconds(kDialRefreshIntervalSecs)), |
+ expiration_delta_(TimeDelta::FromSeconds(kDialExpirationSecs)), |
+ max_devices_(kDialMaxDevices), |
+ clock_(new base::DefaultClock()) { |
DCHECK_CURRENTLY_ON(BrowserThread::IO); |
DCHECK_GT(max_devices_, 0U); |
// This is a leaky singleton, so there's no code to remove |this| as an |
@@ -73,10 +74,6 @@ void DialRegistry::ClearDialService() { |
dial_.reset(); |
} |
-base::Time DialRegistry::Now() const { |
- return Time::Now(); |
-} |
- |
void DialRegistry::OnListenerAdded() { |
DCHECK_CURRENTLY_ON(BrowserThread::IO); |
if (++num_listeners_ == 1) { |
@@ -125,6 +122,10 @@ void DialRegistry::AddDeviceForTest(const DialDeviceData& device_data) { |
std::make_pair(device_data.device_id(), std::move(test_data))); |
} |
+void DialRegistry::SetClockForTest(std::unique_ptr<base::Clock> clock) { |
+ clock_ = std::move(clock); |
+} |
+ |
bool DialRegistry::ReadyToDiscover() { |
if (num_listeners_ == 0) { |
OnDialError(DIAL_NO_LISTENERS); |
@@ -219,7 +220,7 @@ bool DialRegistry::PruneExpiredDevices() { |
} |
bool DialRegistry::IsDeviceExpired(const DialDeviceData& device) const { |
- Time now = Now(); |
+ Time now = clock_->Now(); |
// Check against our default expiration timeout. |
Time default_expiration_time = device.response_time() + expiration_delta_; |