summaryrefslogtreecommitdiffstats
path: root/base
diff options
context:
space:
mode:
authortedvessenes@gmail.com <tedvessenes@gmail.com@0039d316-1c4b-4281-b951-d872f2087c98>2012-02-04 16:44:53 +0000
committertedvessenes@gmail.com <tedvessenes@gmail.com@0039d316-1c4b-4281-b951-d872f2087c98>2012-02-04 16:44:53 +0000
commit5761ab9c0748737773196f3ed02616ae6c6a1b59 (patch)
tree33a2d59a92143e36fb9790822a76e6468b885f19 /base
parentd8f868a635906d720e5a717e5a81f36df211b719 (diff)
downloadchromium_src-5761ab9c0748737773196f3ed02616ae6c6a1b59.zip
chromium_src-5761ab9c0748737773196f3ed02616ae6c6a1b59.tar.gz
chromium_src-5761ab9c0748737773196f3ed02616ae6c6a1b59.tar.bz2
Fix calls in base and net unit tests to use TimeDelta.
I found another batch of unit tests that needed their Sleep() and PostDelayedTask() interfaces updated. As far as I know, this is the last batch of changes required before the deprecated integer interfaces to these functions can be removed. R=jar@chromium.org BUG=108171 TEST= Review URL: http://codereview.chromium.org/9316036 git-svn-id: svn://svn.chromium.org/chrome/trunk/src@120480 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'base')
-rw-r--r--base/message_loop_unittest.cc85
-rw-r--r--base/message_pump_glib_unittest.cc23
-rw-r--r--base/threading/sequenced_worker_pool_unittest.cc4
3 files changed, 72 insertions, 40 deletions
diff --git a/base/message_loop_unittest.cc b/base/message_loop_unittest.cc
index 9cf4400..85ee568 100644
--- a/base/message_loop_unittest.cc
+++ b/base/message_loop_unittest.cc
@@ -165,21 +165,21 @@ void RunTest_PostDelayedTask_Basic(MessageLoop::Type message_loop_type) {
// Test that PostDelayedTask results in a delayed task.
- const int kDelayMS = 100;
+ const TimeDelta kDelay = TimeDelta::FromMilliseconds(100);
int num_tasks = 1;
Time run_time;
loop.PostDelayedTask(
FROM_HERE, base::Bind(&RecordRunTimeFunc, &run_time, &num_tasks),
- kDelayMS);
+ kDelay);
Time time_before_run = Time::Now();
loop.Run();
Time time_after_run = Time::Now();
EXPECT_EQ(0, num_tasks);
- EXPECT_LT(kDelayMS, (time_after_run - time_before_run).InMilliseconds());
+ EXPECT_LT(kDelay, time_after_run - time_before_run);
}
void RunTest_PostDelayedTask_InDelayOrder(
@@ -191,11 +191,15 @@ void RunTest_PostDelayedTask_InDelayOrder(
Time run_time1, run_time2;
loop.PostDelayedTask(
- FROM_HERE, base::Bind(&RecordRunTimeFunc, &run_time1, &num_tasks), 200);
+ FROM_HERE,
+ base::Bind(&RecordRunTimeFunc, &run_time1, &num_tasks),
+ TimeDelta::FromMilliseconds(200));
// If we get a large pause in execution (due to a context switch) here, this
// test could fail.
loop.PostDelayedTask(
- FROM_HERE, base::Bind(&RecordRunTimeFunc, &run_time2, &num_tasks), 10);
+ FROM_HERE,
+ base::Bind(&RecordRunTimeFunc, &run_time2, &num_tasks),
+ TimeDelta::FromMilliseconds(10));
loop.Run();
EXPECT_EQ(0, num_tasks);
@@ -215,17 +219,17 @@ void RunTest_PostDelayedTask_InPostOrder(
// posted at the exact same time. It would be nice if the API allowed us to
// specify the desired run time.
- const int kDelayMS = 100;
+ const TimeDelta kDelay = TimeDelta::FromMilliseconds(100);
int num_tasks = 2;
Time run_time1, run_time2;
loop.PostDelayedTask(
FROM_HERE,
- base::Bind(&RecordRunTimeFunc, &run_time1, &num_tasks), kDelayMS);
+ base::Bind(&RecordRunTimeFunc, &run_time1, &num_tasks), kDelay);
loop.PostDelayedTask(
FROM_HERE,
- base::Bind(&RecordRunTimeFunc, &run_time2, &num_tasks), kDelayMS);
+ base::Bind(&RecordRunTimeFunc, &run_time2, &num_tasks), kDelay);
loop.Run();
EXPECT_EQ(0, num_tasks);
@@ -247,7 +251,9 @@ void RunTest_PostDelayedTask_InPostOrder_2(
loop.PostTask(FROM_HERE, base::Bind(&SlowFunc, kPause, &num_tasks));
loop.PostDelayedTask(
- FROM_HERE, base::Bind(&RecordRunTimeFunc, &run_time, &num_tasks), 10);
+ FROM_HERE,
+ base::Bind(&RecordRunTimeFunc, &run_time, &num_tasks),
+ TimeDelta::FromMilliseconds(10));
Time time_before_run = Time::Now();
loop.Run();
@@ -277,7 +283,8 @@ void RunTest_PostDelayedTask_InPostOrder_3(
base::Bind(&RecordRunTimeFunc, &run_time1, &num_tasks));
loop.PostDelayedTask(
- FROM_HERE, base::Bind(&RecordRunTimeFunc, &run_time2, &num_tasks), 1);
+ FROM_HERE, base::Bind(&RecordRunTimeFunc, &run_time2, &num_tasks),
+ TimeDelta::FromMilliseconds(1));
loop.Run();
EXPECT_EQ(0, num_tasks);
@@ -300,9 +307,11 @@ void RunTest_PostDelayedTask_SharedTimer(
loop.PostDelayedTask(
FROM_HERE,
base::Bind(&RecordRunTimeFunc, &run_time1, &num_tasks),
- 1000000);
+ TimeDelta::FromSeconds(1000));
loop.PostDelayedTask(
- FROM_HERE, base::Bind(&RecordRunTimeFunc, &run_time2, &num_tasks), 10);
+ FROM_HERE,
+ base::Bind(&RecordRunTimeFunc, &run_time2, &num_tasks),
+ TimeDelta::FromMilliseconds(10));
Time start_time = Time::Now();
@@ -352,10 +361,13 @@ void RunTest_PostDelayedTask_SharedTimer_SubPump() {
loop.PostDelayedTask(
FROM_HERE,
base::Bind(&RecordRunTimeFunc, &run_time, &num_tasks),
- 1000000);
+ TimeDelta::FromSeconds(1000));
// This slightly delayed task should run from within SubPumpFunc).
- loop.PostDelayedTask(FROM_HERE, base::Bind(&PostQuitMessage, 0), 10);
+ loop.PostDelayedTask(
+ FROM_HERE,
+ base::Bind(&PostQuitMessage, 0),
+ TimeDelta::FromMilliseconds(10));
Time start_time = Time::Now();
@@ -406,10 +418,11 @@ void RunTest_EnsureDeletion(MessageLoop::Type message_loop_type) {
loop.PostTask(
FROM_HERE, base::Bind(&RecordDeletionProbe::Run,
new RecordDeletionProbe(NULL, &a_was_deleted)));
+ // TODO(ajwong): Do we really need 1000ms here?
loop.PostDelayedTask(
FROM_HERE, base::Bind(&RecordDeletionProbe::Run,
new RecordDeletionProbe(NULL, &b_was_deleted)),
- 1000); // TODO(ajwong): Do we really need 1000ms here?
+ TimeDelta::FromMilliseconds(1000));
}
EXPECT_TRUE(a_was_deleted);
EXPECT_TRUE(b_was_deleted);
@@ -811,9 +824,13 @@ void RunTest_RecursiveDenial3(MessageLoop::Type message_loop_type) {
MessageLoop::current()->PostTask(
FROM_HERE, base::Bind(&RecursiveSlowFunc, &order, 2, 2, false));
MessageLoop::current()->PostDelayedTask(
- FROM_HERE, base::Bind(&OrderedFunc, &order, 3), 5);
+ FROM_HERE,
+ base::Bind(&OrderedFunc, &order, 3),
+ TimeDelta::FromMilliseconds(5));
MessageLoop::current()->PostDelayedTask(
- FROM_HERE, base::Bind(&QuitFunc, &order, 4), 5);
+ FROM_HERE,
+ base::Bind(&QuitFunc, &order, 4),
+ TimeDelta::FromMilliseconds(5));
MessageLoop::current()->Run();
@@ -1015,7 +1032,7 @@ void RunTest_NonNestableInNestedLoop(MessageLoop::Type message_loop_type,
MessageLoop::current()->PostNonNestableDelayedTask(
FROM_HERE,
base::Bind(&OrderedFunc, &order, 2),
- 1);
+ TimeDelta::FromMilliseconds(1));
} else {
MessageLoop::current()->PostNonNestableTask(
FROM_HERE,
@@ -1032,7 +1049,7 @@ void RunTest_NonNestableInNestedLoop(MessageLoop::Type message_loop_type,
MessageLoop::current()->PostNonNestableDelayedTask(
FROM_HERE,
base::Bind(&QuitFunc, &order, 6),
- 2);
+ TimeDelta::FromMilliseconds(2));
} else {
MessageLoop::current()->PostNonNestableTask(
FROM_HERE,
@@ -1085,8 +1102,10 @@ void MouseDownUp() {
void RunTest_Dispatcher(MessageLoop::Type message_loop_type) {
MessageLoop loop(message_loop_type);
- MessageLoop::current()->PostDelayedTask(FROM_HERE,
- base::Bind(&MouseDownUp), 100);
+ MessageLoop::current()->PostDelayedTask(
+ FROM_HERE,
+ base::Bind(&MouseDownUp),
+ TimeDelta::FromMilliseconds(100));
DispatcherImpl dispatcher;
MessageLoopForUI::current()->RunWithDispatcher(&dispatcher);
ASSERT_EQ(2, dispatcher.dispatch_count_);
@@ -1104,8 +1123,10 @@ LRESULT CALLBACK MsgFilterProc(int code, WPARAM wparam, LPARAM lparam) {
void RunTest_DispatcherWithMessageHook(MessageLoop::Type message_loop_type) {
MessageLoop loop(message_loop_type);
- MessageLoop::current()->PostDelayedTask(FROM_HERE,
- base::Bind(&MouseDownUp), 100);
+ MessageLoop::current()->PostDelayedTask(
+ FROM_HERE,
+ base::Bind(&MouseDownUp),
+ TimeDelta::FromMilliseconds(100));
HHOOK msg_hook = SetWindowsHookEx(WH_MSGFILTER,
MsgFilterProc,
NULL,
@@ -1189,7 +1210,7 @@ void RunTest_IOHandler() {
thread_loop->PostTask(FROM_HERE, base::Bind(&TestIOHandler::Init,
base::Unretained(&handler)));
// Make sure the thread runs and sleeps for lack of work.
- base::PlatformThread::Sleep(base::TimeDelta::FromMilliseconds(100));
+ base::PlatformThread::Sleep(TimeDelta::FromMilliseconds(100));
const char buffer[] = "Hello there!";
DWORD written;
@@ -1232,7 +1253,7 @@ void RunTest_WaitForIO() {
base::Unretained(&handler1)));
// TODO(ajwong): Do we really need such long Sleeps in ths function?
// Make sure the thread runs and sleeps for lack of work.
- base::TimeDelta delay = base::TimeDelta::FromMilliseconds(100);
+ TimeDelta delay = TimeDelta::FromMilliseconds(100);
base::PlatformThread::Sleep(delay);
thread_loop->PostTask(FROM_HERE, base::Bind(&TestIOHandler::Init,
base::Unretained(&handler2)));
@@ -1488,21 +1509,21 @@ TEST(MessageLoopTest, WaitForIO) {
TEST(MessageLoopTest, HighResolutionTimer) {
MessageLoop loop;
- const int kFastTimerMs = 5;
- const int kSlowTimerMs = 100;
+ const TimeDelta kFastTimer = TimeDelta::FromMilliseconds(5);
+ const TimeDelta kSlowTimer = TimeDelta::FromMilliseconds(100);
EXPECT_FALSE(loop.high_resolution_timers_enabled());
// Post a fast task to enable the high resolution timers.
loop.PostDelayedTask(FROM_HERE, base::Bind(&PostNTasksThenQuit, 1),
- kFastTimerMs);
+ kFastTimer);
loop.Run();
EXPECT_TRUE(loop.high_resolution_timers_enabled());
// Post a slow task and verify high resolution timers
// are still enabled.
loop.PostDelayedTask(FROM_HERE, base::Bind(&PostNTasksThenQuit, 1),
- kSlowTimerMs);
+ kSlowTimer);
loop.Run();
EXPECT_TRUE(loop.high_resolution_timers_enabled());
@@ -1512,7 +1533,7 @@ TEST(MessageLoopTest, HighResolutionTimer) {
// Post a slow task to disable the high resolution timers.
loop.PostDelayedTask(FROM_HERE, base::Bind(&PostNTasksThenQuit, 1),
- kSlowTimerMs);
+ kSlowTimer);
loop.Run();
EXPECT_FALSE(loop.high_resolution_timers_enabled());
}
@@ -1642,7 +1663,7 @@ TEST(MessageLoopTest, DestructionObserverTest) {
// Verify that the destruction observer gets called at the very end (after
// all the pending tasks have been destroyed).
MessageLoop* loop = new MessageLoop;
- const int kDelayMS = 100;
+ const TimeDelta kDelay = TimeDelta::FromMilliseconds(100);
bool task_destroyed = false;
bool destruction_observer_called = false;
@@ -1654,7 +1675,7 @@ TEST(MessageLoopTest, DestructionObserverTest) {
base::Bind(&DestructionObserverProbe::Run,
new DestructionObserverProbe(&task_destroyed,
&destruction_observer_called)),
- kDelayMS);
+ kDelay);
delete loop;
EXPECT_TRUE(observer.task_destroyed_before_message_loop());
// The task should have been destroyed when we deleted the loop.
diff --git a/base/message_pump_glib_unittest.cc b/base/message_pump_glib_unittest.cc
index c709355..550c0e7 100644
--- a/base/message_pump_glib_unittest.cc
+++ b/base/message_pump_glib_unittest.cc
@@ -252,7 +252,9 @@ TEST_F(MessagePumpGLibTest, TestWorkWhileWaitingForEvents) {
task_count = 0;
for (int i = 0; i < 10; ++i) {
loop()->PostDelayedTask(
- FROM_HERE, base::Bind(&IncrementInt, &task_count), 10*i);
+ FROM_HERE,
+ base::Bind(&IncrementInt, &task_count),
+ base::TimeDelta::FromMilliseconds(10*i));
}
// After all the previous tasks have executed, enqueue an event that will
// quit.
@@ -261,7 +263,8 @@ TEST_F(MessagePumpGLibTest, TestWorkWhileWaitingForEvents) {
loop()->PostDelayedTask(
FROM_HERE,
base::Bind(&EventInjector::AddEvent, base::Unretained(injector()), 10,
- MessageLoop::QuitClosure()), 150);
+ MessageLoop::QuitClosure()),
+ base::TimeDelta::FromMilliseconds(150));
loop()->Run();
ASSERT_EQ(10, task_count);
EXPECT_EQ(1, injector()->processed_events());
@@ -497,9 +500,13 @@ void TestGLibLoopInternal(EventInjector* injector) {
injector->AddDummyEvent(10);
// Delayed work
MessageLoop::current()->PostDelayedTask(
- FROM_HERE, base::Bind(&IncrementInt, &task_count), 30);
+ FROM_HERE,
+ base::Bind(&IncrementInt, &task_count),
+ base::TimeDelta::FromMilliseconds(30));
MessageLoop::current()->PostDelayedTask(
- FROM_HERE, base::Bind(&GLibLoopRunner::Quit, runner.get()), 40);
+ FROM_HERE,
+ base::Bind(&GLibLoopRunner::Quit, runner.get()),
+ base::TimeDelta::FromMilliseconds(40));
// Run a nested, straight GLib message loop.
runner->RunGLib();
@@ -528,9 +535,13 @@ void TestGtkLoopInternal(EventInjector* injector) {
injector->AddDummyEvent(10);
// Delayed work
MessageLoop::current()->PostDelayedTask(
- FROM_HERE, base::Bind(&IncrementInt, &task_count), 30);
+ FROM_HERE,
+ base::Bind(&IncrementInt, &task_count),
+ base::TimeDelta::FromMilliseconds(30));
MessageLoop::current()->PostDelayedTask(
- FROM_HERE, base::Bind(&GLibLoopRunner::Quit, runner.get()), 40);
+ FROM_HERE,
+ base::Bind(&GLibLoopRunner::Quit, runner.get()),
+ base::TimeDelta::FromMilliseconds(40));
// Run a nested, straight Gtk message loop.
runner->RunLoop();
diff --git a/base/threading/sequenced_worker_pool_unittest.cc b/base/threading/sequenced_worker_pool_unittest.cc
index a3f26ec..25736d0 100644
--- a/base/threading/sequenced_worker_pool_unittest.cc
+++ b/base/threading/sequenced_worker_pool_unittest.cc
@@ -1,4 +1,4 @@
-// Copyright (c) 2011 The Chromium Authors. All rights reserved.
+// Copyright (c) 2012 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -71,7 +71,7 @@ class TestTracker : public base::RefCountedThreadSafe<TestTracker> {
SignalWorkerDone(id);
}
void SlowTask(int id) {
- base::PlatformThread::Sleep(1000);
+ base::PlatformThread::Sleep(base::TimeDelta::FromSeconds(1));
SignalWorkerDone(id);
}