]> jspc29.x-matter.uni-frankfurt.de Git - daqdata.git/commitdiff
*** empty log message ***
authorhades <hades>
Thu, 5 Apr 2001 13:51:19 +0000 (13:51 +0000)
committerhades <hades>
Thu, 5 Apr 2001 13:51:19 +0000 (13:51 +0000)
12 files changed:
allParam/ca/server/Makefile
allParam/ca/server/arrayDest.cc [new file with mode: 0644]
allParam/ca/server/arrayDest.h [new file with mode: 0644]
allParam/ca/server/paramBlobRecord.cc
allParam/ca/server/paramFilenameRecord.cc
allParam/ca/server/paramIntRecord.cc
allParam/ca/server/paramIntRecord.h
allParam/ca/server/paramRecord.cc
allParam/ca/server/paramRecord.h
allParam/ca/server/paramRecordSet.cc
allParam/ca/server/paramRecordSet.h
allParam/ca/server/paramStringRecord.cc

index fbd7d6144eb0901a25a1e845e946ec609625b6c1..42e3628fbacd93c9f6f0f647efeb33225c9127ef 100644 (file)
@@ -11,7 +11,7 @@ LOADLIBES = -L$(EPICS_BASE)/lib/$(HOST_ARCH) -lcas -lgdd -lca -lCom
 
 # Objects
 
-OBJS = record.o paramRecord.o paramIntRecord.o paramStringRecord.o \
+OBJS = record.o paramRecord.o arrayDest.o paramIntRecord.o paramStringRecord.o \
   paramFilenameRecord.o paramBlobRecord.o paramRecordSet.o paramServer.o
 
 ###########
@@ -49,6 +49,7 @@ paramRecordSet.o: paramRecordSet.cc paramRecordSet.h \
   paramRecord.h record.h
 
 record.o : record.cc record.h
+arrayDest.o : arrayDest.cc arrayDest.h
 paramRecord.o: paramRecord.cc paramRecord.h record.h
 paramIntRecord.o: paramIntRecord.cc paramIntRecord.h paramRecord.h record.h
 paramStringRecord.o: paramStringRecord.cc paramStringRecord.h paramRecord.h \
diff --git a/allParam/ca/server/arrayDest.cc b/allParam/ca/server/arrayDest.cc
new file mode 100644 (file)
index 0000000..2147a25
--- /dev/null
@@ -0,0 +1,21 @@
+#define _POSIX_C_SOURCE 199509L
+
+#include <aitTypes.h>
+
+#include "arrayDest.h"
+
+void ArrayDestructor::run(void *todelete) {
+       aitUint32 *pd = (aitUint32 *) todelete;
+       delete [] pd;
+}
+
+void ArrayIntDestructor::run(void *todelete) {
+       aitUint32 *pd = (aitUint32 *) todelete;
+       delete [] pd;
+}
+
+void ArrayStringDestructor::run(void *todelete) {
+       aitString *pd = (aitString *) todelete;
+       delete [] pd;
+}
+
diff --git a/allParam/ca/server/arrayDest.h b/allParam/ca/server/arrayDest.h
new file mode 100644 (file)
index 0000000..bee9b9b
--- /dev/null
@@ -0,0 +1,19 @@
+#ifndef ARRAYDEST_H
+#define ARRAYDEST_H
+
+#include <gdd.h>
+
+class ArrayDestructor : public gddDestructor {
+       virtual void run(void *);
+};
+
+class ArrayIntDestructor : public ArrayDestructor {
+       virtual void run(void *);
+};
+
+class ArrayStringDestructor : public ArrayDestructor {
+       virtual void run(void *);
+};
+
+#endif
+
index f663c662a0740f75d5abc1982203901da045c345..8203dda1e69ddbcc961f28f83dbc62db4b4fe055 100644 (file)
@@ -14,6 +14,9 @@ ParamBlobRecord::ParamBlobRecord(caServer& cas, const Param *p, const char *rn,
 {
        size_t size;
        FILE *tmp;
+
+       pDest = new ArrayIntDestructor;
+
        if(Param_getBlob(param, name, idx, &size, &tmp) == 0) {
                index = (unsigned int) ((size - 1) / sizeof(aitUint32)) + 2;
                if (index > EPICS_MAX_INDEX) {
@@ -89,7 +92,6 @@ caStatus ParamBlobRecord::scan()
        FILE *blob;
        size_t size;
        int retVal;
-       ArrayDestructor *pDest = new ArrayDestructor;
 
        caServer *pCAS = this->getCAS();
 
@@ -116,8 +118,6 @@ caStatus ParamBlobRecord::scan()
                this->postEvent (select, *val);
        }
 
-       delete pDest;
-
        return S_cas_success;
 }
 
index 62a51b9682163e5f4f6bf85f0f382609e2d9897a..b4e27b3cb472eade873472c4d09086b9d083df6a 100644 (file)
@@ -12,6 +12,8 @@ ParamFilenameRecord::ParamFilenameRecord(caServer& cas, const Param *p, const ch
        int rows;
        char *tmp[PARAM_MAX_ARRAY_LEN];
 
+       pDest = new ArrayStringDestructor;
+
        for (int i = 0 ; i < PARAM_MAX_ARRAY_LEN ; i++) {
                tmp[i] = new char[PARAM_MAX_VALUE_LEN];
        }
@@ -107,7 +109,6 @@ caStatus ParamFilenameRecord::scan()
        caServer *pCAS = this->getCAS();
        int pretVal;
        int rows;
-       ArrayDestructor *pDest = new ArrayDestructor;
 
        for (int i = 0 ; i < PARAM_MAX_ARRAY_LEN ; i++) {
                ourValue[i] = new char[PARAM_MAX_VALUE_LEN];
@@ -147,8 +148,6 @@ caStatus ParamFilenameRecord::scan()
                this->postEvent (select, *val);
        }
 
-       delete pDest;
-
        return retVal;
 }
 
index fb8bb8851a90c76520be810affa1f6a34b43fa6a..bbb077aa329ec65cba38ddae4742fd09eee8ee5d 100644 (file)
@@ -12,6 +12,8 @@ ParamIntRecord::ParamIntRecord(caServer& cas, const Param *p, const char *rn, co
        int rows;
        unsigned long int tmp[PARAM_MAX_ARRAY_LEN];
 
+       pDest = new ArrayIntDestructor;
+
        if(Param_getIntArray(param, name, idx, PARAM_MAX_ARRAY_LEN, &rows, tmp) == 0) {
                if ((rows == 0) || (rows == 1)) {
                        index = 1;
@@ -92,7 +94,6 @@ caStatus ParamIntRecord::scan()
        caServer *pCAS = this->getCAS();
        int rows;
        int retVal;
-       ArrayDestructor *pDest = new ArrayDestructor;
 
        retVal = Param_getIntArray(param, name, idx, PARAM_MAX_ARRAY_LEN, &rows, ourValue);
        if((retVal != 0) || (rows == 0)) {
@@ -126,8 +127,6 @@ caStatus ParamIntRecord::scan()
                this->postEvent (select, *val);
        }
 
-       delete pDest;
-
        return S_cas_success;
 }
 
index 518378d7ff80bce48827a72b1b4d9e20cb7023fb..381460040fa890364b572e2c0bbaf9e683dba485 100644 (file)
@@ -2,6 +2,7 @@
 #define PARAMINTRECORD_H
 
 #include "paramRecord.h"
+#include "arrayDest.h"
 
 class ParamIntRecord : public ParamRecord {
   private:
index 7b073789214b3fb599ad1b7c316af68c59e1e242..e229d9d8d47b85ddea9e05b4a63b145ea566235d 100644 (file)
@@ -8,11 +8,6 @@ extern "C" {
 
 #include "paramRecord.h"
 
-void ArrayDestructor::run(void *todelete) {
-       aitString *pd = (aitString *) todelete;
-       delete [] pd;
-}
-
 ParamRecord::ParamRecord(caServer& cas, const Param *p, const char *rn, const char *u) :
   Record(cas, rn, u, aitEnumString), param(p)
 {
@@ -25,8 +20,7 @@ ParamRecord::ParamRecord(caServer& cas, const Param *p, const char *rn, const ch
        strcpy(buf1, "");
        strcpy(buf2, "");
        strcpy(buf3, "");
-       sscanf(pPVName, "HAD:P%c:%[^:]:%[^:]:%[^:]", &tmp, buf1, buf2, buf3);
-       if(strcmp(buf3, "") == 0) {
+       if(sscanf(pPVName, "HAD:P%c:%[^:]:%[^:]:%[^:]", &tmp, buf1, buf2, buf3) != 4) {
                strcpy(name, buf1);
                strcpy(idx, buf2);
        } else {
@@ -45,6 +39,7 @@ ParamRecord::ParamRecord(caServer& cas, const Param *p, const char *rn, const ch
 
 ParamRecord::~ParamRecord()
 {
+       delete pDest;
 }
 
 const char *ParamRecord::getPVName()
index d595cc5ee49739321309c3219568597584fa8732..5a37f56416ac64bb7b12d3a7b620029c266ee134 100644 (file)
@@ -8,13 +8,11 @@ extern "C" {
 }
 
 #include "record.h"
-
-class ArrayDestructor : public gddDestructor {
-       virtual void run(void *);
-};
+#include "arrayDest.h"
 
 class ParamRecord : public Record {
   protected:
+       ArrayDestructor *pDest;
        const Param *param;
        char pPVName[PARAM_MAX_VALUE_LEN];
        char name[PARAM_MAX_VALUE_LEN];
index ad1e7222a0610c63ae2b03858005242831b5054d..c68504884cd62826dbca7139eae1a8b5d1e4d89b 100644 (file)
@@ -75,10 +75,6 @@ pvExistReturn ParamRecordSet::pvExistTest(const casCtx &ctx, const char *pPVName
 
        if(strncmp(pPVName, "HAD:P", strlen("HAD:P")) == 0) {
                if (sscanf(pPVName, "HAD:P%*c:%[^:]:%[^:]:%[^:]", buf1, buf2, buf3) != 3) {
-#if 0
-               sscanf(pPVName, "HAD:P%*c:%[^:]:%[^:]:%[^:]", buf1, buf2, buf3);
-               if (strcmp(buf3, "") == 0) {
-#endif
                        setup = NULL;
                } else {
                        setup = buf1;
@@ -124,10 +120,6 @@ pvCreateReturn ParamRecordSet::createPV(const casCtx &ctx, const char *pPVName)
 
        if(strncmp(pPVName, "HAD:P", strlen("HAD:P")) == 0) {
                if(sscanf(pPVName, "HAD:P%c:%[^:]:%[^:]:%[^:]", &type, buf1, buf2, buf3) != 4) {
-#if 0
-               sscanf(pPVName, "HAD:P%c:%[^:]:%[^:]:%[^:]", &type, buf1, buf2, buf3);
-               if (strcmp(buf3, "") == 0) {
-#endif
                        setup = NULL;
                } else {
                        setup = buf1;
index cf72ddf97eb2d5588153ed121182a95be2428128..16830a1d174a02c5ad910f3919e9094a0301c1aa 100644 (file)
@@ -9,7 +9,7 @@ extern "C" {
 
 #include "paramRecord.h"
 
-#define MAX_PARAM_SRC 16
+#define MAX_PARAM_SRC 128
 #define MAX_NUM_PV 1024
 
 class ParamRecordSet : public caServer {
index ab0cc66dbc2526e971fc665452e74c345ea3e277..fe40569b744448826b7d793bc9b0fb9f8b6c3ab6 100644 (file)
@@ -12,6 +12,8 @@ ParamStringRecord::ParamStringRecord(caServer& cas, const Param *p, const char *
        int rows;
        char *tmp[PARAM_MAX_ARRAY_LEN];
 
+       pDest = new ArrayStringDestructor;
+
        for (int i = 0 ; i < PARAM_MAX_ARRAY_LEN ; i++) {
                tmp[i] = new char[PARAM_MAX_VALUE_LEN];
        }
@@ -108,7 +110,6 @@ caStatus ParamStringRecord::scan()
        caServer *pCAS = this->getCAS();
        int pretVal;
        int rows;
-       ArrayDestructor *pDest = new ArrayDestructor;
 
        for (int i = 0 ; i < PARAM_MAX_ARRAY_LEN ; i++) {
                ourValue[i] = new char[PARAM_MAX_VALUE_LEN];
@@ -133,7 +134,7 @@ caStatus ParamStringRecord::scan()
 
                val = new gddAtomic(gddAppType_value, aitEnumString, 1, index);
 
-               val->putRef(stringValue);
+               val->putRef(stringValue, pDest);
 
                retVal = S_casApp_success;
        }
@@ -142,18 +143,14 @@ caStatus ParamStringRecord::scan()
                delete [] ourValue[i];
        }
 
-#if 0
        val->setStat(epicsAlarmNone);
        val->setSevr(epicsSevNone);
-#endif
 
        if (this->interest == aitTrue && pCAS != NULL) {
                casEventMask select(pCAS->valueEventMask|pCAS->logEventMask|pCAS->alarmEventMask);
                this->postEvent (select, *val);
        }
 
-       delete pDest;
-
        return retVal;
 }