more logging

main
Tom Early 4 years ago
parent eff07fda5b
commit afae846707

@ -124,6 +124,8 @@ bool CController::InitDevices()
type = (type == Encoding::dstar) ? Encoding::dmr : Encoding::dstar; type = (type == Encoding::dstar) ? Encoding::dmr : Encoding::dstar;
} }
std::cout << "Device count: DStar=" << dstar_device.size() << " DMR=" << dmr_device.size() << std::endl;
return false; return false;
} }
@ -212,7 +214,7 @@ void CController::ReadReflector()
dmr_device[devnum]->packet_queue.push(packet); dmr_device[devnum]->packet_queue.push(packet);
//increment the dmr vocoder index //increment the dmr vocoder index
IncrementDMRVocoder(); 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; break;
case ECodecType::none: case ECodecType::none:
default: default:

@ -56,6 +56,14 @@ public:
mutex.unlock(); mutex.unlock();
} }
std::size_t size()
{
mutex.lock();
auto s = queue.size();
mutex.unlock();
return s;
}
protected: protected:
std::mutex mutex; std::mutex mutex;
std::queue<std::shared_ptr<CTranscoderPacket>> queue; std::queue<std::shared_ptr<CTranscoderPacket>> queue;

Loading…
Cancel
Save

Powered by TurnKey Linux.