sunrpc/svc_raw.c

   1 /*
   2  * svc_raw.c,   This a toy for simple testing and timing.
   3  * Interface to create an rpc client and server in the same UNIX process.
   4  * This lets us simulate rpc and get rpc (round trip) overhead, without
   5  * any interference from the kernel.
   6  *
   7  * Copyright (c) 2010, Oracle America, Inc.
   8  *
   9  * Redistribution and use in source and binary forms, with or without
  10  * modification, are permitted provided that the following conditions are
  11  * met:
  12  *
  13  *     * Redistributions of source code must retain the above copyright
  14  *       notice, this list of conditions and the following disclaimer.
  15  *     * Redistributions in binary form must reproduce the above
  16  *       copyright notice, this list of conditions and the following
  17  *       disclaimer in the documentation and/or other materials
  18  *       provided with the distribution.
  19  *     * Neither the name of the "Oracle America, Inc." nor the names of its
  20  *       contributors may be used to endorse or promote products derived
  21  *       from this software without specific prior written permission.
  22  *
  23  *   THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  24  *   "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  25  *   LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
  26  *   FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
  27  *   COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
  28  *   INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  29  *   DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE
  30  *   GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
  31  *   INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
  32  *   WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
  33  *   NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  34  *   OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  35  */
  36
  37 #include <rpc/rpc.h>
  38 #include <rpc/svc.h>
  39 #include <shlib-compat.h>
  40
  41 /*
  42  * This is the "network" that we will be moving data over
  43  */
  44 struct svcraw_private_s
  45   {
  46     char _raw_buf[UDPMSGSIZE];
  47     SVCXPRT server;
  48     XDR xdr_stream;
  49     char verf_body[MAX_AUTH_BYTES];
  50   };
  51 #ifdef _RPC_THREAD_SAFE_
  52 #define svcraw_private RPC_THREAD_VARIABLE(svcraw_private_s)
  53 #else
  54 static struct svcraw_private_s *svcraw_private;
  55 #endif
  56
  57 static bool_t svcraw_recv (SVCXPRT *, struct rpc_msg *);
  58 static enum xprt_stat svcraw_stat (SVCXPRT *);
  59 static bool_t svcraw_getargs (SVCXPRT *, xdrproc_t, caddr_t);
  60 static bool_t svcraw_reply (SVCXPRT *, struct rpc_msg *);
  61 static bool_t svcraw_freeargs (SVCXPRT *, xdrproc_t, caddr_t);
  62 static void svcraw_destroy (SVCXPRT *);
  63
  64 static const struct xp_ops server_ops =
  65 {
  66   svcraw_recv,
  67   svcraw_stat,
  68   svcraw_getargs,
  69   svcraw_reply,
  70   svcraw_freeargs,
  71   svcraw_destroy
  72 };
  73
  74 SVCXPRT *
  75 svcraw_create (void)
  76 {
  77   struct svcraw_private_s *srp = svcraw_private;
  78
  79   if (srp == 0)
  80     {
  81       srp = (struct svcraw_private_s *) calloc (1, sizeof (*srp));
  82       if (srp == 0)
  83         return NULL;
  84     }
  85   srp->server.xp_sock = 0;
  86   srp->server.xp_port = 0;
  87   srp->server.xp_ops = (struct xp_ops *) &server_ops;
  88   srp->server.xp_verf.oa_base = srp->verf_body;
  89   xdrmem_create (&srp->xdr_stream, srp->_raw_buf, UDPMSGSIZE, XDR_FREE);
  90   return &srp->server;
  91 }
  92 libc_hidden_nolink_sunrpc (svcraw_create, GLIBC_2_0)
  93
  94 static enum xprt_stat
  95 svcraw_stat (SVCXPRT *xprt)
  96 {
  97   return XPRT_IDLE;
  98 }
  99
 100 static bool_t
 101 svcraw_recv (SVCXPRT *xprt, struct rpc_msg *msg)
 102 {
 103   struct svcraw_private_s *srp = svcraw_private;
 104   XDR *xdrs;
 105
 106   if (srp == 0)
 107     return FALSE;
 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 (SVCXPRT *xprt, struct rpc_msg *msg)
 118 {
 119   struct svcraw_private_s *srp = svcraw_private;
 120   XDR *xdrs;
 121
 122   if (srp == 0)
 123     return FALSE;
 124   xdrs = &srp->xdr_stream;
 125   xdrs->x_op = XDR_ENCODE;
 126   XDR_SETPOS (xdrs, 0);
 127   if (!xdr_replymsg (xdrs, msg))
 128     return FALSE;
 129   (void) XDR_GETPOS (xdrs);     /* called just for overhead */
 130   return TRUE;
 131 }
 132
 133 static bool_t
 134 svcraw_getargs (SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr)
 135 {
 136   struct svcraw_private_s *srp = svcraw_private;
 137
 138   if (srp == 0)
 139     return FALSE;
 140   return (*xdr_args) (&srp->xdr_stream, args_ptr);
 141 }
 142
 143 static bool_t
 144 svcraw_freeargs (SVCXPRT *xprt, xdrproc_t xdr_args, caddr_t args_ptr)
 145 {
 146   struct svcraw_private_s *srp = svcraw_private;
 147   XDR *xdrs;
 148
 149   if (srp == 0)
 150     return FALSE;
 151   xdrs = &srp->xdr_stream;
 152   xdrs->x_op = XDR_FREE;
 153   return (*xdr_args) (xdrs, args_ptr);
 154 }
 155
 156 static void
 157 svcraw_destroy (SVCXPRT *xprt)
 158 {
 159 }