main
Tom Early 2 years ago
parent 842d2e0a59
commit 88046aba9e

@ -250,6 +250,8 @@ void CController::ReadReflectorThread()
{ {
while (keep_running) while (keep_running)
{ {
tcClient.CheckConnections();
std::queue<std::unique_ptr<STCPacket>> queue; std::queue<std::unique_ptr<STCPacket>> queue;
// wait up to 100 ms to read something on the unix port // wait up to 100 ms to read something on the unix port
if (tcClient.Receive(queue, 100)) if (tcClient.Receive(queue, 100))
@ -266,11 +268,11 @@ void CController::ReadReflectorThread()
dstar_device->AddPacket(packet); dstar_device->AddPacket(packet);
break; break;
case ECodecType::dmr: case ECodecType::dmr:
#ifdef USE_SW_AMBE2 #ifdef USE_SW_AMBE2
swambe2_queue.push(packet); swambe2_queue.push(packet);
#else #else
dmrsf_device->AddPacket(packet); dmrsf_device->AddPacket(packet);
#endif #endif
break; break;
case ECodecType::p25: case ECodecType::p25:
imbe_queue.push(packet); imbe_queue.push(packet);

Loading…
Cancel
Save

Powered by TurnKey Linux.