diff --git a/.vscode/launch.json b/.vscode/launch.json index b50f43a6a..89f017d25 100644 --- a/.vscode/launch.json +++ b/.vscode/launch.json @@ -930,7 +930,7 @@ }, { "name": "HOLOSCAN_LOG_LEVEL", - "value": "INFO" + "value": "DEBUG" } ], "stopAtEntry": false, @@ -963,7 +963,7 @@ }, { "name": "HOLOSCAN_LOG_LEVEL", - "value": "INFO" + "value": "DEBUG" } ], "stopAtEntry": false, diff --git a/applications/distributed/grpc/grpc_endoscopy_tool_tracking/cpp/endoscopy_tool_tracking.yaml b/applications/distributed/grpc/grpc_endoscopy_tool_tracking/cpp/endoscopy_tool_tracking.yaml index 2909fd6c3..72d44c667 100644 --- a/applications/distributed/grpc/grpc_endoscopy_tool_tracking/cpp/endoscopy_tool_tracking.yaml +++ b/applications/distributed/grpc/grpc_endoscopy_tool_tracking/cpp/endoscopy_tool_tracking.yaml @@ -29,7 +29,7 @@ replayer: basename: "surgical_video" frame_rate: 0 # as specified in timestamps repeat: false # default: false - realtime: true # default: true + realtime: false # default: true count: 0 # default: 0 (no frame count restriction) format_converter: diff --git a/operators/grpc_operators/common/asynchronous_condition_queue.hpp b/operators/grpc_operators/common/asynchronous_condition_queue.hpp index 765115026..c04ef2bf0 100644 --- a/operators/grpc_operators/common/asynchronous_condition_queue.hpp +++ b/operators/grpc_operators/common/asynchronous_condition_queue.hpp @@ -49,12 +49,14 @@ class AsynchronousConditionQueue : public Resource { if (data_available_condition_->event_state() == AsynchronousEventState::EVENT_WAITING) { data_available_condition_->event_state(AsynchronousEventState::EVENT_DONE); } + HOLOSCAN_LOG_DEBUG("Items queued+: {}", queue_.size()); } DataT pop() { if (empty()) { return nullptr; } auto item = queue_.front(); queue_.pop(); + HOLOSCAN_LOG_DEBUG("Items queued-: {}", queue_.size()); return item; } diff --git a/operators/grpc_operators/common/conditional_variable_queue.hpp b/operators/grpc_operators/common/conditional_variable_queue.hpp index f76715a9f..30c536990 100644 --- a/operators/grpc_operators/common/conditional_variable_queue.hpp +++ b/operators/grpc_operators/common/conditional_variable_queue.hpp @@ -47,6 +47,7 @@ class ConditionVariableQueue : public Resource { std::lock_guard lock(response_available_mutex_); queue_.push(value); data_available_condition_.notify_one(); + HOLOSCAN_LOG_DEBUG("Items queued+: {}", queue_.size()); } DataT pop() { @@ -54,6 +55,7 @@ class ConditionVariableQueue : public Resource { data_available_condition_.wait(lock, [this]() { return !queue_.empty(); }); auto item = queue_.front(); queue_.pop(); + HOLOSCAN_LOG_DEBUG("Items queued-: {}", queue_.size()); return item; }