| OLD | NEW |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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/macros.h" | 6 #include "base/macros.h" |
| 7 #include "base/message_loop/message_loop.h" | 7 #include "base/message_loop/message_loop.h" |
| 8 #include "base/run_loop.h" | 8 #include "base/run_loop.h" |
| 9 #include "mojo/public/c/system/main.h" | 9 #include "mojo/public/c/system/main.h" |
| 10 #include "mojo/public/cpp/bindings/binding_set.h" | 10 #include "mojo/public/cpp/bindings/binding_set.h" |
| (...skipping 75 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 86 // InterfaceFactory<test::mojom::BlockedInterface>: | 86 // InterfaceFactory<test::mojom::BlockedInterface>: |
| 87 void Create(Connection* connection, | 87 void Create(Connection* connection, |
| 88 test::mojom::BlockedInterfaceRequest request) override { | 88 test::mojom::BlockedInterfaceRequest request) override { |
| 89 blocked_bindings_.AddBinding(this, std::move(request)); | 89 blocked_bindings_.AddBinding(this, std::move(request)); |
| 90 } | 90 } |
| 91 | 91 |
| 92 // test::mojom::ConnectTestService: | 92 // test::mojom::ConnectTestService: |
| 93 void GetTitle(const GetTitleCallback& callback) override { | 93 void GetTitle(const GetTitleCallback& callback) override { |
| 94 callback.Run("APP"); | 94 callback.Run("APP"); |
| 95 } | 95 } |
| 96 void GetInstance(const GetInstanceCallback& callback) override { |
| 97 callback.Run(identity_.instance()); |
| 98 } |
| 96 | 99 |
| 97 // test::mojom::StandaloneApp: | 100 // test::mojom::StandaloneApp: |
| 98 void ConnectToAllowedAppInBlockedPackage( | 101 void ConnectToAllowedAppInBlockedPackage( |
| 99 const ConnectToAllowedAppInBlockedPackageCallback& callback) override { | 102 const ConnectToAllowedAppInBlockedPackageCallback& callback) override { |
| 100 base::RunLoop run_loop; | 103 base::RunLoop run_loop; |
| 101 scoped_ptr<Connection> connection = | 104 scoped_ptr<Connection> connection = |
| 102 connector_->Connect("mojo:connect_test_a"); | 105 connector_->Connect("mojo:connect_test_a"); |
| 103 connection->SetConnectionLostClosure( | 106 connection->SetConnectionLostClosure( |
| 104 base::Bind(&ConnectTestApp::OnConnectionBlocked, | 107 base::Bind(&ConnectTestApp::OnConnectionBlocked, |
| 105 base::Unretained(this), callback, &run_loop)); | 108 base::Unretained(this), callback, &run_loop)); |
| 106 test::mojom::ConnectTestServicePtr test_service; | 109 test::mojom::ConnectTestServicePtr test_service; |
| 107 connection->GetInterface(&test_service); | 110 connection->GetInterface(&test_service); |
| 108 test_service->GetTitle( | 111 test_service->GetTitle( |
| 109 base::Bind(&ConnectTestApp::OnGotTitle, base::Unretained(this), | 112 base::Bind(&ConnectTestApp::OnGotTitle, base::Unretained(this), |
| 110 callback, &run_loop)); | 113 callback, &run_loop)); |
| 111 { | 114 { |
| 112 // This message is dispatched as a task on the same run loop, so we need | 115 // This message is dispatched as a task on the same run loop, so we need |
| 113 // to allow nesting in order to pump additional signals. | 116 // to allow nesting in order to pump additional signals. |
| 114 base::MessageLoop::ScopedNestableTaskAllower allow( | 117 base::MessageLoop::ScopedNestableTaskAllower allow( |
| 115 base::MessageLoop::current()); | 118 base::MessageLoop::current()); |
| 116 run_loop.Run(); | 119 run_loop.Run(); |
| 117 } | 120 } |
| 118 } | 121 } |
| 119 void GetInstance(const GetInstanceCallback& callback) override { | |
| 120 callback.Run(identity_.instance()); | |
| 121 } | |
| 122 | 122 |
| 123 // test::mojom::BlockedInterface: | 123 // test::mojom::BlockedInterface: |
| 124 void GetTitleBlocked(const GetTitleBlockedCallback& callback) override { | 124 void GetTitleBlocked(const GetTitleBlockedCallback& callback) override { |
| 125 callback.Run("Called Blocked Interface!"); | 125 callback.Run("Called Blocked Interface!"); |
| 126 } | 126 } |
| 127 | 127 |
| 128 void OnConnectionBlocked( | 128 void OnConnectionBlocked( |
| 129 const ConnectToAllowedAppInBlockedPackageCallback& callback, | 129 const ConnectToAllowedAppInBlockedPackageCallback& callback, |
| 130 base::RunLoop* run_loop) { | 130 base::RunLoop* run_loop) { |
| 131 callback.Run("uninitialized"); | 131 callback.Run("uninitialized"); |
| (...skipping 26 matching lines...) Expand all Loading... |
| 158 | 158 |
| 159 } // namespace shell | 159 } // namespace shell |
| 160 } // namespace mojo | 160 } // namespace mojo |
| 161 | 161 |
| 162 | 162 |
| 163 MojoResult MojoMain(MojoHandle shell_handle) { | 163 MojoResult MojoMain(MojoHandle shell_handle) { |
| 164 MojoResult rv = mojo::ApplicationRunner( | 164 MojoResult rv = mojo::ApplicationRunner( |
| 165 new mojo::shell::ConnectTestApp).Run(shell_handle); | 165 new mojo::shell::ConnectTestApp).Run(shell_handle); |
| 166 return rv; | 166 return rv; |
| 167 } | 167 } |
| OLD | NEW |