Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(147)

Side by Side Diff: dbus/signal_sender_verification_unittest.cc

Issue 16012018: Cleanup: Put DBus unit tests in the dbus namespace, so one does not need to write dbus:: everywhere… (Closed) Base URL: svn://chrome-svn/chrome/trunk/src/
Patch Set: Created 7 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « dbus/property_unittest.cc ('k') | dbus/string_util_unittest.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "base/bind.h" 5 #include "base/bind.h"
6 #include "base/memory/scoped_ptr.h" 6 #include "base/memory/scoped_ptr.h"
7 #include "base/message_loop.h" 7 #include "base/message_loop.h"
8 #include "base/metrics/histogram.h" 8 #include "base/metrics/histogram.h"
9 #include "base/metrics/histogram_samples.h" 9 #include "base/metrics/histogram_samples.h"
10 #include "base/metrics/statistics_recorder.h" 10 #include "base/metrics/statistics_recorder.h"
11 #include "base/test/test_timeouts.h" 11 #include "base/test/test_timeouts.h"
12 #include "base/threading/platform_thread.h" 12 #include "base/threading/platform_thread.h"
13 #include "base/threading/thread_restrictions.h" 13 #include "base/threading/thread_restrictions.h"
14 #include "dbus/bus.h" 14 #include "dbus/bus.h"
15 #include "dbus/message.h" 15 #include "dbus/message.h"
16 #include "dbus/object_proxy.h" 16 #include "dbus/object_proxy.h"
17 #include "dbus/test_service.h" 17 #include "dbus/test_service.h"
18 #include "testing/gtest/include/gtest/gtest.h" 18 #include "testing/gtest/include/gtest/gtest.h"
19 19
20 namespace dbus {
21
20 // The test for sender verification in ObjectProxy. 22 // The test for sender verification in ObjectProxy.
21 class SignalSenderVerificationTest : public testing::Test { 23 class SignalSenderVerificationTest : public testing::Test {
22 public: 24 public:
23 SignalSenderVerificationTest() 25 SignalSenderVerificationTest()
24 : on_name_owner_changed_called_(false), 26 : on_name_owner_changed_called_(false),
25 on_ownership_called_(false) { 27 on_ownership_called_(false) {
26 } 28 }
27 29
28 virtual void SetUp() { 30 virtual void SetUp() {
29 base::StatisticsRecorder::Initialize(); 31 base::StatisticsRecorder::Initialize();
30 32
31 // Make the main thread not to allow IO. 33 // Make the main thread not to allow IO.
32 base::ThreadRestrictions::SetIOAllowed(false); 34 base::ThreadRestrictions::SetIOAllowed(false);
33 35
34 // Start the D-Bus thread. 36 // Start the D-Bus thread.
35 dbus_thread_.reset(new base::Thread("D-Bus Thread")); 37 dbus_thread_.reset(new base::Thread("D-Bus Thread"));
36 base::Thread::Options thread_options; 38 base::Thread::Options thread_options;
37 thread_options.message_loop_type = base::MessageLoop::TYPE_IO; 39 thread_options.message_loop_type = base::MessageLoop::TYPE_IO;
38 ASSERT_TRUE(dbus_thread_->StartWithOptions(thread_options)); 40 ASSERT_TRUE(dbus_thread_->StartWithOptions(thread_options));
39 41
40 // Create the client, using the D-Bus thread. 42 // Create the client, using the D-Bus thread.
41 dbus::Bus::Options bus_options; 43 Bus::Options bus_options;
42 bus_options.bus_type = dbus::Bus::SESSION; 44 bus_options.bus_type = Bus::SESSION;
43 bus_options.connection_type = dbus::Bus::PRIVATE; 45 bus_options.connection_type = Bus::PRIVATE;
44 bus_options.dbus_task_runner = dbus_thread_->message_loop_proxy(); 46 bus_options.dbus_task_runner = dbus_thread_->message_loop_proxy();
45 bus_ = new dbus::Bus(bus_options); 47 bus_ = new Bus(bus_options);
46 object_proxy_ = bus_->GetObjectProxy( 48 object_proxy_ = bus_->GetObjectProxy(
47 "org.chromium.TestService", 49 "org.chromium.TestService",
48 dbus::ObjectPath("/org/chromium/TestObject")); 50 ObjectPath("/org/chromium/TestObject"));
49 ASSERT_TRUE(bus_->HasDBusThread()); 51 ASSERT_TRUE(bus_->HasDBusThread());
50 52
51 object_proxy_->SetNameOwnerChangedCallback( 53 object_proxy_->SetNameOwnerChangedCallback(
52 base::Bind(&SignalSenderVerificationTest::OnNameOwnerChanged, 54 base::Bind(&SignalSenderVerificationTest::OnNameOwnerChanged,
53 base::Unretained(this), 55 base::Unretained(this),
54 &on_name_owner_changed_called_)); 56 &on_name_owner_changed_called_));
55 57
56 // Connect to the "Test" signal of "org.chromium.TestInterface" from 58 // Connect to the "Test" signal of "org.chromium.TestInterface" from
57 // the remote object. 59 // the remote object.
58 object_proxy_->ConnectToSignal( 60 object_proxy_->ConnectToSignal(
59 "org.chromium.TestInterface", 61 "org.chromium.TestInterface",
60 "Test", 62 "Test",
61 base::Bind(&SignalSenderVerificationTest::OnTestSignal, 63 base::Bind(&SignalSenderVerificationTest::OnTestSignal,
62 base::Unretained(this)), 64 base::Unretained(this)),
63 base::Bind(&SignalSenderVerificationTest::OnConnected, 65 base::Bind(&SignalSenderVerificationTest::OnConnected,
64 base::Unretained(this))); 66 base::Unretained(this)));
65 // Wait until the object proxy is connected to the signal. 67 // Wait until the object proxy is connected to the signal.
66 message_loop_.Run(); 68 message_loop_.Run();
67 69
68 // Start the test service, using the D-Bus thread. 70 // Start the test service, using the D-Bus thread.
69 dbus::TestService::Options options; 71 TestService::Options options;
70 options.dbus_task_runner = dbus_thread_->message_loop_proxy(); 72 options.dbus_task_runner = dbus_thread_->message_loop_proxy();
71 test_service_.reset(new dbus::TestService(options)); 73 test_service_.reset(new TestService(options));
72 ASSERT_TRUE(test_service_->StartService()); 74 ASSERT_TRUE(test_service_->StartService());
73 ASSERT_TRUE(test_service_->WaitUntilServiceIsStarted()); 75 ASSERT_TRUE(test_service_->WaitUntilServiceIsStarted());
74 ASSERT_TRUE(test_service_->HasDBusThread()); 76 ASSERT_TRUE(test_service_->HasDBusThread());
75 ASSERT_TRUE(test_service_->has_ownership()); 77 ASSERT_TRUE(test_service_->has_ownership());
76 78
77 // Same setup for the second TestService. This service should not have the 79 // Same setup for the second TestService. This service should not have the
78 // ownership of the name at this point. 80 // ownership of the name at this point.
79 test_service2_.reset(new dbus::TestService(options)); 81 test_service2_.reset(new TestService(options));
80 ASSERT_TRUE(test_service2_->StartService()); 82 ASSERT_TRUE(test_service2_->StartService());
81 ASSERT_TRUE(test_service2_->WaitUntilServiceIsStarted()); 83 ASSERT_TRUE(test_service2_->WaitUntilServiceIsStarted());
82 ASSERT_TRUE(test_service2_->HasDBusThread()); 84 ASSERT_TRUE(test_service2_->HasDBusThread());
83 ASSERT_FALSE(test_service2_->has_ownership()); 85 ASSERT_FALSE(test_service2_->has_ownership());
84 86
85 // The name should be owned and known at this point. 87 // The name should be owned and known at this point.
86 if (!on_name_owner_changed_called_) 88 if (!on_name_owner_changed_called_)
87 message_loop_.Run(); 89 message_loop_.Run();
88 ASSERT_FALSE(latest_name_owner_.empty()); 90 ASSERT_FALSE(latest_name_owner_.empty());
89 } 91 }
(...skipping 21 matching lines...) Expand all
111 FROM_HERE, 113 FROM_HERE,
112 base::Bind(&SignalSenderVerificationTest::OnOwnershipInternal, 114 base::Bind(&SignalSenderVerificationTest::OnOwnershipInternal,
113 base::Unretained(this))); 115 base::Unretained(this)));
114 } 116 }
115 117
116 void OnOwnershipInternal() { 118 void OnOwnershipInternal() {
117 on_ownership_called_ = true; 119 on_ownership_called_ = true;
118 message_loop_.Quit(); 120 message_loop_.Quit();
119 } 121 }
120 122
121 void OnNameOwnerChanged(bool* called_flag, dbus::Signal* signal) { 123 void OnNameOwnerChanged(bool* called_flag, Signal* signal) {
122 dbus::MessageReader reader(signal); 124 MessageReader reader(signal);
123 std::string name, old_owner, new_owner; 125 std::string name, old_owner, new_owner;
124 ASSERT_TRUE(reader.PopString(&name)); 126 ASSERT_TRUE(reader.PopString(&name));
125 ASSERT_TRUE(reader.PopString(&old_owner)); 127 ASSERT_TRUE(reader.PopString(&old_owner));
126 ASSERT_TRUE(reader.PopString(&new_owner)); 128 ASSERT_TRUE(reader.PopString(&new_owner));
127 latest_name_owner_ = new_owner; 129 latest_name_owner_ = new_owner;
128 *called_flag = true; 130 *called_flag = true;
129 message_loop_.Quit(); 131 message_loop_.Quit();
130 } 132 }
131 133
132 // Called when the "Test" signal is received, in the main thread. 134 // Called when the "Test" signal is received, in the main thread.
133 // Copy the string payload to |test_signal_string_|. 135 // Copy the string payload to |test_signal_string_|.
134 void OnTestSignal(dbus::Signal* signal) { 136 void OnTestSignal(Signal* signal) {
135 dbus::MessageReader reader(signal); 137 MessageReader reader(signal);
136 ASSERT_TRUE(reader.PopString(&test_signal_string_)); 138 ASSERT_TRUE(reader.PopString(&test_signal_string_));
137 message_loop_.Quit(); 139 message_loop_.Quit();
138 } 140 }
139 141
140 // Called when connected to the signal. 142 // Called when connected to the signal.
141 void OnConnected(const std::string& interface_name, 143 void OnConnected(const std::string& interface_name,
142 const std::string& signal_name, 144 const std::string& signal_name,
143 bool success) { 145 bool success) {
144 ASSERT_TRUE(success); 146 ASSERT_TRUE(success);
145 message_loop_.Quit(); 147 message_loop_.Quit();
146 } 148 }
147 149
148 protected: 150 protected:
149 // Wait for the hey signal to be received. 151 // Wait for the hey signal to be received.
150 void WaitForTestSignal() { 152 void WaitForTestSignal() {
151 // OnTestSignal() will quit the message loop. 153 // OnTestSignal() will quit the message loop.
152 message_loop_.Run(); 154 message_loop_.Run();
153 } 155 }
154 156
155 base::MessageLoop message_loop_; 157 base::MessageLoop message_loop_;
156 scoped_ptr<base::Thread> dbus_thread_; 158 scoped_ptr<base::Thread> dbus_thread_;
157 scoped_refptr<dbus::Bus> bus_; 159 scoped_refptr<Bus> bus_;
158 dbus::ObjectProxy* object_proxy_; 160 ObjectProxy* object_proxy_;
159 scoped_ptr<dbus::TestService> test_service_; 161 scoped_ptr<TestService> test_service_;
160 scoped_ptr<dbus::TestService> test_service2_; 162 scoped_ptr<TestService> test_service2_;
161 // Text message from "Test" signal. 163 // Text message from "Test" signal.
162 std::string test_signal_string_; 164 std::string test_signal_string_;
163 165
164 // The known latest name owner of TestService. Updated in OnNameOwnerChanged. 166 // The known latest name owner of TestService. Updated in OnNameOwnerChanged.
165 std::string latest_name_owner_; 167 std::string latest_name_owner_;
166 168
167 // Boolean flags to record callback calls. 169 // Boolean flags to record callback calls.
168 bool on_name_owner_changed_called_; 170 bool on_name_owner_changed_called_;
169 bool on_ownership_called_; 171 bool on_ownership_called_;
170 }; 172 };
(...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after
241 243
242 test_service2_->SendTestSignal(kNewMessage); 244 test_service2_->SendTestSignal(kNewMessage);
243 WaitForTestSignal(); 245 WaitForTestSignal();
244 ASSERT_EQ(kNewMessage, test_signal_string_); 246 ASSERT_EQ(kNewMessage, test_signal_string_);
245 } 247 }
246 248
247 // Fails on Linux ChromiumOS Tests 249 // Fails on Linux ChromiumOS Tests
248 TEST_F(SignalSenderVerificationTest, DISABLED_TestMultipleObjects) { 250 TEST_F(SignalSenderVerificationTest, DISABLED_TestMultipleObjects) {
249 const char kMessage[] = "hello, world"; 251 const char kMessage[] = "hello, world";
250 252
251 dbus::ObjectProxy* object_proxy2 = bus_->GetObjectProxy( 253 ObjectProxy* object_proxy2 = bus_->GetObjectProxy(
252 "org.chromium.TestService", 254 "org.chromium.TestService",
253 dbus::ObjectPath("/org/chromium/DifferentObject")); 255 ObjectPath("/org/chromium/DifferentObject"));
254 256
255 bool second_name_owner_changed_called = false; 257 bool second_name_owner_changed_called = false;
256 object_proxy2->SetNameOwnerChangedCallback( 258 object_proxy2->SetNameOwnerChangedCallback(
257 base::Bind(&SignalSenderVerificationTest::OnNameOwnerChanged, 259 base::Bind(&SignalSenderVerificationTest::OnNameOwnerChanged,
258 base::Unretained(this), 260 base::Unretained(this),
259 &second_name_owner_changed_called)); 261 &second_name_owner_changed_called));
260 262
261 // Connect to a signal on the additional remote object to trigger the 263 // Connect to a signal on the additional remote object to trigger the
262 // name owner matching. 264 // name owner matching.
263 object_proxy2->ConnectToSignal( 265 object_proxy2->ConnectToSignal(
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after
304 // latest_name_owner_ becomes non empty as the new owner appears. 306 // latest_name_owner_ becomes non empty as the new owner appears.
305 ASSERT_FALSE(latest_name_owner_.empty()); 307 ASSERT_FALSE(latest_name_owner_.empty());
306 308
307 // Now the second service owns the name. 309 // Now the second service owns the name.
308 const char kNewMessage[] = "hello, new world"; 310 const char kNewMessage[] = "hello, new world";
309 311
310 test_service2_->SendTestSignal(kNewMessage); 312 test_service2_->SendTestSignal(kNewMessage);
311 WaitForTestSignal(); 313 WaitForTestSignal();
312 ASSERT_EQ(kNewMessage, test_signal_string_); 314 ASSERT_EQ(kNewMessage, test_signal_string_);
313 } 315 }
316
317 } // namespace dbus
OLDNEW
« no previous file with comments | « dbus/property_unittest.cc ('k') | dbus/string_util_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698