clnt_raw.c 6.3 KB

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