clnt_raw.c 6.7 KB

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