| Index: dbus/end_to_end_sync_unittest.cc
|
| ===================================================================
|
| --- dbus/end_to_end_sync_unittest.cc (revision 205628)
|
| +++ dbus/end_to_end_sync_unittest.cc (working copy)
|
| @@ -11,6 +11,8 @@
|
| #include "dbus/test_service.h"
|
| #include "testing/gtest/include/gtest/gtest.h"
|
|
|
| +namespace dbus {
|
| +
|
| // The end-to-end test exercises the synchronous APIs in ObjectProxy and
|
| // ExportedObject. The test will launch a thread for the service side
|
| // operations (i.e. ExportedObject side).
|
| @@ -21,20 +23,20 @@
|
|
|
| virtual void SetUp() {
|
| // Start the test service;
|
| - dbus::TestService::Options options;
|
| - test_service_.reset(new dbus::TestService(options));
|
| + TestService::Options options;
|
| + test_service_.reset(new TestService(options));
|
| ASSERT_TRUE(test_service_->StartService());
|
| ASSERT_TRUE(test_service_->WaitUntilServiceIsStarted());
|
| ASSERT_FALSE(test_service_->HasDBusThread());
|
|
|
| // Create the client.
|
| - dbus::Bus::Options client_bus_options;
|
| - client_bus_options.bus_type = dbus::Bus::SESSION;
|
| - client_bus_options.connection_type = dbus::Bus::PRIVATE;
|
| - client_bus_ = new dbus::Bus(client_bus_options);
|
| + Bus::Options client_bus_options;
|
| + client_bus_options.bus_type = Bus::SESSION;
|
| + client_bus_options.connection_type = Bus::PRIVATE;
|
| + client_bus_ = new Bus(client_bus_options);
|
| object_proxy_ = client_bus_->GetObjectProxy(
|
| "org.chromium.TestService",
|
| - dbus::ObjectPath("/org/chromium/TestObject"));
|
| + ObjectPath("/org/chromium/TestObject"));
|
| ASSERT_FALSE(client_bus_->HasDBusThread());
|
| }
|
|
|
| @@ -45,27 +47,27 @@
|
| }
|
|
|
| protected:
|
| - scoped_ptr<dbus::TestService> test_service_;
|
| - scoped_refptr<dbus::Bus> client_bus_;
|
| - dbus::ObjectProxy* object_proxy_;
|
| + scoped_ptr<TestService> test_service_;
|
| + scoped_refptr<Bus> client_bus_;
|
| + ObjectProxy* object_proxy_;
|
| };
|
|
|
| TEST_F(EndToEndSyncTest, Echo) {
|
| const std::string kHello = "hello";
|
|
|
| // Create the method call.
|
| - dbus::MethodCall method_call("org.chromium.TestInterface", "Echo");
|
| - dbus::MessageWriter writer(&method_call);
|
| + MethodCall method_call("org.chromium.TestInterface", "Echo");
|
| + MessageWriter writer(&method_call);
|
| writer.AppendString(kHello);
|
|
|
| // Call the method.
|
| - const int timeout_ms = dbus::ObjectProxy::TIMEOUT_USE_DEFAULT;
|
| - scoped_ptr<dbus::Response> response(
|
| + const int timeout_ms = ObjectProxy::TIMEOUT_USE_DEFAULT;
|
| + scoped_ptr<Response> response(
|
| object_proxy_->CallMethodAndBlock(&method_call, timeout_ms));
|
| ASSERT_TRUE(response.get());
|
|
|
| // Check the response. kHello should be echoed back.
|
| - dbus::MessageReader reader(response.get());
|
| + MessageReader reader(response.get());
|
| std::string returned_message;
|
| ASSERT_TRUE(reader.PopString(&returned_message));
|
| EXPECT_EQ(kHello, returned_message);
|
| @@ -75,48 +77,48 @@
|
| const std::string kHello = "hello";
|
|
|
| // Create the method call.
|
| - dbus::MethodCall method_call("org.chromium.TestInterface", "DelayedEcho");
|
| - dbus::MessageWriter writer(&method_call);
|
| + MethodCall method_call("org.chromium.TestInterface", "DelayedEcho");
|
| + MessageWriter writer(&method_call);
|
| writer.AppendString(kHello);
|
|
|
| // Call the method with timeout of 0ms.
|
| const int timeout_ms = 0;
|
| - scoped_ptr<dbus::Response> response(
|
| + scoped_ptr<Response> response(
|
| object_proxy_->CallMethodAndBlock(&method_call, timeout_ms));
|
| // Should fail because of timeout.
|
| ASSERT_FALSE(response.get());
|
| }
|
|
|
| TEST_F(EndToEndSyncTest, NonexistentMethod) {
|
| - dbus::MethodCall method_call("org.chromium.TestInterface", "Nonexistent");
|
| + MethodCall method_call("org.chromium.TestInterface", "Nonexistent");
|
|
|
| - const int timeout_ms = dbus::ObjectProxy::TIMEOUT_USE_DEFAULT;
|
| - scoped_ptr<dbus::Response> response(
|
| + const int timeout_ms = ObjectProxy::TIMEOUT_USE_DEFAULT;
|
| + scoped_ptr<Response> response(
|
| object_proxy_->CallMethodAndBlock(&method_call, timeout_ms));
|
| ASSERT_FALSE(response.get());
|
| }
|
|
|
| TEST_F(EndToEndSyncTest, BrokenMethod) {
|
| - dbus::MethodCall method_call("org.chromium.TestInterface", "BrokenMethod");
|
| + MethodCall method_call("org.chromium.TestInterface", "BrokenMethod");
|
|
|
| - const int timeout_ms = dbus::ObjectProxy::TIMEOUT_USE_DEFAULT;
|
| - scoped_ptr<dbus::Response> response(
|
| + const int timeout_ms = ObjectProxy::TIMEOUT_USE_DEFAULT;
|
| + scoped_ptr<Response> response(
|
| object_proxy_->CallMethodAndBlock(&method_call, timeout_ms));
|
| ASSERT_FALSE(response.get());
|
| }
|
|
|
| TEST_F(EndToEndSyncTest, InvalidObjectPath) {
|
| // Trailing '/' is only allowed for the root path.
|
| - const dbus::ObjectPath invalid_object_path("/org/chromium/TestObject/");
|
| + const ObjectPath invalid_object_path("/org/chromium/TestObject/");
|
|
|
| // Replace object proxy with new one.
|
| object_proxy_ = client_bus_->GetObjectProxy("org.chromium.TestService",
|
| invalid_object_path);
|
|
|
| - dbus::MethodCall method_call("org.chromium.TestInterface", "Echo");
|
| + MethodCall method_call("org.chromium.TestInterface", "Echo");
|
|
|
| - const int timeout_ms = dbus::ObjectProxy::TIMEOUT_USE_DEFAULT;
|
| - scoped_ptr<dbus::Response> response(
|
| + const int timeout_ms = ObjectProxy::TIMEOUT_USE_DEFAULT;
|
| + scoped_ptr<Response> response(
|
| object_proxy_->CallMethodAndBlock(&method_call, timeout_ms));
|
| ASSERT_FALSE(response.get());
|
| }
|
| @@ -127,12 +129,14 @@
|
|
|
| // Replace object proxy with new one.
|
| object_proxy_ = client_bus_->GetObjectProxy(
|
| - invalid_service_name, dbus::ObjectPath("org.chromium.TestObject"));
|
| + invalid_service_name, ObjectPath("org.chromium.TestObject"));
|
|
|
| - dbus::MethodCall method_call("org.chromium.TestInterface", "Echo");
|
| + MethodCall method_call("org.chromium.TestInterface", "Echo");
|
|
|
| - const int timeout_ms = dbus::ObjectProxy::TIMEOUT_USE_DEFAULT;
|
| - scoped_ptr<dbus::Response> response(
|
| + const int timeout_ms = ObjectProxy::TIMEOUT_USE_DEFAULT;
|
| + scoped_ptr<Response> response(
|
| object_proxy_->CallMethodAndBlock(&method_call, timeout_ms));
|
| ASSERT_FALSE(response.get());
|
| }
|
| +
|
| +} // namespace dbus
|
|
|