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