diff options
Diffstat (limited to 'xpa/xpaset.c')
| -rw-r--r-- | xpa/xpaset.c | 239 |
1 files changed, 239 insertions, 0 deletions
diff --git a/xpa/xpaset.c b/xpa/xpaset.c new file mode 100644 index 0000000..4e4d8c2 --- /dev/null +++ b/xpa/xpaset.c @@ -0,0 +1,239 @@ +/* + * Copyright (c) 1999-2003 Smithsonian Astrophysical Observatory + */ + +#include <xpap.h> + +extern char *optarg; +extern int optind; + +#ifdef ANSI_FUNC +void +usage (char *s) +#else +void usage(s) + char *s; +#endif +{ + fprintf(stderr, "\n"); + fprintf(stderr, "usage:\n"); + fprintf(stderr, " <data> | %s [-h] [-i nsinet] [-m method] [-n] [-p] [-s] [-t sval,lval] [-u users] <tmpl|host:port> [paramlist]\n", s); + fprintf(stderr, "\n"); + fprintf(stderr, "switches:\n"); + fprintf(stderr, "\t-h\tprint this message\n"); + fprintf(stderr, "\t-i\toverride XPA_NSINET environment variable\n"); + fprintf(stderr, "\t-m\toverride XPA_METHOD environment variable\n"); + fprintf(stderr, "\t-n\tdon't wait for message after server completes\n"); + fprintf(stderr, "\t-p\tdon't read (or send) buf data from stdin\n"); + fprintf(stderr, "\t-s\tserver mode\n"); + fprintf(stderr, "\t-t \toverride XPA_[SHORT,LONG]_TIMEOUT environment variables\n"); + fprintf(stderr, "\t-u\toverride XPA_NSUSERS environment variable\n"); + fprintf(stderr, "\t-v\tverify message to stdout\n"); + fprintf(stderr, "\t--version display version and exit\n"); + fprintf(stderr, "\n"); + fprintf(stderr, "Data will be sent to access points matching the template or host:port.\n"); + fprintf(stderr, "Templates are of the form [class:]name. Wildcards *,?,[] are accepted.\n"); + fprintf(stderr, "A set of qualifying parameters can be appended.\n"); + fprintf(stderr, "\n"); + fprintf(stderr, "examples:\n"); + fprintf(stderr, "\tcsh> xpaset ds9 fits foo.fits < foo.fits\n"); + fprintf(stderr, "\tcsh> echo \"stop\" | xpaset bynars:28571\n"); + fprintf(stderr, "\n(version: %s)\n", XPA_VERSION); + exit(1); +} + +#ifdef ANSI_FUNC +int +main (int argc, char **argv) +#else +int +main(argc, argv) + int argc; + char **argv; +#endif +{ + int i; + int c; + int got; + int lp; + int errcode=0; + int server=0; + int hmax=XPA_MAXHOSTS; + char *paramlist=NULL; + char *xtemplate=NULL; + char lbuf[SZ_LINE]; + char tbuf[SZ_LINE]; + char mode[SZ_LINE]; + char cmd[SZ_LINE]; + char *s; + char **errs=NULL; + char **names=NULL; + int fd; + XPA xpa=NULL; + + /* display version and exit, if necessary */ + if( (argc == 2) && !strcmp(argv[1], "--version") ){ + fprintf(stderr, "%s\n", XPA_VERSION); + exit(0); + } + + /* make sure we have enough arguments */ + if( argc < 2 ) + usage(argv[0]); + + /* start with no mode flag */ + *mode = '\0'; + + /* read from stdin */ + fd = fileno(stdin); + + /* we want the args in the same order in which they arrived, and + gnu getopt sometimes changes things without this */ + putenv("POSIXLY_CORRECT=true"); + + /* process switch arguments */ + while ((c = getopt(argc, argv, "hi:m:npst:u:vwW")) != -1){ + switch(c){ + case 'h': + usage(argv[0]); + case 'i': + snprintf(cmd, SZ_LINE, "XPA_NSINET=%s", optarg); + putenv(xstrdup(cmd)); + break; + case 'm': + snprintf(cmd, SZ_LINE, "XPA_METHOD=%s", optarg); + putenv(xstrdup(cmd)); + break; + case 'n': + if( *mode != '\0' ) + strcat(mode, ","); + strcat(mode, "ack=false"); + break; + case 'p': + fd = -1; + break; + case 's': + server = 1; + if( xpa == NULL ) + xpa = XPAOpen(NULL); + break; + case 't': + { + int xip=0; + char xbuf[SZ_LINE]; + newdtable(",;"); + if( word(optarg, xbuf, &xip) && *xbuf && (*xbuf != '*') ){ + snprintf(cmd, SZ_LINE, "XPA_SHORT_TIMEOUT=%s", xbuf); + putenv(xstrdup(cmd)); + } + if( word(optarg, xbuf, &xip) && *xbuf && (*xbuf != '*') ){ + snprintf(cmd, SZ_LINE, "XPA_LONG_TIMEOUT=%s", xbuf); + putenv(xstrdup(cmd)); + } + freedtable(); + } + break; + case 'u': + snprintf(cmd, SZ_LINE, "XPA_NSUSERS=%s", optarg); + putenv(xstrdup(cmd)); + break; + case 'v': + if( *mode != '\0' ) + strcat(mode, ","); + strcat(mode, "verify=true"); + break; + /* for backward compatibility with 1.0 */ + case 'w': + case 'W': + break; + } + } + + /* no explicit host:port specified, so we should have a name */ + if( optind >= argc ){ + /* in server mode, we can skip the host on the command line */ + if( !server ) + usage(argv[0]); + } + else{ + xtemplate = xstrdup(argv[optind]); + optind++; + } + + /* make the paramlist */ + paramlist = XPAArgvParamlist(argc, argv, optind); + + /* init variables for names and ports */ + if( (s=(char *)getenv("XPA_MAXHOSTS")) != NULL ) + hmax = atoi(s); + names = (char **)xcalloc(hmax, sizeof(char *)); + errs = (char **)xcalloc(hmax, sizeof(char *)); + +again: + /* if we are in server mode, we might have to read a line from stdin + to grab the template and paramlist */ + if( server && (xtemplate==NULL) ){ + /* read description of template and paramlist */ + if( fgets(lbuf, SZ_LINE, stdin) == NULL ) + exit(errcode); + if( (*lbuf == '#') || (*lbuf == '\n') ) + goto again; + lp = 0; + if( word(lbuf, tbuf, &lp) && !strcmp(tbuf, "xpaset") && + word(lbuf, tbuf, &lp) ){ + xtemplate = xstrdup(tbuf); + paramlist = xstrdup(&(lbuf[lp])); + nowhite(paramlist, paramlist); + } + else{ + fprintf(stderr, "XPA$ERROR invalid command: %s", lbuf); + exit(++errcode); + } + } + + /* process xpa requests */ + got = XPASetFd(xpa, xtemplate, paramlist, mode, fd, names, errs, hmax); + + /* process errors */ + if( got == 0 ){ + fprintf(stderr, "XPA$ERROR no 'xpaset' access points match template: %s\n", + xtemplate); + errcode++; + } + else{ + /* display errors and free up strings */ + for(i=0; i<got; i++){ + if( errs[i] != NULL ){ + fprintf(stderr, "%s", errs[i]); + xfree(errs[i]); + errcode++; + } + if( names[i] != NULL ) + xfree(names[i]); + } + } + + /* free the paramlist */ + if( paramlist!= NULL ){ + xfree(paramlist); + paramlist = NULL; + } + /* and the template */ + if( xtemplate != NULL ){ + xfree(xtemplate); + xtemplate = NULL; + } + + /* if we are in server mode, go back for more */ + if( server ) + goto again; + /* else exit */ + else{ + /* clean up */ + if( errs ) xfree(errs); + if( names ) xfree(names); + XPACleanup(); + exit(errcode); + } + return(0); +} |