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

Stats fixes

Browse source
This commit is contained in:
Thulinma 2018-11-15 10:36:03 +01:00
parent 0d9ff7da2e
commit 0707257127
1 changed files with 19 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
src/controller/controller_statistics.cpp
View file

@ -113,12 +113,24 @@ void Controller::SharedMemStats(void * config){
std::set<std::string> inactiveStreams; std::set<std::string> inactiveStreams;
Controller::initState(); Controller::initState();
bool shiftWrites = true; bool shiftWrites = true;
bool firstRun = true;
while(((Util::Config*)config)->is_active){ while(((Util::Config*)config)->is_active){
{ {
tthread::lock_guard<tthread::mutex> guard(Controller::configMutex); tthread::lock_guard<tthread::mutex> guard(Controller::configMutex);
tthread::lock_guard<tthread::mutex> guard2(statsMutex); tthread::lock_guard<tthread::mutex> guard2(statsMutex);
//parse current users //parse current users
statServer.parseEach(parseStatistics); statServer.parseEach(parseStatistics);
if (firstRun){
firstRun = false;
servUpOtherBytes = 0;
servDownOtherBytes = 0;
servUpBytes = 0;
servDownBytes = 0;
for (std::map<std::string, struct streamTotals>::iterator it = streamStats.begin(); it != streamStats.end(); ++it){
it->second.upBytes = 0;
it->second.downBytes = 0;
}
}
//wipe old statistics //wipe old statistics
if (sessions.size()){ if (sessions.size()){
std::list<sessIndex> mustWipe; std::list<sessIndex> mustWipe;
@ -238,9 +250,9 @@ void Controller::statSession::update(unsigned long index, IPC::statExchange & da
if (currUp - prevUp < 0 || currDown-prevDown < 0){ if (currUp - prevUp < 0 || currDown-prevDown < 0){
INFO_MSG("Negative data usage! %lldu/%lldd (u%lld->%lld) in %s over %s, #%lu", currUp-prevUp, currDown-prevDown, prevUp, currUp, data.streamName().c_str(), data.connector().c_str(), index); INFO_MSG("Negative data usage! %lldu/%lldd (u%lld->%lld) in %s over %s, #%lu", currUp-prevUp, currDown-prevDown, prevUp, currUp, data.streamName().c_str(), data.connector().c_str(), index);
} }
if (currDown + currUp > COUNTABLE_BYTES){ if (currDown + currUp >= COUNTABLE_BYTES){
std::string streamName = data.streamName(); std::string streamName = data.streamName();
if (prevUp + prevDown < COUNTABLE_BYTES){ if (sessionType == SESS_UNSET){
if (data.connector() == "INPUT"){ if (data.connector() == "INPUT"){
streamStats[streamName].inputs++; streamStats[streamName].inputs++;
streamStats[streamName].currIns++; streamStats[streamName].currIns++;
@ -254,6 +266,10 @@ void Controller::statSession::update(unsigned long index, IPC::statExchange & da
streamStats[streamName].currViews++; streamStats[streamName].currViews++;
sessionType = SESS_VIEWER; sessionType = SESS_VIEWER;
} }
}
//If previous < COUNTABLE_BYTES, we haven't counted any data so far.
//We need to count all the data in that case, otherwise we only count the difference.
if (prevUp + prevDown < COUNTABLE_BYTES){
if (!streamName.size() || streamName[0] == 0){ if (!streamName.size() || streamName[0] == 0){
if (streamStats.count(streamName)){streamStats.erase(streamName);} if (streamStats.count(streamName)){streamStats.erase(streamName);}
}else{ }else{
@ -267,15 +283,6 @@ void Controller::statSession::update(unsigned long index, IPC::statExchange & da
streamStats[streamName].upBytes += currUp - prevUp; streamStats[streamName].upBytes += currUp - prevUp;
streamStats[streamName].downBytes += currDown - prevDown; streamStats[streamName].downBytes += currDown - prevDown;
} }
if (sessionType == SESS_UNSET){
if (data.connector() == "INPUT"){
sessionType = SESS_INPUT;
}else if (data.connector() == "OUTPUT"){
sessionType = SESS_OUTPUT;
}else{
sessionType = SESS_VIEWER;
}
}
} }
} }
} }
@ -347,6 +354,7 @@ void Controller::statSession::ping(const Controller::sessIndex & index, unsigned
wipedUp = 0; wipedUp = 0;
wipedDown = 0; wipedDown = 0;
oldConns.clear(); oldConns.clear();
sessionType = SESS_UNSET;
} }
} }