sunrpc/clnt_simp.c

   1 /*
   2  * clnt_simple.c
   3  * Simplified front end to rpc.
   4  *
   5  * Copyright (c) 2010, Oracle America, Inc.
   6  *
   7  * Redistribution and use in source and binary forms, with or without
   8  * modification, are permitted provided that the following conditions are
   9  * met:
  10  *
  11  *     * Redistributions of source code must retain the above copyright
  12  *       notice, this list of conditions and the following disclaimer.
  13  *     * Redistributions in binary form must reproduce the above
  14  *       copyright notice, this list of conditions and the following
  15  *       disclaimer in the documentation and/or other materials
  16  *       provided with the distribution.
  17  *     * Neither the name of the "Oracle America, Inc." nor the names of its
  18  *       contributors may be used to endorse or promote products derived
  19  *       from this software without specific prior written permission.
  20  *
  21  *   THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  22  *   "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  23  *   LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
  24  *   FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
  25  *   COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
  26  *   INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  27  *   DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE
  28  *   GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
  29  *   INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
  30  *   WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
  31  *   NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  32  *   OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  33  */
  34
  35 #include <alloca.h>
  36 #include <errno.h>
  37 #include <stdio.h>
  38 #include <unistd.h>
  39 #include <rpc/rpc.h>
  40 #include <sys/socket.h>
  41 #include <netdb.h>
  42 #include <string.h>
  43 #include <shlib-compat.h>
  44
  45 struct callrpc_private_s
  46   {
  47     CLIENT *client;
  48     int socket;
  49     u_long oldprognum, oldversnum, valid;
  50     char *oldhost;
  51   };
  52 #ifdef _RPC_THREAD_SAFE_
  53 #define callrpc_private RPC_THREAD_VARIABLE(callrpc_private_s)
  54 #else
  55 static struct callrpc_private_s *callrpc_private;
  56 #endif
  57
  58 int
  59 callrpc (const char *host, u_long prognum, u_long versnum, u_long procnum,
  60          xdrproc_t inproc, const char *in, xdrproc_t outproc, char *out)
  61 {
  62   struct callrpc_private_s *crp = callrpc_private;
  63   struct sockaddr_in server_addr;
  64   enum clnt_stat clnt_stat;
  65   struct timeval timeout, tottimeout;
  66
  67   if (crp == 0)
  68     {
  69       crp = (struct callrpc_private_s *) calloc (1, sizeof (*crp));
  70       if (crp == 0)
  71         return 0;
  72       callrpc_private = crp;
  73     }
  74   if (crp->oldhost == NULL)
  75     {
  76       crp->oldhost = malloc (256);
  77       crp->oldhost[0] = 0;
  78       crp->socket = RPC_ANYSOCK;
  79     }
  80   if (crp->valid && crp->oldprognum == prognum && crp->oldversnum == versnum
  81       && strcmp (crp->oldhost, host) == 0)
  82     {
  83       /* reuse old client */
  84     }
  85   else
  86     {
  87       crp->valid = 0;
  88       if (crp->socket != RPC_ANYSOCK)
  89         {
  90           (void) __close (crp->socket);
  91           crp->socket = RPC_ANYSOCK;
  92         }
  93       if (crp->client)
  94         {
  95           clnt_destroy (crp->client);
  96           crp->client = NULL;
  97         }
  98
  99       if (__libc_rpc_gethostbyname (host, &server_addr) != 0)
 100         return (int) get_rpc_createerr().cf_stat;
 101
 102       timeout.tv_usec = 0;
 103       timeout.tv_sec = 5;
 104       if ((crp->client = clntudp_create (&server_addr, (u_long) prognum,
 105                           (u_long) versnum, timeout, &crp->socket)) == NULL)
 106         return (int) get_rpc_createerr().cf_stat;
 107       crp->valid = 1;
 108       crp->oldprognum = prognum;
 109       crp->oldversnum = versnum;
 110       (void) strncpy (crp->oldhost, host, 255);
 111       crp->oldhost[255] = '\0';
 112     }
 113   tottimeout.tv_sec = 25;
 114   tottimeout.tv_usec = 0;
 115   clnt_stat = clnt_call (crp->client, procnum, inproc, (char *) in,
 116                          outproc, out, tottimeout);
 117   /*
 118    * if call failed, empty cache
 119    */
 120   if (clnt_stat != RPC_SUCCESS)
 121     crp->valid = 0;
 122   return (int) clnt_stat;
 123 }
 124 libc_hidden_nolink_sunrpc (callrpc, GLIBC_2_0)
 125
 126 #ifdef _RPC_THREAD_SAFE_
 127 void
 128 __rpc_thread_clnt_cleanup (void)
 129 {
 130         struct callrpc_private_s *rcp = RPC_THREAD_VARIABLE(callrpc_private_s);
 131
 132         if (rcp) {
 133                 if (rcp->client)
 134                         CLNT_DESTROY (rcp->client);
 135                 free (rcp);
 136         }
 137 }
 138 #endif /* _RPC_THREAD_SAFE_ */