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

Stats now working and saved locally as well as transmitted to gearbox. No stats resetting yet for debugging purposes.

Browse source
This commit is contained in:
Thulinma 2011-12-04 21:29:04 +01:00
parent c2b01eabba
commit 78d45fc7b5
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
DDV_Controller/main.cpp
View file

@ -452,7 +452,6 @@ int main(int argc, char ** argv){
size_t newlines = it->Received().find("\n\n"); size_t newlines = it->Received().find("\n\n");
while (newlines != std::string::npos){ while (newlines != std::string::npos){
if (JsonParse.parse(it->Received().substr(0, newlines), Request, false)){ if (JsonParse.parse(it->Received().substr(0, newlines), Request, false)){
Log("STAT", "Received stats from a buffer: "+Request.toStyledString());
if (Request.isMember("totals") && Request["totals"].isMember("buffer")){ if (Request.isMember("totals") && Request["totals"].isMember("buffer")){
std::string thisbuffer = Request["totals"]["buffer"].asString(); std::string thisbuffer = Request["totals"]["buffer"].asString();
Storage["statistics"][thisbuffer]["curr"] = Request["curr"]; Storage["statistics"][thisbuffer]["curr"] = Request["curr"];
@ -460,12 +459,15 @@ int main(int argc, char ** argv){
st << Request["totals"]["now"].asUInt(); st << Request["totals"]["now"].asUInt();
std::string nowstr = st.str(); std::string nowstr = st.str();
Storage["statistics"][thisbuffer]["totals"][nowstr] = Request["totals"]; Storage["statistics"][thisbuffer]["totals"][nowstr] = Request["totals"];
if (!Storage["statistics"][thisbuffer].isMember("log")){
Storage["statistics"][thisbuffer]["log"] = Json::Value(Json::arrayValue);
}
for (Json::ValueIterator jit = Request["log"].begin(); jit != Request["log"].end(); jit++){ for (Json::ValueIterator jit = Request["log"].begin(); jit != Request["log"].end(); jit++){
Storage["statistics"][thisbuffer]["log"][jit.memberName()] = Request["log"][jit.memberName()]; Storage["statistics"][thisbuffer]["log"].append(Request["log"][jit.memberName()]);
} }
} }
}else{ }else{
Log("STAT", "Failed to parse stats from a buffer: "+it->Received().substr(0, newlines)); Log("STAT", "Failed to parse stats info from buffer: "+it->Received().substr(0, newlines));
} }
it->Received().erase(0, newlines+2); it->Received().erase(0, newlines+2);
newlines = it->Received().find("\n\n"); newlines = it->Received().find("\n\n");