blob: 6dc66690cfed09ab91350249de9a4abf27a1b1ff (
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
|
// Copyright 2013 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_CAST_RTP_SENDER_RTP_PACKETIZER_RTP_PACKETIZER_H_
#define MEDIA_CAST_RTP_SENDER_RTP_PACKETIZER_RTP_PACKETIZER_H_
#include <cmath>
#include <list>
#include <map>
#include "base/time/time.h"
#include "media/cast/rtp_common/rtp_defines.h"
#include "media/cast/rtp_sender/packet_storage/packet_storage.h"
#include "media/cast/rtp_sender/rtp_packetizer/rtp_packetizer_config.h"
namespace media {
namespace cast {
class PacedPacketSender;
// This object is only called from the main cast thread.
// This class break encoded audio and video frames into packets and add an RTP
// header to each packet.
class RtpPacketizer {
public:
RtpPacketizer(PacedPacketSender* transport,
PacketStorage* packet_storage,
RtpPacketizerConfig rtp_packetizer_config);
~RtpPacketizer();
// The video_frame objects ownership is handled by the main cast thread.
void IncomingEncodedVideoFrame(const EncodedVideoFrame* video_frame,
const base::TimeTicks& capture_time);
// The audio_frame objects ownership is handled by the main cast thread.
void IncomingEncodedAudioFrame(const EncodedAudioFrame* audio_frame,
const base::TimeTicks& recorded_time);
bool LastSentTimestamp(base::TimeTicks* time_sent,
uint32* rtp_timestamp) const;
// Return the next sequence number, and increment by one. Enables unique
// incremental sequence numbers for every packet (including retransmissions).
uint16 NextSequenceNumber();
int send_packets_count() { return send_packets_count_; }
size_t send_octet_count() { return send_octet_count_; }
private:
void Cast(bool is_key, uint32 frame_id, uint32 reference_frame_id,
uint32 timestamp, const std::string& data);
void BuildCommonRTPheader(std::vector<uint8>* packet, bool marker_bit,
uint32 time_stamp);
RtpPacketizerConfig config_;
PacedPacketSender* transport_;
PacketStorage* packet_storage_;
base::TimeTicks time_last_sent_rtp_timestamp_;
uint16 sequence_number_;
uint32 rtp_timestamp_;
uint16 packet_id_;
int send_packets_count_;
size_t send_octet_count_;
};
} // namespace cast
} // namespace media
#endif // MEDIA_CAST_RTP_SENDER_RTP_PACKETIZER_RTP_PACKETIZER_H_
|
