sunrpc/svc_raw.c

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