std/rec/test: add asTest

src/std/rec/test/Makefile

@@ -25,6 +25,16 @@ testHarness_SRCS += arrayOpTest.c
 TESTFILES += ../arrayOpTest.db
 TESTS += arrayOpTest
 
+TARGETS += $(COMMON_DIR)/asTestIoc.dbd
+asTestIoc_DBD += base.dbd
+asTestIoc_DBD += asTest.dbd
+TESTPROD_HOST += asTest
+asTest_SRCS += asTest.c
+asTest_SRCS += asTestIoc_registerRecordDeviceDriver.cpp
+#testHarness_SRCS += asTest.c
+TESTFILES += ../asTest.db
+TESTS += asTest
+
 TARGETS += $(COMMON_DIR)/analogMonitorTest.dbd
 analogMonitorTest_DBD += base.dbd
 TESTPROD_HOST += analogMonitorTest

src/std/rec/test/asTest.c

@@ -0,0 +1,217 @@
+/*************************************************************************\
+* Copyright (c) 2015 Brookhaven Science Assoc. as operator of Brookhaven
+*               National Laboratory.
+* EPICS BASE is distributed subject to a Software License Agreement found
+* in file LICENSE that is included with this distribution.
+ \*************************************************************************/
+
+/*
+ *  Author: Michael Davidsaver <mdavidsaver@bnl.gov>
+ *
+ * Test the hooks that autosave uses during initialization
+ */
+
+#include "string.h"
+
+#include "epicsString.h"
+#include "dbUnitTest.h"
+#include "epicsThread.h"
+#include "iocInit.h"
+#include "dbBase.h"
+#include "link.h"
+#include "recSup.h"
+#include "dbAccess.h"
+#include "dbConvert.h"
+#include "dbStaticLib.h"
+#include "registry.h"
+#include "dbStaticLib.h"
+#include "dbStaticPvt.h"
+#include "osiFileName.h"
+#include "initHooks.h"
+#include "devSup.h"
+#include "errlog.h"
+
+#include "aoRecord.h"
+#include "waveformRecord.h"
+
+#include "testMain.h"
+
+#include "epicsExport.h"
+
+void asTestIoc_registerRecordDeviceDriver(struct dbBase *);
+
+static unsigned iran;
+
+static void hookPass0(initHookState state)
+{
+    DBENTRY entry;
+    if(state!=initHookAfterInitDevSup)
+        return;
+    testDiag("initHookAfterInitDevSup");
+
+    dbInitEntry(pdbbase, &entry);
+
+    /* rec0.VAL is initially 1, set it to 2 */
+    if(dbFindRecord(&entry, "rec0.VAL")==0) {
+        aoRecord *prec = entry.precnode->precord;
+        testOk(prec->val==1, "VAL %d==1 (initial value from .db)", (int)prec->val);
+        testOk1(dbPutString(&entry, "2")==0);
+        testOk(prec->val==2, "VAL %d==2", (int)prec->val);
+    } else {
+        testFail("Missing rec0");
+        testSkip(1, "missing record");
+    }
+
+    /* rec0.OUT is initially "rec0.DISV", set it to "rec0.SEVR" */
+    if(dbFindRecord(&entry, "rec0.OUT")==0) {
+        aoRecord *prec = entry.precnode->precord;
+        if(prec->out.type==PV_LINK)
+            testOk(strcmp(prec->out.value.pv_link.pvname,"rec0.DISV")==0,
+                   "%s==rec0.DISV (initial value from .db)",
+                   prec->out.value.pv_link.pvname);
+        else
+            testFail("Wrong link type");
+
+        testOk1(dbPutString(&entry, "rec0.SEVR")==0);
+    } else{
+        testFail("Missing rec0");
+        testSkip(1, "missing record");
+    }
+
+    /* can't restore array field in pass0 */
+
+    dbFinishEntry(&entry);
+}
+
+static long initRec0(aoRecord *prec)
+{
+    DBLINK *plink = &prec->out;
+    testDiag("init_record(%s)", prec->name);
+    testOk(prec->val==2, "VAL %d==2 (pass0 value)", (int)prec->val);
+    prec->val = 3;
+    testOk(prec->val==3, "VAL %d==3", (int)prec->val);
+
+    testOk1(plink->type==DB_LINK);
+    if(plink->type==DB_LINK)
+        testOk(strcmp(plink->value.pv_link.pvname,"rec0.SEVR")==0,
+               "%s==rec0.SEVR (pass0 value)", plink->value.pv_link.pvname);
+    else
+        testFail("Wrong link type");
+
+    iran |= 1;
+    return 2; /* we set .VAL, so don't use RVAL */
+}
+
+static long initRec1(waveformRecord *prec)
+{
+    testDiag("init_record(%s)", prec->name);
+    testOk(prec->nord==0, "NORD %d==0", (int)prec->nord);
+    iran |= 2;
+    return 0;
+}
+
+static double values[] = {1,2,3,4,5};
+
+static void hookPass1(initHookState state)
+{
+    DBENTRY entry;
+    DBADDR  addr;
+    if(state!=initHookAfterInitDatabase)
+        return;
+    testDiag("initHookAfterInitDatabase");
+
+    dbInitEntry(pdbbase, &entry);
+
+    if(dbFindRecord(&entry, "rec0.VAL")==0) {
+        aoRecord *prec = entry.precnode->precord;
+        testOk(prec->val==3, "VAL %d==3 (init_record value)", (int)prec->val);
+        testOk1(dbPutString(&entry, "4")==0);
+        testOk(prec->val==4, "VAL %d==4", (int)prec->val);
+    } else{
+        testFail("Missing rec0");
+        testSkip(1, "missing record");
+    }
+
+    /* Can't restore links in pass 1 */
+
+    if(dbNameToAddr("rec1.VAL", &addr)) {
+        testFail("missing rec1");
+        testSkip(3, "missing record");
+    } else {
+        struct rset *prset = dbGetRset(&addr);
+        dbfType ftype = addr.field_type;
+        long count=-1, offset=-1, maxcount = addr.no_elements;
+        testOk1(prset && prset->get_array_info && prset->put_array_info);
+        testOk1((*prset->get_array_info)(&addr, &count, &offset)==0);
+        /* count is ignored */
+        testOk1((*dbPutConvertRoutine[DBF_DOUBLE][ftype])(&addr, values, NELEMENTS(values), maxcount,offset)==0);
+        testOk1((*prset->put_array_info)(&addr, NELEMENTS(values))==0);
+    }
+
+    dbFinishEntry(&entry);
+}
+
+static void testRestore(void)
+{
+    aoRecord *rec0;
+    waveformRecord *rec1;
+    testDiag("test Restore");
+
+    initHookRegister(hookPass0);
+    initHookRegister(hookPass1);
+
+    testdbPrepare();
+
+    testdbReadDatabase("asTestIoc.dbd", NULL, NULL);
+
+    asTestIoc_registerRecordDeviceDriver(pdbbase);
+
+    testdbReadDatabase("asTest.db", NULL, NULL);
+
+    rec0 = (aoRecord*)testdbRecordPtr("rec0");
+    rec1 = (waveformRecord*)testdbRecordPtr("rec1");
+
+    //eltc(0);
+    testIocInitOk();
+    //eltc(1);
+
+    testDiag("Post initialization");
+
+    testOk1(iran==3);
+
+    testOk1(rec0->val==4);
+    testOk1(rec1->nord==5);
+    {
+        double *buf = rec1->bptr;
+        testOk(buf[0]==1, "buf[0]  %f==1", buf[0]);
+        testOk1(buf[1]==2);
+        testOk1(buf[2]==3);
+        testOk1(buf[3]==4);
+        testOk1(buf[4]==5);
+    }
+
+    testIocShutdownOk();
+
+    testdbCleanup();
+}
+
+MAIN(asTest)
+{
+    testPlan(25);
+    testRestore();
+    return testDone();
+}
+
+struct dset6 {
+    dset common;
+    DEVSUPFUN proc;
+    DEVSUPFUN linconv;
+};
+
+static long noop() {return 0;}
+
+static struct dset6 devAOasTest = { {6, NULL, NULL, (DEVSUPFUN)initRec0, NULL}, (DEVSUPFUN)noop, NULL};
+static struct dset6 devWFasTest = { {6, NULL, NULL, (DEVSUPFUN)initRec1, NULL}, (DEVSUPFUN)noop, NULL};
+
+epicsExportAddress(dset, devAOasTest);
+epicsExportAddress(dset, devWFasTest);

src/std/rec/test/asTest.db

@@ -0,0 +1,11 @@
+record(ao, "rec0") {
+  field(DTYP, "asTest")
+  field(VAL, "1")
+  field(OUT, "rec0.DISV")
+}
+
+record(waveform, "rec1") {
+  field(DTYP, "asTest")
+  field(FTVL, "DOUBLE")
+  field(NELM, "5")
+}

src/std/rec/test/asTest.dbd

@@ -0,0 +1,2 @@
+device(ao, CONSTANT, devAOasTest, "asTest")
+device(waveform, CONSTANT, devWFasTest, "asTest")