From afae846707a7b9323fdf5ecde9f4271bb06d7c2e Mon Sep 17 00:00:00 2001
From: Tom Early <n7tae@tearly.net>
Date: Thu, 9 Dec 2021 05:14:14 -0700
Subject: [PATCH] more logging

---
 Controller.cpp | 4 +++-
 PacketQueue.h  | 8 ++++++++
 2 files changed, 11 insertions(+), 1 deletion(-)

diff --git a/Controller.cpp b/Controller.cpp
index fd8cc8c..981485b 100644
--- a/Controller.cpp
+++ b/Controller.cpp
@@ -124,6 +124,8 @@ bool CController::InitDevices()
 		type = (type == Encoding::dstar) ? Encoding::dmr : Encoding::dstar;
 	}
 
+	std::cout << "Device count: DStar=" << dstar_device.size() << " DMR=" << dmr_device.size() << std::endl;
+
 	return false;
 }
 
@@ -212,7 +214,7 @@ void CController::ReadReflector()
 				dmr_device[devnum]->packet_queue.push(packet);
 				//increment the dmr vocoder index
 				IncrementDMRVocoder();
-				std::cout << "USE COUNT: " << packet.use_count() << std::endl;
+				std::cout << "packet_queue sizes: DStar=" << dstar_device[0]->packet_queue.size() << " DMR=" << dmr_device[0]->packet_queue.size() << std::endl;
 				break;
 			case ECodecType::none:
 			default:
diff --git a/PacketQueue.h b/PacketQueue.h
index c1e982d..25c0577 100644
--- a/PacketQueue.h
+++ b/PacketQueue.h
@@ -56,6 +56,14 @@ public:
 		mutex.unlock();
 	}
 
+	std::size_t size()
+	{
+		mutex.lock();
+		auto s = queue.size();
+		mutex.unlock();
+		return s;
+	}
+
 protected:
 	std::mutex mutex;
 	std::queue<std::shared_ptr<CTranscoderPacket>> queue;