1 // Copyright 2013 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
6 #include "base/memory/ref_counted.h"
7 #include "base/run_loop.h"
9 #include "dbus/object_proxy.h"
10 #include "dbus/test_service.h"
11 #include "testing/gtest/include/gtest/gtest.h"
16 class ObjectProxyTest : public testing::Test {
18 virtual void SetUp() OVERRIDE {
19 Bus::Options bus_options;
20 bus_options.bus_type = Bus::SESSION;
21 bus_options.connection_type = Bus::PRIVATE;
22 bus_ = new Bus(bus_options);
24 object_proxy_ = bus_->GetObjectProxy(
25 "org.chromium.TestService", ObjectPath("/org/chromium/TestObject"));
28 virtual void TearDown() OVERRIDE {
29 bus_->ShutdownAndBlock();
32 base::MessageLoopForIO message_loop_;
33 scoped_refptr<Bus> bus_;
34 ObjectProxy* object_proxy_;
37 // Used as a WaitForServiceToBeAvailableCallback.
38 void OnServiceIsAvailable(scoped_ptr<base::RunLoop>* run_loop,
39 bool service_is_available) {
40 EXPECT_TRUE(service_is_available);
41 ASSERT_TRUE(*run_loop);
45 TEST_F(ObjectProxyTest, WaitForServiceToBeAvailable) {
46 scoped_ptr<base::RunLoop> run_loop;
48 // Callback is not yet called because the service is not available.
49 object_proxy_->WaitForServiceToBeAvailable(
50 base::Bind(&OnServiceIsAvailable, &run_loop));
51 base::RunLoop().RunUntilIdle();
54 TestService::Options options;
55 TestService test_service(options);
56 ASSERT_TRUE(test_service.StartService());
57 ASSERT_TRUE(test_service.WaitUntilServiceIsStarted());
58 ASSERT_TRUE(test_service.has_ownership());
60 // Callback is called beacuse the service became available.
61 run_loop.reset(new base::RunLoop);
64 // Callback is called because the service is already available.
65 run_loop.reset(new base::RunLoop);
66 object_proxy_->WaitForServiceToBeAvailable(
67 base::Bind(&OnServiceIsAvailable, &run_loop));
70 // Shut down the service.
71 test_service.ShutdownAndBlock();