OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 <algorithm> | 5 #include <algorithm> |
6 #include <string> | 6 #include <string> |
7 #include <vector> | 7 #include <vector> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/memory/scoped_ptr.h" | 10 #include "base/memory/scoped_ptr.h" |
(...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
48 dbus::Bus::Options bus_options; | 48 dbus::Bus::Options bus_options; |
49 bus_options.bus_type = dbus::Bus::SESSION; | 49 bus_options.bus_type = dbus::Bus::SESSION; |
50 bus_options.connection_type = dbus::Bus::PRIVATE; | 50 bus_options.connection_type = dbus::Bus::PRIVATE; |
51 bus_options.dbus_thread_message_loop_proxy = | 51 bus_options.dbus_thread_message_loop_proxy = |
52 dbus_thread_->message_loop_proxy(); | 52 dbus_thread_->message_loop_proxy(); |
53 bus_ = new dbus::Bus(bus_options); | 53 bus_ = new dbus::Bus(bus_options); |
54 object_proxy_ = bus_->GetObjectProxy("org.chromium.TestService", | 54 object_proxy_ = bus_->GetObjectProxy("org.chromium.TestService", |
55 "/org/chromium/TestObject"); | 55 "/org/chromium/TestObject"); |
56 ASSERT_TRUE(bus_->HasDBusThread()); | 56 ASSERT_TRUE(bus_->HasDBusThread()); |
57 | 57 |
58 // Connect to the "Test" signal from the remote object. | 58 // Connect to the "Test" signal of "org.chromium.TestInterface" from |
| 59 // the remote object. |
59 object_proxy_->ConnectToSignal( | 60 object_proxy_->ConnectToSignal( |
60 "org.chromium.TestInterface", | 61 "org.chromium.TestInterface", |
61 "Test", | 62 "Test", |
62 base::Bind(&EndToEndAsyncTest::OnTestSignal, | 63 base::Bind(&EndToEndAsyncTest::OnTestSignal, |
63 base::Unretained(this)), | 64 base::Unretained(this)), |
64 base::Bind(&EndToEndAsyncTest::OnConnected, | 65 base::Bind(&EndToEndAsyncTest::OnConnected, |
65 base::Unretained(this))); | 66 base::Unretained(this))); |
| 67 // Connect to the "Test2" signal of "org.chromium.TestInterface" from |
| 68 // the remote object. There was a bug where we were emitting error |
| 69 // messages like "Requested to remove an unknown match rule: ..." at |
| 70 // the shutdown of Bus when an object proxy is connected to more than |
| 71 // one signal of the same interface. See crosbug.com/23382 for details. |
| 72 object_proxy_->ConnectToSignal( |
| 73 "org.chromium.TestInterface", |
| 74 "Test2", |
| 75 base::Bind(&EndToEndAsyncTest::OnTest2Signal, |
| 76 base::Unretained(this)), |
| 77 base::Bind(&EndToEndAsyncTest::OnConnected, |
| 78 base::Unretained(this))); |
66 // Wait until the object proxy is connected to the signal. | 79 // Wait until the object proxy is connected to the signal. |
67 message_loop_.Run(); | 80 message_loop_.Run(); |
68 } | 81 } |
69 | 82 |
70 virtual void TearDown() { | 83 virtual void TearDown() { |
71 bus_->ShutdownOnDBusThreadAndBlock(); | 84 bus_->ShutdownOnDBusThreadAndBlock(); |
72 | 85 |
73 // Shut down the service. | 86 // Shut down the service. |
74 test_service_->ShutdownAndBlock(); | 87 test_service_->ShutdownAndBlock(); |
75 | 88 |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
115 }; | 128 }; |
116 | 129 |
117 // Called when the "Test" signal is received, in the main thread. | 130 // Called when the "Test" signal is received, in the main thread. |
118 // Copy the string payload to |test_signal_string_|. | 131 // Copy the string payload to |test_signal_string_|. |
119 void OnTestSignal(dbus::Signal* signal) { | 132 void OnTestSignal(dbus::Signal* signal) { |
120 dbus::MessageReader reader(signal); | 133 dbus::MessageReader reader(signal); |
121 ASSERT_TRUE(reader.PopString(&test_signal_string_)); | 134 ASSERT_TRUE(reader.PopString(&test_signal_string_)); |
122 message_loop_.Quit(); | 135 message_loop_.Quit(); |
123 } | 136 } |
124 | 137 |
| 138 // Called when the "Test2" signal is received, in the main thread. |
| 139 void OnTest2Signal(dbus::Signal* signal) { |
| 140 dbus::MessageReader reader(signal); |
| 141 message_loop_.Quit(); |
| 142 } |
| 143 |
125 // Called when connected to the signal. | 144 // Called when connected to the signal. |
126 void OnConnected(const std::string& interface_name, | 145 void OnConnected(const std::string& interface_name, |
127 const std::string& signal_name, | 146 const std::string& signal_name, |
128 bool success) { | 147 bool success) { |
129 ASSERT_TRUE(success); | 148 ASSERT_TRUE(success); |
130 message_loop_.Quit(); | 149 message_loop_.Quit(); |
131 } | 150 } |
132 | 151 |
133 // Wait for the hey signal to be received. | 152 // Wait for the hey signal to be received. |
134 void WaitForTestSignal() { | 153 void WaitForTestSignal() { |
(...skipping 126 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
261 TEST_F(EndToEndAsyncTest, TestSignalFromRoot) { | 280 TEST_F(EndToEndAsyncTest, TestSignalFromRoot) { |
262 const char kMessage[] = "hello, world"; | 281 const char kMessage[] = "hello, world"; |
263 // Send the test signal from the root object path, to see if we can | 282 // Send the test signal from the root object path, to see if we can |
264 // handle signals sent from "/", like dbus-send does. | 283 // handle signals sent from "/", like dbus-send does. |
265 test_service_->SendTestSignalFromRoot(kMessage); | 284 test_service_->SendTestSignalFromRoot(kMessage); |
266 // Receive the signal with the object proxy. The signal is handled in | 285 // Receive the signal with the object proxy. The signal is handled in |
267 // EndToEndAsyncTest::OnTestSignal() in the main thread. | 286 // EndToEndAsyncTest::OnTestSignal() in the main thread. |
268 WaitForTestSignal(); | 287 WaitForTestSignal(); |
269 ASSERT_EQ(kMessage, test_signal_string_); | 288 ASSERT_EQ(kMessage, test_signal_string_); |
270 } | 289 } |
OLD | NEW |