Merge commit '6054f36bb658916bd231b9002efb94444e2871c8' as 'xpa'

1 files changed, 684 insertions, 0 deletions

diff --git a/xpa/ctest.c b/xpa/ctest.c
new file mode 100644
index 0000000..b4827d1
--- /dev/null
+++ b/xpa/ctest.c
@@ -0,0 +1,684 @@
+/*
+ *	Copyright (c) 1999-2003 Smithsonian Astrophysical Observatory
+ */
+
+/*
+ *
+ * ctest -- client test for xpa
+ *
+ */
+#include <xpap.h>
+
+extern char *optarg;
+extern int optind;
+
+int  quiet=0;
+int  dowait=0;
+int  n=0;
+int don=0;
+int  save_bytes=-1;
+int  exitonerror=0;
+char *save_buf=NULL;
+char *mode="";
+char name[SZ_LINE];
+
+#define MAX_FPS 4
+
+#ifdef ANSI_FUNC
+int 
+send_cb (void *client_data, void *call_data, char *paramlist,
+	 char **buf, size_t *len)
+#else
+int send_cb(client_data, call_data, paramlist, buf, len)
+     void *client_data;
+     void *call_data;
+     char *paramlist;
+     char **buf;
+     size_t *len;
+#endif
+{
+  char *s = (char *)client_data;
+  XPA xpa = (XPA)call_data;
+  char tbuf[SZ_LINE];
+  int sendbuf=0;
+
+  /* introduce ourselves */
+  if( !quiet ){
+    fprintf(stdout, "SEND_CB #%d: %s:%s (%s)\n",
+	    n++, xpa_class(xpa), xpa_name(xpa), s);
+  }
+
+  /* process special paramlist tokens */
+  if( paramlist && *paramlist ){
+    if( !quiet )
+      fprintf(stdout, "\tparamlist: %s\n", paramlist);
+    if( !strncmp(paramlist, "buf", 3) ){
+      sendbuf=1;
+    }
+    else if( !strncmp(paramlist, "error", 5) ){
+      if( !quiet )
+	fprintf(stdout, "\treturning error: %s\n", &paramlist[6]);
+      *len = 0;
+      *buf = NULL;
+      XPAError(xpa, &paramlist[6]);
+      return(-1);
+    }
+    else if( !strcmp(paramlist, "exit") ){
+      if( !quiet )
+	fprintf(stdout, "Exiting\n");
+      exit(0);
+    }
+    else if( !strcmp(paramlist, "wait") ){
+      fprintf(stdout, "Press <CR> to continue ...");
+      fgets(tbuf, SZ_LINE, stdin);
+    }
+  }
+  else if( dowait ){
+    fprintf(stdout, "Press <CR> to continue ...");
+    fgets(tbuf, SZ_LINE, stdin);
+  }
+
+  /* return information about this xpa */
+  if( !sendbuf ){
+    snprintf(tbuf, SZ_LINE,
+	  "nclass: %s\nname: %s\nmethod: %s\nsendian: %s\ncendian: %s\n",
+	  xpa_class(xpa), xpa_name(xpa), xpa_method(xpa),
+	  xpa_sendian(xpa), xpa_cendian(xpa));
+  
+    if( (xpa->send_mode & XPA_MODE_FILLBUF) ){
+      send(xpa_datafd(xpa), tbuf, strlen(tbuf), 0);
+      *len = 0;
+      *buf = NULL;
+      if( !quiet)
+	fprintf(stdout, "\tcallback writes %d bytes to client\n",
+		(int)strlen(tbuf));
+    }
+    /* return the buffer and let xpa transmit it */
+    else{
+      *len = strlen(tbuf);
+      *buf = (char *)xmalloc(*len);
+      memcpy(*buf, tbuf, *len);
+      if( !quiet)
+	fprintf(stdout, "\tcallback returns %d bytes to xpa handler\n",
+		(int)strlen(tbuf));
+    }
+  }
+  /* return the last buffer we were sent */
+  else{
+    if( (xpa->send_mode & XPA_MODE_FILLBUF) ){
+      send(xpa_datafd(xpa), save_buf, save_bytes, 0);
+      *len = 0;
+      *buf = NULL;
+      if( !quiet)
+	fprintf(stdout, "\tcallback writes %d bytes to client\n", save_bytes);
+    }
+    /* return the buffer and let xpa transmit it */
+    else{
+      *len = save_bytes;
+      *buf = (char *)xmalloc(*len);
+      memcpy(*buf, save_buf, *len);
+      if( !quiet)
+	fprintf(stdout, "\tcallback returns %d bytes to xpa handler\n",
+		save_bytes);
+    }
+  }
+  fflush(stdout);
+  fflush(stderr);
+  return(0);
+}
+
+#ifdef ANSI_FUNC
+int 
+receive_cb (void *client_data, void *call_data, char *paramlist,
+	    char *buf, size_t len)
+#else
+int receive_cb(client_data, call_data, paramlist, buf, len)
+     void *client_data;
+     void *call_data;
+     char *paramlist;
+     char *buf;
+     size_t len;
+#endif
+{
+  XPA xpa = (XPA)call_data;
+  char *s = (char *)client_data;
+  char tbuf[SZ_LINE];
+  char *errs[1];
+  int i;
+  int ip;
+  int got;
+  int xwait;
+
+  if( !quiet ){
+    fprintf(stdout, "RECEIVE_CB #%d: %s:%s (%s)\n",
+	    n++, xpa_class(xpa), xpa_name(xpa), s);
+  }
+  if( !quiet ){
+    fprintf(stdout, "\tbuf: %lu bytes\n", (unsigned long)len);
+  }
+
+  /* process param list */
+  if( paramlist && *paramlist ){
+    if( !quiet )
+      fprintf(stdout, "\tparamlist: %s\n", paramlist);
+    if( !strcmp(paramlist, "free") ){
+      if( !quiet )
+	fprintf(stdout, "Freeing xpa struct\n");
+      XPAFree(xpa);
+      return(0);
+    }
+    else if( !strncmp(paramlist, "error", 5) ){
+      if( !quiet )
+	fprintf(stdout, "Processing error: %s\n", &paramlist[6]);
+      XPAError(xpa, &paramlist[6]);
+      return(-1);
+    }
+    else if( !strcmp(paramlist, "exit") ){
+      if( !quiet )
+	fprintf(stdout, "Exiting\n");
+      exit(0);
+    }
+    else if( !strcmp(paramlist, "wait") ){
+      fprintf(stdout, "Press <CR> to continue ...");
+      fgets(tbuf, SZ_LINE, stdin);
+    }
+    else if( !strncmp(paramlist, "xpaset", 6) ){
+      ip = 0;
+      word(paramlist, tbuf, &ip);
+      if( word(paramlist, tbuf, &ip) ){
+	if( !quiet )
+	  fprintf(stdout, "calling XPASet(%s, \"%s\")\n",
+		  tbuf, &(paramlist[ip]));
+	got = XPASet(NULL, tbuf, &(paramlist[ip]), mode,
+		     paramlist, strlen(paramlist), NULL, errs, 1);
+	if( got == 0 ){
+	  if( !quiet )
+	    fprintf(stdout, "no XPA access points matched template %s\n",
+		    tbuf);
+	}
+	else if( errs[0] != NULL ){
+	  if( !quiet )
+	    fprintf(stdout, "Error on xpaset to %s: %s\n", tbuf, errs[0]);
+	  xfree(errs[0]);
+	  if( exitonerror )
+	    exit(1);
+	}
+	else{
+	  if( !quiet )
+	    fprintf(stdout, "XPASet to %s successful\n", tbuf);
+	}
+      }
+      return(0);
+    }
+  }
+  else if( dowait ){
+    fprintf(stdout, "Press <CR> to continue ...");
+    fgets(tbuf, SZ_LINE, stdin);
+  }
+
+  /* reset save buffer */
+  if( save_buf != NULL ){
+    xfree(save_buf);
+    save_buf = NULL;
+  }
+  save_bytes = 0;
+
+  xwait = dowait;
+  if( !(xpa->receive_mode & XPA_MODE_FILLBUF) ){
+    while( (got=recv(xpa_datafd(xpa), tbuf, SZ_LINE, 0)) >0 ){
+      if( xwait >0 ){
+	fprintf(stdout, "got %d bytes ... press <CR> to continue ...", got);
+	fgets(tbuf, SZ_LINE, stdin);
+	xwait--;
+      }
+      i = save_bytes;
+      save_bytes += got;
+      if( save_buf == NULL )
+	save_buf = (char *)xmalloc(save_bytes);
+      else
+	save_buf = (char *)xrealloc(save_buf, save_bytes);
+      memcpy(&save_buf[i], tbuf, got);
+    }
+    if( !quiet )
+      fprintf(stdout, "callback read %d bytes\n", save_bytes);
+  }
+  else{
+    save_bytes = len;
+    save_buf = (char *)xmalloc(len);
+    memcpy(save_buf, buf, len);
+  }
+  fflush(stdout);
+  fflush(stderr);
+  return(0);
+}
+
+#ifdef ANSI_FUNC
+int 
+info_cb (void *client_data, void *call_data, char *paramlist)
+#else
+int info_cb(client_data, call_data, paramlist)
+     void *client_data;
+     void *call_data;
+     char *paramlist;
+#endif
+{
+  XPA xpa = (XPA)call_data;
+  char *s = (char *)client_data;
+  char xtemplate[SZ_LINE];
+  char *names[MAX_FPS];
+  char *bufs[MAX_FPS];
+  char *errs[MAX_FPS];
+  size_t lens[MAX_FPS];
+  int i;
+  int ip;
+  int got;
+
+  if( !quiet ){
+    fprintf(stdout, "INFO_CB #%d: %s:%s (%s)\n",
+	    n++, xpa_class(xpa), xpa_name(xpa), s);
+  }
+
+  if( paramlist && *paramlist ){
+    if( !quiet )
+      fprintf(stdout, "\tparamlist: %s\n", paramlist);
+    ip = 0;
+    word(paramlist, xtemplate, &ip);
+    if( !strcmp(xtemplate, "xpaget") ){
+      word(paramlist, xtemplate, &ip);
+      got = XPAGet(xpa, xtemplate, &(paramlist[ip]), NULL,
+		   bufs, lens, names, errs, MAX_FPS);
+      if( !quiet )
+	fprintf(stdout, "XPAGet (%s) returned %d buffer(s)\n", xtemplate, got);
+      for(i=0; i<got; i++){
+	if( !quiet )
+	  fprintf(stdout, "\t%d: %s\n", i, names[i]);
+	if( errs[i] == NULL ){
+	  if( lens[i] > 0 ){
+	    fprintf(stdout, "contents (%lu bytes):\n", (unsigned long)lens[i]);
+	    write(fileno(stdout), bufs[i], lens[i]);
+	  }
+	  if( !quiet )
+	    fprintf(stdout, "\n");
+	}
+	else{
+	  write(fileno(stdout), errs[i], strlen(errs[i]));
+	  if( exitonerror )
+	    exit(1);
+	}
+	if( bufs[i] )
+	  xfree(bufs[i]);
+	if( names[i] )
+	  xfree(names[i]);
+	if( errs[i] )
+	  xfree(errs[i]);
+      }
+    }
+  }
+  fflush(stdout);
+  fflush(stderr);
+  return(0);
+}
+
+#ifdef ANSI_FUNC
+int 
+main (int argc, char **argv)
+#else
+int
+main(argc, argv)
+     int argc;
+     char **argv;
+#endif
+{
+  char *plist=NULL;
+  char *paramlist=NULL;
+  char *xtemplate="*:*";
+  char *smode=NULL;
+  char tbuf[SZ_LINE];
+  char name[SZ_LINE];
+  char cmd[SZ_LINE];
+  char fxpa[SZ_LINE];
+  char *names[MAX_FPS];
+  char *bufs[MAX_FPS];
+  char *dbufs[MAX_FPS];
+  char *errs[MAX_FPS];
+  char *buf=NULL;
+  int c;
+  size_t lens[MAX_FPS];
+  size_t dlens[MAX_FPS];
+  int i;
+  int got;
+  int maxbufs;
+  int j=0;
+  int loop=1;
+  int delay=0;
+  int get=1;
+  int set=0;
+  int info=0;
+  int access=0;
+  int pipe=0;
+  int tiny=0;
+  int doxpa = 0;
+  int xpaopen=0;
+  int wait=0;
+  XPA xpa=NULL;
+  XPA xpa1=NULL;
+  int fds[1];
+
+#if HAVE_MINGW32==0
+  setvbuf(stdout, NULL, _IONBF, 0);
+  setvbuf(stderr, NULL, _IONBF, 0);
+#endif
+
+  *cmd = '\0';
+  /* process switch arguments */
+  while ((c = getopt(argc, argv, "abd:ef:gil:m:nopqstwx:")) != -1){
+    switch(c){
+    case 'a':
+      get = 0;
+      set = 0;
+      info = 0;
+      access = 1;
+      break;
+    case 'b':
+      get = 1;
+      set = 1;
+      info = 0;
+      access = 0;
+      break;
+    case 'd':
+      delay = atoi(optarg);
+      break;
+    case 'e':
+      exitonerror++;
+      break;
+    case 'f':
+      snprintf(cmd, SZ_LINE, "stest %s &\n", optarg);
+      snprintf(fxpa, SZ_LINE, "%s1", optarg);
+      break;
+    case 'g':
+      get = 1;
+      set = 0;
+      info = 0;
+      access = 0;
+      break;
+    case 'i':
+      get = 0;
+      set = 0;
+      info = 1;
+      access = 0;
+      break;
+    case 'l':
+      loop = atoi(optarg);
+      break;
+    case 'm':
+      smode = xstrdup(optarg);
+      break;
+    case 'n':
+      don = 1;
+      break;
+    case 'o':
+      xpaopen = 1;
+      break;
+    case 'p':
+      pipe = 1;
+      fds[0] = fileno(stdout);
+      break;
+    case 'q':
+      quiet = 1;
+      break;
+    case 's':
+      get = 0;
+      set = 1;
+      info = 0;
+      access = 0;
+      break;
+    case 't':
+      tiny = 1;
+      break;
+    case 'w':
+      wait = 1;
+      break;
+    case 'x':
+      doxpa = 1;
+      strcpy(name, optarg);
+      break;
+    }
+  }
+  if( optind < argc ){
+    xtemplate = argv[optind];
+    optind++;
+  }
+
+  /* make up the paramlist */
+  plist = XPAArgvParamlist(argc, argv, optind);
+  if( !don )
+    paramlist = plist;
+  else
+    paramlist = (char *)xcalloc(strlen(plist)+SZ_LINE, sizeof(char));
+
+  /* for setting, make up a number of dbufs that we will send */
+  if( set ){
+    /* must be less than MAX_FPS */
+    maxbufs = 2;
+
+    dbufs[0] = (char *)xmalloc(SZ_LINE);
+    strcpy(dbufs[0], "this is a short string");
+    dlens[0] = strlen(dbufs[0]);
+
+    if( tiny )
+      dlens[1] = 256+1;
+    else
+      dlens[1] = 256*1000+1;
+    dbufs[1] = (char *)xmalloc(dlens[1]);
+    for(j=0, buf=dbufs[1]; j<dlens[1]; j++){
+      buf[j] = j%256;
+    }
+  }
+
+  /* background process initialization */
+  if( *cmd != '\0' ){
+    fprintf(stdout, "starting bkgd process: %s", cmd);
+    system(cmd);
+    for(i=0, n=0; i<5; i++){
+      if( (got=XPAAccess(NULL, fxpa, "g", NULL, names, errs, MAX_FPS)) ){
+	for(j=0; j<got; j++){
+	  if( names[j] ) xfree(names[j]);
+	  if( !errs[j] )
+	    n++;
+	  else
+	    xfree(errs[j]);
+	}
+	if( n ){
+	  fprintf(stdout, "process is started\n");
+	  break;
+	}
+      }
+      else{
+        XPASleep(1000);
+      }
+    }
+  }
+
+  /* start up an xpa server, if necessary */
+  if( doxpa ) {
+    snprintf(tbuf, SZ_LINE, "%s from ctest", name);
+    if( (xpa1 = XPANew("CLIENT", name, name,
+		       send_cb, tbuf, mode, receive_cb, tbuf, mode)) == NULL ){
+      fprintf(stderr, "ERROR: could not init client xpa: %s\n", name);
+    }
+    else{
+      fprintf(stdout, "%s using method: %s\n",
+	      xpa_name(xpa1), xpa_method(xpa1));
+    }
+  }
+
+  /* XPAOpen */
+  if( xpaopen ){
+    if( (xpa = XPAOpen(NULL)) == NULL ){
+      fprintf(stderr, "ERROR: could not open any xpa access points: %s\n",
+	      xtemplate);
+      exit(1);
+    }
+  }
+
+  /* iterate */
+  for(j=0; j<loop; j++){
+    if( loop > 1 ){
+      if( !quiet ){
+	fprintf(stdout, "CLIENT #%d: %s\n", j, xtemplate);
+	if( paramlist && *paramlist )
+	  fprintf(stdout, "\tparamlist: %s\n", paramlist);
+      }
+    }
+    /* make up paramlist, if necessary */
+    if( don )
+      snprintf(paramlist, SZ_LINE, "%s %d", plist, j);
+    /* XPAGet, XPAGetFd */
+    if( get ){
+      if( pipe ){
+	got = XPAGetFd(xpa, xtemplate, paramlist, smode,
+		       fds, names, errs, -MAX_FPS);
+      }
+      else{
+	got = XPAGet(xpa, xtemplate, paramlist, smode, 
+		     bufs, lens, names, errs, MAX_FPS);
+	for(i=0; i<got; i++){
+	  if( !quiet ){
+	    if( strcmp(paramlist, "buf") )
+	      fprintf(stdout, "\treceived from %s\n", names[i]);
+	    if( errs[i] == NULL ){
+	      if( lens[i] > 0 ){
+		write(fileno(stdout), bufs[i], lens[i]);
+	      }
+	      if( strcmp(paramlist, "buf") )
+		fprintf(stdout, "\n");
+	    }
+	    else{
+	      write(fileno(stdout), errs[i], strlen(errs[i]));
+	      if( exitonerror )
+		exit(1);
+	    }
+	  }
+	  if( bufs[i] )
+	    xfree(bufs[i]);
+	  if( names[i] )
+	    xfree(names[i]);
+	  if( errs[i] )
+	    xfree(errs[i]);
+	}
+      }
+    }
+    
+    /* XPASet, XPASetFd */
+    if( set ){
+      if( pipe ){
+	if( !quiet )
+	  fprintf(stdout, "\tsending data from stdin\n");
+	got =XPASetFd(xpa, xtemplate, paramlist, smode, 
+		      fileno(stdin), names, errs, MAX_FPS);
+      }
+      else{
+	got = XPASet(xpa, xtemplate, paramlist, smode,
+		     dbufs[j%maxbufs], dlens[j%maxbufs],
+		     names, errs, MAX_FPS);
+      }
+      for(i=0; i<got; i++){
+	if( !quiet )
+	  fprintf(stdout, "\tsent %lu bytes to %s\n",
+		  (unsigned long)dlens[j%maxbufs], names[i]);
+	if( errs[i] != NULL ){
+	  fprintf(stdout, "Error from server %s\n", names[i]);
+	  write(fileno(stdout), errs[i], strlen(errs[i]));
+	  if( exitonerror )
+	    exit(1);
+	}
+	if( names[i] )
+	  xfree(names[i]);
+	if( errs[i] )
+	  xfree(errs[i]);
+      }
+    }
+
+    /* XPAInfo */
+    if( info ){
+      got = XPAInfo(xpa, xtemplate, paramlist, smode, names, errs, MAX_FPS);
+      for(i=0; i<got; i++){
+	if( !quiet ){
+	  fprintf(stdout, "\tinfo from %s\n", names[i]);
+	  if( errs[i] != NULL ){
+	    write(fileno(stdout), errs[i], strlen(errs[i]));
+	    if( exitonerror )
+	      exit(1);
+	  }
+	}
+	if( names[i] )
+	  xfree(names[i]);
+	if( errs[i] )
+	  xfree(errs[i]);
+      }
+    }
+
+    /* XPAAccess */
+    if( access ){
+      got = XPAAccess(xpa, xtemplate, paramlist, smode, names, errs, MAX_FPS);
+      for(i=0; i<got; i++){
+	if( !quiet ){
+	  fprintf(stdout, "\taccess from %s\n", names[i]);
+	  if( errs[i] != NULL ){
+	    write(fileno(stdout), errs[i], strlen(errs[i]));
+	    if( exitonerror )
+	      exit(1);
+	  }
+	}
+	if( names[i] )
+	  xfree(names[i]);
+	if( errs[i] )
+	  xfree(errs[i]);
+      }
+    }
+
+    /* if we processed no access points, let`s hear about it */
+    if( got == 0 ){
+      fprintf(stderr, "XPA$ERROR: no xpa access points processed\n");
+    }
+    else{
+	if( !quiet ){
+	  if( strcmp(paramlist, "buf") )
+	    fprintf(stdout, "CLIENT #%d complete\n", j);
+	}
+	else{
+	  fprintf(stdout, ".");
+	  fflush(stdout);
+	}
+    }
+
+    /* wait for next iteration */
+    if( wait ){
+      fprintf(stdout, "Press <CR> to continue ...");
+      fgets(tbuf, SZ_LINE, stdin);
+    }
+
+    /* delay */
+    if( delay )
+      XPASleep(delay);
+  }
+
+  /* XPAOpen/XPAClose */
+  if( xpaopen ){
+    XPAClose(xpa);
+  }
+
+  /* free up space */
+  if( set ){
+    for(j=0; j<maxbufs; j++){
+      if( dbufs[j] )
+	xfree(dbufs[j]);
+    }
+  }
+  if(  plist ) xfree(plist);
+  if( don )    xfree(paramlist);
+  if( smode )  xfree(smode);
+  /* make valgrind happy */
+  XPACleanup();
+  exit(0);
+}