msysmon.cxx File Reference

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <stdint.h>
#include <sys/time.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <errno.h>
#include <math.h>
#include <ctype.h>
#include <assert.h>
#include <string.h>
#include <iostream>
#include "midas.h"
#include "mfe.h"
#include "mstrlcpy.h"
#include "msystem.h"
#include <fstream>

Include dependency graph for msysmon.cxx:

Go to the source code of this file.

Classes
struct	CPUData_
struct	NetStat

Macros
#define	PROCSTATFILE   "/proc/stat"
#define	PROCMEMINFOFILE   "/proc/meminfo"
#define	PROCNETSTATFILE   "/proc/net/dev"
#define	String_startsWith(s, match)   (strstr((s), (match)) == (s))
#define	EVID_MONITOR   63

Typedefs
typedef struct CPUData_	CPUData

Functions
INT	frontend_init ()
	Frontend initialization.
INT	frontend_exit ()
	Frontend exit.
INT	begin_of_run (INT run_number, char *error)
	Begin of Run.
INT	end_of_run (INT run_number, char *error)
	End of Run.
INT	pause_run (INT run_number, char *error)
	Pause Run.
INT	resume_run (INT run_number, char *error)
	Resume Run.
INT	frontend_loop ()
	Frontend loop.
INT	poll_event (INT source, INT count, BOOL test)
INT	interrupt_configure (INT cmd, INT source, PTYPE adr)
int	read_system_load (char *pevent, int off)
void	ReadCPUData ()
void	ReadNetData ()
INT	rpc_callback (INT index, void *prpc_param[])
void	BuildHostHistoryPlot ()
void	BuildHostCPUPlot ()
void	BuildHostNetPlot ()
void	InitGPU ()

Variables
const char *	frontend_name = "msysmon"
const char *	frontend_file_name = __FILE__
BOOL	frontend_call_loop = TRUE
INT	display_period = 0
INT	max_event_size = 4*1024*1024
INT	max_event_size_frag = 4*1024*1024
INT	event_buffer_size = 10*1024*1024
BOOL	equipment_common_overwrite = FALSE
EQUIPMENT	equipment []
int	cpuCount
std::vector< CPUData * >	cpus
unsigned long long int	usertime
unsigned long long int	nicetime
unsigned long long int	systemtime
unsigned long long int	idletime
int	networkInterfaceCount =0
std::vector< NetStat * >	NetReceive
std::vector< NetStat * >	NetTransmit
std::string	colours [16]
int	event_size = 10*1024
HNDLE	hSet
int	test_rb_wait_sleep = 1
timeval	tv
timeval	old_tv
timeval	new_tv

Macro Definition Documentation

EVID_MONITOR

#define EVID_MONITOR   63

Definition at line 97 of file msysmon.cxx.

PROCMEMINFOFILE

#define PROCMEMINFOFILE   "/proc/meminfo"

Definition at line 23 of file msysmon.cxx.

PROCNETSTATFILE

#define PROCNETSTATFILE   "/proc/net/dev"

Definition at line 27 of file msysmon.cxx.

PROCSTATFILE

#define PROCSTATFILE   "/proc/stat"

Definition at line 19 of file msysmon.cxx.

String_startsWith

#define String_startsWith	(		s,
			match
	)		(strstr((s), (match)) == (s))

Definition at line 30 of file msysmon.cxx.

Typedef Documentation

CPUData

typedef struct CPUData_ CPUData

Function Documentation

begin_of_run()

INT begin_of_run	(	INT	run_number,
		char *	error
	)

Begin of Run.

Called every run start transition. Set equipment status in ODB, start acquisition on the modules.

Parameters

[in]	run_number	Number of the run being started
[out]	error	Can be used to write a message string to midas.log

Definition at line 956 of file msysmon.cxx.

{
   return SUCCESS;
}

BuildHostCPUPlot()

void BuildHostCPUPlot

(

)

Definition at line 634 of file msysmon.cxx.

{
   //Insert per CPU graphs into the history
   int status, size;
   char path[256];
   int NVARS=cpuCount;
   // Setup variables to plot:
   size = 64;
   sprintf(path,"/History/Display/msysmon/%s-CPU/Variables",equipment[0].info.frontend_host);
   {
      char vars[size*NVARS];
      memset(vars, 0, size*NVARS);
#ifdef CLASSIC_CPU_VARS
      for (int i=0; i<cpuCount; i++)
      {
         int icpu=i+1;
         int h='0'+icpu/100;
         int t='0'+(icpu%100)/10;
         int u='0'+icpu%10;
         if (icpu<10)
            sprintf(vars+size*i,"%s:CPU%c[3]",equipment[0].name,u);
         else if (icpu<100)
            sprintf(vars+size*i,"%s:CP%c%c[3]",equipment[0].name,t,u);
         else if (icpu<1000)
            sprintf(vars+size*i,"%s:C%c%c%c[3]",equipment[0].name,h,t,u);
         else
         {
            cm_msg(MERROR, frontend_name, "Cannot handle a system with more than 1000 CPUs");
            exit(FE_ERR_HW);
         }
      }
#else
      for (int i=0; i<cpuCount; i++)
      {
         sprintf(vars+size*i,"%s:CPUA[%d]",equipment[0].name,i);
      }
#endif
      status = db_set_value(hDB, 0, path,  vars, size*NVARS, NVARS, TID_STRING);
   }
   assert(status == DB_SUCCESS);
 
   // Setup labels 
   size = 32;
   sprintf(path,"/History/Display/msysmon/%s-CPU/Label",equipment[0].info.frontend_host);
   {
      char vars[size*NVARS];
      memset(vars, 0, size*NVARS);
      for (int i=0; i<cpuCount; i++)
         sprintf(vars+size*i,"CPU%d Load (%%)",i+1);
      status = db_set_value(hDB, 0, path,  vars, size*NVARS, NVARS, TID_STRING);
   }
   assert(status == DB_SUCCESS);
 
   // Setup colours:
   size = 32;
   sprintf(path,"/History/Display/msysmon/%s-CPU/Colour",equipment[0].info.frontend_host);
   {
      char vars[size*NVARS];
      memset(vars, 0, size*NVARS);
      for (int i=0; i<NVARS; i++)
         sprintf(vars+size*i,"%s",(colours[i%16]).c_str());
      status = db_set_value(hDB, 0, path,  vars, size*NVARS, NVARS, TID_STRING);
   }
   assert(status == DB_SUCCESS);
   // Setup time scale and range:
   sprintf(path,"/History/Display/msysmon/%s-CPU/Timescale",equipment[0].info.frontend_host);
   status = db_set_value(hDB,0,path,"1h",3,1,TID_STRING);
   double *m=new double();
   *m=0.;
   sprintf(path,"/History/Display/msysmon/%s-CPU/Minimum",equipment[0].info.frontend_host);
   status = db_set_value(hDB,0,path,m,sizeof(double),1,TID_DOUBLE);
   *m=100.;
   sprintf(path,"/History/Display/msysmon/%s-CPU/Maximum",equipment[0].info.frontend_host);
   status = db_set_value(hDB,0,path,m,sizeof(double),1,TID_DOUBLE);
   delete m;
}

Here is the call graph for this function:

Here is the caller graph for this function:

BuildHostHistoryPlot()

void BuildHostHistoryPlot

(

)

Definition at line 562 of file msysmon.cxx.

{
  //Insert myself into the history
 
   char path[256];
   int status;
   int size;
   int NVARS=5;
   
   // Setup variables to plot:
   size = 64; // String length in ODB
   sprintf(path,"/History/Display/msysmon/%s/Variables",equipment[0].info.frontend_host);
   {
      char vars[size*NVARS];
      memset(vars, 0, size*NVARS);
      sprintf(vars+size*0,"%s:LOAD[%d]",equipment[0].name,0);
      sprintf(vars+size*1,"%s:LOAD[%d]",equipment[0].name,1);
      sprintf(vars+size*2,"%s:LOAD[%d]",equipment[0].name,2);
      sprintf(vars+size*3,"%s:MEMP",equipment[0].name);
      sprintf(vars+size*4,"%s:SWAP",equipment[0].name);
      status = db_set_value(hDB, 0, path,  vars, size*NVARS, NVARS, TID_STRING);
   }
   assert(status == DB_SUCCESS);
 
   // Setup labels 
   size = 32;
   sprintf(path,"/History/Display/msysmon/%s/Label",equipment[0].info.frontend_host);
   {
      char vars[size*NVARS];
      memset(vars, 0, size*NVARS);
      sprintf(vars+size*0,"NICE CPU Load (%%)");
      sprintf(vars+size*1,"USER CPU Load (%%)");
      sprintf(vars+size*2,"SYSTEM CPU Load (%%)");
      sprintf(vars+size*3,"Memory Usage (%%)");
      sprintf(vars+size*4,"Swap Usage (%%)");
      status = db_set_value(hDB, 0, path,  vars, size*NVARS, NVARS, TID_STRING);
   }
   assert(status == DB_SUCCESS);
 
   // Setup colours:
   size = 32;
   sprintf(path,"/History/Display/msysmon/%s/Colour",equipment[0].info.frontend_host);
   {
      char vars[size*NVARS];
      memset(vars, 0, size*NVARS);
      for (int i=0; i<NVARS; i++)
         sprintf(vars+size*i,"%s",(colours[i%16]).c_str());
      status = db_set_value(hDB, 0, path,  vars, size*NVARS, NVARS, TID_STRING);
   }
   assert(status == DB_SUCCESS);
 
   // Setup time scale and range:
   sprintf(path,"/History/Display/msysmon/%s/Timescale",equipment[0].info.frontend_host);
   status = db_set_value(hDB,0,path,"1h",3,1,TID_STRING);
   double *m=new double();
   *m=0.;
   sprintf(path,"/History/Display/msysmon/%s/Minimum",equipment[0].info.frontend_host);
   status = db_set_value(hDB,0,path,m,sizeof(double),1,TID_DOUBLE);
   *m=100.;
   sprintf(path,"/History/Display/msysmon/%s/Maximum",equipment[0].info.frontend_host);
   status = db_set_value(hDB,0,path,m,sizeof(double),1,TID_DOUBLE);
   delete m;
}

Here is the call graph for this function:

Here is the caller graph for this function:

BuildHostNetPlot()

void BuildHostNetPlot

(

)

Definition at line 719 of file msysmon.cxx.

{
   //Insert per CPU graphs into the history
   int status, size;
   char path[256];
   int NVARS=networkInterfaceCount*2;
   // Setup variables to plot:
   size = 64;
   sprintf(path,"/History/Display/msysmon/%s-net/Variables",equipment[0].info.frontend_host);
   {
      char vars[size*NVARS];
      memset(vars, 0, size*NVARS);
      for (int i=0; i<networkInterfaceCount; i++)
         sprintf(vars+size*i,"%s:NETR[%d]",equipment[0].name,i);
      for (int i=networkInterfaceCount; i<NVARS; i++)
         sprintf(vars+size*i,"%s:NETT[%d]",equipment[0].name,i-networkInterfaceCount);
      status = db_set_value(hDB, 0, path,  vars, size*NVARS, NVARS, TID_STRING);
   }
   assert(status == DB_SUCCESS);
 
   // Setup labels 
   size = 32;
   sprintf(path,"/History/Display/msysmon/%s-net/Label",equipment[0].info.frontend_host);
   {
      char vars[size*NVARS];
      memset(vars, 0, size*NVARS);
      for (int i=0; i<networkInterfaceCount; i++)
         sprintf(vars+size*i,"%s Received (Mbps)",NetReceive.at(i)->face.c_str());
      for (int i=networkInterfaceCount; i<NVARS; i++)
         sprintf(vars+size*i,"%s Transmitted (Mbps)",NetReceive.at(i-networkInterfaceCount)->face.c_str());
      status = db_set_value(hDB, 0, path,  vars, size*NVARS, NVARS, TID_STRING);
   }
   assert(status == DB_SUCCESS);
 
   // Setup colours:
   size = 32;
   sprintf(path,"/History/Display/msysmon/%s-net/Colour",equipment[0].info.frontend_host);
   {
      char vars[size*NVARS];
      memset(vars, 0, size*NVARS);
      for (int i=0; i<NVARS; i++)
         sprintf(vars+size*i,"%s",(colours[i%16]).c_str());
      status = db_set_value(hDB, 0, path,  vars, size*NVARS, NVARS, TID_STRING);
   }
   assert(status == DB_SUCCESS);
   // Setup time scale and range:
   sprintf(path,"/History/Display/msysmon/%s-net/Timescale",equipment[0].info.frontend_host);
   status = db_set_value(hDB,0,path,"1h",3,1,TID_STRING);
   double *m=new double();
   *m=0.;
   sprintf(path,"/History/Display/msysmon/%s-net/Minimum",equipment[0].info.frontend_host);
   status = db_set_value(hDB,0,path,m,sizeof(double),1,TID_DOUBLE);
   *m=1.0/0.0; //infinity
   sprintf(path,"/History/Display/msysmon/%s-net/Maximum",equipment[0].info.frontend_host);
   status = db_set_value(hDB,0,path,m,sizeof(double),1,TID_DOUBLE);
   delete m;
}

Here is the call graph for this function:

Here is the caller graph for this function:

end_of_run()

INT end_of_run	(	INT	run_number,
		char *	error
	)

End of Run.

Called every stop run transition. Set equipment status in ODB, stop acquisition on the modules.

Parameters

[in]	run_number	Number of the run being ended
[out]	error	Can be used to write a message string to midas.log

Definition at line 963 of file msysmon.cxx.

{
   return SUCCESS;
}

frontend_exit()

INT frontend_exit

(

void

)

Frontend exit.

Runs at frontend shutdown. Disconnect hardware and set equipment status in ODB

Returns

Midas status code

Definition at line 949 of file msysmon.cxx.

{
   return SUCCESS;
}

frontend_init()

INT frontend_init

(

void

)

Frontend initialization.

Runs once at application startup. We initialize the hardware and optical interfaces and set the equipment status in ODB. We also lock the frontend to once physical cpu core.

Returns

Midas status code

Definition at line 868 of file msysmon.cxx.

{
   int status;
   printf("frontend_init!\n");
 
   FILE* file = fopen(PROCSTATFILE, "r");
   if (file == NULL) {
      cm_msg(MERROR, frontend_name, "Cannot open " PROCSTATFILE);
      return FE_ERR_HW;
   }
   char buffer[256];
   int Ncpus = -1;
   do {
      Ncpus++;
      const char*s = fgets(buffer, 255, file);
      if (!s) // EOF
         break;
   } while (String_startsWith(buffer, "cpu"));
   fclose(file);
   cpuCount = MAX(Ncpus - 1, 1);
   printf("%d CPUs found\n",cpuCount);
   //Note, cpus[0] is a total for all CPUs
   for (int i = 0; i <= cpuCount; i++) {
      cpus.push_back(new CPUData);
   }
   
   file = fopen(PROCNETSTATFILE, "r");
   if (file == NULL) {
      cm_msg(MERROR, frontend_name, "Cannot open " PROCNETSTATFILE);
      return FE_ERR_HW;
   }
    do {
      if (!fgets(buffer, 255, file)) break;
      for (int i=0; i<255; i++)
      {
         if (!buffer[i]) break;
         if (buffer[i]==':') 
         {
            NetStat* r=new NetStat;
            r->face=std::string(buffer,&buffer[i]);
            NetReceive.push_back(r);
 
            NetStat* t=new NetStat;
            t->face=std::string(buffer,&buffer[i]);
            NetTransmit.push_back(t);
 
            networkInterfaceCount++;
         }
      }
   } while (1);
   fclose(file);
   printf("%d network inferfaces found\n",networkInterfaceCount);
   
   ReadCPUData();
   ReadNetData();
   BuildHostHistoryPlot();
   BuildHostCPUPlot();
   BuildHostNetPlot();
 
#ifdef HAVE_NVIDIA
   BuildHostGPUPlot();
   InitGPU();
#endif
 
#ifdef HAVE_LM_SENSORS
   if (!sensors)
      sensors= new LM_Sensors();
   sensors->BuildHostTemperaturePlot();
 
#endif
 
#ifdef RPC_JRPC
   status = cm_register_function(RPC_JRPC, rpc_callback);
   assert(status == SUCCESS);
#endif
 
   return SUCCESS;
}

Here is the call graph for this function:

frontend_loop()

INT frontend_loop

(

void

)

Frontend loop.

If frontend_call_loop is true, this routine gets called when the frontend is idle or once between every event.

Returns

Midas status code

Definition at line 984 of file msysmon.cxx.

{
   /* if frontend_call_loop is true, this routine gets called when
      the frontend is idle or once between every event */
   ss_sleep(100); // don't eat all CPU
   return SUCCESS;
}

Here is the call graph for this function:

InitGPU()

void InitGPU

(

)

Here is the caller graph for this function:

interrupt_configure()

INT interrupt_configure	(	INT	cmd,
		INT	source,
		PTYPE	adr
	)

Definition at line 1013 of file msysmon.cxx.

{
   printf("interrupt_configure!\n");
 
   switch(cmd)
      {
      case CMD_INTERRUPT_ENABLE:
         break;
      case CMD_INTERRUPT_DISABLE:
         break;
      case CMD_INTERRUPT_ATTACH:
         break;
      case CMD_INTERRUPT_DETACH:
         break;
      }
   return SUCCESS;
}

Here is the call graph for this function:

pause_run()

INT pause_run	(	INT	run_number,
		char *	error
	)

Pause Run.

Called every pause run transition.

Parameters

[in]	run_number	Number of the run being ended
[out]	error	Can be used to write a message string to midas.log

Returns

Midas status code

Definition at line 970 of file msysmon.cxx.

{
   return SUCCESS;
}

poll_event()

INT poll_event	(	INT	source,
		INT	count,
		BOOL	test
	)

Definition at line 1000 of file msysmon.cxx.

{
   if (test) {
      ss_sleep (count);
   }
   return (0);
}

Here is the call graph for this function:

read_system_load()

int read_system_load	(	char *	pevent,
		int	off
	)

Definition at line 1275 of file msysmon.cxx.

{
   bk_init32(pevent);
 
   ReadCPUData();
 
   ReadNetData();
 
   //Calculate load:
   // The classic layout of CPU variables would be to log a bank for 4 doubles for each CPU core. This will not scale with very high core counts in the future
#ifdef CLASSIC_CPU_VARS
   double CPULoadTotal[4]; //nice, user, system, total
   for (int j=0; j<4; j++)
      CPULoadTotal[j]=0;
 
   double CPULoad[4]; //nice, user, system, total
   for (int i = 0; i <= cpuCount; i++) {
      CPUData* cpuData = (cpus[i]);
      double total = (double) ( cpuData->totalPeriod == 0 ? 1 : cpuData->totalPeriod);
      CPULoad[0] = cpuData->nicePeriod / total * 100.0;
      CPULoad[1] = cpuData->userPeriod / total * 100.0;
      CPULoad[2] = cpuData->systemPeriod / total * 100.0;
      CPULoad[3]=CPULoad[0]+CPULoad[1]+CPULoad[2];
 
      for (int j=0; j<4; j++)
      {
         CPULoadTotal[j]+=CPULoad[j];
      }
 
      // This is a little long for just setting a bank name, but it
      // avoids format-truncation warnings and supports machines with upto
      // 1000 CPUs... another case can be put in when we reach that new limit
      char name[5]="LOAD";
      //i==0 is a total for ALL Cpus
      if (i!=0)
      {
         int h='0'+i/100;
         int t='0'+(i%100)/10;
         int u='0'+i%10;
         if (i<10)
            snprintf(name,5,"CPU%c",u);
         else if (i<100)
            snprintf(name,5,"CP%c%c",t,u);
         else if (i<1000)
            snprintf(name,5,"C%c%c%c",h,t,u);
         else
            cm_msg(MERROR, frontend_name, "Cannot handle a system with more than 1000 CPUs");
      }
      double* a;
      bk_create(pevent, name, TID_DOUBLE, (void**)&a);
      for (int k=0; k<4; k++)
      {
         *a=CPULoad[k];
         a++;
      }
      bk_close(pevent,a);
   
   }
#else
   //Instead of the 'Classic' variables. Log 4 banks with N doubles, where N is the number of CPUs
   double CPUN[cpuCount]; // % nice time
   double CPUU[cpuCount]; // % user time
   double CPUS[cpuCount]; // % system time
   double CPUA[cpuCount]; // % total CPU time
   for (int i = 0; i <= cpuCount; i++) {
      CPUData* cpuData = (cpus[i]);
      double total = (double) ( cpuData->totalPeriod == 0 ? 1 : cpuData->totalPeriod);
      CPUN[i] = cpuData->nicePeriod / total * 100.0;
      CPUU[i] = cpuData->userPeriod / total * 100.0;
      CPUS[i] = cpuData->systemPeriod / total * 100.0;
      CPUA[i] = CPUN[i]+CPUU[i]+CPUS[i];
   }
   double* c;
   bk_create(pevent, "CPUN", TID_DOUBLE, (void**)&c);
   for (int k=0; k<cpuCount; k++)
   {
      *c=CPUN[k];
      c++;
   }
   bk_close(pevent,c);
   bk_create(pevent, "CPUU", TID_DOUBLE, (void**)&c);
   for (int k=0; k<cpuCount; k++)
   {
      *c=CPUU[k];
      c++;
   }
   bk_close(pevent,c);
   
   bk_create(pevent, "CPUS", TID_DOUBLE, (void**)&c);
   for (int k=0; k<cpuCount; k++)
   {
      *c=CPUS[k];
      c++;
   }
   bk_close(pevent,c);
   
   bk_create(pevent, "CPUA", TID_DOUBLE, (void**)&c);
   for (int k=0; k<cpuCount; k++)
   {
      *c=CPUA[k];
      c++;
   }
   bk_close(pevent,c);
   double TotalLoad[4]={0};
   for (int k=0; k<cpuCount; k++)
   {
      TotalLoad[0]+=CPUN[k];
      TotalLoad[1]+=CPUU[k];
      TotalLoad[2]+=CPUS[k];
      TotalLoad[3]+=CPUA[k];
   }
   bk_create(pevent, "LOAD", TID_DOUBLE, (void**)&c);
   for (int k=0; k<4; k++)
   {
      *c=TotalLoad[k]/(double)cpuCount;
      c++;
   }
   bk_close(pevent,c);
#endif
 
 
//Read and log system temperatures
#ifdef HAVE_LM_SENSORS
   pevent = sensors->ReadAndLogSensors(pevent);
#endif
 
   double DataRecieve;
   double DataTransmit;
 
   double* a;
   char name[5]="NETR";
   bk_create(pevent, name, TID_DOUBLE, (void**)&a);
   for (int i=0; i<networkInterfaceCount; i++)
   {
      NetStat* RData = NetReceive.at(i);
      double Rdt=RData->tv.tv_sec + (RData->tv.tv_usec * 1e-6);
      DataRecieve=(double)(RData->bytesPeriod)*8./1024./1024. / Rdt; //Megabits / s
      *a=DataRecieve;
      a++;
   }
   bk_close(pevent,a);
 
   double* b;
   sprintf(name,"NETT");
   bk_create(pevent, name, TID_DOUBLE, (void**)&b);
   for (int i=0; i<networkInterfaceCount; i++)
   {
      NetStat* SData = NetTransmit.at(i);
      double Sdt=SData->tv.tv_sec + (SData->tv.tv_usec * 1e-6);
      DataTransmit=(double)(SData->bytesPeriod)*8./1024./1024. / Sdt; //Megabits /s
      *b=DataTransmit;
      b++;
   }
   bk_close(pevent,b);
 
   //Again from htop:
   unsigned long long int totalMem;
   unsigned long long int usedMem;
   unsigned long long int freeMem;
   unsigned long long int sharedMem;
   unsigned long long int buffersMem;
   unsigned long long int cachedMem;
   unsigned long long int totalSwap;
   unsigned long long int usedSwap;
   unsigned long long int freeSwap;
   FILE* file = fopen(PROCMEMINFOFILE, "r");
   if (file == NULL) {
      cm_msg(MERROR, frontend_name, "Cannot open " PROCMEMINFOFILE);
   }
   char buffer[128];
   while (fgets(buffer, 128, file)) {
       switch (buffer[0]) {
      case 'M':
         if (String_startsWith(buffer, "MemTotal:"))
            sscanf(buffer, "MemTotal: %32llu kB", &totalMem);
         else if (String_startsWith(buffer, "MemFree:"))
            sscanf(buffer, "MemFree: %32llu kB", &freeMem);
         else if (String_startsWith(buffer, "MemShared:"))
            sscanf(buffer, "MemShared: %32llu kB", &sharedMem);
         break;
      case 'B':
         if (String_startsWith(buffer, "Buffers:"))
            sscanf(buffer, "Buffers: %32llu kB", &buffersMem);
         break;
      case 'C':
         if (String_startsWith(buffer, "Cached:"))
            sscanf(buffer, "Cached: %32llu kB", &cachedMem);
         break;
      case 'S':
         if (String_startsWith(buffer, "SwapTotal:"))
            sscanf(buffer, "SwapTotal: %32llu kB", &totalSwap);
         if (String_startsWith(buffer, "SwapFree:"))
            sscanf(buffer, "SwapFree: %32llu kB", &freeSwap);
         break;
      }
   }
   fclose(file);
   //end htop code
 
   usedMem = totalMem - cachedMem- freeMem;
   usedSwap = totalSwap - freeSwap;
   double mem_percent=100.*(double)usedMem/(double)totalMem;
   double swap_percent=100;
   if (totalSwap) //If there is an swap space, calculate... else always say 100% used
      swap_percent=100*(double)usedSwap/(double)totalSwap;
#ifdef FE_DEBUG
   printf("-----------------------------\n");
   printf("MemUsed:  %lld kB (%lld GB) (%.2f%%)\n",usedMem,usedMem/1024/1024,mem_percent);
   printf("SwapUsed: %lld kB (%lld GB) (%.2f%%)\n",usedSwap,usedSwap/1024/1024,swap_percent);
   printf("-----------------------------\n");
#endif
   double* m;
   bk_create(pevent, "MEMP", TID_DOUBLE, (void**)&m);
   *m=mem_percent;
   bk_close(pevent,m+1);
 
   if (totalSwap) //Only log SWAP if there is any
   {
      bk_create(pevent, "SWAP", TID_DOUBLE, (void**)&m);
      *m=swap_percent;
      bk_close(pevent,m+1);
   }
 
#if HAVE_NVIDIA
   ReadGPUData();
   int* t;
 
   //GPU Temperature
   bk_create(pevent, "GPUT", TID_INT, (void**)&t);
   for (unsigned i=0; i<nGPUs; i++)
   {
      *t=GPUs[i]->temperature;
      t++;
   }
   bk_close(pevent,t);
 
   //GPU Fan speed
   bk_create(pevent, "GPUF", TID_INT, (void**)&t);
   for (unsigned i=0; i<nGPUs; i++)
   {
      *t=GPUs[i]->fan;
      t++;
   }
   bk_close(pevent,t);
 
   //GPU Power (W)
   bk_create(pevent, "GPUP", TID_INT, (void**)&t);
   for (unsigned i=0; i<nGPUs; i++)
   {
      *t=GPUs[i]->power_usage/1000;
      t++;
   }
   bk_close(pevent,t);
 
   //GPU Utilisiation (%)
   bk_create(pevent, "GPUU", TID_INT, (void**)&t);
   for (unsigned i=0; i<nGPUs; i++)
   {
      *t=GPUs[i]->util.gpu;
      t++;
   }
   bk_close(pevent,t);
 
   //GPU Memory Utilisiation (%)
   bk_create(pevent, "GPUM", TID_DOUBLE, (void**)&m);
   for (unsigned i=0; i<nGPUs; i++)
   {
     *m=100.*(double)GPUs[i]->memory.used/(double)GPUs[i]->memory.total;
      m++;
   }
   bk_close(pevent,m);
 
#endif
 
   return bk_size(pevent);
}

Here is the call graph for this function:

ReadCPUData()

void ReadCPUData

(

)

Definition at line 1031 of file msysmon.cxx.

{
   //Largely from htop: https://github.com/hishamhm/htop (GNU licence)
   FILE* file = fopen(PROCSTATFILE, "r");
   if (file == NULL) {
      cm_msg(MERROR, frontend_name, "Cannot open " PROCSTATFILE);
   }
   for (int i = 0; i <= cpuCount; i++) {
      char buffer[256];
      int cpuid;
      unsigned long long int ioWait, irq, softIrq, steal, guest, guestnice;
      unsigned long long int systemalltime, idlealltime, totaltime, virtalltime;
      ioWait = irq = softIrq = steal = guest = guestnice = 0;
      // Dependending on your kernel version,
      // 5, 7, 8 or 9 of these fields will be set.
      // The rest will remain at zero.
      const  char*s = fgets(buffer, 255, file);
      if (!s) // EOF
         break;
      if (i == 0)
         sscanf(buffer, "cpu  %16llu %16llu %16llu %16llu %16llu %16llu %16llu %16llu %16llu %16llu", &usertime, &nicetime, &systemtime, &idletime, &ioWait, &irq, &softIrq, &steal, &guest, &guestnice);
      else {
         sscanf(buffer, "cpu%4d %16llu %16llu %16llu %16llu %16llu %16llu %16llu %16llu %16llu %16llu", &cpuid, &usertime, &nicetime, &systemtime, &idletime, &ioWait, &irq, &softIrq, &steal, &guest, &guestnice);
         assert(cpuid == i - 1);
      }
      // Guest time is already accounted in usertime
      usertime = usertime - guest;
      nicetime = nicetime - guestnice;
      // Fields existing on kernels >= 2.6
      // (and RHEL's patched kernel 2.4...)
      idlealltime = idletime + ioWait;
      systemalltime = systemtime + irq + softIrq;
      virtalltime = guest + guestnice;
      totaltime = usertime + nicetime + systemalltime + idlealltime + steal + virtalltime;
      CPUData* cpuData = cpus.at(i);
      cpuData->userPeriod = usertime - cpuData->userTime;
      cpuData->nicePeriod = nicetime - cpuData->niceTime;
      cpuData->systemPeriod = systemtime - cpuData->systemTime;
      cpuData->systemAllPeriod = systemalltime - cpuData->systemAllTime;
      cpuData->idleAllPeriod = idlealltime - cpuData->idleAllTime;
      cpuData->idlePeriod = idletime - cpuData->idleTime;
      cpuData->ioWaitPeriod = ioWait - cpuData->ioWaitTime;
      cpuData->irqPeriod = irq - cpuData->irqTime;
      cpuData->softIrqPeriod = softIrq - cpuData->softIrqTime;
      cpuData->stealPeriod = steal - cpuData->stealTime;
      cpuData->guestPeriod = virtalltime - cpuData->guestTime;
      cpuData->totalPeriod = totaltime - cpuData->totalTime;
      cpuData->userTime = usertime;
      cpuData->niceTime = nicetime;
      cpuData->systemTime = systemtime;
      cpuData->systemAllTime = systemalltime;
      cpuData->idleAllTime = idlealltime;
      cpuData->idleTime = idletime;
      cpuData->ioWaitTime = ioWait;
      cpuData->irqTime = irq;
      cpuData->softIrqTime = softIrq;
      cpuData->stealTime = steal;
      cpuData->guestTime = virtalltime;
      cpuData->totalTime = totaltime;
   }
   fclose(file);
   //end htop code
}

Here is the call graph for this function:

Here is the caller graph for this function:

ReadNetData()

void ReadNetData

(

)

Definition at line 1096 of file msysmon.cxx.

{
   FILE* file = fopen(PROCNETSTATFILE,"r");
   if (file == NULL) {
      cm_msg(MERROR, frontend_name, "Cannot open " PROCNETSTATFILE);
   }
   gettimeofday(&new_tv, NULL);
   timersub(&new_tv, &old_tv, &tv);
   //Note, there are two title lines (hence +2)
   const int title_lines=2;
   for (int i = 0; i < networkInterfaceCount+title_lines; i++) {
      char buffer[256];
      char InterfaceName[20];
      unsigned long int rbytes, rpackets, rerrs, rdrop, rfifo, rframe, rcompressed, rmulticast;
      unsigned long int sbytes, spackets, serrs, sdrop, sfifo, sframe, scompressed, smulticast;
      // Dependending on your kernel version,
      // 5, 7, 8 or 9 of these fields will be set.
      // The rest will remain at zero.
      const char*s = fgets(buffer, 255, file);
      if (!s) // EOF
         break;
      if (i < 2)
         continue; //Title lines
      else
         sscanf(buffer, "%[^:]: %lu %lu %lu %lu %lu %lu %lu %lu %lu %lu %lu %lu %lu %lu %lu %lu",InterfaceName, &rbytes, &rpackets, &rerrs, &rdrop, &rfifo, &rframe, &rcompressed, &rmulticast,&sbytes, &spackets, &serrs, &sdrop, &sfifo, &sframe, &scompressed, &smulticast);
#ifdef FE_DEBUG
      printf("--------------------Parsing line %d from " PROCNETSTATFILE "---------------------\n",i);
      printf("Intput: %s\n",buffer);
      printf("Output: %s: %16lu %16lu %16lu %16lu %16lu %16lu %16lu %16lu %16lu %16lu %16lu %16lu %16lu %16lu %16lu %16lu\n\n",InterfaceName, rbytes, rpackets, rerrs, rdrop, rfifo, rframe, rcompressed, rmulticast,sbytes, spackets, serrs, sdrop, sfifo, sframe, scompressed, smulticast);
      printf("-------------------------------------------------------------------------------\n");
#endif
      NetStat* RData = NetReceive.at(i-title_lines);
      NetStat* SData = NetTransmit.at(i-title_lines);
      
      RData->bytesPeriod      =rbytes-RData->bytes;
      RData->packetsPeriod    =rpackets-RData->packets;
      RData->errsPeriod       =rerrs-RData->errs;
      RData->dropPeriod       =rdrop-RData->drop;
      RData->fifoPeriod       =rfifo-RData->fifo;
      RData->framePeriod      =rframe-RData->frame;
      RData->compressedPeriod =rcompressed-RData->compressed;
      RData->multicastPeriod  =rmulticast-RData->multicast;
 
      RData->bytes      =rbytes;
      RData->packets    =rpackets;
      RData->errs       =rerrs;
      RData->drop       =rdrop;
      RData->fifo       =rfifo;
      RData->frame      =rframe;
      RData->compressed =rcompressed;
      RData->multicast  =rmulticast;
      RData->tv         =tv;
      
      SData->bytesPeriod      =sbytes-SData->bytes;
      SData->packetsPeriod    =spackets-SData->packets;
      SData->errsPeriod       =serrs-SData->errs;
      SData->dropPeriod       =sdrop-SData->drop;
      SData->fifoPeriod       =sfifo-SData->fifo;
      SData->framePeriod      =sframe-SData->frame;
      SData->compressedPeriod =scompressed-SData->compressed;
      SData->multicastPeriod  =smulticast-SData->multicast;
      
      SData->bytes      =sbytes;
      SData->packets    =spackets;
      SData->errs       =serrs;
      SData->drop       =sdrop;
      SData->fifo       =sfifo;
      SData->frame      =sframe;
      SData->compressed =scompressed;
      SData->multicast  =smulticast;
      SData->tv         =tv;
   }
   old_tv = new_tv;
   fclose(file);
}

Here is the call graph for this function:

Here is the caller graph for this function:

resume_run()

INT resume_run	(	INT	run_number,
		char *	error
	)

Resume Run.

Called every resume run transition.

Parameters

[in]	run_number	Number of the run being ended
[out]	error	Can be used to write a message string to midas.log

Returns

Midas status code

Definition at line 977 of file msysmon.cxx.

{
   return SUCCESS;
}

rpc_callback()

INT rpc_callback	(	INT	index,
		void *	prpc_param[]
	)

Definition at line 536 of file msysmon.cxx.

{
   const char* cmd  = CSTRING(0);
   const char* args = CSTRING(1);
   char* return_buf = CSTRING(2);
   int   return_max_length = CINT(3);
 
   cm_msg(MINFO, "rpc_callback", "--------> rpc_callback: index %d, max_length %d, cmd [%s], args [%s]", index, return_max_length, cmd, args);
 
   //int example_int = strtol(args, NULL, 0);
   //int size = sizeof(int);
   //int status = db_set_value(hDB, 0, "/Equipment/" EQ_NAME "/Settings/example_int", &example_int, size, 1, TID_INT);
 
   char tmp[256];
   time_t now = time(NULL);
   sprintf(tmp, "{ \"current_time\" : [ %d, \"%s\"] }", (int)now, ctime(&now));
 
   mstrlcpy(return_buf, tmp, return_max_length);
 
   return RPC_SUCCESS;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

colours

std::string colours[16]

Initial value:

={
     "#00AAFF", "#FF9000", "#FF00A0", "#00C030",
     "#A0C0D0", "#D0A060", "#C04010", "#807060",
     "#F0C000", "#2090A0", "#D040D0", "#90B000",
     "#B0B040", "#B0B0FF", "#FFA0A0", "#A0FFA0"}

Definition at line 311 of file msysmon.cxx.

                      {
     "#00AAFF", "#FF9000", "#FF00A0", "#00C030",
     "#A0C0D0", "#D0A060", "#C04010", "#807060",
     "#F0C000", "#2090A0", "#D040D0", "#90B000",
     "#B0B040", "#B0B0FF", "#FFA0A0", "#A0FFA0"};

cpuCount

int cpuCount

Definition at line 150 of file msysmon.cxx.

cpus

std::vector<CPUData*> cpus

Definition at line 151 of file msysmon.cxx.

display_period

INT display_period = 0

Definition at line 72 of file msysmon.cxx.

equipment

EQUIPMENT equipment[]

Initial value:

= {
 
  { "${HOSTNAME}_msysmon",       {
      EVID_MONITOR, 0,      
      "SYSTEM",             
      EQ_PERIODIC,          
      0,                    
      "MIDAS",              
      TRUE,                 
      RO_ALWAYS | RO_ODB,   
      10000,                
      0,                    
      0,                    
      1,                    
      "", "", ""
    },
    read_system_load,
  },
  { "" }
}

Definition at line 101 of file msysmon.cxx.

                        {
 
  { "${HOSTNAME}_msysmon",   /* equipment name */    {
      EVID_MONITOR, 0,      /* event ID, trigger mask */
      "SYSTEM",             /* event buffer */
      EQ_PERIODIC,          /* equipment type */
      0,                    /* event source */
      "MIDAS",              /* format */
      TRUE,                 /* enabled */
      RO_ALWAYS | RO_ODB,   /* Read when running */
      10000,                /* poll every so milliseconds */
      0,                    /* stop run after this event limit */
      0,                    /* number of sub events */
      1,                    /* history period */
      "", "", ""
    },
    read_system_load,/* readout routine */
  },
  { "" }
};

equipment_common_overwrite

BOOL equipment_common_overwrite = FALSE

Definition at line 99 of file msysmon.cxx.

event_buffer_size

INT event_buffer_size = 10*1024*1024

Definition at line 79 of file msysmon.cxx.

event_size

int event_size = 10*1024

Definition at line 527 of file msysmon.cxx.

frontend_call_loop

BOOL frontend_call_loop = TRUE

Definition at line 68 of file msysmon.cxx.

frontend_file_name

const char* frontend_file_name = __FILE__

Definition at line 65 of file msysmon.cxx.

frontend_name

const char* frontend_name = "msysmon"

Definition at line 62 of file msysmon.cxx.

hSet

HNDLE hSet

Definition at line 531 of file msysmon.cxx.

idletime

unsigned long long int idletime

Definition at line 153 of file msysmon.cxx.

max_event_size

INT max_event_size = 4*1024*1024

Definition at line 75 of file msysmon.cxx.

max_event_size_frag

INT max_event_size_frag = 4*1024*1024

Definition at line 76 of file msysmon.cxx.

NetReceive

std::vector<NetStat*> NetReceive

Definition at line 178 of file msysmon.cxx.

NetTransmit

std::vector<NetStat*> NetTransmit

Definition at line 179 of file msysmon.cxx.

networkInterfaceCount

int networkInterfaceCount =0

Definition at line 177 of file msysmon.cxx.

new_tv

timeval new_tv

Definition at line 1095 of file msysmon.cxx.

nicetime

unsigned long long int nicetime

Definition at line 153 of file msysmon.cxx.

old_tv

timeval old_tv

Definition at line 1095 of file msysmon.cxx.

systemtime

unsigned long long int systemtime

Definition at line 153 of file msysmon.cxx.

test_rb_wait_sleep

int test_rb_wait_sleep = 1

Definition at line 532 of file msysmon.cxx.

tv

timeval tv

Definition at line 1095 of file msysmon.cxx.

usertime

unsigned long long int usertime

Definition at line 153 of file msysmon.cxx.