Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(716)

Unified Diff: media/remoting/remoting_source_impl.h

Issue 2643253003: Media Remoting Clean-up: Less-redundant naming, style consistency, etc. (Closed)
Patch Set: REBASE Created 3 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « media/remoting/remoting_sink_observer.cc ('k') | media/remoting/remoting_source_impl.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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_
« no previous file with comments | « media/remoting/remoting_sink_observer.cc ('k') | media/remoting/remoting_source_impl.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698