restructure; new Symb support
This commit is contained in:
Marty Kraimer
6
src/dev/vxStatsDev/Makefile
Normal file
6
src/dev/vxStatsDev/Makefile
Normal file
@@ -0,0 +1,6 @@
|
||||
TOP=../../..
|
||||
|
||||
include $(TOP)/config/CONFIG_BASE
|
||||
|
||||
include $(TOP)/config/RULES_ARCHS
|
||||
|
||||
10
src/dev/vxStatsDev/Makefile.Vx
Normal file
10
src/dev/vxStatsDev/Makefile.Vx
Normal file
@@ -0,0 +1,10 @@
|
||||
TOP = ../../../..
|
||||
include $(TOP)/config/CONFIG_BASE
|
||||
|
||||
SRCS.c += ../devVXStats.c
|
||||
|
||||
PROD = $(SRCS.c:../%.c=%.o)
|
||||
|
||||
include $(TOP)/config/RULES.Vx
|
||||
|
||||
|
||||
402
src/dev/vxStatsDev/devVXStats.c
Normal file
402
src/dev/vxStatsDev/devVXStats.c
Normal file
@@ -0,0 +1,402 @@
|
||||
/* devVXStats.c - Device Support Routines for vxWorks statistics */
|
||||
/*
|
||||
* Original Author: Jim Kowalkowski
|
||||
* Date: 2/1/96
|
||||
* Current Author: Marty Kraimer
|
||||
* Date: 18NOV1997
|
||||
*/
|
||||
/*****************************************************************
|
||||
COPYRIGHT NOTIFICATION
|
||||
*****************************************************************
|
||||
|
||||
(C) COPYRIGHT 1993 UNIVERSITY OF CHICAGO
|
||||
|
||||
This software was developed under a United States Government license
|
||||
described on the COPYRIGHT_UniversityOfChicago file included as part
|
||||
of this distribution.
|
||||
**********************************************************************/
|
||||
|
||||
#include <vxWorks.h>
|
||||
#include <stddef.h>
|
||||
#include <stdlib.h>
|
||||
#include <stdio.h>
|
||||
#include <string.h>
|
||||
#include <taskLib.h>
|
||||
#include <wdLib.h>
|
||||
#include <tickLib.h>
|
||||
#include <sysLib.h>
|
||||
|
||||
#include <alarm.h>
|
||||
#include <dbDefs.h>
|
||||
#include <dbScan.h>
|
||||
#include <dbAccess.h>
|
||||
#include <callback.h>
|
||||
#include <recSup.h>
|
||||
#include <devSup.h>
|
||||
#include <link.h>
|
||||
#include <aiRecord.h>
|
||||
#include <aoRecord.h>
|
||||
|
||||
/*
|
||||
The following device definitions must exist
|
||||
|
||||
device(ai,INST_IO,devAiVXStats,"VX stats")
|
||||
device(ao,INST_IO,devAoVXStats,"VX stats")
|
||||
|
||||
--------------------------------------------------------------------
|
||||
sample db file to use all data available:
|
||||
Notive that the valid values for the parm field of the link
|
||||
information are:
|
||||
|
||||
ai:
|
||||
memory - % memory used
|
||||
cpu - % CPU usage by tasks
|
||||
fd - % of file descripters used
|
||||
ao:
|
||||
memoryScanRate - Set memory scan rate
|
||||
cpuScanRate - Set cpu scan rate
|
||||
fdScanRate - Set fd scan rate
|
||||
|
||||
|
||||
# sample database using all the different types of statistics
|
||||
record(ai,"$(IOC):memory")
|
||||
{
|
||||
field(DTYP,"VX stats")
|
||||
field(SCAN,"I/O Intr")
|
||||
field(INP,"@memory")
|
||||
field(HOPR,"100.0")
|
||||
field(HIHI,"90.0")
|
||||
field(HIGH,"60.0")
|
||||
field(HHSV, "MAJOR")
|
||||
field(HSV, "MINOR")
|
||||
}
|
||||
record(ai,"$(IOC):cpu")
|
||||
{
|
||||
field(DTYP,"VX stats")
|
||||
field(SCAN,"I/O Intr")
|
||||
field(INP,"@cpu")
|
||||
field(HOPR,"100.0")
|
||||
field(HIHI,"90.0")
|
||||
field(HIGH,"60.0")
|
||||
field(HHSV, "MAJOR")
|
||||
field(HSV, "MINOR")
|
||||
}
|
||||
record(ai,"$(IOC):fd")
|
||||
{
|
||||
field(DTYP,"VX stats")
|
||||
field(SCAN,"I/O Intr")
|
||||
field(INP,"@fd")
|
||||
field(HOPR,"100.0")
|
||||
field(HIHI,"90.0")
|
||||
field(HIGH,"60.0")
|
||||
field(HHSV, "MAJOR")
|
||||
field(HSV, "MINOR")
|
||||
}
|
||||
record(ao,"$(IOC):memoryScanRate")
|
||||
{
|
||||
field(DTYP,"VX stats")
|
||||
field(OUT,"@memoryScanRate")
|
||||
}
|
||||
record(ao,"$(IOC):fdScanRate")
|
||||
{
|
||||
field(DTYP,"VX stats")
|
||||
field(OUT,"@fdScanRate")
|
||||
}
|
||||
record(ao,"$(IOC):cpuScanRate")
|
||||
{
|
||||
field(DTYP,"VX stats")
|
||||
field(OUT,"@cpuScanRate")
|
||||
}
|
||||
*/
|
||||
|
||||
#define MEMORY_TYPE 0
|
||||
#define CPU_TYPE 1
|
||||
#define FD_TYPE 2
|
||||
#define TOTAL_TYPES 3
|
||||
|
||||
#define SECONDS_TO_BURN 5
|
||||
|
||||
/* default rate in seconds (memory,cpu,fd) */
|
||||
static int default_scan_rate[] = { 10,50,10 };
|
||||
|
||||
static char *aiparmValue[TOTAL_TYPES] = {"memory","cpu","fd"};
|
||||
static char *aoparmValue[TOTAL_TYPES] = {
|
||||
"memoryScanRate","cpuScanRate","fdScanRate"};
|
||||
|
||||
typedef struct devPvt
|
||||
{
|
||||
int type;
|
||||
}devPvt;
|
||||
|
||||
typedef struct scanInfo
|
||||
{
|
||||
IOSCANPVT ioscanpvt;
|
||||
WDOG_ID wd;
|
||||
int rate_tick; /* ticks */
|
||||
}scanInfo;
|
||||
|
||||
static scanInfo scan[TOTAL_TYPES];
|
||||
|
||||
static double getMemory(void);
|
||||
static double getCpu(void);
|
||||
static double getFd(void);
|
||||
static void wdCallback(int type);
|
||||
static void cpuUsageInit(void);
|
||||
|
||||
typedef struct aiaodset
|
||||
{
|
||||
long number;
|
||||
DEVSUPFUN report;
|
||||
DEVSUPFUN init;
|
||||
DEVSUPFUN init_record;
|
||||
DEVSUPFUN get_ioint_info;
|
||||
DEVSUPFUN read_write;
|
||||
DEVSUPFUN special_linconv;
|
||||
}aiaodset;
|
||||
static long ai_init(int pass);
|
||||
static long ai_init_record(aiRecord*);
|
||||
static long ai_read(aiRecord*);
|
||||
static long ai_ioint_info(int cmd,aiRecord* pr,IOSCANPVT* iopvt);
|
||||
|
||||
static long ao_init_record(aoRecord* pr);
|
||||
static long ao_write(aoRecord*);
|
||||
aiaodset devAiVXStats={ 6,NULL,ai_init,ai_init_record,ai_ioint_info,ai_read,NULL };
|
||||
aiaodset devAoVXStats={ 6,NULL,NULL,ao_init_record,NULL,ao_write,NULL };
|
||||
|
||||
static long ai_init(int pass)
|
||||
{
|
||||
int type;
|
||||
|
||||
if(pass==1) {
|
||||
for(type=0;type<TOTAL_TYPES;type++)
|
||||
wdStart(scan[type].wd,scan[type].rate_tick,(FUNCPTR)wdCallback,type);
|
||||
return(0);
|
||||
}
|
||||
for(type=0;type<TOTAL_TYPES;type++) {
|
||||
scanIoInit(&scan[type].ioscanpvt);
|
||||
scan[type].wd=wdCreate();
|
||||
scan[type].rate_tick=default_scan_rate[type]*sysClkRateGet();
|
||||
}
|
||||
cpuUsageInit();
|
||||
return 0;
|
||||
}
|
||||
|
||||
static long ai_init_record(aiRecord* pr)
|
||||
{
|
||||
int type;
|
||||
devPvt* pvt = NULL;
|
||||
char *parm;
|
||||
|
||||
if(pr->inp.type!=INST_IO) {
|
||||
recGblRecordError(S_db_badField,(void*)pr,
|
||||
"devAiStats (init_record) Illegal INP field");
|
||||
return S_db_badField;
|
||||
}
|
||||
parm = pr->inp.value.instio.string;
|
||||
for(type=0; type < TOTAL_TYPES; type++) {
|
||||
if(strcmp(parm,aiparmValue[type])==0) {
|
||||
pvt=(devPvt*)malloc(sizeof(devPvt));
|
||||
pvt->type=type;
|
||||
}
|
||||
}
|
||||
if(pvt==NULL) {
|
||||
recGblRecordError(S_db_badField,(void*)pr,
|
||||
"devAiStats (init_record) Illegal INP parm field");
|
||||
return S_db_badField;
|
||||
}
|
||||
/* Make sure record processing routine does not perform any conversion*/
|
||||
pr->linr=0;
|
||||
pr->dpvt=pvt;
|
||||
pr->hopr = 100.0;
|
||||
pr->lopr = 0.0;
|
||||
pr->prec = 2;
|
||||
return 0;
|
||||
}
|
||||
|
||||
static long ao_init_record(aoRecord* pr)
|
||||
{
|
||||
int type;
|
||||
devPvt* pvt = NULL;
|
||||
char *parm;
|
||||
|
||||
if(pr->out.type!=INST_IO) {
|
||||
recGblRecordError(S_db_badField,(void*)pr,
|
||||
"devAiStats (init_record) Illegal OUT field");
|
||||
return S_db_badField;
|
||||
}
|
||||
parm = pr->out.value.instio.string;
|
||||
for(type=0; type < TOTAL_TYPES; type++) {
|
||||
if(strcmp(parm,aoparmValue[type])==0) {
|
||||
pvt=(devPvt*)malloc(sizeof(devPvt));
|
||||
pvt->type=type;
|
||||
}
|
||||
}
|
||||
if(pvt==NULL) {
|
||||
recGblRecordError(S_db_badField,(void*)pr,
|
||||
"devAiStats (init_record) Illegal INP parm field");
|
||||
return S_db_badField;
|
||||
}
|
||||
/* Make sure record processing routine does not perform any conversion*/
|
||||
pr->linr=0;
|
||||
pr->dpvt=pvt;
|
||||
return 2;
|
||||
}
|
||||
|
||||
static void wdCallback(int type)
|
||||
{
|
||||
scanIoRequest(scan[type].ioscanpvt);
|
||||
wdStart(scan[type].wd,scan[type].rate_tick, (FUNCPTR)wdCallback,type);
|
||||
}
|
||||
|
||||
static long ai_ioint_info(int cmd,aiRecord* pr,IOSCANPVT* iopvt)
|
||||
{
|
||||
devPvt* pvt=(devPvt*)pr->dpvt;
|
||||
|
||||
*iopvt=scan[pvt->type].ioscanpvt;
|
||||
return 0;
|
||||
}
|
||||
|
||||
static long ao_write(aoRecord* pr)
|
||||
{
|
||||
devPvt* pvt=(devPvt*)pr->dpvt;
|
||||
|
||||
if(!pvt) return(0);
|
||||
scan[pvt->type].rate_tick = (int)pr->val * sysClkRateGet();
|
||||
return 0;
|
||||
}
|
||||
|
||||
static long ai_read(aiRecord* pr)
|
||||
{
|
||||
double value = 0.0;
|
||||
devPvt* pvt=(devPvt*)pr->dpvt;
|
||||
|
||||
if(!pvt) return(0);
|
||||
switch(pvt->type) {
|
||||
case MEMORY_TYPE: value = getMemory(); break;
|
||||
case CPU_TYPE: value = getCpu(); break;
|
||||
case FD_TYPE: value = getFd(); break;
|
||||
default: recGblRecordError(S_db_badField,(void*)pr,"Illegal type");
|
||||
}
|
||||
pr->val=value;
|
||||
pr->udf=0;
|
||||
return 2; /* don't convert */
|
||||
}
|
||||
|
||||
/*Memory statistics*/
|
||||
#include <memLib.h>
|
||||
static MEM_PART_STATS meminfo;
|
||||
|
||||
/* -------------------------------------------------------------------- */
|
||||
|
||||
static double getMemory(void)
|
||||
{
|
||||
double nfree,nalloc;
|
||||
|
||||
memPartInfoGet(memSysPartId,&(meminfo));
|
||||
nfree = meminfo.numBytesFree;
|
||||
nalloc = meminfo.numBytesAlloc;
|
||||
return(100.0 * nalloc/(nalloc + nfree));
|
||||
}
|
||||
|
||||
|
||||
/* fd usage */
|
||||
#include <private/iosLibP.h>
|
||||
static double getFd()
|
||||
{
|
||||
int i,tot;
|
||||
|
||||
for(tot=0,i=0;i<maxFiles;i++) {
|
||||
if(fdTable[i].inuse)
|
||||
tot++;
|
||||
}
|
||||
return(100.0*(double)tot/(double)maxFiles);
|
||||
}
|
||||
|
||||
typedef struct cpuUsage {
|
||||
SEM_ID startSem;
|
||||
int didNotComplete;
|
||||
unsigned long ticksNoContention;
|
||||
int nBurnNoContention;
|
||||
unsigned long ticksNow;
|
||||
int nBurnNow;
|
||||
double usage;
|
||||
} cpuUsage;
|
||||
|
||||
static cpuUsage *pcpuUsage=0;
|
||||
|
||||
static double cpuBurn()
|
||||
{
|
||||
int i;
|
||||
double result = 0.0;
|
||||
|
||||
for(i=0;i<5; i++) result += sqrt((double)i);
|
||||
return(result);
|
||||
}
|
||||
|
||||
static void cpuUsageTask()
|
||||
{
|
||||
while(TRUE) {
|
||||
int i;
|
||||
unsigned long tickStart,tickEnd;
|
||||
|
||||
semTake(pcpuUsage->startSem,WAIT_FOREVER);
|
||||
pcpuUsage->ticksNow=0;
|
||||
pcpuUsage->nBurnNow=0;
|
||||
tickStart = tickGet();
|
||||
for(i=0; i< pcpuUsage->nBurnNoContention; i++) {
|
||||
cpuBurn();
|
||||
pcpuUsage->ticksNow = tickGet() - tickStart;
|
||||
++pcpuUsage->nBurnNow;
|
||||
}
|
||||
tickEnd = tickGet();
|
||||
pcpuUsage->didNotComplete = FALSE;
|
||||
pcpuUsage->ticksNow = tickEnd - tickStart;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
static double getCpu()
|
||||
{
|
||||
if(pcpuUsage->didNotComplete && pcpuUsage->nBurnNow==0) {
|
||||
pcpuUsage->usage = 100.0;
|
||||
} else {
|
||||
double temp;
|
||||
double ticksNow,nBurnNow;
|
||||
|
||||
ticksNow = (double)pcpuUsage->ticksNow;
|
||||
nBurnNow = (double)pcpuUsage->nBurnNow;
|
||||
ticksNow *= (double)pcpuUsage->nBurnNoContention/nBurnNow;
|
||||
temp = ticksNow - (double)pcpuUsage->ticksNoContention;
|
||||
temp = 100.0 * temp/ticksNow;
|
||||
if(temp<0.0 || temp>100.0) temp=0.0;/*take care of tick overflow*/
|
||||
pcpuUsage->usage = temp;
|
||||
}
|
||||
pcpuUsage->didNotComplete = TRUE;
|
||||
semGive(pcpuUsage->startSem);
|
||||
return(pcpuUsage->usage);
|
||||
}
|
||||
|
||||
static void cpuUsageInit(void)
|
||||
{
|
||||
unsigned long tickStart,tickNow;
|
||||
int nBurnNoContention=0;
|
||||
int ticksToWait;
|
||||
|
||||
ticksToWait = SECONDS_TO_BURN*sysClkRateGet();
|
||||
pcpuUsage = calloc(1,sizeof(cpuUsage));
|
||||
tickStart = tickGet();
|
||||
/*wait for a tick*/
|
||||
while(tickStart==(tickNow = tickGet())) {;}
|
||||
tickStart = tickNow;
|
||||
while(TRUE) {
|
||||
if((tickGet() - tickStart)>=ticksToWait) break;
|
||||
cpuBurn();
|
||||
nBurnNoContention++;
|
||||
}
|
||||
pcpuUsage->nBurnNoContention = nBurnNoContention;
|
||||
pcpuUsage->startSem = semBCreate (SEM_Q_FIFO,SEM_EMPTY);
|
||||
pcpuUsage->ticksNoContention = ticksToWait;
|
||||
pcpuUsage->didNotComplete = TRUE;
|
||||
taskSpawn("cpuUsageTask",255,VX_FP_TASK,1000,(FUNCPTR)cpuUsageTask,
|
||||
0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
|
||||
}
|
||||
Reference in New Issue
Block a user