blob: e55a4a7e0c399db26700ae8e70d7ad67345fa7a6 (
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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
// Copyright 2020 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_LOOPING_FILE_SENDER_H_
#define CAST_STANDALONE_SENDER_LOOPING_FILE_SENDER_H_
#include <algorithm>
#include <string>
#include "cast/standalone_sender/constants.h"
#include "cast/standalone_sender/simulated_capturer.h"
#include "cast/standalone_sender/streaming_opus_encoder.h"
#include "cast/standalone_sender/streaming_vp8_encoder.h"
#include "cast/streaming/sender_session.h"
namespace openscreen {
namespace cast {
// Plays the media file at a given path over and over again, transcoding and
// streaming its audio/video.
class LoopingFileSender final : public SimulatedAudioCapturer::Client,
public SimulatedVideoCapturer::Client {
public:
LoopingFileSender(Environment* environment,
const char* path,
const SenderSession* session,
SenderSession::ConfiguredSenders senders,
int max_bitrate);
~LoopingFileSender() final;
private:
void UpdateEncoderBitrates();
void ControlForNetworkCongestion();
void SendFileAgain();
// SimulatedAudioCapturer overrides.
void OnAudioData(const float* interleaved_samples,
int num_samples,
Clock::time_point capture_time) final;
// SimulatedVideoCapturer overrides;
void OnVideoFrame(const AVFrame& av_frame,
Clock::time_point capture_time) final;
void UpdateStatusOnConsole();
// SimulatedCapturer overrides.
void OnEndOfFile(SimulatedCapturer* capturer) final;
void OnError(SimulatedCapturer* capturer, std::string message) final;
const char* ToTrackName(SimulatedCapturer* capturer) const;
// Holds the required injected dependencies (clock, task runner) used for Cast
// Streaming, and owns the UDP socket over which all communications occur with
// the remote's Receivers.
Environment* const env_;
// The path to the media file to stream over and over.
const char* const path_;
// Session to query for bandwidth information.
const SenderSession* session_;
// User provided maximum bitrate (from command line argument).
const int max_bitrate_;
int bandwidth_estimate_ = 0;
int bandwidth_being_utilized_;
StreamingOpusEncoder audio_encoder_;
StreamingVp8Encoder video_encoder_;
int num_capturers_running_ = 0;
Clock::time_point capture_start_time_{};
Clock::time_point latest_frame_time_{};
absl::optional<SimulatedAudioCapturer> audio_capturer_;
absl::optional<SimulatedVideoCapturer> video_capturer_;
Alarm next_task_;
Alarm console_update_task_;
};
} // namespace cast
} // namespace openscreen
#endif // CAST_STANDALONE_SENDER_LOOPING_FILE_SENDER_H_
|
