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

Implemented STREAM_BUFFER RECOVER state.

Browse source
This commit is contained in:
Thulinma 2016-05-19 15:37:07 +02:00
parent 91c226e4af
commit b77e7c8b7c
1 changed files with 8 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/input/input_buffer.cpp
View file

@ -237,6 +237,7 @@ namespace Mist {
/// FULL or EMPTY (depending on current state)
/// ~~~~~~~~~~~~~~~
void inputBuffer::updateMeta() {
static bool wentDry = false;
static long long unsigned int lastFragCount = 0xFFFFull;
long long unsigned int firstms = 0xFFFFFFFFFFFFFFFFull;
long long unsigned int lastms = 0;
@ -267,7 +268,12 @@ namespace Mist {
/*LTS-START*/
if (fragCount >= FRAG_BOOT && fragCount != 0xFFFFull && (lastFragCount == 0xFFFFull || lastFragCount < FRAG_BOOT)) {
if (Triggers::shouldTrigger("STREAM_BUFFER")) {
std::string payload = config->getString("streamname") + "\nFULL";
std::string payload;
if (wentDry){
payload = config->getString("streamname") + "\nRECOVER";
}else{
payload = config->getString("streamname") + "\nFULL";
}
Triggers::doTrigger("STREAM_BUFFER", payload, config->getString("streamname"));
}
}
@ -275,6 +281,7 @@ namespace Mist {
if (Triggers::shouldTrigger("STREAM_BUFFER")) {
std::string payload = config->getString("streamname") + "\nDRY";
Triggers::doTrigger("STREAM_BUFFER", payload, config->getString("streamname"));
wentDry = true;
}
}
lastFragCount = fragCount;