// 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. #ifndef MEDIAPIPE_FRAMEWORK_OUTPUT_STREAM_SHARD_H_ #define MEDIAPIPE_FRAMEWORK_OUTPUT_STREAM_SHARD_H_ #include <list> #include <string> #include "absl/log/absl_check.h" #include "mediapipe/framework/output_stream.h" #include "mediapipe/framework/packet.h" #include "mediapipe/framework/packet_type.h" #include "mediapipe/framework/port.h" #include "mediapipe/framework/timestamp.h" namespace mediapipe { class OutputStreamManager; // The output stream spec shared across all output stream shards and their // output stream manager. struct OutputStreamSpec { … }; // OutputStreamShard, a subclass of OutputStream, holds an output queue // and a timetstamp bound of an output stream. Each call to // Calculator::Open(), Calculator::Process(), and Calculator::Close() can only // access its own OutputStreamShard. class OutputStreamShard : public OutputStream { … }; } // namespace mediapipe #endif // MEDIAPIPE_FRAMEWORK_OUTPUT_STREAM_SHARD_H_