sunrpc/clnt_raw.c

   1 /* @(#)clnt_raw.c       2.2 88/08/01 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[] = "@(#)clnt_raw.c 1.22 87/08/11 Copyr 1984 Sun Micro";
  32 #endif
  33
  34 /*
  35  * clnt_raw.c
  36  *
  37  * Copyright (C) 1984, Sun Microsystems, Inc.
  38  *
  39  * Memory based rpc for simple testing and timing.
  40  * Interface to create an rpc client and server in the same process.
  41  * This lets us similate rpc and get round trip overhead, without
  42  * any interference from the kernal.
  43  */
  44
  45 #include <rpc/rpc.h>
  46
  47 #define MCALL_MSG_SIZE 24
  48
  49 /*
  50  * This is the "network" we will be moving stuff over.
  51  */
  52 static struct clntraw_private {
  53         CLIENT  client_object;
  54         XDR     xdr_stream;
  55         char    _raw_buf[UDPMSGSIZE];
  56         char    mashl_callmsg[MCALL_MSG_SIZE];
  57         u_int   mcnt;
  58 } *clntraw_private;
  59
  60 static enum clnt_stat   clntraw_call();
  61 static void             clntraw_abort();
  62 static void             clntraw_geterr();
  63 static bool_t           clntraw_freeres();
  64 static bool_t           clntraw_control();
  65 static void             clntraw_destroy();
  66
  67 static struct clnt_ops client_ops = {
  68         clntraw_call,
  69         clntraw_abort,
  70         clntraw_geterr,
  71         clntraw_freeres,
  72         clntraw_destroy,
  73         clntraw_control
  74 };
  75
  76 void    svc_getreq();
  77
  78 /*
  79  * Create a client handle for memory based rpc.
  80  */
  81 CLIENT *
  82 clntraw_create(prog, vers)
  83         u_long prog;
  84         u_long vers;
  85 {
  86         register struct clntraw_private *clp = clntraw_private;
  87         struct rpc_msg call_msg;
  88         XDR *xdrs = &clp->xdr_stream;
  89         CLIENT  *client = &clp->client_object;
  90
  91         if (clp == 0) {
  92                 clp = (struct clntraw_private *)calloc(1, sizeof (*clp));
  93                 if (clp == 0)
  94                         return (0);
  95                 clntraw_private = clp;
  96         }
  97         /*
  98          * pre-serialize the staic part of the call msg and stash it away
  99          */
 100         call_msg.rm_direction = CALL;
 101         call_msg.rm_call.cb_rpcvers = RPC_MSG_VERSION;
 102         call_msg.rm_call.cb_prog = prog;
 103         call_msg.rm_call.cb_vers = vers;
 104         xdrmem_create(xdrs, clp->mashl_callmsg, MCALL_MSG_SIZE, XDR_ENCODE);
 105         if (! xdr_callhdr(xdrs, &call_msg)) {
 106                 perror("clnt_raw.c - Fatal header serialization error.");
 107         }
 108         clp->mcnt = XDR_GETPOS(xdrs);
 109         XDR_DESTROY(xdrs);
 110
 111         /*
 112          * Set xdrmem for client/server shared buffer
 113          */
 114         xdrmem_create(xdrs, clp->_raw_buf, UDPMSGSIZE, XDR_FREE);
 115
 116         /*
 117          * create client handle
 118          */
 119         client->cl_ops = &client_ops;
 120         client->cl_auth = authnone_create();
 121         return (client);
 122 }
 123
 124 static enum clnt_stat
 125 clntraw_call(h, proc, xargs, argsp, xresults, resultsp, timeout)
 126         CLIENT *h;
 127         u_long proc;
 128         xdrproc_t xargs;
 129         caddr_t argsp;
 130         xdrproc_t xresults;
 131         caddr_t resultsp;
 132         struct timeval timeout;
 133 {
 134         register struct clntraw_private *clp = clntraw_private;
 135         register XDR *xdrs = &clp->xdr_stream;
 136         struct rpc_msg msg;
 137         enum clnt_stat status;
 138         struct rpc_err error;
 139
 140         if (clp == 0)
 141                 return (RPC_FAILED);
 142 call_again:
 143         /*
 144          * send request
 145          */
 146         xdrs->x_op = XDR_ENCODE;
 147         XDR_SETPOS(xdrs, 0);
 148         ((struct rpc_msg *)clp->mashl_callmsg)->rm_xid ++ ;
 149         if ((! XDR_PUTBYTES(xdrs, clp->mashl_callmsg, clp->mcnt)) ||
 150             (! XDR_PUTLONG(xdrs, (long *)&proc)) ||
 151             (! AUTH_MARSHALL(h->cl_auth, xdrs)) ||
 152             (! (*xargs)(xdrs, argsp))) {
 153                 return (RPC_CANTENCODEARGS);
 154         }
 155         (void)XDR_GETPOS(xdrs);  /* called just to cause overhead */
 156
 157         /*
 158          * We have to call server input routine here because this is
 159          * all going on in one process. Yuk.
 160          */
 161         svc_getreq(1);
 162
 163         /*
 164          * get results
 165          */
 166         xdrs->x_op = XDR_DECODE;
 167         XDR_SETPOS(xdrs, 0);
 168         msg.acpted_rply.ar_verf = _null_auth;
 169         msg.acpted_rply.ar_results.where = resultsp;
 170         msg.acpted_rply.ar_results.proc = xresults;
 171         if (! xdr_replymsg(xdrs, &msg))
 172                 return (RPC_CANTDECODERES);
 173         _seterr_reply(&msg, &error);
 174         status = error.re_status;
 175
 176         if (status == RPC_SUCCESS) {
 177                 if (! AUTH_VALIDATE(h->cl_auth, &msg.acpted_rply.ar_verf)) {
 178                         status = RPC_AUTHERROR;
 179                 }
 180         }  /* end successful completion */
 181         else {
 182                 if (AUTH_REFRESH(h->cl_auth))
 183                         goto call_again;
 184         }  /* end of unsuccessful completion */
 185
 186         if (status == RPC_SUCCESS) {
 187                 if (! AUTH_VALIDATE(h->cl_auth, &msg.acpted_rply.ar_verf)) {
 188                         status = RPC_AUTHERROR;
 189                 }
 190                 if (msg.acpted_rply.ar_verf.oa_base != NULL) {
 191                         xdrs->x_op = XDR_FREE;
 192                         (void)xdr_opaque_auth(xdrs, &(msg.acpted_rply.ar_verf));
 193                 }
 194         }
 195
 196         return (status);
 197 }
 198
 199 static void
 200 clntraw_geterr()
 201 {
 202 }
 203
 204
 205 static bool_t
 206 clntraw_freeres(cl, xdr_res, res_ptr)
 207         CLIENT *cl;
 208         xdrproc_t xdr_res;
 209         caddr_t res_ptr;
 210 {
 211         register struct clntraw_private *clp = clntraw_private;
 212         register XDR *xdrs = &clp->xdr_stream;
 213         bool_t rval;
 214
 215         if (clp == 0)
 216         {
 217                 rval = (bool_t) RPC_FAILED;
 218                 return (rval);
 219         }
 220         xdrs->x_op = XDR_FREE;
 221         return ((*xdr_res)(xdrs, res_ptr));
 222 }
 223
 224 static void
 225 clntraw_abort()
 226 {
 227 }
 228
 229 static bool_t
 230 clntraw_control()
 231 {
 232         return (FALSE);
 233 }
 234
 235 static void
 236 clntraw_destroy()
 237 {
 238 }