adamk@chromium.org | 35c0eef | 2012-02-11 06:45:23 +0900 | [diff] [blame^] | 1 | // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
satorux@chromium.org | dccbb7b | 2011-08-24 04:25:20 +0900 | [diff] [blame] | 2 | // Use of this source code is governed by a BSD-style license that can be |
| 3 | // found in the LICENSE file. |
| 4 | |
| 5 | #include "dbus/bus.h" |
| 6 | |
satorux@chromium.org | d336d45 | 2011-09-02 15:56:23 +0900 | [diff] [blame] | 7 | #include "base/bind.h" |
| 8 | #include "base/message_loop.h" |
satorux@chromium.org | dccbb7b | 2011-08-24 04:25:20 +0900 | [diff] [blame] | 9 | #include "base/memory/ref_counted.h" |
satorux@chromium.org | d336d45 | 2011-09-02 15:56:23 +0900 | [diff] [blame] | 10 | #include "base/threading/thread.h" |
satorux@chromium.org | dccbb7b | 2011-08-24 04:25:20 +0900 | [diff] [blame] | 11 | #include "dbus/exported_object.h" |
| 12 | #include "dbus/object_proxy.h" |
| 13 | |
| 14 | #include "testing/gtest/include/gtest/gtest.h" |
| 15 | |
satorux@chromium.org | 66bc4c2 | 2011-10-06 09:20:53 +0900 | [diff] [blame] | 16 | namespace { |
| 17 | |
| 18 | // Used to test AddFilterFunction(). |
| 19 | DBusHandlerResult DummyHandler(DBusConnection* connection, |
| 20 | DBusMessage* raw_message, |
| 21 | void* user_data) { |
| 22 | return DBUS_HANDLER_RESULT_NOT_YET_HANDLED; |
| 23 | } |
| 24 | |
| 25 | } // namespace |
| 26 | |
satorux@chromium.org | dccbb7b | 2011-08-24 04:25:20 +0900 | [diff] [blame] | 27 | TEST(BusTest, GetObjectProxy) { |
| 28 | dbus::Bus::Options options; |
| 29 | scoped_refptr<dbus::Bus> bus = new dbus::Bus(options); |
| 30 | |
| 31 | dbus::ObjectProxy* object_proxy1 = |
| 32 | bus->GetObjectProxy("org.chromium.TestService", |
| 33 | "/org/chromium/TestObject"); |
| 34 | ASSERT_TRUE(object_proxy1); |
| 35 | |
| 36 | // This should return the same object. |
| 37 | dbus::ObjectProxy* object_proxy2 = |
| 38 | bus->GetObjectProxy("org.chromium.TestService", |
| 39 | "/org/chromium/TestObject"); |
| 40 | ASSERT_TRUE(object_proxy2); |
| 41 | EXPECT_EQ(object_proxy1, object_proxy2); |
| 42 | |
| 43 | // This should not. |
| 44 | dbus::ObjectProxy* object_proxy3 = |
| 45 | bus->GetObjectProxy("org.chromium.TestService", |
| 46 | "/org/chromium/DifferentTestObject"); |
| 47 | ASSERT_TRUE(object_proxy3); |
| 48 | EXPECT_NE(object_proxy1, object_proxy3); |
satorux@chromium.org | f06eb89 | 2011-10-13 09:45:26 +0900 | [diff] [blame] | 49 | |
| 50 | bus->ShutdownAndBlock(); |
satorux@chromium.org | dccbb7b | 2011-08-24 04:25:20 +0900 | [diff] [blame] | 51 | } |
| 52 | |
adamk@chromium.org | 35c0eef | 2012-02-11 06:45:23 +0900 | [diff] [blame^] | 53 | TEST(BusTest, GetObjectProxyIgnoreUnknownService) { |
| 54 | dbus::Bus::Options options; |
| 55 | scoped_refptr<dbus::Bus> bus = new dbus::Bus(options); |
| 56 | |
| 57 | dbus::ObjectProxy* object_proxy1 = |
| 58 | bus->GetObjectProxyWithOptions( |
| 59 | "org.chromium.TestService", |
| 60 | "/org/chromium/TestObject", |
| 61 | dbus::ObjectProxy::IGNORE_SERVICE_UNKNOWN_ERRORS); |
| 62 | ASSERT_TRUE(object_proxy1); |
| 63 | |
| 64 | // This should return the same object. |
| 65 | dbus::ObjectProxy* object_proxy2 = |
| 66 | bus->GetObjectProxyWithOptions( |
| 67 | "org.chromium.TestService", |
| 68 | "/org/chromium/TestObject", |
| 69 | dbus::ObjectProxy::IGNORE_SERVICE_UNKNOWN_ERRORS); |
| 70 | ASSERT_TRUE(object_proxy2); |
| 71 | EXPECT_EQ(object_proxy1, object_proxy2); |
| 72 | |
| 73 | // This should not. |
| 74 | dbus::ObjectProxy* object_proxy3 = |
| 75 | bus->GetObjectProxyWithOptions( |
| 76 | "org.chromium.TestService", |
| 77 | "/org/chromium/DifferentTestObject", |
| 78 | dbus::ObjectProxy::IGNORE_SERVICE_UNKNOWN_ERRORS); |
| 79 | ASSERT_TRUE(object_proxy3); |
| 80 | EXPECT_NE(object_proxy1, object_proxy3); |
| 81 | |
| 82 | bus->ShutdownAndBlock(); |
| 83 | } |
| 84 | |
satorux@chromium.org | dccbb7b | 2011-08-24 04:25:20 +0900 | [diff] [blame] | 85 | TEST(BusTest, GetExportedObject) { |
| 86 | dbus::Bus::Options options; |
| 87 | scoped_refptr<dbus::Bus> bus = new dbus::Bus(options); |
| 88 | |
| 89 | dbus::ExportedObject* object_proxy1 = |
| 90 | bus->GetExportedObject("org.chromium.TestService", |
| 91 | "/org/chromium/TestObject"); |
| 92 | ASSERT_TRUE(object_proxy1); |
| 93 | |
| 94 | // This should return the same object. |
| 95 | dbus::ExportedObject* object_proxy2 = |
| 96 | bus->GetExportedObject("org.chromium.TestService", |
| 97 | "/org/chromium/TestObject"); |
| 98 | ASSERT_TRUE(object_proxy2); |
| 99 | EXPECT_EQ(object_proxy1, object_proxy2); |
| 100 | |
| 101 | // This should not. |
| 102 | dbus::ExportedObject* object_proxy3 = |
| 103 | bus->GetExportedObject("org.chromium.TestService", |
| 104 | "/org/chromium/DifferentTestObject"); |
| 105 | ASSERT_TRUE(object_proxy3); |
| 106 | EXPECT_NE(object_proxy1, object_proxy3); |
satorux@chromium.org | f06eb89 | 2011-10-13 09:45:26 +0900 | [diff] [blame] | 107 | |
| 108 | bus->ShutdownAndBlock(); |
satorux@chromium.org | dccbb7b | 2011-08-24 04:25:20 +0900 | [diff] [blame] | 109 | } |
satorux@chromium.org | d336d45 | 2011-09-02 15:56:23 +0900 | [diff] [blame] | 110 | |
| 111 | TEST(BusTest, ShutdownAndBlock) { |
| 112 | dbus::Bus::Options options; |
| 113 | scoped_refptr<dbus::Bus> bus = new dbus::Bus(options); |
| 114 | ASSERT_FALSE(bus->shutdown_completed()); |
| 115 | |
| 116 | // Shut down synchronously. |
| 117 | bus->ShutdownAndBlock(); |
| 118 | EXPECT_TRUE(bus->shutdown_completed()); |
| 119 | } |
| 120 | |
| 121 | TEST(BusTest, ShutdownAndBlockWithDBusThread) { |
| 122 | // Start the D-Bus thread. |
| 123 | base::Thread::Options thread_options; |
| 124 | thread_options.message_loop_type = MessageLoop::TYPE_IO; |
| 125 | base::Thread dbus_thread("D-Bus thread"); |
| 126 | dbus_thread.StartWithOptions(thread_options); |
| 127 | |
| 128 | // Create the bus. |
| 129 | dbus::Bus::Options options; |
mdm@chromium.org | 45f2c6a | 2011-09-07 05:03:24 +0900 | [diff] [blame] | 130 | options.dbus_thread_message_loop_proxy = dbus_thread.message_loop_proxy(); |
satorux@chromium.org | d336d45 | 2011-09-02 15:56:23 +0900 | [diff] [blame] | 131 | scoped_refptr<dbus::Bus> bus = new dbus::Bus(options); |
| 132 | ASSERT_FALSE(bus->shutdown_completed()); |
| 133 | |
| 134 | // Shut down synchronously. |
| 135 | bus->ShutdownOnDBusThreadAndBlock(); |
| 136 | EXPECT_TRUE(bus->shutdown_completed()); |
| 137 | dbus_thread.Stop(); |
| 138 | } |
satorux@chromium.org | 66bc4c2 | 2011-10-06 09:20:53 +0900 | [diff] [blame] | 139 | |
| 140 | TEST(BusTest, AddFilterFunction) { |
| 141 | dbus::Bus::Options options; |
| 142 | scoped_refptr<dbus::Bus> bus = new dbus::Bus(options); |
| 143 | // Should connect before calling AddFilterFunction(). |
| 144 | bus->Connect(); |
| 145 | |
| 146 | int data1 = 100; |
| 147 | int data2 = 200; |
| 148 | ASSERT_TRUE(bus->AddFilterFunction(&DummyHandler, &data1)); |
| 149 | // Cannot add the same function with the same data. |
| 150 | ASSERT_FALSE(bus->AddFilterFunction(&DummyHandler, &data1)); |
| 151 | // Can add the same function with different data. |
| 152 | ASSERT_TRUE(bus->AddFilterFunction(&DummyHandler, &data2)); |
| 153 | |
| 154 | ASSERT_TRUE(bus->RemoveFilterFunction(&DummyHandler, &data1)); |
| 155 | ASSERT_FALSE(bus->RemoveFilterFunction(&DummyHandler, &data1)); |
| 156 | ASSERT_TRUE(bus->RemoveFilterFunction(&DummyHandler, &data2)); |
| 157 | |
| 158 | bus->ShutdownAndBlock(); |
| 159 | } |