epics/pcas
0
0
Fork 0
Code Issues Pull Requests Projects Wiki Activity

updated caEventRate to allow multiple subscriptions and provide better statistics

Browse Source
This commit is contained in:
Jeff Hill
2002-11-06 22:37:17 +00:00
parent 721c6f3fde
commit 3bcc880e73
3 changed files with 69 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

57
src/ca/caEventRate.cpp
View File

@@ -10,6 +10,7 @@
#include <stdio.h>
#include <limits.h>
#include <math.h>
#include "cadef.h"
#include "dbDefs.h"
@@ -25,44 +26,69 @@ extern "C" void eventCallBack ( struct event_handler_args args )
(*pCount)++;
}
/*
* caEventRate ()
*/
void caEventRate ( const char *pName )
void caEventRate ( const char *pName, unsigned count )
{
static const double initialSamplePeriod = 1.0;
static const double maxSamplePeriod = 60.0 * 60.0;
printf ( "Connecting to CA Channel \"%s\".", pName );
fflush ( stdout );
chid chan;
int status = ca_search ( pName, &chan );
SEVCHK(status, NULL);
unsigned eventCount = 0u;
status = ca_add_event ( DBR_FLOAT, chan, eventCallBack, &eventCount, NULL);
SEVCHK ( status, __FILE__ );
status = ca_pend_io ( 10.0 );
if ( status != ECA_NORMAL ) {
fprintf ( stderr, "caEventRate: %s not found\n", pName );
return;
}
printf ( " done.\n" );
printf ( "Subscribing %u times.", count );
fflush ( stdout );
unsigned eventCount = 0u;
for ( unsigned i = 0u; i < count; i++ ) {
status = ca_add_event ( DBR_FLOAT, chan, eventCallBack, &eventCount, NULL);
SEVCHK ( status, __FILE__ );
}
status = ca_flush_io ();
SEVCHK ( status, __FILE__ );
printf ( " done.\n" );
printf ( "Waiting for initial value events." );
fflush ( stdout );
// let the first one go by
while ( eventCount < 1u ) {
while ( eventCount < count ) {
status = ca_pend_event ( 0.01 );
if ( status != ECA_TIMEOUT ) {
SEVCHK ( status, NULL );
}
}
printf ( " done.\n" );
double samplePeriod = initialSamplePeriod;
double X = 0.0;
double XX = 0.0;
double test = 0.0;
unsigned N = 0u;
while ( true ) {
unsigned nEvents, lastEventCount, curEventCount;
epicsTime begin = epicsTime::getCurrent ();
lastEventCount = eventCount;
status = ca_pend_event ( samplePeriod );
curEventCount = eventCount;
epicsTime end = epicsTime::getCurrent ();
if ( status != ECA_TIMEOUT ) {
SEVCHK ( status, NULL );
}
@@ -71,11 +97,22 @@ void caEventRate ( const char *pName )
nEvents = curEventCount - lastEventCount;
}
else {
nEvents = ( UINT_MAX - lastEventCount ) + curEventCount +1u;
nEvents = ( UINT_MAX - lastEventCount ) + curEventCount + 1u;
}
errlogPrintf ( "CA Channel \"%s\" is producing %g subscription update events per second.\n",
pName, nEvents / samplePeriod );
N++;
double period = end - begin;
double Hz = nEvents / period;
X += Hz;
XX += Hz * Hz;
double mean = X / N;
double stdDev = sqrt ( XX / N - mean * mean );
printf ( "CA Event Rate (Hz): current %g mean %g std dev %g\n",
Hz, mean, stdDev );
if ( samplePeriod < maxSamplePeriod ) {
samplePeriod += samplePeriod;