Index: media/remoting/remoting_source_impl.h |
diff --git a/media/remoting/remoting_source_impl.h b/media/remoting/remoting_source_impl.h |
deleted file mode 100644 |
index 37ca7004e95460a1bac10577fd520a2660085429..0000000000000000000000000000000000000000 |
--- a/media/remoting/remoting_source_impl.h |
+++ /dev/null |
@@ -1,171 +0,0 @@ |
-// Copyright 2016 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-#ifndef MEDIA_REMOTING_REMOTING_SOURCE_IMPL_H_ |
-#define MEDIA_REMOTING_REMOTING_SOURCE_IMPL_H_ |
- |
-#include <vector> |
-#include "base/callback.h" |
-#include "base/memory/weak_ptr.h" |
-#include "base/threading/thread_checker.h" |
-#include "media/mojo/interfaces/remoting.mojom.h" |
-#include "media/remoting/rpc/rpc_broker.h" |
-#include "mojo/public/cpp/bindings/binding.h" |
- |
-namespace media { |
- |
-// State transition diagram: |
-// |
-// .--> SESSION_UNAVAILABLE |
-// | | ^ |
-// | V | |
-// | SESSION_CAN_START |
-// | | |
-// | V |
-// | .---SESSION_STARTING --. |
-// | | | | |
-// | | V | |
-// | | SESSION_STARTED----| |
-// | | | | |
-// | | V | |
-// | '-> SESSION_STOPPING | |
-// '-----' | | |
-// V V |
-// SESSION_PERMANENTLY_STOPPED |
- |
-enum RemotingSessionState { |
- // Remoting sink is not available. Can't start remoting. |
- SESSION_UNAVAILABLE, |
- // Remoting sink is available, Can start remoting. |
- SESSION_CAN_START, |
- // Starting a remoting session. |
- SESSION_STARTING, |
- // Remoting session is successively started. |
- SESSION_STARTED, |
- // Stopping the session. |
- SESSION_STOPPING, |
- // Remoting session is permanently stopped. This state indicates that the |
- // video stack cannot continue operation. For example, if a remoting session |
- // involving CDM content was stopped, there is no way to continue playback |
- // because the CDM is required but is no longer available. |
- SESSION_PERMANENTLY_STOPPED, |
-}; |
- |
-// Maintains a single remoting session for multiple clients. The session will |
-// start remoting when receiving the first request. Once remoting is started, |
-// it will be stopped when any of the following happens: |
-// 1) Receives the request from any client to stop remoting. |
-// 2) Remote sink is gone. |
-// 3) Any client requests to permanently terminate the session. |
-// 4) All clients are destroyed. |
-// |
-// This class is ref-counted because, in some cases, an instance will have |
-// shared ownership between RemotingRendererController and |
-// RemotingCdmController. |
-class RemotingSourceImpl final |
- : public mojom::RemotingSource, |
- public base::RefCountedThreadSafe<RemotingSourceImpl> { |
- public: |
- class Client { |
- public: |
- // Get notified whether the remoting session is successively started. |
- virtual void OnStarted(bool success) = 0; |
- // Get notified when session state changes. |
- virtual void OnSessionStateChanged() = 0; |
- }; |
- |
- RemotingSourceImpl(mojom::RemotingSourceRequest source_request, |
- mojom::RemoterPtr remoter); |
- |
- // Get the current session state. |
- RemotingSessionState state() const { |
- DCHECK(thread_checker_.CalledOnValidThread()); |
- return state_; |
- } |
- |
- mojom::RemotingSinkCapabilities sink_capabilities() const { |
- return sink_capabilities_; |
- } |
- |
- bool is_remote_decryption_available() const { |
- return sink_capabilities_ == |
- mojom::RemotingSinkCapabilities::CONTENT_DECRYPTION_AND_RENDERING; |
- } |
- |
- // RemotingSource implementations. |
- void OnSinkAvailable(mojom::RemotingSinkCapabilities capabilities) override; |
- void OnSinkGone() override; |
- void OnStarted() override; |
- void OnStartFailed(mojom::RemotingStartFailReason reason) override; |
- void OnMessageFromSink(const std::vector<uint8_t>& message) override; |
- void OnStopped(mojom::RemotingStopReason reason) override; |
- |
- using DataPipeStartCallback = |
- base::Callback<void(mojom::RemotingDataStreamSenderPtrInfo audio, |
- mojom::RemotingDataStreamSenderPtrInfo video, |
- mojo::ScopedDataPipeProducerHandle audio_handle, |
- mojo::ScopedDataPipeProducerHandle video_handle)>; |
- void StartDataPipe(std::unique_ptr<mojo::DataPipe> audio_data_pipe, |
- std::unique_ptr<mojo::DataPipe> video_data_pipe, |
- const DataPipeStartCallback& done_callback); |
- |
- // Requests to start remoting. Will try start a remoting session if not |
- // started yet. |client| will get informed whether the session is |
- // successifully started throught OnStarted(). |
- void StartRemoting(Client* client); |
- |
- // Requests to stop the current remoting session if started. When the session |
- // is stopping, all clients will get notified. |
- void StopRemoting(Client* client); |
- |
- // Permanently terminates the current remoting session. |
- void Shutdown(); |
- |
- // Add/remove a client to/from |clients_|. |
- // Note: Clients can only added/removed through these methods. |
- // Remoting session will be stopped if all clients are gone. |
- void AddClient(Client* client); |
- void RemoveClient(Client* client); |
- |
- remoting::RpcBroker* GetRpcBroker() const; |
- |
- private: |
- friend class base::RefCountedThreadSafe<RemotingSourceImpl>; |
- ~RemotingSourceImpl() override; |
- |
- // Updates the current session state and notifies all the clients if state |
- // changes. |
- void UpdateAndNotifyState(RemotingSessionState state); |
- |
- // Callback from RpcBroker when sending message to remote sink. |
- void SendMessageToSink(std::unique_ptr<std::vector<uint8_t>> message); |
- |
- // TODO(xjz): Might merge RpcBroker into RemotingSourceImpl. |
- // Handle incomging and outgoing RPC message. |
- remoting::RpcBroker rpc_broker_; |
- |
- const mojo::Binding<mojom::RemotingSource> binding_; |
- const mojom::RemoterPtr remoter_; |
- |
- // When the sink is available, this describes its capabilities. When not |
- // available, this is always NONE. Updated by OnSinkAvailable/Gone(). |
- mojom::RemotingSinkCapabilities sink_capabilities_ = |
- mojom::RemotingSinkCapabilities::NONE; |
- |
- // The current state. |
- RemotingSessionState state_ = RemotingSessionState::SESSION_UNAVAILABLE; |
- |
- // Clients are added/removed to/from this list by calling Add/RemoveClient(). |
- // All the clients are not belong to this class. They are supposed to call |
- // RemoveClient() before they are gone. |
- std::vector<Client*> clients_; |
- |
- // This is used to check all the methods are called on the current thread in |
- // debug builds. |
- base::ThreadChecker thread_checker_; |
-}; |
- |
-} // namespace media |
- |
-#endif // MEDIA_REMOTING_REMOTING_SOURCE_IMPL_H_ |