aboutsummaryrefslogtreecommitdiff
path: root/cast/standalone_sender/remoting_sender.h
blob: d331009b773b0004580aa391bef8cc120b4407e3 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
// Copyright 2021 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 CAST_STANDALONE_SENDER_REMOTING_SENDER_H_
#define CAST_STANDALONE_SENDER_REMOTING_SENDER_H_

#include <memory>

#include "cast/streaming/constants.h"
#include "cast/streaming/rpc_messenger.h"

namespace openscreen {
namespace cast {

// This class behaves like a pared-down version of Chrome's StreamProvider (see
// https://source.chromium.org/chromium/chromium/src/+/main:media/remoting/stream_provider.h
// ). Instead of fully managing a media::DemuxerStream however, it just provides
// an RPC initialization routine that notifies the standalone receiver's
// SimpleRemotingReceiver instance (if configured) that initialization has been
// complete and what codecs were selected.
//
// Due to the sheer complexity of remoting, we don't have a fully functional
// implementation of remoting in the standalone_* components, instead Chrome is
// the reference implementation and we have these simple classes to exercise
// the public APIs.
class RemotingSender {
 public:
  using ReadyCallback = std::function<void()>;
  RemotingSender(RpcMessenger* messenger,
                 AudioCodec audio_codec,
                 VideoCodec video_codec,
                 ReadyCallback ready_cb);
  ~RemotingSender();

 private:
  // When the receiver indicates that it is ready for initialization, it will
  // The receiver sends us an "initialization" message that we respond to
  // here with an "initialization callback" message that contains codec
  // information.
  void OnInitializeMessage(const RpcMessage& message);

  // The messenger is the only caller of OnInitializeMessage, so there are no
  // lifetime concerns. However, if this class outlives |messenger_|, it will
  // no longer receive initialization messages.
  RpcMessenger* messenger_;

  // Unlike in Chrome, here we should know the video and audio codecs before any
  // of the remoting code gets set up, and for simplicity's sake we can only
  // populate the AudioDecoderConfig and VideoDecoderConfig objects with the
  // codecs and use the rest of the fields as-is from the OFFER/ANSWER exchange.
  const AudioCodec audio_codec_;
  const VideoCodec video_codec_;

  // The callback method to be called once we get the initialization message
  // from the receiver.
  ReadyCallback ready_cb_;

  // The initialization message from the receiver contains the handle the
  // callback should go to.
  RpcMessenger::Handle receiver_handle_ = RpcMessenger::kInvalidHandle;
};

}  // namespace cast
}  // namespace openscreen

#endif  // CAST_STANDALONE_SENDER_REMOTING_SENDER_H_