1 /* @(#)svc_simple.c 2.2 88/08/01 4.0 RPCSRC */ 2 /* 3 * Sun RPC is a product of Sun Microsystems, Inc. and is provided for 4 * unrestricted use provided that this legend is included on all tape 5 * media and as a part of the software program in whole or part. Users 6 * may copy or modify Sun RPC without charge, but are not authorized 7 * to license or distribute it to anyone else except as part of a product or 8 * program developed by the user. 9 * 10 * SUN RPC IS PROVIDED AS IS WITH NO WARRANTIES OF ANY KIND INCLUDING THE 11 * WARRANTIES OF DESIGN, MERCHANTIBILITY AND FITNESS FOR A PARTICULAR 12 * PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE OR TRADE PRACTICE. 13 * 14 * Sun RPC is provided with no support and without any obligation on the 15 * part of Sun Microsystems, Inc. to assist in its use, correction, 16 * modification or enhancement. 17 * 18 * SUN MICROSYSTEMS, INC. SHALL HAVE NO LIABILITY WITH RESPECT TO THE 19 * INFRINGEMENT OF COPYRIGHTS, TRADE SECRETS OR ANY PATENTS BY SUN RPC 20 * OR ANY PART THEREOF. 21 * 22 * In no event will Sun Microsystems, Inc. be liable for any lost revenue 23 * or profits or other special, indirect and consequential damages, even if 24 * Sun has been advised of the possibility of such damages. 25 * 26 * Sun Microsystems, Inc. 27 * 2550 Garcia Avenue 28 * Mountain View, California 94043 29 */ 30 #if !defined(lint) && defined(SCCSIDS) 31 static char sccsid[] = "@(#)svc_simple.c 1.18 87/08/11 Copyr 1984 Sun Micro"; 32 #endif 33 34 /* 35 * svc_simple.c 36 * Simplified front end to rpc. 37 * 38 * Copyright (C) 1984, Sun Microsystems, Inc. 39 */ 40 41 #include <stdio.h> 42 #include <rpc/rpc.h> 43 #include <sys/socket.h> 44 #include <netdb.h> 45 46 static struct proglst { 47 char *(*p_progname)(); 48 int p_prognum; 49 int p_procnum; 50 xdrproc_t p_inproc, p_outproc; 51 struct proglst *p_nxt; 52 } *proglst; 53 static void universal(); 54 static SVCXPRT *transp; 55 struct proglst *pl; 56 57 registerrpc(prognum, versnum, procnum, progname, inproc, outproc) 58 char *(*progname)(); 59 xdrproc_t inproc, outproc; 60 { 61 62 if (procnum == NULLPROC) { 63 (void) fprintf(stderr, 64 "can't reassign procedure number %d\n", NULLPROC); 65 return (-1); 66 } 67 if (transp == 0) { 68 transp = svcudp_create(RPC_ANYSOCK); 69 if (transp == NULL) { 70 (void) fprintf(stderr, "couldn't create an rpc server\n"); 71 return (-1); 72 } 73 } 74 (void) pmap_unset((u_long)prognum, (u_long)versnum); 75 if (!svc_register(transp, (u_long)prognum, (u_long)versnum, 76 universal, IPPROTO_UDP)) { 77 (void) fprintf(stderr, "couldn't register prog %d vers %d\n", 78 prognum, versnum); 79 return (-1); 80 } 81 pl = (struct proglst *)malloc(sizeof(struct proglst)); 82 if (pl == NULL) { 83 (void) fprintf(stderr, "registerrpc: out of memory\n"); 84 return (-1); 85 } 86 pl->p_progname = progname; 87 pl->p_prognum = prognum; 88 pl->p_procnum = procnum; 89 pl->p_inproc = inproc; 90 pl->p_outproc = outproc; 91 pl->p_nxt = proglst; 92 proglst = pl; 93 return (0); 94 } 95 96 static void 97 universal(rqstp, transp) 98 struct svc_req *rqstp; 99 SVCXPRT *transp; 100 { 101 int prog, proc; 102 char *outdata; 103 char xdrbuf[UDPMSGSIZE]; 104 struct proglst *pl; 105 106 /* 107 * enforce "procnum 0 is echo" convention 108 */ 109 if (rqstp->rq_proc == NULLPROC) { 110 if (svc_sendreply(transp, xdr_void, (char *)NULL) == FALSE) { 111 (void) fprintf(stderr, "xxx\n"); 112 exit(1); 113 } 114 return; 115 } 116 prog = rqstp->rq_prog; 117 proc = rqstp->rq_proc; 118 for (pl = proglst; pl != NULL; pl = pl->p_nxt) 119 if (pl->p_prognum == prog && pl->p_procnum == proc) { 120 /* decode arguments into a CLEAN buffer */ 121 bzero(xdrbuf, sizeof(xdrbuf)); /* required ! */ 122 if (!svc_getargs(transp, pl->p_inproc, xdrbuf)) { 123 svcerr_decode(transp); 124 return; 125 } 126 outdata = (*(pl->p_progname))(xdrbuf); 127 if (outdata == NULL && pl->p_outproc != xdr_void) 128 /* there was an error */ 129 return; 130 if (!svc_sendreply(transp, pl->p_outproc, outdata)) { 131 (void) fprintf(stderr, 132 "trouble replying to prog %d\n", 133 pl->p_prognum); 134 exit(1); 135 } 136 /* free the decoded arguments */ 137 (void)svc_freeargs(transp, pl->p_inproc, xdrbuf); 138 return; 139 } 140 (void) fprintf(stderr, "never registered prog %d\n", prog); 141 exit(1); 142 } 143 144