Commit | Line | Data |
---|---|---|
b58f055e WJ |
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 |