1 /* @(#)svc_raw.c 2.1 88/07/29 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_raw.c 1.15 87/08/11 Copyr 1984 Sun Micro";
32 #endif
33
34 /*
35 * svc_raw.c, This a toy for simple testing and timing.
36 * Interface to create an rpc client and server in the same UNIX process.
37 * This lets us simulate rpc and get rpc (round trip) overhead, without
38 * any interference from the kernel.
39 *
40 * Copyright (C) 1984, Sun Microsystems, Inc.
41 */
42
43 #include "rpc_private.h"
44 #include <rpc/svc.h>
45
46
47 /*
48 * This is the "network" that we will be moving data over
49 */
50 struct svcraw_private_s
51 {
52 char _raw_buf[UDPMSGSIZE];
53 SVCXPRT server;
54 XDR xdr_stream;
55 char verf_body[MAX_AUTH_BYTES];
56 };
57 #ifdef __UCLIBC_HAS_THREADS__
58 #define svcraw_private (*(struct svcraw_private_s **)&RPC_THREAD_VARIABLE(svcraw_private_s))
59 #else
60 static struct svcraw_private_s *svcraw_private;
61 #endif
62
63 static bool_t svcraw_recv (SVCXPRT *, struct rpc_msg *);
64 static enum xprt_stat svcraw_stat (SVCXPRT *);
65 static bool_t svcraw_getargs (SVCXPRT *, xdrproc_t, caddr_t);
66 static bool_t svcraw_reply (SVCXPRT *, struct rpc_msg *);
67 static bool_t svcraw_freeargs (SVCXPRT *, xdrproc_t, caddr_t);
68 static void svcraw_destroy (SVCXPRT *);
69
70 static const struct xp_ops server_ops =
71 {
72 svcraw_recv,
73 svcraw_stat,
74 svcraw_getargs,
75 svcraw_reply,
76 svcraw_freeargs,
77 svcraw_destroy
78 };
79
80 SVCXPRT *
svcraw_create(void)81 svcraw_create (void)
82 {
83 struct svcraw_private_s *srp = svcraw_private;
84
85 if (srp == 0)
86 {
87 srp = (struct svcraw_private_s *) calloc (1, sizeof (*srp));
88 if (srp == 0)
89 return NULL;
90 }
91 srp->server.xp_sock = 0;
92 srp->server.xp_port = 0;
93 srp->server.xp_ops = &server_ops;
94 srp->server.xp_verf.oa_base = srp->verf_body;
95 xdrmem_create (&srp->xdr_stream, srp->_raw_buf, UDPMSGSIZE, XDR_FREE);
96 return &srp->server;
97 }
98
99 static enum xprt_stat
svcraw_stat(SVCXPRT * xprt attribute_unused)100 svcraw_stat (SVCXPRT *xprt attribute_unused)
101 {
102 return XPRT_IDLE;
103 }
104
105 static bool_t
svcraw_recv(SVCXPRT * xprt attribute_unused,struct rpc_msg * msg)106 svcraw_recv (SVCXPRT *xprt attribute_unused, struct rpc_msg *msg)
107 {
108 struct svcraw_private_s *srp = svcraw_private;
109 XDR *xdrs;
110
111 if (srp == 0)
112 return FALSE;
113 xdrs = &srp->xdr_stream;
114 xdrs->x_op = XDR_DECODE;
115 XDR_SETPOS (xdrs, 0);
116 if (!xdr_callmsg (xdrs, msg))
117 return FALSE;
118 return TRUE;
119 }
120
121 static bool_t
svcraw_reply(SVCXPRT * xprt attribute_unused,struct rpc_msg * msg)122 svcraw_reply (SVCXPRT *xprt attribute_unused, struct rpc_msg *msg)
123 {
124 struct svcraw_private_s *srp = svcraw_private;
125 XDR *xdrs;
126
127 if (srp == 0)
128 return FALSE;
129 xdrs = &srp->xdr_stream;
130 xdrs->x_op = XDR_ENCODE;
131 XDR_SETPOS (xdrs, 0);
132 if (!xdr_replymsg (xdrs, msg))
133 return FALSE;
134 (void) XDR_GETPOS (xdrs); /* called just for overhead */
135 return TRUE;
136 }
137
138 static bool_t
svcraw_getargs(SVCXPRT * xprt attribute_unused,xdrproc_t xdr_args,caddr_t args_ptr)139 svcraw_getargs (SVCXPRT *xprt attribute_unused, xdrproc_t xdr_args, caddr_t args_ptr)
140 {
141 struct svcraw_private_s *srp = svcraw_private;
142
143 if (srp == 0)
144 return FALSE;
145 return (*xdr_args) (&srp->xdr_stream, args_ptr);
146 }
147
148 static bool_t
svcraw_freeargs(SVCXPRT * xprt attribute_unused,xdrproc_t xdr_args,caddr_t args_ptr)149 svcraw_freeargs (SVCXPRT *xprt attribute_unused, xdrproc_t xdr_args, caddr_t args_ptr)
150 {
151 struct svcraw_private_s *srp = svcraw_private;
152 XDR *xdrs;
153
154 if (srp == 0)
155 return FALSE;
156 xdrs = &srp->xdr_stream;
157 xdrs->x_op = XDR_FREE;
158 return (*xdr_args) (xdrs, args_ptr);
159 }
160
161 static void
svcraw_destroy(SVCXPRT * xprt attribute_unused)162 svcraw_destroy (SVCXPRT *xprt attribute_unused)
163 {
164 }
165