Benchmark

Signed-off-by: Victor Chang <vicchang@nvidia.com>

Author: mocsharp

.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,

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:

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;
   }
 

operators/grpc_operators/common/conditional_variable_queue.hpp

@@ -47,13 +47,15 @@ class ConditionVariableQueue : public Resource {
     std::lock_guard<std::mutex> lock(response_available_mutex_);
     queue_.push(value);
     data_available_condition_.notify_one();
+    HOLOSCAN_LOG_DEBUG("Items queued+: {}", queue_.size());
   }
 
   DataT pop() {
     std::unique_lock<std::mutex> lock(response_available_mutex_);
     data_available_condition_.wait(lock, [this]() { return !queue_.empty(); });
     auto item = queue_.front();
     queue_.pop();
+    HOLOSCAN_LOG_DEBUG("Items queued-: {}", queue_.size());
     return item;
   }