| Index: media/remoting/rpc/rpc_broker.h
|
| diff --git a/media/remoting/rpc/rpc_broker.h b/media/remoting/rpc/rpc_broker.h
|
| deleted file mode 100644
|
| index 7f5ada9b1ab08a4b3ecef51b7a64fcf1a64d3d5f..0000000000000000000000000000000000000000
|
| --- a/media/remoting/rpc/rpc_broker.h
|
| +++ /dev/null
|
| @@ -1,102 +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_RPC_RPC_BROKER_H_
|
| -#define MEDIA_REMOTING_RPC_RPC_BROKER_H_
|
| -
|
| -#include <map>
|
| -#include <memory>
|
| -#include <string>
|
| -#include <vector>
|
| -
|
| -#include "base/callback.h"
|
| -#include "base/macros.h"
|
| -#include "base/memory/weak_ptr.h"
|
| -#include "base/threading/thread_checker.h"
|
| -#include "media/remoting/remoting_rpc_message.pb.h"
|
| -
|
| -namespace media {
|
| -namespace remoting {
|
| -
|
| -// Predefined invalid handle value for RPC message.
|
| -constexpr int kInvalidHandle = -1;
|
| -
|
| -// Predefined handle value for RPC messages related to initialization.
|
| -constexpr int kReceiverHandle = 0;
|
| -
|
| -// Utility class to process incoming and outgoing RPC message to desired
|
| -// components on both end points. On sender side, for outgoing message, sender
|
| -// sends RPC message with associated handle value. On receiver side, for
|
| -// component which is interested in this RPC message has to register itself to
|
| -// RpcBroker. Before the RPC transmission starts, both sender and receiver need
|
| -// to negotiate the handle value in the existing RPC communication channel using
|
| -// handle kReceiverHandle.
|
| -//
|
| -// The class doesn't actually send RPC message to remote end point. Actual
|
| -// sender needs to set SendMessageCallback to RpcBroker. The class doesn't
|
| -// actually receive RPC message from the remote end point, either. Actually
|
| -// receiver needs to call ProcessMessageFromRemote() when RPC message is
|
| -// received. RpcBroker will distribute each RPC message to the components based
|
| -// on the handle value in the RPC message.
|
| -//
|
| -// Note this is single-threaded class running on main thread. It provides
|
| -// WeakPtr() for caller to post tasks to the main thread.
|
| -class RpcBroker {
|
| - public:
|
| - using SendMessageCallback =
|
| - base::Callback<void(std::unique_ptr<std::vector<uint8_t>>)>;
|
| - explicit RpcBroker(const SendMessageCallback& send_message_cb);
|
| - ~RpcBroker();
|
| -
|
| - // Get unique handle value (larger than 0) for RPC message handles.
|
| - int GetUniqueHandle();
|
| -
|
| - using ReceiveMessageCallback =
|
| - base::Callback<void(std::unique_ptr<pb::RpcMessage>)>;
|
| - // Register a component to receive messages via the given
|
| - // ReceiveMessageCallback. |handle| is a unique handle value provided by a
|
| - // prior call to GetUniqueHandle() and is used to reference the component in
|
| - // the RPC messages. The receiver can then use it to direct an RPC message
|
| - // back to a specific component.
|
| - void RegisterMessageReceiverCallback(int handle,
|
| - const ReceiveMessageCallback& callback);
|
| - // Allows components to unregister in order to stop receiving message.
|
| - void UnregisterMessageReceiverCallback(int handle);
|
| -
|
| - // Allows RpcBroker to distribute incoming RPC message to desired components.
|
| - void ProcessMessageFromRemote(std::unique_ptr<pb::RpcMessage> message);
|
| - // Sends RPC message to remote end point. The actually sender which sets
|
| - // SendMessageCallback to RpcBrokwer will receive RPC message to do actual
|
| - // data transmission.
|
| - void SendMessageToRemote(std::unique_ptr<pb::RpcMessage> message);
|
| -
|
| - // Gets weak pointer of RpcBroker. This allows callers to post tasks to
|
| - // RpcBroker on the main thread.
|
| - base::WeakPtr<RpcBroker> GetWeakPtr();
|
| -
|
| - // Overwrites |send_message_cb_|. This is used only for test purposes.
|
| - void SetMessageCallbackForTesting(const SendMessageCallback& send_message_cb);
|
| -
|
| - private:
|
| - // Checks that all method calls occur on the same thread.
|
| - base::ThreadChecker thread_checker_;
|
| -
|
| - // Next unique handle to return from GetUniqueHandle().
|
| - int next_handle_;
|
| -
|
| - // Maps to hold handle value associated to MessageReceiver.
|
| - std::map<int, ReceiveMessageCallback> receive_callbacks_;
|
| -
|
| - // Callback that is run to send a serialized message.
|
| - SendMessageCallback send_message_cb_;
|
| -
|
| - base::WeakPtrFactory<RpcBroker> weak_factory_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(RpcBroker);
|
| -};
|
| -
|
| -} // namespace remoting
|
| -} // namespace media
|
| -
|
| -#endif // MEDIA_REMOTING_RPC_RPC_BROKER_H_
|
|
|