diff options
Diffstat (limited to 'xpa/stest.c')
| -rw-r--r-- | xpa/stest.c | 729 |
1 files changed, 729 insertions, 0 deletions
diff --git a/xpa/stest.c b/xpa/stest.c new file mode 100644 index 0000000..afceb89 --- /dev/null +++ b/xpa/stest.c @@ -0,0 +1,729 @@ +/* + * Copyright (c) 1999-2003 Smithsonian Astrophysical Observatory + */ + +/* + * + * stest -- server test for xpa + * + */ +#include <xpap.h> + +#ifndef BUILD_WITH_XT +#if HAVE_XT +#undef HAVE_XT +#endif +#endif + +#if HAVE_XT +#include <X11/Intrinsic.h> +#include <X11/StringDefs.h> +#endif + +#define MAX_FPS 10 + +extern char *optarg; +extern int optind; + +XPA xpa1, xpa1a, xpa2, xpa3; +int quiet=0; +int dowait=0; +int dofill=0; +int dosave=1; +int doone=0; +int domyfree=0; +int doatexit=0; +int n=0; +int please_exit=0; +size_t save_bytes=-1; +char *save_buf=NULL; + +char *mode=""; +char name[SZ_LINE]; +char xclass[SZ_LINE]; + +#ifdef ANSI_FUNC +void myfree(void *buf) +#else +void myfree(buf) + void *buf; +#endif +{ + fprintf(stderr, "myfree calling xfree(%p)\n", buf); + xfree(buf); +} + +#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]; + char xtemplate[SZ_LINE]; + char *names[MAX_FPS]; + char *bufs[MAX_FPS]; + char *errs[MAX_FPS]; + size_t lens[MAX_FPS]; + int sendbuf=0; + int got; + int i; + int ip; + + /* set the free routine */ + if( domyfree ) XPASetFree(xpa, myfree, NULL); + + /* introduce ourselves */ + if( !quiet ){ + fprintf(stdout, "SEND_CB #%d: %s:%s %s (%s)\n", + n++, xpa_class(xpa), xpa_name(xpa), xpa_method(xpa), s); + } + + /* process special paramlist tokens */ + if( paramlist && *paramlist ){ + ip = 0; + word(paramlist, xtemplate, &ip); + if( !quiet ) + fprintf(stdout, "\tparamlist: %s\n", paramlist); + if( !strncmp(paramlist, "buf", 3) ){ + sendbuf=1; + } + else if( !strcmp(paramlist, "free") ){ + if( !quiet ) + fprintf(stdout, "Freeing xpa struct\n"); + XPAFree(xpa); + return(0); + } + else if( !strcmp(paramlist, "exit") ){ + if( !quiet ) + fprintf(stdout, "Exiting\n"); + if( doatexit){ + please_exit = 1; + } else { + XPAFree(xpa1); + if( !doone ){ + XPAFree(xpa1a); + XPAFree(xpa2); + XPAFree(xpa3); + } + } + } + else if( !strcmp(paramlist, "Exit") ){ + if( !quiet ) + fprintf(stdout, "Exiting immediately\n"); + exit(0); + } + else if( !strncmp(paramlist, "error", 5) ){ + if( !quiet ) + fprintf(stdout, "\treturning error: %s\n", ¶mlist[6]); + *len = 0; + *buf = NULL; + if( strlen(paramlist) > 6 ) + XPAError(xpa, ¶mlist[6]); + else + XPAError(xpa, "intentional error from client"); + return(-1); + } + else if( !strcmp(paramlist, "wait") || !strcmp(paramlist, "version") ){ + fprintf(stdout, "Press <CR> to continue ..."); + fgets(tbuf, SZ_LINE, stdin); + } + else if( !strcmp(paramlist, "poll") ){ +repoll: + fprintf(stdout, "Press 'q' to quit ..."); + got = XPAPoll (10000, 1); + fprintf(stdout, " XPAPoll returns %d ...", got); + fgets(tbuf, SZ_LINE, stdin); + if( *tbuf != 'q' ) + goto repoll; + } + else if( !strncmp(paramlist, "fork ", 5) ){ +#if HAVE_MINGW32==0 + if( strlen(paramlist) > 5 ){ + fprintf(stdout, "fork command: %s\n", ¶mlist[5]); + /* child forks a command and exits */ + if(!(fork())){ + system(¶mlist[5]); + /* should call _exit but this tests avoidance of atexit routine */ + exit(0); + } + } +#else + fprintf(stderr, "ERROR: fork() not available in mingw\n"); + exit(1); +#endif + } + else 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( !quiet && (lens[i] > 0) ){ + fprintf(stdout, "contents (%lu bytes):\n", (unsigned long)lens[i]); + fwrite(bufs[i], sizeof(char), lens[i], stdout); + } + if( !quiet ) + fprintf(stdout, "\n"); + } + else{ + write(fileno(stdout), errs[i], strlen(errs[i])); + } + if( bufs[i] ) + xfree(bufs[i]); + if( names[i] ) + xfree(names[i]); + if( errs[i] ) + xfree(errs[i]); + } + } + } + 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, + "class: %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 %lu bytes to client\n", + (unsigned long)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 %lu bytes to xpa handler\n", + (unsigned long)save_bytes); + } + } + if( !quiet ){ + fprintf(stdout, "SEND_CB complete\n"); + } + else{ + fprintf(stdout, "."); + } + 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 cbuf[SZ_LINE]; + char *errs[1]; + int i; + int ip; + int got; + int xwait; + + /* set the free routine */ + if( domyfree ) XPASetFree(xpa, myfree, NULL); + + if( !quiet ){ + fprintf(stdout, "RECEIVE_CB #%d: %s:%s %s (%s)\n", + n++, xpa_class(xpa), xpa_name(xpa), xpa_method(xpa), s); + } + /* 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( !strcmp(paramlist, "exit") ){ + if( !quiet ) + fprintf(stdout, "Exiting\n"); + if( doatexit){ + please_exit = 1; + } else { + XPAFree(xpa1); + if( !doone ){ + XPAFree(xpa1a); + XPAFree(xpa2); + XPAFree(xpa3); + } + } + } + else if( !strcmp(paramlist, "Exit") ){ + if( !quiet ) + fprintf(stdout, "Exiting immediately\n"); + exit(0); + } + else if( !strncmp(paramlist, "error", 5) ){ + if( !quiet ) + fprintf(stdout, "Processing error: %s\n", ¶mlist[6]); + if( strlen(paramlist) > 6 ) + XPAError(xpa, ¶mlist[6]); + else + XPAError(xpa, "intentional error from client"); + return(-1); + } + else if( !strcmp(paramlist, "wait") ){ + fprintf(stdout, "Press <CR> to continue ..."); + fgets(tbuf, SZ_LINE, stdin); + } + else if( !strcmp(paramlist, "poll") ){ +repoll: + fprintf(stdout, "Press 'q' to quit ..."); + got = XPAPoll (10000, 1); + fprintf(stdout, " ... XPAPoll returns %d ...", got); + fgets(tbuf, SZ_LINE, stdin); + if( *tbuf != 'q' ) + goto repoll; + } + else if( !strncmp(paramlist, "fork ", 5) ){ +#if HAVE_MINGW32==0 + if( strlen(paramlist) > 5 ){ + fprintf(stdout, "fork command: %s\n", ¶mlist[5]); + /* child forks a command and exits */ + if(!(fork())){ + system(¶mlist[5]); + /* should call _exit but this tests avoidance of atexit routine */ + exit(0); + } + } +#else + fprintf(stderr, "ERROR: fork() not available in mingw\n"); + exit(1); +#endif + } + 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]); + } + 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) && dofill ){ + 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(cbuf, SZ_LINE, stdin); + xwait--; + } + i = save_bytes; + save_bytes += got; + if( dosave ){ + 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, "\tcallback read %lu bytes\n", + (unsigned long)save_bytes); + } + else{ + if( !quiet ){ + fprintf(stdout, "\tenter callback with buf: %lu bytes\n", + (unsigned long)len); + } + save_bytes = len; + save_buf = (char *)xmalloc(len); + memcpy(save_buf, buf, len); + } + if( !quiet ){ + fprintf(stdout, "RECEIVE_CB complete\n"); + } + else{ + fprintf(stdout, "."); + } + 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( !quiet && (lens[i] > 0) ){ + fprintf(stdout, "contents (%lu bytes):\n", + (unsigned long)lens[i]); + fwrite(bufs[i], sizeof(char), lens[i], stdout); + } + if( !quiet ) + fprintf(stdout, "\n"); + } + else{ + write(fileno(stdout), errs[i], strlen(errs[i])); + } + if( bufs[i] ) + xfree(bufs[i]); + if( names[i] ) + xfree(names[i]); + if( errs[i] ) + xfree(errs[i]); + } + } + } + if( !quiet ){ + fprintf(stdout, "INFO_CB complete\n"); + } + else{ + fprintf(stdout, "."); + } + fflush(stdout); + fflush(stderr); + return(0); +} + +#ifdef ANSI_FUNC +int +main (int argc, char **argv) +#else +main(argc, argv) + int argc; + char **argv; +#endif +{ +#if HAVE_XT + Widget top; + XtAppContext appcontext; +#endif + char *proxy=NULL; + char tbuf[SZ_LINE]; + char tbuf2[SZ_LINE]; + char cmd[SZ_LINE]; + int c; + int got=0; + int x=0; + int delay=0; + +#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, "1ad:f:mqrRp:suwxX")) != -1){ + switch(c){ + case '1': + doone = 1; + break; + case 'a': + mode = "ack=false"; + break; + case 'd': + delay = atoi(optarg); + break; + case 'f': + snprintf(cmd, SZ_LINE, "%s %s &\n", argv[0], optarg); + break; + case 'm': + domyfree = 1; + break; + case 'q': + quiet = 1; + break; + case 'p': + proxy = optarg; + break; + case 'r': + mode = "fillbuf=false"; + break; + case 'R': + mode = "fillbuf=false"; + dofill = 1; + dosave = 0; + break; + case 's': + x = 0; + break; + case 'u': + mode = "buf=false"; + break; + case 'w': + dowait++; + break; + case 'x': + doatexit=1; + break; + case 'X': + x = 1; + break; + } + } + + if( optind >= argc ){ + strcpy(name, "xpa"); + } + else{ + strcpy(name, argv[optind]); + } + strcpy(xclass, name); + cluc(xclass); + + if( doatexit ){ +#if HAVE_ATEXIT + XPAAtExit(); +#else + fprintf(stderr, "ERROR: atexit not available\n"); + exit(1); +#endif + } + + if( x ){ +#if HAVE_XT + top = XtAppInitialize(&appcontext, "Server", NULL, 0, + &argc, argv, NULL, NULL, 0); + XtVaSetValues(top, XtNwidth, (XtArgVal)10, XtNheight, (XtArgVal)10, + XtNmappedWhenManaged, (XtArgVal)False, NULL); +#else + fprintf(stderr, "Xt is not available ...\n"); + got = 1; + goto done; +#endif + } + + strcpy(tbuf, name); + snprintf(tbuf2, SZ_LINE, "help for %s", tbuf); + xpa1 = XPANew(xclass, tbuf, tbuf2, + send_cb, (void *)"send1", mode, + receive_cb, (void *)"receive1", mode); + if( xpa1 == NULL ){ + fprintf(stderr, "ERROR: could not init xpa1\n"); + } + else{ + fprintf(stdout, "%s using method: %s\n", xpa_name(xpa1), xpa_method(xpa1)); + } + + if( !doone ){ + snprintf(tbuf, SZ_LINE, "%s1", name); + snprintf(tbuf2, SZ_LINE, "help for %s", tbuf); + xpa1a = XPANew(xclass, tbuf, tbuf2, + send_cb, (void *)"send1a", mode, + receive_cb, (void *)"receive1a", mode); + if( xpa1a == NULL ){ + fprintf(stderr, "ERROR: could not init xpa1a\n"); + } + else{ + fprintf(stdout, "%s using method: %s\n", + xpa_name(xpa1a), xpa_method(xpa1a)); + } + + snprintf(tbuf, SZ_LINE, "c_%s", name); + xpa2 = XPACmdNew(xclass, tbuf); + if( xpa2 == NULL ){ + fprintf(stderr, "ERROR: could not init xpa2\n"); + } + else{ + XPACmdAdd(xpa2, "cmd2", "and help for cmd2", + send_cb, (void *)"cmd2", mode, + receive_cb, (void *)"cmd2", mode); + XPACmdAdd(xpa2, "cmd1 xx yy", "help for cmd1 xx yy", + send_cb, (void *)"cmd1 xx yy", mode, + receive_cb, (void *)"cmd1 xx yy", mode); + XPACmdAdd(xpa2, "cmd1 xx", "help for cmd1 xx", + send_cb, (void *)"cmd1 xx", mode, + receive_cb, (void *)"cmd1 xx", mode); + XPACmdAdd(xpa2, "cmd1", NULL, + send_cb, (void *)"cmd1", mode, + receive_cb, (void *)"cmd1", mode); + fprintf(stdout, "%s using method: %s\n", + xpa_name(xpa2), xpa_method(xpa2)); + } + + snprintf(tbuf, SZ_LINE, "i_%s", name); + xpa3 = XPAInfoNew(xclass, tbuf, info_cb, (void *)"info1", mode); + if( xpa3 == NULL ){ + fprintf(stderr, "ERROR: could not init xpa3\n"); + } + else{ + fprintf(stdout, "%s using method: %s\n", xpa_name(xpa3), xpa_method(xpa3)); + } + } + + if( *cmd != '\0' ){ + fprintf(stdout, "starting bkgd process: %s", cmd); + system(cmd); + } + + /* delay if necessary */ + if( delay ){ + fprintf(stdout, "starting delay of %d seconds ...", delay); + XPASleep(delay*1000); + fprintf(stdout, " done\n"); + } + fflush(stdout); + fflush(stderr); + + /* connect to proxy, if necessary */ + if( proxy ){ + if( XPARemote(xpa1, proxy, "+", "proxy=true") < 0 ){ + fprintf(stderr, "ERROR: could not connect to proxy: %s\n", proxy); + } + } + + if( x ){ +#if HAVE_XT + fprintf(stdout, "\nEntering Xt loop ...\n"); + XPAXtAddInput(appcontext, NULL); + XtRealizeWidget(top); + XtAppMainLoop(appcontext); +#else + fprintf(stderr, "Xt is not available ...\n"); + got = 1; + goto done; +#endif + } + else{ + fprintf(stdout, "\nEntering select loop ...\n"); + if( !doatexit ){ + XPAMainLoop(); + } else { + while( !please_exit ) + if( !XPAPoll(-1, 100) ) please_exit=1; + } + goto done; + } + +done: + if( !doatexit ){ + XPAFree(xpa1); + if( !doone ){ + XPAFree(xpa1a); + XPAFree(xpa2); + XPAFree(xpa3); + } + } + + /* make valgrind happy */ + XPACleanup(); + if( save_buf ) xfree(save_buf); + exit(got); +} |