1 /* $NetBSD: clnt_simple.c,v 1.21 2000/07/06 03:10:34 christos Exp $ */
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.
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.
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.
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.
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.
27 * Sun Microsystems, Inc.
29 * Mountain View, California 94043
32 * Copyright (c) 1986-1991 by Sun Microsystems Inc.
35 #if defined(LIBC_SCCS) && !defined(lint)
36 static char *sccsid2 = "from: @(#)clnt_simple.c 1.35 87/08/11 Copyr 1984 Sun Micro";
37 static char *sccsid = "from: @(#)clnt_simple.c 2.2 88/08/01 4.0 RPCSRC";
39 #include <sys/cdefs.h>
40 __FBSDID("$FreeBSD$");
44 * Simplified front end to client rpc.
48 #include "namespace.h"
49 #include "reentrant.h"
50 #include <sys/param.h>
58 #include "un-namespace.h"
61 #ifndef MAXHOSTNAMELEN
62 #define MAXHOSTNAMELEN 64
69 struct rpc_call_private {
70 int valid; /* Is this entry valid ? */
71 CLIENT *client; /* Client handle */
72 pid_t pid; /* process-id at moment of creation */
73 rpcprog_t prognum; /* Program */
74 rpcvers_t versnum; /* Version */
75 char host[MAXHOSTNAMELEN]; /* Servers host */
76 char nettype[NETIDLEN]; /* Network type */
78 static struct rpc_call_private *rpc_call_private_main;
80 static void rpc_call_destroy(void *);
83 rpc_call_destroy(void *vp)
85 struct rpc_call_private *rcp = (struct rpc_call_private *)vp;
89 CLNT_DESTROY(rcp->client);
95 * This is the simplified interface to the client rpc layer.
96 * The client handle is not destroyed here and is reused for
97 * the future calls to same prog, vers, host and nettype combination.
99 * The total time available is 25 seconds.
102 rpc_call(host, prognum, versnum, procnum, inproc, in, outproc, out, nettype)
103 const char *host; /* host name */
104 rpcprog_t prognum; /* program number */
105 rpcvers_t versnum; /* version number */
106 rpcproc_t procnum; /* procedure number */
107 xdrproc_t inproc, outproc; /* in/out XDR procedures */
109 char *out; /* recv/send data */
110 const char *nettype; /* nettype */
112 struct rpc_call_private *rcp = (struct rpc_call_private *) 0;
113 enum clnt_stat clnt_stat;
114 struct timeval timeout, tottimeout;
115 static thread_key_t rpc_call_key;
118 if ((main_thread = thr_main())) {
119 rcp = rpc_call_private_main;
121 if (rpc_call_key == 0) {
122 mutex_lock(&tsd_lock);
123 if (rpc_call_key == 0)
124 thr_keycreate(&rpc_call_key, rpc_call_destroy);
125 mutex_unlock(&tsd_lock);
127 rcp = (struct rpc_call_private *)thr_getspecific(rpc_call_key);
130 rcp = malloc(sizeof (*rcp));
132 rpc_createerr.cf_stat = RPC_SYSTEMERROR;
133 rpc_createerr.cf_error.re_errno = errno;
134 return (rpc_createerr.cf_stat);
137 rpc_call_private_main = rcp;
139 thr_setspecific(rpc_call_key, (void *) rcp);
143 if ((nettype == NULL) || (nettype[0] == 0))
145 if (!(rcp->valid && rcp->pid == getpid() &&
146 (rcp->prognum == prognum) &&
147 (rcp->versnum == versnum) &&
148 (!strcmp(rcp->host, host)) &&
149 (!strcmp(rcp->nettype, nettype)))) {
154 CLNT_DESTROY(rcp->client);
156 * Using the first successful transport for that type
158 rcp->client = clnt_create(host, prognum, versnum, nettype);
160 if (rcp->client == NULL) {
161 return (rpc_createerr.cf_stat);
164 * Set time outs for connectionless case. Do it
165 * unconditionally. Faster than doing a t_getinfo()
166 * and then doing the right thing.
170 (void) CLNT_CONTROL(rcp->client,
171 CLSET_RETRY_TIMEOUT, (char *)(void *)&timeout);
172 if (CLNT_CONTROL(rcp->client, CLGET_FD, (char *)(void *)&fd))
173 _fcntl(fd, F_SETFD, 1); /* make it "close on exec" */
174 rcp->prognum = prognum;
175 rcp->versnum = versnum;
176 if ((strlen(host) < (size_t)MAXHOSTNAMELEN) &&
177 (strlen(nettype) < (size_t)NETIDLEN)) {
178 (void) strcpy(rcp->host, host);
179 (void) strcpy(rcp->nettype, nettype);
184 } /* else reuse old client */
185 tottimeout.tv_sec = 25;
186 tottimeout.tv_usec = 0;
187 /*LINTED const castaway*/
188 clnt_stat = CLNT_CALL(rcp->client, procnum, inproc, (char *) in,
189 outproc, out, tottimeout);
191 * if call failed, empty cache
193 if (clnt_stat != RPC_SUCCESS)