libc/inet/rpc/clnt_simple.c

   1 /* @(#)clnt_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[] = "@(#)clnt_simple.c 1.35 87/08/11 Copyr 1984 Sun Micro";
  32 #endif
  33
  34 /*
  35  * clnt_simple.c
  36  * Simplified front end to rpc.
  37  *
  38  * Copyright (C) 1984, Sun Microsystems, Inc.
  39  */
  40
  41 #include <alloca.h>
  42 #include <errno.h>
  43 #include <stdio.h>
  44 #include <unistd.h>
  45 #include "rpc_private.h"
  46 #include <sys/socket.h>
  47 #include <netdb.h>
  48 #include <string.h>
  49
  50
  51 struct callrpc_private_s
  52   {
  53     CLIENT *client;
  54     int socket;
  55     u_long oldprognum, oldversnum, valid;
  56     char *oldhost;
  57   };
  58 #ifdef __UCLIBC_HAS_THREADS__
  59 #define callrpc_private (*(struct callrpc_private_s **)&RPC_THREAD_VARIABLE(callrpc_private_s))
  60 #else
  61 static struct callrpc_private_s *callrpc_private;
  62 #endif
  63
  64 int
  65 callrpc (const char *host, u_long prognum, u_long versnum, u_long procnum,
  66          xdrproc_t inproc, const char *in, xdrproc_t outproc, char *out)
  67 {
  68   struct callrpc_private_s *crp = callrpc_private;
  69   struct sockaddr_in server_addr;
  70   enum clnt_stat clnt_stat;
  71   struct hostent hostbuf, *hp;
  72   struct timeval timeout, tottimeout;
  73
  74   if (crp == 0)
  75     {
  76       crp = (struct callrpc_private_s *) calloc (1, sizeof (*crp));
  77       if (crp == 0)
  78         return 0;
  79       callrpc_private = crp;
  80     }
  81   if (crp->oldhost == NULL)
  82     {
  83       crp->oldhost = malloc (256);
  84       crp->oldhost[0] = 0;
  85       crp->socket = RPC_ANYSOCK;
  86     }
  87   if (crp->valid && crp->oldprognum == prognum && crp->oldversnum == versnum
  88       && strcmp (crp->oldhost, host) == 0)
  89     {
  90       /* reuse old client */
  91     }
  92   else
  93     {
  94       size_t buflen;
  95       char *buffer;
  96       int herr;
  97
  98       crp->valid = 0;
  99       if (crp->socket != RPC_ANYSOCK)
 100         {
 101           (void) close (crp->socket);
 102           crp->socket = RPC_ANYSOCK;
 103         }
 104       if (crp->client)
 105         {
 106           clnt_destroy (crp->client);
 107           crp->client = NULL;
 108         }
 109
 110       buflen = 1024;
 111       buffer = alloca (buflen);
 112       while (gethostbyname_r (host, &hostbuf, buffer, buflen,
 113                                 &hp, &herr) != 0
 114              || hp == NULL)
 115         if (herr != NETDB_INTERNAL || errno != ERANGE)
 116           return (int) RPC_UNKNOWNHOST;
 117         else
 118           {
 119             /* Enlarge the buffer.  */
 120             buflen *= 2;
 121             buffer = alloca (buflen);
 122           }
 123
 124       timeout.tv_usec = 0;
 125       timeout.tv_sec = 5;
 126       memcpy ((char *) &server_addr.sin_addr, hp->h_addr, hp->h_length);
 127       server_addr.sin_family = AF_INET;
 128       server_addr.sin_port = 0;
 129       if ((crp->client = clntudp_create (&server_addr, (u_long) prognum,
 130                           (u_long) versnum, timeout, &crp->socket)) == NULL)
 131         return (int) get_rpc_createerr().cf_stat;
 132       crp->valid = 1;
 133       crp->oldprognum = prognum;
 134       crp->oldversnum = versnum;
 135       (void) strncpy (crp->oldhost, host, 255);
 136       crp->oldhost[255] = '\0';
 137     }
 138   tottimeout.tv_sec = 25;
 139   tottimeout.tv_usec = 0;
 140   clnt_stat = clnt_call (crp->client, procnum, inproc, (char *) in,
 141                          outproc, out, tottimeout);
 142   /*
 143    * if call failed, empty cache
 144    */
 145   if (clnt_stat != RPC_SUCCESS)
 146     crp->valid = 0;
 147   return (int) clnt_stat;
 148 }
 149
 150 #ifdef __UCLIBC_HAS_THREADS__
 151 void attribute_hidden __rpc_thread_clnt_cleanup (void)
 152 {
 153         struct callrpc_private_s *rcp = RPC_THREAD_VARIABLE(callrpc_private_s);
 154
 155         if (rcp) {
 156                 if (rcp->client)
 157                         CLNT_DESTROY (rcp->client);
 158                 free (rcp);
 159         }
 160 }
 161 #endif /* __UCLIBC_HAS_THREADS__ */