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