pushes now only restart when stream is truly active
This commit is contained in:
parent
0ca63d1440
commit
e75bf65ab9
1 changed files with 1 additions and 1 deletions
|
@ -133,7 +133,7 @@ namespace Controller{
|
||||||
std::string streamname = jt->first;
|
std::string streamname = jt->first;
|
||||||
std::string target = (*it)[1u];
|
std::string target = (*it)[1u];
|
||||||
if (pStr == streamname || (*pStr.rbegin() == '+' && streamname.substr(0, pStr.size()) == pStr)){
|
if (pStr == streamname || (*pStr.rbegin() == '+' && streamname.substr(0, pStr.size()) == pStr)){
|
||||||
if (!isPushActive(streamname, target)){
|
if (!isPushActive(streamname, target) && Util::getStreamStatus(streamname) == STRMSTAT_READY){
|
||||||
if (waitingPushes[streamname][target]++ >= waittime && (curCount < maxspeed || !maxspeed)){
|
if (waitingPushes[streamname][target]++ >= waittime && (curCount < maxspeed || !maxspeed)){
|
||||||
waitingPushes[streamname].erase(target);
|
waitingPushes[streamname].erase(target);
|
||||||
if (!waitingPushes[streamname].size()){waitingPushes.erase(streamname);}
|
if (!waitingPushes[streamname].size()){waitingPushes.erase(streamname);}
|
||||||
|
|
Loading…
Add table
Reference in a new issue