blob: 1fbb9f54e8c94378becf4ff5b876ef08d3778d9a (
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
|
// Copyright 2019 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.
#include "streaming/cast/receiver_demo/dummy_player.h"
#include <chrono>
#include "absl/types/span.h"
#include "streaming/cast/encoded_frame.h"
#include "util/logging.h"
using std::chrono::microseconds;
namespace openscreen {
namespace cast_streaming {
DummyPlayer::DummyPlayer(Receiver* receiver) : receiver_(receiver) {
OSP_DCHECK(receiver_);
receiver_->SetConsumer(this);
}
DummyPlayer::~DummyPlayer() {
receiver_->SetConsumer(nullptr);
}
void DummyPlayer::OnFramesReady(int buffer_size) {
// Consume the next frame.
buffer_.resize(buffer_size);
const EncodedFrame frame =
receiver_->ConsumeNextFrame(absl::Span<uint8_t>(buffer_));
// Convert the RTP timestamp to a human-readable timestamp (in µs) and log
// some short information about the frame.
const auto media_timestamp =
frame.rtp_timestamp.ToTimeSinceOrigin<microseconds>(
receiver_->rtp_timebase());
OSP_LOG_INFO << "[SSRC " << receiver_->ssrc() << "] "
<< (frame.dependency == EncodedFrame::KEY_FRAME ? "KEY " : "")
<< frame.frame_id << " at " << media_timestamp.count() << "µs, "
<< buffer_size << " bytes";
}
} // namespace cast_streaming
} // namespace openscreen
|
