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
  44 struct callrpc_private_s
  45   {
  46     CLIENT *client;
  47     int socket;
  48     u_long oldprognum, oldversnum, valid;
  49     char *oldhost;
  50   };
  51 #ifdef _RPC_THREAD_SAFE_
  52 #define callrpc_private RPC_THREAD_VARIABLE(callrpc_private_s)
  53 #else
  54 static struct callrpc_private_s *callrpc_private;
  55 #endif
  56
  57 int
  58 callrpc (const char *host, u_long prognum, u_long versnum, u_long procnum,
  59          xdrproc_t inproc, const char *in, xdrproc_t outproc, char *out)
  60 {
  61   struct callrpc_private_s *crp = callrpc_private;
  62   struct sockaddr_in server_addr;
  63   enum clnt_stat clnt_stat;
  64   struct timeval timeout, tottimeout;
  65
  66   if (crp == 0)
  67     {
  68       crp = (struct callrpc_private_s *) calloc (1, sizeof (*crp));
  69       if (crp == 0)
  70         return 0;
  71       callrpc_private = crp;
  72     }
  73   if (crp->oldhost == NULL)
  74     {
  75       crp->oldhost = malloc (256);
  76       crp->oldhost[0] = 0;
  77       crp->socket = RPC_ANYSOCK;
  78     }
  79   if (crp->valid && crp->oldprognum == prognum && crp->oldversnum == versnum
  80       && strcmp (crp->oldhost, host) == 0)
  81     {
  82       /* reuse old client */
  83     }
  84   else
  85     {
  86       crp->valid = 0;
  87       if (crp->socket != RPC_ANYSOCK)
  88         {
  89           (void) __close (crp->socket);
  90           crp->socket = RPC_ANYSOCK;
  91         }
  92       if (crp->client)
  93         {
  94           clnt_destroy (crp->client);
  95           crp->client = NULL;
  96         }
  97
  98       if (__libc_rpc_gethostbyname (host, &server_addr) != 0)
  99         return (int) get_rpc_createerr().cf_stat;
 100
 101       timeout.tv_usec = 0;
 102       timeout.tv_sec = 5;
 103       if ((crp->client = clntudp_create (&server_addr, (u_long) prognum,
 104                           (u_long) versnum, timeout, &crp->socket)) == NULL)
 105         return (int) get_rpc_createerr().cf_stat;
 106       crp->valid = 1;
 107       crp->oldprognum = prognum;
 108       crp->oldversnum = versnum;
 109       (void) strncpy (crp->oldhost, host, 255);
 110       crp->oldhost[255] = '\0';
 111     }
 112   tottimeout.tv_sec = 25;
 113   tottimeout.tv_usec = 0;
 114   clnt_stat = clnt_call (crp->client, procnum, inproc, (char *) in,
 115                          outproc, out, tottimeout);
 116   /*
 117    * if call failed, empty cache
 118    */
 119   if (clnt_stat != RPC_SUCCESS)
 120     crp->valid = 0;
 121   return (int) clnt_stat;
 122 }
 123 libc_hidden_nolink_sunrpc (callrpc, GLIBC_2_0)
 124
 125 #ifdef _RPC_THREAD_SAFE_
 126 void
 127 __rpc_thread_clnt_cleanup (void)
 128 {
 129         struct callrpc_private_s *rcp = RPC_THREAD_VARIABLE(callrpc_private_s);
 130
 131         if (rcp) {
 132                 if (rcp->client)
 133                         CLNT_DESTROY (rcp->client);
 134                 free (rcp);
 135         }
 136 }
 137 #endif /* _RPC_THREAD_SAFE_ */