1 /* $NetBSD: clnt_simple.c,v 1.22 2001/01/04 14:42:19 lukem Exp $ */ 2 3 /* 4 * Sun RPC is a product of Sun Microsystems, Inc. and is provided for 5 * unrestricted use provided that this legend is included on all tape 6 * media and as a part of the software program in whole or part. Users 7 * may copy or modify Sun RPC without charge, but are not authorized 8 * to license or distribute it to anyone else except as part of a product or 9 * program developed by the user. 10 * 11 * SUN RPC IS PROVIDED AS IS WITH NO WARRANTIES OF ANY KIND INCLUDING THE 12 * WARRANTIES OF DESIGN, MERCHANTIBILITY AND FITNESS FOR A PARTICULAR 13 * PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE OR TRADE PRACTICE. 14 * 15 * Sun RPC is provided with no support and without any obligation on the 16 * part of Sun Microsystems, Inc. to assist in its use, correction, 17 * modification or enhancement. 18 * 19 * SUN MICROSYSTEMS, INC. SHALL HAVE NO LIABILITY WITH RESPECT TO THE 20 * INFRINGEMENT OF COPYRIGHTS, TRADE SECRETS OR ANY PATENTS BY SUN RPC 21 * OR ANY PART THEREOF. 22 * 23 * In no event will Sun Microsystems, Inc. be liable for any lost revenue 24 * or profits or other special, indirect and consequential damages, even if 25 * Sun has been advised of the possibility of such damages. 26 * 27 * Sun Microsystems, Inc. 28 * 2550 Garcia Avenue 29 * Mountain View, California 94043 30 */ 31 /* 32 * Copyright (c) 1986-1991 by Sun Microsystems Inc. 33 */ 34 35 /* #ident "@(#)clnt_simple.c 1.17 94/04/24 SMI" */ 36 37 #if 0 38 #if !defined(lint) && defined(SCCSIDS) 39 static char sccsid[] = "@(#)clnt_simple.c 1.49 89/01/31 Copyr 1984 Sun Micro"; 40 #endif 41 #endif 42 43 /* 44 * clnt_simple.c 45 * Simplified front end to client rpc. 46 * 47 */ 48 49 #include "namespace.h" 50 #include "reentrant.h" 51 #include <sys/param.h> 52 #include <stdio.h> 53 #include <assert.h> 54 #include <errno.h> 55 #include <rpc/rpc.h> 56 #include <string.h> 57 #include <stdlib.h> 58 #include <fcntl.h> 59 #include <unistd.h> 60 61 #ifdef __weak_alias 62 __weak_alias(rpc_call,_rpc_call) 63 #endif 64 65 #ifndef MAXHOSTNAMELEN 66 #define MAXHOSTNAMELEN 64 67 #endif 68 69 #ifndef NETIDLEN 70 #define NETIDLEN 32 71 #endif 72 73 struct rpc_call_private { 74 int valid; /* Is this entry valid ? */ 75 CLIENT *client; /* Client handle */ 76 pid_t pid; /* process-id at moment of creation */ 77 rpcprog_t prognum; /* Program */ 78 rpcvers_t versnum; /* Version */ 79 char host[MAXHOSTNAMELEN]; /* Servers host */ 80 char nettype[NETIDLEN]; /* Network type */ 81 }; 82 static struct rpc_call_private *rpc_call_private_main; 83 84 #ifdef __REENT 85 static void rpc_call_destroy __P((void *)); 86 87 static void 88 rpc_call_destroy(void *vp) 89 { 90 struct rpc_call_private *rcp = (struct rpc_call_private *)vp; 91 92 if (rcp) { 93 if (rcp->client) 94 CLNT_DESTROY(rcp->client); 95 free(rcp); 96 } 97 } 98 #endif 99 100 /* 101 * This is the simplified interface to the client rpc layer. 102 * The client handle is not destroyed here and is reused for 103 * the future calls to same prog, vers, host and nettype combination. 104 * 105 * The total time available is 25 seconds. 106 */ 107 enum clnt_stat 108 rpc_call(host, prognum, versnum, procnum, inproc, in, outproc, out, nettype) 109 const char *host; /* host name */ 110 rpcprog_t prognum; /* program number */ 111 rpcvers_t versnum; /* version number */ 112 rpcproc_t procnum; /* procedure number */ 113 xdrproc_t inproc, outproc; /* in/out XDR procedures */ 114 const char *in; 115 char *out; /* recv/send data */ 116 const char *nettype; /* nettype */ 117 { 118 struct rpc_call_private *rcp = (struct rpc_call_private *) 0; 119 enum clnt_stat clnt_stat; 120 struct timeval timeout, tottimeout; 121 #ifdef __REENT 122 static thread_key_t rpc_call_key; 123 extern mutex_t tsd_lock; 124 #endif 125 int main_thread = 1; 126 127 _DIAGASSERT(host != NULL); 128 /* XXX: in may be NULL ??? */ 129 /* XXX: out may be NULL ??? */ 130 /* XXX: nettype may be NULL ??? */ 131 132 #ifdef __REENT 133 if ((main_thread = _thr_main())) { 134 rcp = rpc_call_private_main; 135 } else { 136 if (rpc_call_key == 0) { 137 mutex_lock(&tsd_lock); 138 if (rpc_call_key == 0) 139 thr_keycreate(&rpc_call_key, rpc_call_destroy); 140 mutex_unlock(&tsd_lock); 141 } 142 thr_getspecific(rpc_call_key, (void **) &rcp); 143 } 144 #else 145 rcp = rpc_call_private_main; 146 #endif 147 if (rcp == NULL) { 148 rcp = malloc(sizeof (*rcp)); 149 if (rcp == NULL) { 150 rpc_createerr.cf_stat = RPC_SYSTEMERROR; 151 rpc_createerr.cf_error.re_errno = errno; 152 return (rpc_createerr.cf_stat); 153 } 154 if (main_thread) 155 rpc_call_private_main = rcp; 156 else 157 thr_setspecific(rpc_call_key, (void *) rcp); 158 rcp->valid = 0; 159 rcp->client = NULL; 160 } 161 if ((nettype == NULL) || (nettype[0] == NULL)) 162 nettype = "netpath"; 163 if (!(rcp->valid && rcp->pid == getpid() && 164 (rcp->prognum == prognum) && 165 (rcp->versnum == versnum) && 166 (!strcmp(rcp->host, host)) && 167 (!strcmp(rcp->nettype, nettype)))) { 168 int fd; 169 170 rcp->valid = 0; 171 if (rcp->client) 172 CLNT_DESTROY(rcp->client); 173 /* 174 * Using the first successful transport for that type 175 */ 176 rcp->client = clnt_create(host, prognum, versnum, nettype); 177 rcp->pid = getpid(); 178 if (rcp->client == NULL) { 179 return (rpc_createerr.cf_stat); 180 } 181 /* 182 * Set time outs for connectionless case. Do it 183 * unconditionally. Faster than doing a t_getinfo() 184 * and then doing the right thing. 185 */ 186 timeout.tv_usec = 0; 187 timeout.tv_sec = 5; 188 (void) CLNT_CONTROL(rcp->client, 189 CLSET_RETRY_TIMEOUT, (char *)(void *)&timeout); 190 if (CLNT_CONTROL(rcp->client, CLGET_FD, (char *)(void *)&fd)) 191 fcntl(fd, F_SETFD, 1); /* make it "close on exec" */ 192 rcp->prognum = prognum; 193 rcp->versnum = versnum; 194 if ((strlen(host) < (size_t)MAXHOSTNAMELEN) && 195 (strlen(nettype) < (size_t)NETIDLEN)) { 196 (void) strcpy(rcp->host, host); 197 (void) strcpy(rcp->nettype, nettype); 198 rcp->valid = 1; 199 } else { 200 rcp->valid = 0; 201 } 202 } /* else reuse old client */ 203 tottimeout.tv_sec = 25; 204 tottimeout.tv_usec = 0; 205 /*LINTED const castaway*/ 206 clnt_stat = CLNT_CALL(rcp->client, procnum, inproc, (char *) in, 207 outproc, out, tottimeout); 208 /* 209 * if call failed, empty cache 210 */ 211 if (clnt_stat != RPC_SUCCESS) 212 rcp->valid = 0; 213 return (clnt_stat); 214 } 215