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
89
90
91
92
93
94
95
96
97
98
99
|
// Copyright 2014 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_LOGGING_ENCODING_EVENT_SUBSCRIBER_H_
#define MEDIA_CAST_LOGGING_ENCODING_EVENT_SUBSCRIBER_H_
#include <map>
#include "base/memory/linked_ptr.h"
#include "base/threading/thread_checker.h"
#include "media/cast/logging/logging_defines.h"
#include "media/cast/logging/proto/raw_events.pb.h"
#include "media/cast/logging/raw_event_subscriber.h"
namespace media {
namespace cast {
typedef std::map<RtpTimestamp,
linked_ptr<media::cast::proto::AggregatedFrameEvent> >
FrameEventMap;
typedef std::map<RtpTimestamp,
linked_ptr<media::cast::proto::AggregatedPacketEvent> >
PacketEventMap;
// A RawEventSubscriber implementation that subscribes to events,
// encodes them in protocol buffer format, and aggregates them into a more
// compact structure.
class EncodingEventSubscriber : public RawEventSubscriber {
public:
// |event_media_type|: The subscriber will only process events that
// corresponds to this type.
// |max_frames|: How many events to keep in the frame / packet map.
// This helps keep memory usage bounded.
// Every time one of |OnReceive[Frame,Packet]Event()| is
// called, it will check if the respective map size has exceeded |max_frames|.
// If so, it will remove the oldest aggregated entry (ordered by RTP
// timestamp).
EncodingEventSubscriber(EventMediaType event_media_type, size_t max_frames);
virtual ~EncodingEventSubscriber();
// RawReventSubscriber implementations.
virtual void OnReceiveFrameEvent(const FrameEvent& frame_event) OVERRIDE;
virtual void OnReceivePacketEvent(const PacketEvent& packet_event) OVERRIDE;
virtual void OnReceiveGenericEvent(const GenericEvent& generic_event)
OVERRIDE;
// Assigns frame events and packet events received so far to |frame_events|
// and clears them |packet_events| respectively, assigns the first seen RTP
// timestamp (which is used as a reference for all event entries) to
// |first_rtp_timestamp|, and reset this object's internal states.
// All RTP timestamp values returned in the maps are relative to
// |first_rtp_timestamp|, i.e. suppose |first_rtp_timestamp| is X,
// then the first event will be recorded with a relative
// RTP timestamp value of 0. If the next event has original RTP timestamp
// X+20, it will be recorded with a relative RTP timestamp of 20.
void GetEventsAndReset(FrameEventMap* frame_events,
PacketEventMap* packet_events,
RtpTimestamp* first_rtp_timestamp);
private:
bool ShouldProcessEvent(CastLoggingEvent event);
// Removes oldest entry from |frame_event_map_| (ordered by RTP timestamp).
void TruncateFrameEventMapIfNeeded();
// Removes oldest entry from |packet_event_map_| (ordered by RTP timestamp).
void TruncatePacketEventMapIfNeeded();
// Returns the difference between |rtp_timestamp| and |first_rtp_timestamp_|.
// Sets |first_rtp_timestamp_| if it is not already set.
RtpTimestamp GetRelativeRtpTimestamp(RtpTimestamp rtp_timestamp);
// Clears the maps and first RTP timestamp seen.
void Reset();
const EventMediaType event_media_type_;
const size_t max_frames_;
FrameEventMap frame_event_map_;
PacketEventMap packet_event_map_;
// All functions must be called on the main thread.
base::ThreadChecker thread_checker_;
// Set to true on first event encountered after a |Reset()|.
bool seen_first_rtp_timestamp_;
// Set to RTP timestamp of first event encountered after a |Reset()|.
RtpTimestamp first_rtp_timestamp_;
DISALLOW_COPY_AND_ASSIGN(EncodingEventSubscriber);
};
} // namespace cast
} // namespace media
#endif // MEDIA_CAST_LOGGING_ENCODING_EVENT_SUBSCRIBER_H_
|
