caput.c

/*************************************************************************\
* Copyright (c) 2002 The University of Chicago, as Operator of Argonne
* National Laboratory.
* Copyright (c) 2002 The Regents of the University of California, as
* Operator of Los Alamos National Laboratory.
* This file is distributed subject to a Software License Agreement found
* in the file LICENSE that is included with this distribution. 
\*************************************************************************/
/*
 * Modification Log:
 * -----------------
 * .01  04-28-03        bkc     Fix the problem with -w sec option
 */

#ifdef _WIN32
#include "windows.h"
#endif

#include <dbDefs.h>
#include <cadef.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#ifdef EZCA
    #include <ezca.h>
#endif

#include "EzcaScan.h"
#include "epicsGetopt.h"
extern chandata **chanlist,*pchandata;
#if !defined(_WIN32) && !defined(LINUX) && !defined(SOLARIS)
extern double atof();
int getopt();
#endif
int print_caget(void);
int no_elements(char *);
int data_array(char *,char **);

extern char *optarg;
extern int optind;
int TERSE=0,ENUM_V=1,FORMAT=0,VECTOR=0,INITIAL=0;

char *pvName,f_fmt[15],e_fmt[15];
int noName,req_no=1,rtype,type[1],count[1];
void *value;
char *buff;

int main(argc,argv)
int argc;
char **argv;
{
int c,found,ret,i,len,first=1;
char **pv,**dataArray;
short *sv;
dbr_char_t *cv;
int *iv;
float *fv;
double *dv;
char *tempValue,*tempName,**pvNames;
int noName,noData;

CA.PEND_IOLIST_TIME = 1.;

if (argc < 3) {
	printf("\nUsage:  caput [-t] [-s] [-w sec] [-m] [-z] [--] pv_name  pv_value\n\n");
	printf("This command writes a value or array of values to a channel.\n");
	printf("It can also write an array of single values to an array of channels.\n\n");
        printf("        -t   Terse mode, only the successfully put value is returned\n");
	printf("        -s   pv_value entered as database defined enumeral string\n");
        printf("    -w sec   Wait time, specifies bigger time out, default is 1 second\n");
        printf("  	-m   this option specified the input value string is \n");
	printf("             a comma separated values for a waveform record \n");
        printf("  	-z   zero remaining undefined waveform record fields with 0\n");
        printf("   pv_name   requested database process variable name\n");
        printf("             (multiple PV names must be seperated by comma no space)\n");
        printf("   pv_value  new value to put to IOC\n");
        printf("             (multiple PV values must be seperated by comma no space)\n\n");
	printf("  Examples:    caput  pv_name  pv_value\n");
	printf("               caput  pv_name1,pv_name2   pv_value1,pv_value2\n\n");
	printf("               caput -m  wf_name  v1,v2,v3,...\n");
	printf("               caput -z  wf_name  v1,v2,v3,...\n");
	printf("               caput -z  wf_name  0\n\n");

	exit(1);
	}

while ((c = getopt(argc-2,argv,"tsmzw:")) != -1) 
        switch (c) {
        case 't':
                TERSE = 1;
		break;
        case 's':
                ENUM_V = 0;
		break;
        case 'm':
                VECTOR = 1;
		break;
        case 'z':
                VECTOR = 1;
		INITIAL = 1;
		break;
        case 'w':
                CA.PEND_IOLIST_TIME = atof(optarg);
                if (CA.PEND_IOLIST_TIME < 1.) CA.PEND_IOLIST_TIME = 1.;
                break;
        }

/*
if (argv[optind] == NULL || strlen(argv[optind]) > NAME_LENGTH) {
	printf(" %s is an invalid channel name\n", argv[optind]);
	return(1);     
	}
*/

	first = optind;

	ca_task_initialize();

	noName = 1;
	pvName = argv[first];

/* check for pv list */
	noName = no_elements(argv[first]);

	len = strlen(argv[first]);
	tempName = (char *)calloc(1,len+1);
	strcpy(tempName,argv[first]);

	if (noName > 1 ) {
		pvNames = (char **)calloc(noName,sizeof(char *));
		noName = data_array(tempName,pvNames);

	noData = no_elements(argv[first+1]);

	if (noData > 1 ) {
	dataArray = (char **)calloc(noData,sizeof(char *));
	if (VECTOR==1 || noData == noName) {
	len = strlen(argv[first+1]);
	tempValue = (char *)calloc(1,len+1);
	strcpy(tempValue,argv[first+1]);

		if (argc == first+2) 
		req_no = data_array(tempValue,dataArray);
		else { printf("Syntax error in data elements!! \n");
			return(-1); }
	} else {
		 printf("Error: Inconsistant data elements entered!! \n");
			return(-1); 
	}

	found = Ezca_getTypeCount(noName,pvNames,type,count);

	buff = (char *)calloc(noData,MAX_STRING_SIZE);
	value = (void *)buff;
	pv = (char **)calloc(noName,sizeof(char *));
	for (i=0;i<req_no;i++) pv[i] = buff+i*MAX_STRING_SIZE;

	ret = Ezca_getArray(noName,pvNames,DBR_STRING,1,buff);
	if (!TERSE) {
	for (i=0;i<req_no;i++) printf("Old : %-30s %s\n",pvNames[i],pv[i]);
		}

	for (i=0;i<req_no;i++) 
		strcpy(buff+i*MAX_STRING_SIZE, dataArray[i]);

	ret = Ezca_putArray(noName,pvNames,DBR_STRING,1,buff);

	if (ret == 0) {
	ret = Ezca_getArray(noName,pvNames,DBR_STRING,1,buff);
	for (i=0;i<req_no;i++) {
		if (!TERSE) printf("New : %-30s %s\n",pvNames[i],pv[i]);
		  else printf("%s\n",pv[i]);
		}
	}

	free(pv);
	free(tempValue);
	free(pvNames);
	goto end_task;

	} else {
		 printf("Error: Inconsistant data elements entered!! \n");
			return(-1); 
		}
	}

	found = Ezca_getTypeCount(noName,&pvName,type,count);

	if (found != 0) {
		printf(" %s --- Invalid channel name\n",pvName);
		return(-1);
	} 
	
	rtype = type[0];
	req_no = argc-first-1;
	if (req_no > count[0]) req_no = count[0];

	buff = (char *)calloc(count[0],MAX_STRING_SIZE);
	value = (void *)buff;

/* get old value */

	ret = Ezca_getArray(noName,&pvName,rtype,count[0],value);


/* put value as default except -s for DBR_ENUM */

	dataArray = (char **)calloc(count[0],sizeof(char *));
	if (VECTOR==1) {
		if (argc == first+2) 
		req_no = data_array(argv[first+1],dataArray);
		else { printf("Syntax error in data elements!! \n");
			return(-1); }
	} else {
		for (i=0;i<req_no;i++)
		dataArray[i] = argv[i+first+1];
	}

	if (!TERSE) {
	if (req_no > 1) printf("Old : %s %d ",pvName,req_no);
		else printf("Old : %-30s ",pvName);
	print_caget();
	}

        switch(rtype) {
	case DBR_ENUM: 
		if (ENUM_V == 0) {
		if (INITIAL == 1) {
			for (i=0;i<count[0];i++) 
			strcpy(buff+i*MAX_STRING_SIZE," ");;
		}
		for (i=0;i<req_no;i++) 
		strcpy(buff+i*MAX_STRING_SIZE, dataArray[i]);
		ret = Ezca_putArray(noName,&pvName,DBR_STRING,count[0],buff);
		break;
		} 
		else {
			sv = (short *)value;
			if (INITIAL == 1)  for (i=0;i<count[0];i++) sv[i]=0;
			for (i=0;i<req_no;i++) sv[i] = atoi(dataArray[i]);
			ret = Ezca_putArray(noName,&pvName,rtype,count[0],sv);
		}
		break;

	case DBR_CHAR: /* put char array */
		cv = (dbr_char_t *)value;
		if (INITIAL == 1) for (i=0;i<count[0];i++) cv[i] = 0;
		for (i=0;i<req_no;i++)  cv[i] = atoi(dataArray[i]);
		ret = Ezca_putArray(noName,&pvName,rtype,count[0],cv);
		break;
	
	case DBR_INT: /* put short/int array */
		sv = (short *)value;
		if (INITIAL == 1) for (i=0;i<count[0];i++) sv[i] = 0;
                for (i=0;i<req_no;i++)  sv[i] = atoi(dataArray[i]);
		ret = Ezca_putArray(noName,&pvName,rtype,count[0],sv);
		break;
	
	case DBR_LONG: /* put long array */
		iv = (int *)value;
		if (INITIAL == 1) for (i=0;i<count[0];i++) iv[i] = 0;
                for (i=0;i<req_no;i++)  iv[i] = atoi(dataArray[i]);
		ret = Ezca_putArray(noName,&pvName,rtype,count[0],iv);
		break;
	
	case DBR_FLOAT: /* put float array */
		fv = (float *)buff;
		if (INITIAL == 1) for (i=0;i<count[0];i++) fv[i] = 0.;
                for (i=0;i<req_no;i++)  fv[i] = atof(dataArray[i]);
		ret = Ezca_putArray(noName,&pvName,rtype,count[0],fv);
		break;
	
	case DBR_DOUBLE: /* put double array */
		dv = (double *)buff;
		if (INITIAL == 1) for (i=0;i<count[0];i++) dv[i] = 0.;
                for (i=0;i<req_no;i++)  dv[i] = atof(dataArray[i]);
		ret = Ezca_putArray(noName,&pvName,rtype,count[0],dv);
		break;

	default: /* put as string */
		if (INITIAL == 1) {
			for (i=0;i<count[0];i++) 
			strcpy(buff+i*MAX_STRING_SIZE," ");;
		}
		for (i=0;i<req_no;i++) 
		strcpy(buff+i*MAX_STRING_SIZE, dataArray[i]);
		ret = Ezca_putArray(noName,&pvName,DBR_STRING,count[0],buff);
		break;
	}

		
/*get new value */

	if (ret == 0 ) {
	value = (void *)buff;
	ret = Ezca_getArray(noName,&pvName,rtype,count[0],value);

	if (!TERSE) {
	  if (req_no > 1) printf("New : %s %d ",pvName,req_no);
	  else printf("New : %-30s ",pvName);
	}
	print_caget();
	} 

end_task:
	ca_task_exit();

	free(dataArray);
	free(tempName);
	free(buff);
	return(0);
}


int print_caget(void)
{
int i;
char **pv;
short *sv;
dbr_char_t *cv;
int *iv;
float *fv;
double *dv;

		switch (rtype) {
		case DBR_INT:  /* DBR_SHORT */
			sv = (short *)value;
			for (i=0;i<req_no;i++) {
			if (FORMAT==1) printf(f_fmt,(float)sv[i]);
			else if (FORMAT==2) printf(e_fmt,(float)sv[i]);
			else 	
			 	printf("%d ",sv[i]);
			}
		     break;
		case DBR_CHAR: /* DBR_UCHAR */ 
			cv = (dbr_char_t *)value;
			for (i=0;i<req_no;i++) {
			if (FORMAT==1) printf(f_fmt,(float)cv[i]);
			else if (FORMAT==2) printf(e_fmt,(float)cv[i]);
			else 	
			 	printf("%d ",cv[i]);
			}
		     break;
		case DBR_ENUM: 
			sv = (short *)value;
			if (count[0] > 1) {
			for (i=0;i<req_no;i++) {
			if (FORMAT==1) printf(f_fmt,(float)sv[i]);
			else if (FORMAT==2) printf(e_fmt,(float)sv[i]);
			else 	
				printf("%d ",sv[i]);
				}
			} else {
			if (ENUM_V == 1) printf("%d ",sv[0]);
			else if (strlen(value) > 0 ) 
				printf("%s ",(char *)value);
			else	printf("%d ",sv[0]);
			}
		     break;
		case DBR_FLOAT:
			fv = (float *)value;
			for (i=0;i<req_no;i++) {
			if (FORMAT==1) printf(f_fmt,fv[i]);
			else if (FORMAT==2) printf(e_fmt,fv[i]);
			else 	printf("%g ",fv[i]);
			}
		     break;
		case DBR_DOUBLE:
			dv = (double *)value;
			for (i=0;i<req_no;i++) {
			if (FORMAT==1) printf(f_fmt,dv[i]);
			else if (FORMAT==2) printf(e_fmt,dv[i]);
			else 	printf("%g ",dv[i]);
			}
		     break;
		case DBR_STRING:
		pv = (char **)calloc(req_no,sizeof(char *));
		for (i=0;i<req_no;i++) pv[i]=buff+i*MAX_STRING_SIZE;
			for (i=0;i<req_no;i++) {
			if (FORMAT==1) printf(f_fmt,atof(pv[i]));
			else if (FORMAT==2) printf(e_fmt,atof(pv[i]));
			else 	
			 	printf("%s ",pv[i]);
			}
			free(pv);
		     break;
		
		default:
		case DBR_LONG: 
			iv = (int *)value;
			for (i=0;i<req_no;i++) {
			if (FORMAT==1) printf(f_fmt,(float)iv[i]);
			else if (FORMAT==2) printf(e_fmt,(float)iv[i]);
			else 	
			 	printf("%d ",iv[i]);
			}
		     break;
		}

	printf("\n");
	return(0);
}

int no_elements(stringVar)
char *stringVar;
{
int i,j=0,len;
char *s1;
        len = strlen(stringVar);
        s1 = stringVar;

        for (i=0;i<len;i++) {
        if (*(s1+i) == 44) j++;    /* ',' */
        }
        return(j+1);
}


int data_array(stringVar,strarray)
char *stringVar;
char **strarray;
{
int i,j=0,c,len;
char *s1;
	len = strlen(stringVar);
	s1 = stringVar;
	strarray[0] = s1;

	for (i=0;i<len;i++) {
	c = *(s1+i);
	if (*(s1+i) == 44) {  /* ',' = 44,*/ 
		j++;
		strarray[j] = s1+i+1;
		*(s1+i)='\0';
		}
	}

	return(j+1);
}