1 /* 2 * Sun RPC is a product of Sun Microsystems, Inc. and is provided for 3 * unrestricted use provided that this legend is included on all tape 4 * media and as a part of the software program in whole or part. Users 5 * may copy or modify Sun RPC without charge, but are not authorized 6 * to license or distribute it to anyone else except as part of a product or 7 * program developed by the user. 8 * 9 * SUN RPC IS PROVIDED AS IS WITH NO WARRANTIES OF ANY KIND INCLUDING THE 10 * WARRANTIES OF DESIGN, MERCHANTIBILITY AND FITNESS FOR A PARTICULAR 11 * PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE OR TRADE PRACTICE. 12 * 13 * Sun RPC is provided with no support and without any obligation on the 14 * part of Sun Microsystems, Inc. to assist in its use, correction, 15 * modification or enhancement. 16 * 17 * SUN MICROSYSTEMS, INC. SHALL HAVE NO LIABILITY WITH RESPECT TO THE 18 * INFRINGEMENT OF COPYRIGHTS, TRADE SECRETS OR ANY PATENTS BY SUN RPC 19 * OR ANY PART THEREOF. 20 * 21 * In no event will Sun Microsystems, Inc. be liable for any lost revenue 22 * or profits or other special, indirect and consequential damages, even if 23 * Sun has been advised of the possibility of such damages. 24 * 25 * Sun Microsystems, Inc. 26 * 2550 Garcia Avenue 27 * Mountain View, California 94043 28 * 29 * @(#)svc_raw.c 1.15 87/08/11 Copyr 1984 Sun Micro 30 * @(#)svc_raw.c 2.1 88/07/29 4.0 RPCSRC 31 * $FreeBSD: src/lib/libc/rpc/svc_raw.c,v 1.7 1999/08/28 00:00:49 peter Exp $ 32 * $DragonFly: src/lib/libc/rpc/svc_raw.c,v 1.2 2003/06/17 04:26:45 dillon Exp $ 33 */ 34 35 /* 36 * svc_raw.c, This a toy for simple testing and timing. 37 * Interface to create an rpc client and server in the same UNIX process. 38 * This lets us similate rpc and get rpc (round trip) overhead, without 39 * any interference from the kernal. 40 * 41 * Copyright (C) 1984, Sun Microsystems, Inc. 42 */ 43 44 #include <rpc/rpc.h> 45 #include <stdlib.h> 46 47 /* 48 * This is the "network" that we will be moving data over 49 */ 50 static struct svcraw_private { 51 char _raw_buf[UDPMSGSIZE]; 52 SVCXPRT server; 53 XDR xdr_stream; 54 char verf_body[MAX_AUTH_BYTES]; 55 } *svcraw_private; 56 57 static bool_t svcraw_recv(); 58 static enum xprt_stat svcraw_stat(); 59 static bool_t svcraw_getargs(); 60 static bool_t svcraw_reply(); 61 static bool_t svcraw_freeargs(); 62 static void svcraw_destroy(); 63 64 static struct xp_ops server_ops = { 65 svcraw_recv, 66 svcraw_stat, 67 svcraw_getargs, 68 svcraw_reply, 69 svcraw_freeargs, 70 svcraw_destroy 71 }; 72 73 SVCXPRT * 74 svcraw_create() 75 { 76 register struct svcraw_private *srp = svcraw_private; 77 78 if (srp == 0) { 79 srp = (struct svcraw_private *)calloc(1, sizeof (*srp)); 80 if (srp == 0) 81 return (0); 82 } 83 srp->server.xp_sock = 0; 84 srp->server.xp_port = 0; 85 srp->server.xp_ops = &server_ops; 86 srp->server.xp_verf.oa_base = srp->verf_body; 87 xdrmem_create(&srp->xdr_stream, srp->_raw_buf, UDPMSGSIZE, XDR_FREE); 88 return (&srp->server); 89 } 90 91 static enum xprt_stat 92 svcraw_stat() 93 { 94 95 return (XPRT_IDLE); 96 } 97 98 static bool_t 99 svcraw_recv(xprt, msg) 100 SVCXPRT *xprt; 101 struct rpc_msg *msg; 102 { 103 register struct svcraw_private *srp = svcraw_private; 104 register XDR *xdrs; 105 106 if (srp == 0) 107 return (0); 108 xdrs = &srp->xdr_stream; 109 xdrs->x_op = XDR_DECODE; 110 XDR_SETPOS(xdrs, 0); 111 if (! xdr_callmsg(xdrs, msg)) 112 return (FALSE); 113 return (TRUE); 114 } 115 116 static bool_t 117 svcraw_reply(xprt, msg) 118 SVCXPRT *xprt; 119 struct rpc_msg *msg; 120 { 121 register struct svcraw_private *srp = svcraw_private; 122 register XDR *xdrs; 123 124 if (srp == 0) 125 return (FALSE); 126 xdrs = &srp->xdr_stream; 127 xdrs->x_op = XDR_ENCODE; 128 XDR_SETPOS(xdrs, 0); 129 if (! xdr_replymsg(xdrs, msg)) 130 return (FALSE); 131 (void)XDR_GETPOS(xdrs); /* called just for overhead */ 132 return (TRUE); 133 } 134 135 static bool_t 136 svcraw_getargs(xprt, xdr_args, args_ptr) 137 SVCXPRT *xprt; 138 xdrproc_t xdr_args; 139 caddr_t args_ptr; 140 { 141 register struct svcraw_private *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 149 svcraw_freeargs(xprt, xdr_args, args_ptr) 150 SVCXPRT *xprt; 151 xdrproc_t xdr_args; 152 caddr_t args_ptr; 153 { 154 register struct svcraw_private *srp = svcraw_private; 155 register XDR *xdrs; 156 157 if (srp == 0) 158 return (FALSE); 159 xdrs = &srp->xdr_stream; 160 xdrs->x_op = XDR_FREE; 161 return ((*xdr_args)(xdrs, args_ptr)); 162 } 163 164 static void 165 svcraw_destroy() 166 { 167 } 168