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

updated CA test routines

Browse Source
This commit is contained in:
Jeff Hill
1991-09-20 15:23:22 +00:00
parent a68ec3f02d
commit 202979b8ed
1 changed files with 302 additions and 251 deletions
Download Patch File Download Diff File Expand all files Collapse all files

553
src/ca/acctst.c
View File

@@ -1,10 +1,16 @@
/*
A CA test/debug routine
*/
* CA test/debug routine
*/
#define CA_TEST_CHNL "ca:ai_2000"
#define CA_TEST_CHNL4 "ca:bo_000"
/* System includes */
#ifdef UNIX
#include <stdio.h>
#endif
/* System includes */
#include <vxWorks.h>
#ifdef vxWorks
#include <taskLib.h>
@@ -13,13 +19,10 @@
#include <cadef.h>
#include <db_access.h>
#define CA_TEST_CHNL "ca:ai_2000"
#define CA_TEST_CHNL4 "ca:bo_000"
/*
#define EVENT_ROUTINE ca_test_event
#define CONN_ROUTINE NULL
*/
* #define EVENT_ROUTINE ca_test_event #define CONN_ROUTINE NULL
*/
#define EVENT_ROUTINE null_event
#define CONN_ROUTINE conn
@@ -29,9 +32,9 @@
#ifdef vxWorks
spacctst()
{
int acctst();
int acctst();
return taskSpawn("acctst",200,VX_FP_TASK,20000,acctst);
return taskSpawn("acctst", 200, VX_FP_TASK, 20000, acctst);
}
#endif
@@ -42,259 +45,307 @@ acctst()
main()
#endif
{
chid chix1;
chid chix2;
chid chix3;
chid chix4;
void ca_test_event();
void null_event();
struct dbr_gr_float *ptr;
struct dbr_gr_float *pgrfloat;
float delay = .003;
chid chix1;
chid chix2;
chid chix3;
chid chix4;
void ca_test_event();
void null_event();
struct dbr_gr_float *ptr;
struct dbr_gr_float *pgrfloat;
float delay = .003;
long status;
long pid;
long i,j;
float delta = 1.0;
long monix;
char string[41];
float value;
float *pfloat;
double *pdouble;
struct dbr_ctrl_float *pctrl;
char pstring[NUM][MAX_STRING_SIZE];
void write_event();
void conn();
long status;
long pid;
long i, j;
float delta = 1.0;
evid monix;
char string[41];
float value;
float *pfloat;
double *pdouble;
struct dbr_ctrl_float *pctrl;
char pstring[NUM][MAX_STRING_SIZE];
void write_event();
void conn();
SEVCHK(ca_task_initialize(),"Unable to initialize");
SEVCHK(ca_task_initialize(), "Unable to initialize");
printf("begin\n");
# ifdef VMS
lib$init_timer();
# endif
ptr = (struct dbr_gr_float *)
malloc(dbr_size[DBR_GR_FLOAT] + dbr_value_size[DBR_GR_FLOAT]*(NUM-1));
for(i=0; i<0; i++){
status = ca_array_build( CA_TEST_CHNL, /* channel ASCII name */
DBR_GR_FLOAT, /* fetch external type */
NUM, /* array element cnt */
&chix3, /* ptr to chid */
ptr /* pointer to recv buf */
);
SEVCHK(status, NULL);
SEVCHK(ca_build_and_connect(
CA_TEST_CHNL4,
TYPENOTCONN,
0,
&chix4,
NULL,
CONN_ROUTINE,
NULL),NULL);
SEVCHK(ca_build_and_connect(
CA_TEST_CHNL,
TYPENOTCONN,
0,
&chix2,
NULL,
CONN_ROUTINE,
NULL),NULL);
SEVCHK(ca_build_and_connect(
CA_TEST_CHNL,
TYPENOTCONN,
0,
&chix1,
NULL,
CONN_ROUTINE,
NULL),NULL);
status = ca_pend_io(10.0);
SEVCHK(status,NULL);
SEVCHK(ca_clear_channel(chix4),NULL);
SEVCHK(ca_clear_channel(chix2),NULL);
SEVCHK(ca_clear_channel(chix3),NULL);
SEVCHK(ca_clear_channel(chix1),NULL);
free(ptr);
}
status = ca_array_build(
CA_TEST_CHNL, /* channel ASCII name */
DBR_GR_FLOAT, /* fetch external type */
NUM, /* array element cnt */
&chix3, /* ptr to chid */
ptr /* pointer to recv buf */
);
SEVCHK(status, NULL);
SEVCHK(ca_build_and_connect(
CA_TEST_CHNL4,
TYPENOTCONN,
0,
&chix4,
NULL,
CONN_ROUTINE,
NULL),NULL);
SEVCHK(ca_build_and_connect(
CA_TEST_CHNL,
TYPENOTCONN,
0,
&chix2,
NULL,
CONN_ROUTINE,
NULL),NULL);
SEVCHK(ca_build_and_connect(
CA_TEST_CHNL,
TYPENOTCONN,
0,
&chix1,
NULL,
CONN_ROUTINE,
NULL),NULL);
status = ca_pend_io(10.0);
SEVCHK(status,NULL);
if(INVALID_DB_REQ(chix1->type))
printf("Failed to locate %s\n",CA_TEST_CHNL);
if(INVALID_DB_REQ(chix2->type))
printf("Failed to locate %s\n",CA_TEST_CHNL);
if(INVALID_DB_REQ(chix3->type))
printf("Failed to locate %s\n",CA_TEST_CHNL);
if(INVALID_DB_REQ(chix4->type))
printf("Failed to locate %s\n",CA_TEST_CHNL4);
/*
SEVCHK(status,NULL);
if(status == ECA_TIMEOUT)
exit();
*/
# ifdef VMS
lib$show_timer();
printf("begin\n");
#ifdef VMS
lib$init_timer();
#endif
pfloat = &ptr->value;
for(i=0;i<NUM;i++)
printf("Value Returned from build %f\n",pfloat[i]);
ptr = (struct dbr_gr_float *)
malloc(dbr_size[DBR_GR_FLOAT] +
dbr_value_size[DBR_GR_FLOAT] * (NUM - 1));
for (i = 0; i < 0; i++) {
status = ca_array_build(CA_TEST_CHNL, /* channel ASCII name */
DBR_GR_FLOAT, /* fetch external type */
NUM, /* array element cnt */
&chix3, /* ptr to chid */
ptr /* pointer to recv buf */
);
SEVCHK(status, NULL);
SEVCHK(ca_build_and_connect(
CA_TEST_CHNL4,
TYPENOTCONN,
0,
&chix4,
NULL,
CONN_ROUTINE,
NULL), NULL);
SEVCHK(ca_build_and_connect(
CA_TEST_CHNL,
TYPENOTCONN,
0,
&chix2,
NULL,
CONN_ROUTINE,
NULL), NULL);
SEVCHK(ca_build_and_connect(
CA_TEST_CHNL,
TYPENOTCONN,
0,
&chix1,
NULL,
CONN_ROUTINE,
NULL), NULL);
status = ca_pend_io(10.0);
SEVCHK(status, NULL);
SEVCHK(ca_clear_channel(chix4), NULL);
SEVCHK(ca_clear_channel(chix2), NULL);
SEVCHK(ca_clear_channel(chix3), NULL);
SEVCHK(ca_clear_channel(chix1), NULL);
free(ptr);
}
status = ca_array_build(
CA_TEST_CHNL, /* channel ASCII name */
DBR_GR_FLOAT, /* fetch external type */
NUM, /* array element cnt */
&chix3, /* ptr to chid */
ptr /* pointer to recv buf */
);
SEVCHK(status, NULL);
SEVCHK(ca_build_and_connect(
CA_TEST_CHNL4,
TYPENOTCONN,
0,
&chix4,
NULL,
CONN_ROUTINE,
NULL), NULL);
SEVCHK(ca_build_and_connect(
CA_TEST_CHNL,
TYPENOTCONN,
0,
&chix2,
NULL,
CONN_ROUTINE,
NULL), NULL);
SEVCHK(ca_build_and_connect(
CA_TEST_CHNL,
TYPENOTCONN,
0,
&chix1,
NULL,
CONN_ROUTINE,
NULL), NULL);
status = ca_pend_io(10.0);
SEVCHK(status, NULL);
if (INVALID_DB_REQ(chix1->type))
printf("Failed to locate %s\n", CA_TEST_CHNL);
if (INVALID_DB_REQ(chix2->type))
printf("Failed to locate %s\n", CA_TEST_CHNL);
if (INVALID_DB_REQ(chix3->type))
printf("Failed to locate %s\n", CA_TEST_CHNL);
if (INVALID_DB_REQ(chix4->type))
printf("Failed to locate %s\n", CA_TEST_CHNL4);
/*
* SEVCHK(status,NULL); if(status == ECA_TIMEOUT) exit();
*/
#ifdef VMS
lib$init_timer();
# endif
if(VALID_DB_REQ(chix4->type)){
status = ca_add_event(DBR_FLOAT, chix4, EVENT_ROUTINE, 0xaaaaaaaa, &monix);
SEVCHK(status,NULL);
SEVCHK(ca_clear_event(monix),NULL);
status = ca_add_event(DBR_FLOAT, chix4, EVENT_ROUTINE, 0xaaaaaaaa, &monix);
SEVCHK(status,NULL);
}
if(VALID_DB_REQ(chix4->type)){
status = ca_add_event(DBR_FLOAT, chix4, EVENT_ROUTINE, 0xaaaaaaaa, &monix);
SEVCHK(status,NULL);
SEVCHK(ca_clear_event(monix),NULL);
}
if(VALID_DB_REQ(chix3->type)){
status = ca_add_event(DBR_FLOAT, chix3, EVENT_ROUTINE, 0xaaaaaaaa, &monix);
SEVCHK(status,NULL);
status = ca_add_event(DBR_FLOAT, chix3, write_event, 0xaaaaaaaa, &monix);
SEVCHK(status,NULL);
}
pfloat = (float *) malloc(sizeof(float)*NUM);
pdouble = (double *) malloc(sizeof(double)*NUM);
pgrfloat = (struct dbr_gr_float *) malloc(sizeof(*pgrfloat)*NUM);
if(VALID_DB_REQ(chix1->type))
if(pfloat)
for(i=0;i<NUM;i++){
for(j=0;j<NUM;j++)
sprintf(&pstring[j][0],"%d",j+100);
SEVCHK(ca_array_put(DBR_STRING,NUM,chix1,pstring),NULL)
SEVCHK(ca_array_get(DBR_FLOAT,NUM,chix1,pfloat),NULL)
SEVCHK(ca_array_get(DBR_DOUBLE,NUM,chix1,pdouble),NULL)
SEVCHK(ca_array_get(DBR_GR_FLOAT,NUM,chix1,pgrfloat),NULL)
}
else
abort();
SEVCHK(ca_pend_io(4.0),NULL);
# ifdef VMS
lib$show_timer();
# endif
for(i=0;i<NUM;i++){
printf("Float value Returned from put/get %f\n",pfloat[i]);
printf("Double value Returned from put/get %f\n",pdouble[i]);
printf("GR Float value Returned from put/get %f\n",pgrfloat[i].value);
}
for(i=0;i<10;i++)
ca_get_callback(DBR_GR_FLOAT, chix1, ca_test_event, NULL);
printf("-- Put/Gets done- waiting for Events --\n");
status = ca_pend_event(60.0);
if(status == ECA_TIMEOUT){
free(ptr);
free(pfloat);
free(pgrfloat);
exit();
}else
SEVCHK(status,NULL);
}
void null_event()
{
static int i;
if(i++>1000){
printf("1000 occured\n");
i = 0;
}
}
void write_event(args)
struct event_handler_args args;
{
float a = *(float *) args.dbr;
a += 10.1;
SEVCHK(ca_rput(args.chid, &a),"write fail in event");
SEVCHK(ca_flush_io(),NULL);
/*
#ifdef vxWorks
taskDelay(20);
lib$show_timer();
#endif
*/
pfloat = &ptr->value;
for (i = 0; i < NUM; i++)
printf("Value Returned from build %f\n", pfloat[i]);
#ifdef VMS
lib$init_timer();
#endif
/*
* verify we dont jam up on many uninterrupted
* solicitations
*/
printf("Performing multiple get test...");
#ifdef UNIX
fflush(stdout);
#endif
{
struct dbr_ctrl_float temp;
for(i=0; i<10000; i++){
SEVCHK(ca_get(DBR_GR_FLOAT, chix4, &temp),NULL);
}
SEVCHK(ca_pend_io(200.0), NULL);
}
printf("done.\n");
/*
* verify we can add many monitors at once
*/
printf("Performing multiple monitor test...");
#ifdef UNIX
fflush(stdout);
#endif
{
evid mid[1000];
float temp;
for(i=0; i<NELEMENTS(mid); i++){
SEVCHK(ca_add_event(DBR_GR_FLOAT, chix4, null_event,
0x55555555, &mid[i]),NULL);
}
/*
* force all of the monitors requests to
* complete
*/
SEVCHK(ca_get(DBR_FLOAT,chix4,&temp),NULL);
SEVCHK(ca_pend_io(100.0),NULL);
for(i=0; i<NELEMENTS(mid); i++){
SEVCHK(ca_clear_event(mid[i]),NULL);
}
/*
* force all of the clear event requests to
* complete
*/
SEVCHK(ca_get(DBR_FLOAT,chix4,&temp),NULL);
SEVCHK(ca_pend_io(100.0),NULL);
}
printf("done.\n");
if (VALID_DB_REQ(chix4->type)) {
status = ca_add_event(DBR_FLOAT, chix4, EVENT_ROUTINE, 0xaaaaaaaa, &monix);
SEVCHK(status, NULL);
SEVCHK(ca_clear_event(monix), NULL);
status = ca_add_event(DBR_FLOAT, chix4, EVENT_ROUTINE, 0xaaaaaaaa, &monix);
SEVCHK(status, NULL);
}
if (VALID_DB_REQ(chix4->type)) {
status = ca_add_event(DBR_FLOAT, chix4, EVENT_ROUTINE, 0xaaaaaaaa, &monix);
SEVCHK(status, NULL);
SEVCHK(ca_clear_event(monix), NULL);
}
if (VALID_DB_REQ(chix3->type)) {
status = ca_add_event(DBR_FLOAT, chix3, EVENT_ROUTINE, 0xaaaaaaaa, &monix);
SEVCHK(status, NULL);
status = ca_add_event(DBR_FLOAT, chix3, write_event, 0xaaaaaaaa, &monix);
SEVCHK(status, NULL);
}
pfloat = (float *) malloc(sizeof(float) * NUM);
pdouble = (double *) malloc(sizeof(double) * NUM);
pgrfloat = (struct dbr_gr_float *) malloc(sizeof(*pgrfloat) * NUM);
if (VALID_DB_REQ(chix1->type))
if (pfloat)
for (i = 0; i < NUM; i++) {
for (j = 0; j < NUM; j++)
sprintf(&pstring[j][0], "%d", j + 100);
SEVCHK(ca_array_put(DBR_STRING, NUM, chix1, pstring), NULL)
SEVCHK(ca_array_get(DBR_FLOAT, NUM, chix1, pfloat), NULL)
SEVCHK(ca_array_get(DBR_DOUBLE, NUM, chix1, pdouble), NULL)
SEVCHK(ca_array_get(DBR_GR_FLOAT, NUM, chix1, pgrfloat), NULL)
}
else
abort();
SEVCHK(ca_pend_io(4.0), NULL);
#ifdef VMS
lib$show_timer();
#endif
for (i = 0; i < NUM; i++) {
printf("Float value Returned from put/get %f\n", pfloat[i]);
printf("Double value Returned from put/get %f\n", pdouble[i]);
printf("GR Float value Returned from put/get %f\n", pgrfloat[i].value);
}
for (i = 0; i < 10; i++)
ca_get_callback(DBR_GR_FLOAT, chix1, ca_test_event, NULL);
printf("-- Put/Gets done- waiting for Events --\n");
status = ca_pend_event(60.0);
if (status == ECA_TIMEOUT) {
free(ptr);
free(pfloat);
free(pgrfloat);
exit();
} else
SEVCHK(status, NULL);
}
void conn(args)
struct connection_handler_args args;
void
null_event()
{
static int i;
if (i++ > 1000) {
printf("1000 occured\n");
i = 0;
}
}
void
write_event(args)
struct event_handler_args args;
{
float a = *(float *) args.dbr;
a += 10.1;
SEVCHK(ca_rput(args.chid, &a), "write fail in event");
SEVCHK(ca_flush_io(), NULL);
/*
* #ifdef vxWorks taskDelay(20); #endif
*/
}
void
conn(args)
struct connection_handler_args args;
{
if(args.op == CA_OP_CONN_UP)
printf("Channel On Line [%s]\n", ca_name(args.chid));
else if(args.op == CA_OP_CONN_DOWN)
printf("Channel Off Line [%s]\n", ca_name(args.chid));
else
printf("Ukn conn ev\n");
if (args.op == CA_OP_CONN_UP)
printf("Channel On Line [%s]\n", ca_name(args.chid));
else if (args.op == CA_OP_CONN_DOWN)
printf("Channel Off Line [%s]\n", ca_name(args.chid));
else
printf("Ukn conn ev\n");
}