From 3eeadec05bebbf408f2a5f6e21a5420d2bb4162e Mon Sep 17 00:00:00 2001
From: Nicolas Pope <nwpope@utu.fi>
Date: Wed, 12 Jun 2019 10:14:23 +0300
Subject: [PATCH] Debug output for vision freeze
---
components/rgbd-sources/src/streamer.cpp | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
diff --git a/components/rgbd-sources/src/streamer.cpp b/components/rgbd-sources/src/streamer.cpp
index 0acd8a97d..bbdbc87ee 100644
--- a/components/rgbd-sources/src/streamer.cpp
+++ b/components/rgbd-sources/src/streamer.cpp
@@ -191,6 +191,8 @@ void Streamer::_schedule() {
// Prevent new clients during processing.
shared_lock<shared_mutex> slk(mutex_);
+ LOG(INFO) << "SCHEDULE FRAME";
+
for (auto s : sources_) {
string uri = s.first;
@@ -231,7 +233,9 @@ void Streamer::_schedule() {
LOG(INFO) << "GRAB Elapsed: " << elapsed.count();*/
// CHECK (Nick) Can state be an atomic instead?
+ LOG(INFO) << "Wait to finish grab";
unique_lock<shared_mutex> lk(src->mutex);
+ LOG(INFO) << "Grab finished";
src->state |= ftl::rgbd::detail::kGrabbed;
_swap(*src);
lk.unlock();
@@ -290,8 +294,9 @@ void Streamer::_schedule() {
LOG(INFO) << "Stream Elapsed: " << elapsed.count();*/
// CHECK (Nick) Could state be an atomic?
+ LOG(INFO) << "Wait Tx frame";
unique_lock<shared_mutex> lk(src->mutex);
- DLOG(2) << "Tx Frame: " << uri;
+ LOG(INFO) << "Tx Frame: " << uri;
src->state |= ftl::rgbd::detail::kTransmitted;
_swap(*src);
lk.unlock();
@@ -305,8 +310,10 @@ void Streamer::_schedule() {
}
// Wait for all jobs to complete before finishing frame
+ LOG(INFO) << "WAIT FRAME";
unique_lock<mutex> lk(job_mtx);
job_cv.wait(lk, [&jobs]{ return jobs == 0; });
+ LOG(INFO) << "END FRAME";
}
Source *Streamer::get(const std::string &uri) {
--
GitLab