hydrar/mistserver
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Tweaks to output drop behaviour

Browse source
This commit is contained in:
Thulinma 2016-07-22 14:30:40 +02:00
parent 55528a014a
commit 5f6abd291d
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/output/output.cpp
View file

@ -1181,8 +1181,8 @@ namespace Mist {
if (++emptyCount < 100){ if (++emptyCount < 100){
Util::wait(250); Util::wait(250);
//we're waiting for new data to show up //we're waiting for new data to show up
if (emptyCount % 8 == 0){ if (emptyCount % 64 == 0){
reconnect();//reconnect every 2 seconds reconnect();//reconnect every 16 seconds
}else{ }else{
if (emptyCount % 4 == 0){ if (emptyCount % 4 == 0){
updateMeta(); updateMeta();
@ -1190,7 +1190,7 @@ namespace Mist {
} }
}else{ }else{
//after ~25 seconds, give up and drop the track. //after ~25 seconds, give up and drop the track.
dropTrack(nxt.tid, "could not reload empty packet"); dropTrack(nxt.tid, "EOP: could not reload empty packet");
} }
return false; return false;
} }
@ -1201,7 +1201,7 @@ namespace Mist {
if (nProxy.curPage.count(nxt.tid) && nProxy.curPage[nxt.tid].mapped){ if (nProxy.curPage.count(nxt.tid) && nProxy.curPage[nxt.tid].mapped){
unsigned long long nextTime = getDTSCTime(nProxy.curPage[nxt.tid].mapped, nxt.offset); unsigned long long nextTime = getDTSCTime(nProxy.curPage[nxt.tid].mapped, nxt.offset);
if (nextTime && nextTime < nxt.time){ if (nextTime && nextTime < nxt.time){
dropTrack(nxt.tid, "time going backwards ("+JSON::Value((long long)nextTime).asString()+" < "+JSON::Value((long long)nxt.time).asString()+")"); dropTrack(nxt.tid, "EOP: time going backwards ("+JSON::Value((long long)nextTime).asString()+" < "+JSON::Value((long long)nxt.time).asString()+")");
}else{ }else{
if (nextTime){ if (nextTime){
nxt.time = nextTime; nxt.time = nextTime;