chromium/third_party/mediapipe/src/mediapipe/framework/output_stream_shard.cc

// Copyright 2019 The MediaPipe Authors.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//      http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

#include "mediapipe/framework/output_stream_shard.h"

#include "absl/log/absl_check.h"
#include "mediapipe/framework/port/source_location.h"
#include "mediapipe/framework/port/status.h"
#include "mediapipe/framework/port/status_builder.h"

namespace mediapipe {

OutputStreamShard::OutputStreamShard() : … { … }

void OutputStreamShard::SetSpec(OutputStreamSpec* output_stream_spec) { … }

const std::string& OutputStreamShard::Name() const { … }

void OutputStreamShard::SetNextTimestampBound(Timestamp bound) { … }

void OutputStreamShard::Close() { … }

bool OutputStreamShard::IsClosed() const { … }

void OutputStreamShard::SetOffset(TimestampDiff offset) { … }

void OutputStreamShard::SetHeader(const Packet& header) { … }

const Packet& OutputStreamShard::Header() const { … }

// In this context, T&& is a forwarding reference, and can be deduced as either
// a const lvalue reference for AddPacket(const Packet&) or an rvalue reference
// for AddPacket(Packet&&). Although those two AddPacket versions share the
// code by calling AddPacketInternal, there are two separate copies in the
// binary.  This function can be defined in the .cc file because only two
// versions are ever instantiated, and all call sites are within this .cc file.
template <typename T>
absl::Status OutputStreamShard::AddPacketInternal(T&& packet) { … }

void OutputStreamShard::AddPacket(const Packet& packet) { … }

void OutputStreamShard::AddPacket(Packet&& packet) { … }

Timestamp OutputStreamShard::LastAddedPacketTimestamp() const { … }

void OutputStreamShard::Reset(Timestamp next_timestamp_bound, bool close) { … }

}  // namespace mediapipe