Fixed TS input not shutting down correctly, fixed issue when track is not properly filled
This commit is contained in:
parent
106967515a
commit
3e6b7fc9e8
1 changed files with 4 additions and 1 deletions
|
@ -71,7 +71,7 @@ void parseThread(void * ignored) {
|
||||||
Util::sleep(100);
|
Util::sleep(100);
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
while (liveStream.hasPacket(tid)){
|
while (liveStream.hasPacket(tid) && (Util::bootSecs() - threadTimer[tid] < THREAD_TIMEOUT && cfgPointer->is_active && (!liveStream.isDataTrack(tid) || myProxy.userClient.isAlive()))){
|
||||||
liveStream.initializeMetadata(myMeta, tid);
|
liveStream.initializeMetadata(myMeta, tid);
|
||||||
DTSC::Packet pack;
|
DTSC::Packet pack;
|
||||||
liveStream.getPacket(tid, pack);
|
liveStream.getPacket(tid, pack);
|
||||||
|
@ -79,6 +79,9 @@ void parseThread(void * ignored) {
|
||||||
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