| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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 #ifndef COMPONENTS_ARC_ARC_BRIDGE_SERVICE_H_ | 5 #ifndef COMPONENTS_ARC_ARC_BRIDGE_SERVICE_H_ |
| 6 #define COMPONENTS_ARC_ARC_BRIDGE_SERVICE_H_ | 6 #define COMPONENTS_ARC_ARC_BRIDGE_SERVICE_H_ |
| 7 | 7 |
| 8 #include "base/macros.h" | 8 #include "base/macros.h" |
| 9 #include "base/observer_list.h" | 9 #include "base/observer_list.h" |
| 10 #include "base/sequenced_task_runner.h" | 10 #include "base/sequenced_task_runner.h" |
| 11 #include "ipc/ipc_channel_handle.h" |
| 11 #include "ipc/ipc_channel_proxy.h" | 12 #include "ipc/ipc_channel_proxy.h" |
| 12 #include "ipc/ipc_listener.h" | 13 #include "ipc/ipc_listener.h" |
| 13 #include "ipc/ipc_message.h" | 14 #include "ipc/ipc_message.h" |
| 14 | 15 |
| 16 namespace content { |
| 17 class GpuArcAcceleratorHost; |
| 18 } |
| 19 |
| 15 namespace arc { | 20 namespace arc { |
| 16 | 21 |
| 17 // The Chrome-side service that handles ARC instances and ARC bridge creation. | 22 // The Chrome-side service that handles ARC instances and ARC bridge creation. |
| 18 // This service handles the lifetime of ARC instances and sets up the | 23 // This service handles the lifetime of ARC instances and sets up the |
| 19 // communication channel (the ARC bridge) used to send and receive messages. | 24 // communication channel (the ARC bridge) used to send and receive messages. |
| 20 class ArcBridgeService : public IPC::Listener { | 25 class ArcBridgeService : public IPC::Listener, public IPC::Sender { |
| 21 public: | 26 public: |
| 22 // The possible states of the bridge. In the normal flow, the state changes | 27 // The possible states of the bridge. In the normal flow, the state changes |
| 23 // in the following sequence: | 28 // in the following sequence: |
| 24 // | 29 // |
| 25 // STOPPED | 30 // STOPPED |
| 26 // SetAvailable(true) + HandleStartup() -> SocketConnect() -> | 31 // SetAvailable(true) + HandleStartup() -> SocketConnect() -> |
| 27 // CONNECTING | 32 // CONNECTING |
| 28 // Connect() -> | 33 // Connect() -> |
| 29 // CONNECTED | 34 // CONNECTED |
| 30 // SocketConnectAfterSetSocketPermissions() -> | 35 // SocketConnectAfterSetSocketPermissions() -> |
| (...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 73 | 78 |
| 74 ArcBridgeService( | 79 ArcBridgeService( |
| 75 const scoped_refptr<base::SingleThreadTaskRunner>& ipc_task_runner, | 80 const scoped_refptr<base::SingleThreadTaskRunner>& ipc_task_runner, |
| 76 const scoped_refptr<base::SequencedTaskRunner>& file_task_runner); | 81 const scoped_refptr<base::SequencedTaskRunner>& file_task_runner); |
| 77 ~ArcBridgeService() override; | 82 ~ArcBridgeService() override; |
| 78 | 83 |
| 79 // Gets the global instance of the ARC Bridge Service. This can only be | 84 // Gets the global instance of the ARC Bridge Service. This can only be |
| 80 // called on the thread that this class was created on. | 85 // called on the thread that this class was created on. |
| 81 static ArcBridgeService* Get(); | 86 static ArcBridgeService* Get(); |
| 82 | 87 |
| 88 // IPC::Sender: |
| 89 bool Send(IPC::Message* message) override; |
| 90 |
| 83 // DetectAvailability() should be called once D-Bus is available. It will | 91 // DetectAvailability() should be called once D-Bus is available. It will |
| 84 // call CheckArcAvailability() on the session_manager. This can only be | 92 // call CheckArcAvailability() on the session_manager. This can only be |
| 85 // called on the thread that this class was created on. | 93 // called on the thread that this class was created on. |
| 86 void DetectAvailability(); | 94 void DetectAvailability(); |
| 87 | 95 |
| 88 // HandleStartup() should be called upon profile startup. This will only | 96 // HandleStartup() should be called upon profile startup. This will only |
| 89 // launch an instance if the instance service is available and it is enabled. | 97 // launch an instance if the instance service is available and it is enabled. |
| 90 // This can only be called on the thread that this class was created on. | 98 // This can only be called on the thread that this class was created on. |
| 91 void HandleStartup(); | 99 void HandleStartup(); |
| 92 | 100 |
| (...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 141 void SocketConnectAfterSetSocketPermissions(const base::FilePath& socket_path, | 149 void SocketConnectAfterSetSocketPermissions(const base::FilePath& socket_path, |
| 142 bool socket_permissions_success); | 150 bool socket_permissions_success); |
| 143 | 151 |
| 144 // Stops the running instance. | 152 // Stops the running instance. |
| 145 void StopInstance(); | 153 void StopInstance(); |
| 146 | 154 |
| 147 // Called when the ARC instance has finished setting up and is ready for user | 155 // Called when the ARC instance has finished setting up and is ready for user |
| 148 // interaction. | 156 // interaction. |
| 149 void OnInstanceReady(); | 157 void OnInstanceReady(); |
| 150 | 158 |
| 159 void OnCreateArcVideoAccelerator(uint32_t device_type, |
| 160 IPC::Message* reply_msg); |
| 161 void ReplyCreateArcVideoAccelerator(IPC::Message* reply, |
| 162 IPC::ChannelHandle handle, |
| 163 uint32_t result); |
| 164 |
| 151 // Changes the current state and notifies all observers. | 165 // Changes the current state and notifies all observers. |
| 152 void SetState(State state); | 166 void SetState(State state); |
| 153 | 167 |
| 154 // IPC::Listener: | 168 // IPC::Listener: |
| 155 bool OnMessageReceived(const IPC::Message& message) override; | 169 bool OnMessageReceived(const IPC::Message& message) override; |
| 156 | 170 |
| 157 // DBus callbacks. | 171 // DBus callbacks. |
| 158 void OnArcAvailable(bool available); | 172 void OnArcAvailable(bool available); |
| 159 void OnInstanceStarted(bool success); | 173 void OnInstanceStarted(bool success); |
| 160 void OnInstanceStopped(bool success); | 174 void OnInstanceStopped(bool success); |
| 161 | 175 |
| 176 scoped_ptr<content::GpuArcAcceleratorHost> gpu_arc_accelerator_host_; |
| 162 scoped_refptr<base::SequencedTaskRunner> origin_task_runner_; | 177 scoped_refptr<base::SequencedTaskRunner> origin_task_runner_; |
| 163 scoped_refptr<base::SingleThreadTaskRunner> ipc_task_runner_; | 178 scoped_refptr<base::SingleThreadTaskRunner> ipc_task_runner_; |
| 164 scoped_refptr<base::SequencedTaskRunner> file_task_runner_; | 179 scoped_refptr<base::SequencedTaskRunner> file_task_runner_; |
| 165 | 180 |
| 166 scoped_ptr<IPC::ChannelProxy> ipc_channel_; | 181 scoped_ptr<IPC::ChannelProxy> ipc_channel_; |
| 167 | 182 |
| 168 base::ObserverList<Observer> observer_list_; | 183 base::ObserverList<Observer> observer_list_; |
| 169 | 184 |
| 170 // If the user's session has started. | 185 // If the user's session has started. |
| 171 bool session_started_; | 186 bool session_started_; |
| 172 | 187 |
| 173 // If the ARC instance service is available. | 188 // If the ARC instance service is available. |
| 174 bool available_; | 189 bool available_; |
| 175 | 190 |
| 176 // The current state of the bridge. | 191 // The current state of the bridge. |
| 177 ArcBridgeService::State state_; | 192 ArcBridgeService::State state_; |
| 178 | 193 |
| 179 // WeakPtrFactory to use callbacks. | 194 // WeakPtrFactory to use callbacks. |
| 180 base::WeakPtrFactory<ArcBridgeService> weak_factory_; | 195 base::WeakPtrFactory<ArcBridgeService> weak_factory_; |
| 181 | 196 |
| 182 DISALLOW_COPY_AND_ASSIGN(ArcBridgeService); | 197 DISALLOW_COPY_AND_ASSIGN(ArcBridgeService); |
| 183 }; | 198 }; |
| 184 | 199 |
| 185 } // namespace arc | 200 } // namespace arc |
| 186 | 201 |
| 187 #endif // COMPONENTS_ARC_ARC_BRIDGE_SERVICE_H_ | 202 #endif // COMPONENTS_ARC_ARC_BRIDGE_SERVICE_H_ |
| OLD | NEW |