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

Added CPU and memory stats to instrumentation outputs.

Browse source
This commit is contained in:
Thulinma 2016-04-26 16:18:43 +02:00
parent dbe2b1f661
commit 36d8986f4b
1 changed files with 65 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

65
src/controller/controller_statistics.cpp
View file

@ -1,5 +1,6 @@
#include <cstdio> #include <cstdio>
#include <list> #include <list>
#include <fstream>
#include <mist/config.h> #include <mist/config.h>
#include <mist/shared_memory.h> #include <mist/shared_memory.h>
#include <mist/dtsc.h> #include <mist/dtsc.h>
@ -986,8 +987,69 @@ void Controller::handlePrometheus(HTTP::Parser & H, Socket::Connection & conn, i
H.SetHeader("Server", "MistServer/" PACKAGE_VERSION); H.SetHeader("Server", "MistServer/" PACKAGE_VERSION);
H.StartResponse("200", "OK", H, conn); H.StartResponse("200", "OK", H, conn);
//Collect core server stats
long long int cpu_use = 0;
long long int mem_total = 0, mem_free = 0, mem_bufcache = 0;
{
std::ifstream cpustat("/proc/stat");
if (cpustat){
char line[300];
while (cpustat.getline(line, 300)){
static unsigned long long cl_total = 0, cl_idle = 0;
unsigned long long c_user, c_nice, c_syst, c_idle, c_total;
if (sscanf(line, "cpu %Lu %Lu %Lu %Lu", &c_user, &c_nice, &c_syst, &c_idle) == 4){
c_total = c_user + c_nice + c_syst + c_idle;
cpu_use = (long long int)(1000 - ((c_idle - cl_idle) * 1000) / (c_total - cl_total));
cl_total = c_total;
cl_idle = c_idle;
break;
}
}
}
std::ifstream meminfo("/proc/meminfo");
if (meminfo){
char line[300];
while (meminfo.good()){
meminfo.getline(line, 300);
if (meminfo.fail()){
//empty lines? ignore them, clear flags, continue
if ( !meminfo.eof()){
meminfo.ignore();
meminfo.clear();
}
continue;
}
long long int i;
if (sscanf(line, "MemTotal : %lli kB", &i) == 1){
mem_total = i;
}
if (sscanf(line, "MemFree : %lli kB", &i) == 1){
mem_free = i;
}
if (sscanf(line, "Buffers : %lli kB", &i) == 1){
mem_bufcache += i;
}
if (sscanf(line, "Cached : %lli kB", &i) == 1){
mem_bufcache += i;
}
}
}
}
if (mode == PROMETHEUS_TEXT){ if (mode == PROMETHEUS_TEXT){
std::stringstream response; std::stringstream response;
response << "# HELP mist_cpu Total CPU usage in tenths of percent.\n";
response << "# TYPE mist_cpu gauge\n";
response << "mist_cpu " << cpu_use << "\n\n";
response << "# HELP mist_mem_total Total memory available in KiB.\n";
response << "# TYPE mist_mem_total gauge\n";
response << "mist_mem_total " << mem_total << "\n\n";
response << "# HELP mist_mem_used Total memory in use in KiB.\n";
response << "# TYPE mist_mem_used gauge\n";
response << "mist_mem_used " << (mem_total - mem_free - mem_bufcache) << "\n\n";
{//Scope for shortest possible blocking of statsMutex {//Scope for shortest possible blocking of statsMutex
tthread::lock_guard<tthread::mutex> guard(statsMutex); tthread::lock_guard<tthread::mutex> guard(statsMutex);
response << "# HELP mist_sessions_cached Number of sessions active in the last ~10 minutes.\n"; response << "# HELP mist_sessions_cached Number of sessions active in the last ~10 minutes.\n";
@ -1047,6 +1109,9 @@ void Controller::handlePrometheus(HTTP::Parser & H, Socket::Connection & conn, i
} }
if (mode == PROMETHEUS_JSON){ if (mode == PROMETHEUS_JSON){
JSON::Value resp; JSON::Value resp;
resp["cpu"] = cpu_use;
resp["mem_total"] = mem_total;
resp["mem_used"] = (mem_total - mem_free - mem_bufcache);
{//Scope for shortest possible blocking of statsMutex {//Scope for shortest possible blocking of statsMutex
tthread::lock_guard<tthread::mutex> guard(statsMutex); tthread::lock_guard<tthread::mutex> guard(statsMutex);
//collect the data first //collect the data first