support/rpc/svc_raw.c

   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
  30 #if defined(LIBC_SCCS) && !defined(lint)
  31 static char *rcsid = "$OpenBSD: svc_raw.c,v 1.4 1996/09/15 09:31:39 tholo Exp $";
  32 #endif /* LIBC_SCCS and not lint */
  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 <stdlib.h>
  44 #include <rpc/rpc.h>
  45
  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 /* ARGSUSED */
  99 static bool_t
 100 svcraw_recv(xprt, msg)
 101         SVCXPRT *xprt;
 102         struct rpc_msg *msg;
 103 {
 104         register struct svcraw_private *srp = svcraw_private;
 105         register XDR *xdrs;
 106
 107         if (srp == 0)
 108                 return (0);
 109         xdrs = &srp->xdr_stream;
 110         xdrs->x_op = XDR_DECODE;
 111         XDR_SETPOS(xdrs, 0);
 112         if (! xdr_callmsg(xdrs, msg))
 113                return (FALSE);
 114         return (TRUE);
 115 }
 116
 117 /* ARGSUSED */
 118 static bool_t
 119 svcraw_reply(xprt, msg)
 120         SVCXPRT *xprt;
 121         struct rpc_msg *msg;
 122 {
 123         register struct svcraw_private *srp = svcraw_private;
 124         register XDR *xdrs;
 125
 126         if (srp == 0)
 127                 return (FALSE);
 128         xdrs = &srp->xdr_stream;
 129         xdrs->x_op = XDR_ENCODE;
 130         XDR_SETPOS(xdrs, 0);
 131         if (! xdr_replymsg(xdrs, msg))
 132                return (FALSE);
 133         (void)XDR_GETPOS(xdrs);  /* called just for overhead */
 134         return (TRUE);
 135 }
 136
 137 /* ARGSUSED */
 138 static bool_t
 139 svcraw_getargs(xprt, xdr_args, args_ptr)
 140         SVCXPRT *xprt;
 141         xdrproc_t xdr_args;
 142         caddr_t args_ptr;
 143 {
 144         register struct svcraw_private *srp = svcraw_private;
 145
 146         if (srp == 0)
 147                 return (FALSE);
 148         return ((*xdr_args)(&srp->xdr_stream, args_ptr));
 149 }
 150
 151 /* ARGSUSED */
 152 static bool_t
 153 svcraw_freeargs(xprt, xdr_args, args_ptr)
 154         SVCXPRT *xprt;
 155         xdrproc_t xdr_args;
 156         caddr_t args_ptr;
 157 {
 158         register struct svcraw_private *srp = svcraw_private;
 159         register XDR *xdrs;
 160
 161         if (srp == 0)
 162                 return (FALSE);
 163         xdrs = &srp->xdr_stream;
 164         xdrs->x_op = XDR_FREE;
 165         return ((*xdr_args)(xdrs, args_ptr));
 166 }
 167
 168 static void
 169 svcraw_destroy()
 170 {
 171 }