Initial revision

1994-02-14 13:05:42 +00:00
parent 7cadbe5cfd
commit 6991308d5f
1 changed files with 122 additions and 0 deletions
--- a/src/as/asDbLib.c
+++ b/src/as/asDbLib.c
@@ -0,0 +1,122 @@
+/* share/src/as/dbAsLib.c	*/
+/* share/src/as $Id$ */
+/*
+ *      Author:  Marty Kraimer
+ *      Date:    02-11-94
+ *
+ *      Experimental Physics and Industrial Control System (EPICS)
+ *
+ *      Copyright 1991, the Regents of the University of California,
+ *      and the University of Chicago Board of Governors.
+ *
+ *      This software was produced under  U.S. Government contracts:
+ *      (W-7405-ENG-36) at the Los Alamos National Laboratory,
+ *      and (W-31-109-ENG-38) at Argonne National Laboratory.
+ *
+ *      Initial development by:
+ *              The Controls and Automation Group (AT-8)
+ *              Ground Test Accelerator
+ *              Accelerator Technology Division
+ *              Los Alamos National Laboratory
+ *
+ *      Co-developed with
+ *              The Controls and Computing Group
+ *              Accelerator Systems Division
+ *              Advanced Photon Source
+ *              Argonne National Laboratory
+ *
+ * Modification Log:
+ * -----------------
+ * .01  02-11-94	mrk	Initial Implementation
+ */
+#include <stdlib.h>
+#include <stddef.h>
+#include <stdio.h>
+#include <string.h>
+#include <dbDefs.h>
+#include <dbStaticLib.h>
+#include <asLib.h>
+
+extern struct dbBase *pdbBase;
+static FILE *stream;
+
+#define BUF_SIZE 100
+static char *my_buffer;
+static char *my_buffer_ptr=NULL;
+
+static int my_yyinput(char *buf, int max_size)
+{
+    int	l,n;
+    
+    if(!my_buffer_ptr || *my_buffer_ptr==0) {
+	if(fgets(my_buffer,BUF_SIZE,stream)==NULL) return(0);
+printf("INPUT: %s",my_buffer);
+	my_buffer_ptr = my_buffer;
+    }
+    l = strlen(my_buffer_ptr);
+    n = (l<=max_size ? l : max_size);
+    memcpy(buf,my_buffer_ptr,n);
+    my_buffer_ptr += n;
+    return(n);
+}
+
+static long asDbEnterRecords(void)
+{
+    DBENTRY		dbentry;
+    DBENTRY		*pdbentry=&dbentry;
+    long		status;
+    struct dbCommon	*precord;
+
+    dbInitEntry(pdbBase,pdbentry);
+    status = dbFirstRecdes(pdbentry);
+    while(!status) {
+	status = dbFirstRecord(pdbentry);
+	while(!status) {
+	    precord = pdbentry->precnode->precord;
+	    if(!precord->asp) {
+		status = asAddMember((ASMEMBERPVT *)&precord->asp,precord->asg);
+		if(status) errMessage(status,"asDbEnterRecords:asAddMember");
+		asPutMemberPvt(precord->asp,precord);
+	    }
+	    status = dbNextRecord(pdbentry);
+	}
+	status = dbNextRecdes(pdbentry);
+    }
+    dbFinishEntry(pdbentry);
+    return(0);
+}
+
+int asInit(char *filename)
+{
+    long status;
+
+    my_buffer = malloc(BUF_SIZE);
+    if(!my_buffer) {
+	errMessage(0,"asInit malloc failure");
+	return(-1);
+    }
+    stream = fopen(filename,"r");
+    if(!stream) {
+	errMessage(0,"asInit failure");
+	return(-1);
+    }
+    status = asInitialize(my_yyinput);
+    if(fclose(stream)==EOF) errMessage(0,"asInit fclose failure");
+    free((void *)my_buffer);
+    asDbEnterRecords();
+    return(0);
+}
+
+void static myMemberCallback(ASMEMBERPVT memPvt)
+{
+    struct dbCommon	*precord;
+
+    precord = asGetMemberPvt(memPvt);
+    if(precord) printf(" Record:%s",precord->name);
+}
+
+int asdbdump()
+{
+    asDump(myMemberCallback,NULL);
+    return(0);
+}