cassdlcm/mediapipe
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Internal change

Browse Source 
PiperOrigin-RevId: 524496413
This commit is contained in:
MediaPipe Team 2023-04-15 02:32:12 -07:00 committed by Copybara-Service
parent b63a0e15a3
commit 547d3c00a7
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
mediapipe/framework/stream_handler/fixed_size_input_stream_handler.cc
View File

@ -131,9 +131,9 @@ class FixedSizeInputStreamHandler : public DefaultInputStreamHandler {
ABSL_EXCLUSIVE_LOCKS_REQUIRED(erase_mutex_) { ABSL_EXCLUSIVE_LOCKS_REQUIRED(erase_mutex_) {
// Record the most recent first kept timestamp on any stream. // Record the most recent first kept timestamp on any stream.
for (const auto& stream : input_stream_managers_) { for (const auto& stream : input_stream_managers_) {
int32 queue_size = (stream->QueueSize() >= trigger_queue_size_) int32_t queue_size = (stream->QueueSize() >= trigger_queue_size_)
? target_queue_size_ ? target_queue_size_
: trigger_queue_size_ - 1; : trigger_queue_size_ - 1;
if (stream->QueueSize() > queue_size) { if (stream->QueueSize() > queue_size) {
kept_timestamp_ = std::max( kept_timestamp_ = std::max(
kept_timestamp_, stream->GetMinTimestampAmongNLatest(queue_size + 1) kept_timestamp_, stream->GetMinTimestampAmongNLatest(queue_size + 1)
@ -214,8 +214,8 @@ class FixedSizeInputStreamHandler : public DefaultInputStreamHandler {
} }
private: private:
int32 trigger_queue_size_; int32_t trigger_queue_size_;
int32 target_queue_size_; int32_t target_queue_size_;
bool fixed_min_size_; bool fixed_min_size_;
// Indicates that GetNodeReadiness has returned kReadyForProcess once, and // Indicates that GetNodeReadiness has returned kReadyForProcess once, and
// the corresponding call to FillInputSet has not yet completed. // the corresponding call to FillInputSet has not yet completed.