svc_simple.c 5.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209
  1. /* @(#)svc_simple.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[] = "@(#)svc_simple.c 1.18 87/08/11 Copyr 1984 Sun Micro";
  32. #endif
  33. /*
  34. * svc_simple.c
  35. * Simplified front end to rpc.
  36. *
  37. * Copyright (C) 1984, Sun Microsystems, Inc.
  38. */
  39. #define __FORCE_GLIBC
  40. #include <features.h>
  41. #include <stdio.h>
  42. #include <string.h>
  43. #include <unistd.h>
  44. #include "rpc_private.h"
  45. #include <rpc/pmap_clnt.h>
  46. #include <sys/socket.h>
  47. #include <netdb.h>
  48. #ifdef USE_IN_LIBIO
  49. # include <wchar.h>
  50. # include <libio/iolibio.h>
  51. # define fputs(s, f) _IO_fputs (s, f)
  52. #endif
  53. /* Experimentally off - libc_hidden_proto(strdup) */
  54. /* Experimentally off - libc_hidden_proto(memset) */
  55. libc_hidden_proto(asprintf)
  56. libc_hidden_proto(fputs)
  57. libc_hidden_proto(write)
  58. libc_hidden_proto(exit)
  59. libc_hidden_proto(svc_sendreply)
  60. libc_hidden_proto(svc_register)
  61. libc_hidden_proto(svcerr_decode)
  62. libc_hidden_proto(svcudp_create)
  63. libc_hidden_proto(pmap_unset)
  64. libc_hidden_proto(xdr_void)
  65. struct proglst_
  66. {
  67. char *(*p_progname) (char *);
  68. int p_prognum;
  69. int p_procnum;
  70. xdrproc_t p_inproc, p_outproc;
  71. struct proglst_ *p_nxt;
  72. };
  73. #ifdef __UCLIBC_HAS_THREADS__
  74. #define proglst (*(struct proglst_ **)&RPC_THREAD_VARIABLE(svcsimple_proglst_s))
  75. #else
  76. static struct proglst_ *proglst;
  77. #endif
  78. static void universal (struct svc_req *rqstp, SVCXPRT *transp_s);
  79. #ifdef __UCLIBC_HAS_THREADS__
  80. #define transp (*(SVCXPRT **)&RPC_THREAD_VARIABLE(svcsimple_transp_s))
  81. #else
  82. static SVCXPRT *transp;
  83. #endif
  84. int registerrpc (u_long prognum, u_long versnum, u_long procnum,
  85. char *(*progname) (char *), xdrproc_t inproc, xdrproc_t outproc);
  86. int
  87. registerrpc (u_long prognum, u_long versnum, u_long procnum,
  88. char *(*progname) (char *), xdrproc_t inproc, xdrproc_t outproc)
  89. {
  90. struct proglst_ *pl;
  91. char *buf;
  92. if (procnum == NULLPROC)
  93. {
  94. (void) asprintf (&buf, _("can't reassign procedure number %ld\n"),
  95. NULLPROC);
  96. goto err_out;
  97. }
  98. if (transp == 0)
  99. {
  100. transp = svcudp_create (RPC_ANYSOCK);
  101. if (transp == NULL)
  102. {
  103. buf = strdup (_("couldn't create an rpc server\n"));
  104. goto err_out;
  105. }
  106. }
  107. (void) pmap_unset ((u_long) prognum, (u_long) versnum);
  108. if (!svc_register (transp, (u_long) prognum, (u_long) versnum,
  109. universal, IPPROTO_UDP))
  110. {
  111. (void) asprintf (&buf, _("couldn't register prog %ld vers %ld\n"),
  112. prognum, versnum);
  113. goto err_out;
  114. }
  115. pl = (struct proglst_ *) malloc (sizeof (struct proglst_));
  116. if (pl == NULL)
  117. {
  118. buf = strdup (_("registerrpc: out of memory\n"));
  119. goto err_out;
  120. }
  121. pl->p_progname = progname;
  122. pl->p_prognum = prognum;
  123. pl->p_procnum = procnum;
  124. pl->p_inproc = inproc;
  125. pl->p_outproc = outproc;
  126. pl->p_nxt = proglst;
  127. proglst = pl;
  128. return 0;
  129. err_out:
  130. #ifdef USE_IN_LIBIO
  131. if (_IO_fwide (stderr, 0) > 0)
  132. (void) __fwprintf (stderr, L"%s", buf);
  133. else
  134. #endif
  135. (void) fputs (buf, stderr);
  136. free (buf);
  137. return -1;
  138. }
  139. static void
  140. universal (struct svc_req *rqstp, SVCXPRT *transp_l)
  141. {
  142. int prog, proc;
  143. char *outdata;
  144. char xdrbuf[UDPMSGSIZE];
  145. struct proglst_ *pl;
  146. char *buf = NULL;
  147. /*
  148. * enforce "procnum 0 is echo" convention
  149. */
  150. if (rqstp->rq_proc == NULLPROC)
  151. {
  152. if (svc_sendreply (transp_l, (xdrproc_t)xdr_void, (char *) NULL) == FALSE)
  153. {
  154. write (STDERR_FILENO, "xxx\n", 4);
  155. exit (1);
  156. }
  157. return;
  158. }
  159. prog = rqstp->rq_prog;
  160. proc = rqstp->rq_proc;
  161. for (pl = proglst; pl != NULL; pl = pl->p_nxt)
  162. if (pl->p_prognum == prog && pl->p_procnum == proc)
  163. {
  164. /* decode arguments into a CLEAN buffer */
  165. memset (xdrbuf, 0, sizeof (xdrbuf)); /* required ! */
  166. if (!svc_getargs (transp_l, pl->p_inproc, xdrbuf))
  167. {
  168. svcerr_decode (transp_l);
  169. return;
  170. }
  171. outdata = (*(pl->p_progname)) (xdrbuf);
  172. if (outdata == NULL && pl->p_outproc != (xdrproc_t)xdr_void)
  173. /* there was an error */
  174. return;
  175. if (!svc_sendreply (transp_l, pl->p_outproc, outdata))
  176. {
  177. (void) asprintf (&buf,
  178. _("trouble replying to prog %d\n"),
  179. pl->p_prognum);
  180. exit (1);
  181. }
  182. /* free the decoded arguments */
  183. (void) svc_freeargs (transp_l, pl->p_inproc, xdrbuf);
  184. return;
  185. }
  186. (void) asprintf (&buf, _("never registered prog %d\n"), prog);
  187. #ifdef USE_IN_LIBIO
  188. if (_IO_fwide (stderr, 0) > 0)
  189. __fwprintf (stderr, L"%s", buf);
  190. else
  191. #endif
  192. fputs (buf, stderr);
  193. free (buf);
  194. exit (1);
  195. }