From 8400381e962498fdf7adbc19e7e518cb7e986b97 Mon Sep 17 00:00:00 2001
From: "Janet B. Anderson" <jba@aps.anl.gov>
Date: Tue, 14 May 1991 09:42:18 +0000
Subject: [PATCH] Initial revision

---
 src/dev/devWfTestAsyn.c | 122 ++++++++++++++++++++++++++++++++++++++++
 1 file changed, 122 insertions(+)
 create mode 100644 src/dev/devWfTestAsyn.c

diff --git a/src/dev/devWfTestAsyn.c b/src/dev/devWfTestAsyn.c
new file mode 100644
index 000000000..b6e381338
--- /dev/null
+++ b/src/dev/devWfTestAsyn.c
@@ -0,0 +1,122 @@
+/* devWfTestAsyn.c */
+/* share/src/dev $Id$ */
+
+/* devWfTestAsyn.c - Device Support Routines for testing asynchronous processing*/
+
+
+#include	<vxWorks.h>
+#include	<types.h>
+#include	<stdioLib.h>
+#include	<wdLib.h>
+
+#include	<alarm.h>
+#include	<dbDefs.h>
+#include	<dbAccess.h>
+#include	<devSup.h>
+#include	<link.h>
+#include	<waveformRecord.h>
+
+/* Create the dset for devWfTestAsyn */
+long init_record();
+long read_wf();
+struct {
+	long		number;
+	DEVSUPFUN	report;
+	DEVSUPFUN	init;
+	DEVSUPFUN	init_record;
+	DEVSUPFUN	get_ioint_info;
+	DEVSUPFUN	read_wf;
+	DEVSUPFUN	special_linconv;
+}devWfTestAsyn={
+	6,
+	NULL,
+	NULL,
+	init_record,
+	NULL,
+	read_wf,
+	NULL};
+
+/* control block for callback*/
+struct callback {
+	void (*callback)();
+	int priority;
+	struct dbAddr dbAddr;
+	WDOG_ID wd_id;
+	void (*process)();
+};
+void callbackRequest();
+
+static void myCallback(pcallback)
+    struct callback *pcallback;
+{
+    struct wfRecord *pwf=(struct wfRecord *)(pcallback->dbAddr.precord);
+
+    dbScanLock(pwf);
+    (pcallback->process)(&pcallback->dbAddr);
+    dbScanUnlock(pwf);
+}
+static long init_record(pwf,process)
+    struct wfRecord	*pwf;
+    void (*process)();
+{
+    char message[100];
+    struct callback *pcallback;
+
+    /* wf.inp must be a CONSTANT*/
+    switch (pwf->inp.type) {
+    case (CONSTANT) :
+	pcallback = (struct callback *)(calloc(1,sizeof(struct callback)));
+	pwf->dpvt = (caddr_t)pcallback;
+	pcallback->callback = myCallback;
+	pcallback->priority = priorityLow;
+	if(dbNameToAddr(pwf->name,&(pcallback->dbAddr))) {
+		logMsg("dbNameToAddr failed in init_record for devWfTestAsyn\n");
+		exit(1);
+	}
+	pcallback->wd_id = wdCreate();
+	pcallback->process = process;
+	pwf->nord = 0;
+	break;
+    default :
+	strcpy(message,pwf->name);
+	strcat(message,": devWfTestAsyn (init_record) Illegal INP field");
+	errMessage(S_db_badField,message);
+	return(S_db_badField);
+    }
+    return(0);
+}
+
+static long read_wf(pwf)
+    struct waveformRecord	*pwf;
+{
+    char message[100];
+    long status,options,nRequest;
+    struct callback *pcallback=(struct callback *)(pwf->dpvt);
+    int		wait_time;
+
+    /* wf.inp must be a CONSTANT*/
+    switch (pwf->inp.type) {
+    case (CONSTANT) :
+	if(pwf->pact) {
+		printf("%s Completed\n",pwf->name);
+		return(0); /* don`t convert*/
+	} else {
+		wait_time = (int)(pwf->disv * vxTicksPerSecond);
+		if(wait_time<=0) return(0);
+		printf("%s Starting asynchronous processing\n",pwf->name);
+		wdStart(pcallback->wd_id,wait_time,callbackRequest,pcallback);
+		return(1);
+	}
+    default :
+	if(pwf->nsev<VALID_ALARM) {
+		pwf->nsev = VALID_ALARM;
+		pwf->nsta = SOFT_ALARM;
+		if(pwf->stat!=SOFT_ALARM) {
+			strcpy(message,pwf->name);
+			strcat(message,": devWfTestAsyn (read_wf) Illegal INP field");
+			errMessage(S_db_badField,message);
+		}
+	}
+    }
+    return(0);
+}