clnt_simple.c revision 156090 
1/*	$NetBSD: clnt_simple.c,v 1.21 2000/07/06 03:10:34 christos 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#if defined(LIBC_SCCS) && !defined(lint)
36static char *sccsid2 = "from: @(#)clnt_simple.c 1.35 87/08/11 Copyr 1984 Sun Micro";
37static char *sccsid = "from: @(#)clnt_simple.c	2.2 88/08/01 4.0 RPCSRC";
38#endif
39#include <sys/cdefs.h>
40__FBSDID("$FreeBSD: head/lib/libc/rpc/clnt_simple.c 156090 2006-02-27 22:10:59Z deischen $");
41
42/*
43 * clnt_simple.c
44 * Simplified front end to client rpc.
45 *
46 */
47
48#include "namespace.h"
49#include "reentrant.h"
50#include <sys/param.h>
51#include <stdio.h>
52#include <errno.h>
53#include <rpc/rpc.h>
54#include <string.h>
55#include <stdlib.h>
56#include <fcntl.h>
57#include <unistd.h>
58#include "un-namespace.h"
59#include "mt_misc.h"
60
61#ifndef MAXHOSTNAMELEN
62#define	MAXHOSTNAMELEN 64
63#endif
64
65#ifndef NETIDLEN
66#define	NETIDLEN 32
67#endif
68
69struct 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 */
77};
78static struct rpc_call_private *rpc_call_private_main;
79
80static void rpc_call_destroy(void *);
81
82static void
83rpc_call_destroy(void *vp)
84{
85	struct rpc_call_private *rcp = (struct rpc_call_private *)vp;
86
87	if (rcp) {
88		if (rcp->client)
89			CLNT_DESTROY(rcp->client);
90		free(rcp);
91	}
92}
93
94/*
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.
98 *
99 * The total time available is 25 seconds.
100 */
101enum clnt_stat
102rpc_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 */
108	const char *in;
109	char  *out;			/* recv/send data */
110	const char *nettype;			/* nettype */
111{
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;
116	int main_thread = 1;
117
118	if ((main_thread = thr_main())) {
119		rcp = rpc_call_private_main;
120	} else {
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);
126		}
127		rcp = (struct rpc_call_private *)thr_getspecific(rpc_call_key);
128	}
129	if (rcp == NULL) {
130		rcp = malloc(sizeof (*rcp));
131		if (rcp == NULL) {
132			rpc_createerr.cf_stat = RPC_SYSTEMERROR;
133			rpc_createerr.cf_error.re_errno = errno;
134			return (rpc_createerr.cf_stat);
135		}
136		if (main_thread)
137			rpc_call_private_main = rcp;
138		else
139			thr_setspecific(rpc_call_key, (void *) rcp);
140		rcp->valid = 0;
141		rcp->client = NULL;
142	}
143	if ((nettype == NULL) || (nettype[0] == 0))
144		nettype = "netpath";
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)))) {
150		int fd;
151
152		rcp->valid = 0;
153		if (rcp->client)
154			CLNT_DESTROY(rcp->client);
155		/*
156		 * Using the first successful transport for that type
157		 */
158		rcp->client = clnt_create(host, prognum, versnum, nettype);
159		rcp->pid = getpid();
160		if (rcp->client == NULL) {
161			return (rpc_createerr.cf_stat);
162		}
163		/*
164		 * Set time outs for connectionless case.  Do it
165		 * unconditionally.  Faster than doing a t_getinfo()
166		 * and then doing the right thing.
167		 */
168		timeout.tv_usec = 0;
169		timeout.tv_sec = 5;
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);
180			rcp->valid = 1;
181		} else {
182			rcp->valid = 0;
183		}
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);
190	/*
191	 * if call failed, empty cache
192	 */
193	if (clnt_stat != RPC_SUCCESS)
194		rcp->valid = 0;
195	return (clnt_stat);
196}
197