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