Even more TS input tweaks
This commit is contained in:
parent
2acfd6e4c5
commit
def6c2266e
1 changed files with 5 additions and 4 deletions
|
@ -75,13 +75,14 @@ void parseThread(void * ignored) {
|
||||||
liveStream.initializeMetadata(myMeta, tid);
|
liveStream.initializeMetadata(myMeta, tid);
|
||||||
DTSC::Packet pack;
|
DTSC::Packet pack;
|
||||||
liveStream.getPacket(tid, 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.continueNegotiate(tid, myMeta, true);
|
||||||
myProxy.bufferLivePacket(pack, myMeta);
|
myProxy.bufferLivePacket(pack, myMeta);
|
||||||
}
|
}
|
||||||
if (!pack){
|
|
||||||
Util::sleep(500);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
{
|
{
|
||||||
tthread::lock_guard<tthread::mutex> guard(threadClaimMutex);
|
tthread::lock_guard<tthread::mutex> guard(threadClaimMutex);
|
||||||
|
|
Loading…
Add table
Reference in a new issue