chromium/media/cast/logging/encoding_event_subscriber.cc

// Copyright 2014 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "media/cast/logging/encoding_event_subscriber.h"

#include <stdint.h>

#include <algorithm>
#include <cstring>
#include <utility>

#include "base/logging.h"
#include "base/not_fatal_until.h"
#include "base/numerics/safe_conversions.h"
#include "media/cast/logging/proto/proto_utils.h"

RepeatedPtrField;
AggregatedFrameEvent;
AggregatedPacketEvent;
BasePacketEvent;
LogMetadata;

namespace {

// A size limit on maps to keep lookups fast.
const size_t kMaxMapSize = …;

// The smallest (oredered by RTP timestamp) |kNumMapEntriesToTransfer| entries
// will be moved when the map size reaches |kMaxMapSize|.
// Must be smaller than |kMaxMapSize|.
const size_t kNumMapEntriesToTransfer = …;

template <typename ProtoPtr>
bool IsRtpTimestampLessThan(const ProtoPtr& lhs, const ProtoPtr& rhs) { … }

BasePacketEvent* GetNewBasePacketEvent(AggregatedPacketEvent* event_proto,
    int packet_id, int size) { … }

}  // namespace

namespace media {
namespace cast {

EncodingEventSubscriber::EncodingEventSubscriber(
    EventMediaType event_media_type,
    size_t max_frames)
    : … { … }

EncodingEventSubscriber::~EncodingEventSubscriber() { … }

void EncodingEventSubscriber::OnReceiveFrameEvent(
    const FrameEvent& frame_event) { … }

void EncodingEventSubscriber::OnReceivePacketEvent(
    const PacketEvent& packet_event) { … }

void EncodingEventSubscriber::GetEventsAndReset(LogMetadata* metadata,
    FrameEventList* frame_events, PacketEventList* packet_events) { … }

void EncodingEventSubscriber::TransferFrameEvents(size_t max_num_entries) { … }

void EncodingEventSubscriber::TransferPacketEvents(size_t max_num_entries) { … }

void EncodingEventSubscriber::AddFrameEventToStorage(
    std::unique_ptr<AggregatedFrameEvent> frame_event_proto) { … }

void EncodingEventSubscriber::AddPacketEventToStorage(
    std::unique_ptr<AggregatedPacketEvent> packet_event_proto) { … }

bool EncodingEventSubscriber::ShouldCreateNewProto(
    uint32_t relative_rtp_timestamp_lower_32_bits) const { … }

void EncodingEventSubscriber::IncrementStoredProtoCount(
    uint32_t relative_rtp_timestamp_lower_32_bits) { … }

void EncodingEventSubscriber::DecrementStoredProtoCount(
    uint32_t relative_rtp_timestamp_lower_32_bits) { … }

RtpTimeDelta EncodingEventSubscriber::GetRelativeRtpTimestamp(
    RtpTimeTicks rtp_timestamp) { … }

void EncodingEventSubscriber::Reset() { … }

}  // namespace cast
}  // namespace media