diff --git a/src/input/input_ts.cpp b/src/input/input_ts.cpp index d74f0f3c..48446968 100755 --- a/src/input/input_ts.cpp +++ b/src/input/input_ts.cpp @@ -75,13 +75,14 @@ void parseThread(void * ignored) { liveStream.initializeMetadata(myMeta, tid); DTSC::Packet pack; liveStream.getPacket(tid, pack); - if (pack && myMeta.tracks.count(tid)){ + if (!pack){ + Util::sleep(100); + break; + } + if (myMeta.tracks.count(tid)){ myProxy.continueNegotiate(tid, myMeta, true); myProxy.bufferLivePacket(pack, myMeta); } - if (!pack){ - Util::sleep(500); - } } { tthread::lock_guard guard(threadClaimMutex);