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 0
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 <string.h>
43 #include <unistd.h>
44 #include "rpc_private.h"
45 #include <rpc/pmap_clnt.h>
46 #include <sys/socket.h>
47 #include <netdb.h>
48
49 struct proglst_
50 {
51 char *(*p_progname) (char *);
52 int p_prognum;
53 int p_procnum;
54 xdrproc_t p_inproc, p_outproc;
55 struct proglst_ *p_nxt;
56 };
57 #ifdef __UCLIBC_HAS_THREADS__
58 #define proglst (*(struct proglst_ **)&RPC_THREAD_VARIABLE(svcsimple_proglst_s))
59 #else
60 static struct proglst_ *proglst;
61 #endif
62
63
64 static void universal (struct svc_req *rqstp, SVCXPRT *transp_s);
65 #ifdef __UCLIBC_HAS_THREADS__
66 #define transp (*(SVCXPRT **)&RPC_THREAD_VARIABLE(svcsimple_transp_s))
67 #else
68 static SVCXPRT *transp;
69 #endif
70
71 int registerrpc (u_long prognum, u_long versnum, u_long procnum,
72 char *(*progname) (char *), xdrproc_t inproc, xdrproc_t outproc);
73 int
registerrpc(u_long prognum,u_long versnum,u_long procnum,char * (* progname)(char *),xdrproc_t inproc,xdrproc_t outproc)74 registerrpc (u_long prognum, u_long versnum, u_long procnum,
75 char *(*progname) (char *), xdrproc_t inproc, xdrproc_t outproc)
76 {
77 struct proglst_ *pl;
78 char *buf;
79
80 if (procnum == NULLPROC)
81 {
82
83 (void) asprintf (&buf, _("can't reassign procedure number %ld\n"),
84 NULLPROC);
85 goto err_out;
86 }
87 if (transp == 0)
88 {
89 transp = svcudp_create (RPC_ANYSOCK);
90 if (transp == NULL)
91 {
92 buf = strdup (_("couldn't create an rpc server\n"));
93 goto err_out;
94 }
95 }
96 (void) pmap_unset ((u_long) prognum, (u_long) versnum);
97 if (!svc_register (transp, (u_long) prognum, (u_long) versnum,
98 universal, IPPROTO_UDP))
99 {
100 (void) asprintf (&buf, _("couldn't register prog %ld vers %ld\n"),
101 prognum, versnum);
102 goto err_out;
103 }
104 pl = (struct proglst_ *) malloc (sizeof (struct proglst_));
105 if (pl == NULL)
106 {
107 buf = strdup (_("registerrpc: out of memory\n"));
108 goto err_out;
109 }
110 pl->p_progname = progname;
111 pl->p_prognum = prognum;
112 pl->p_procnum = procnum;
113 pl->p_inproc = inproc;
114 pl->p_outproc = outproc;
115 pl->p_nxt = proglst;
116 proglst = pl;
117 return 0;
118
119 err_out:
120 (void) fputs (buf, stderr);
121 free (buf);
122 return -1;
123 }
124
125 static void
universal(struct svc_req * rqstp,SVCXPRT * transp_l)126 universal (struct svc_req *rqstp, SVCXPRT *transp_l)
127 {
128 int prog, proc;
129 char *outdata;
130 char xdrbuf[UDPMSGSIZE];
131 struct proglst_ *pl;
132 char *buf = NULL;
133
134 /*
135 * enforce "procnum 0 is echo" convention
136 */
137 if (rqstp->rq_proc == NULLPROC)
138 {
139 if (svc_sendreply (transp_l, (xdrproc_t)xdr_void, (char *) NULL) == FALSE)
140 {
141 write (STDERR_FILENO, "xxx\n", 4);
142 exit (1);
143 }
144 return;
145 }
146 prog = rqstp->rq_prog;
147 proc = rqstp->rq_proc;
148 for (pl = proglst; pl != NULL; pl = pl->p_nxt)
149 if (pl->p_prognum == prog && pl->p_procnum == proc)
150 {
151 /* decode arguments into a CLEAN buffer */
152 memset (xdrbuf, 0, sizeof (xdrbuf)); /* required ! */
153 if (!svc_getargs (transp_l, pl->p_inproc, xdrbuf))
154 {
155 svcerr_decode (transp_l);
156 return;
157 }
158 outdata = (*(pl->p_progname)) (xdrbuf);
159 if (outdata == NULL && pl->p_outproc != (xdrproc_t)xdr_void)
160 /* there was an error */
161 return;
162 if (!svc_sendreply (transp_l, pl->p_outproc, outdata))
163 {
164 (void) asprintf (&buf,
165 _("trouble replying to prog %d\n"),
166 pl->p_prognum);
167 exit (1);
168 }
169 /* free the decoded arguments */
170 (void) svc_freeargs (transp_l, pl->p_inproc, xdrbuf);
171 return;
172 }
173 (void) asprintf (&buf, _("never registered prog %d\n"), prog);
174 fputs (buf, stderr);
175 free (buf);
176 exit (1);
177 }
178