Home | History | Annotate | Line # | Download | only in rpc
clnt_simple.c revision 1.6.2.1
      1  1.6.2.1      jtc /*	$NetBSD: clnt_simple.c,v 1.6.2.1 1996/09/16 23:44:22 jtc Exp $	*/
      2      1.3      cgd 
      3      1.1      cgd /*
      4      1.1      cgd  * Sun RPC is a product of Sun Microsystems, Inc. and is provided for
      5      1.1      cgd  * unrestricted use provided that this legend is included on all tape
      6      1.1      cgd  * media and as a part of the software program in whole or part.  Users
      7      1.1      cgd  * may copy or modify Sun RPC without charge, but are not authorized
      8      1.1      cgd  * to license or distribute it to anyone else except as part of a product or
      9      1.1      cgd  * program developed by the user.
     10      1.1      cgd  *
     11      1.1      cgd  * SUN RPC IS PROVIDED AS IS WITH NO WARRANTIES OF ANY KIND INCLUDING THE
     12      1.1      cgd  * WARRANTIES OF DESIGN, MERCHANTIBILITY AND FITNESS FOR A PARTICULAR
     13      1.1      cgd  * PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE OR TRADE PRACTICE.
     14      1.1      cgd  *
     15      1.1      cgd  * Sun RPC is provided with no support and without any obligation on the
     16      1.1      cgd  * part of Sun Microsystems, Inc. to assist in its use, correction,
     17      1.1      cgd  * modification or enhancement.
     18      1.1      cgd  *
     19      1.1      cgd  * SUN MICROSYSTEMS, INC. SHALL HAVE NO LIABILITY WITH RESPECT TO THE
     20      1.1      cgd  * INFRINGEMENT OF COPYRIGHTS, TRADE SECRETS OR ANY PATENTS BY SUN RPC
     21      1.1      cgd  * OR ANY PART THEREOF.
     22      1.1      cgd  *
     23      1.1      cgd  * In no event will Sun Microsystems, Inc. be liable for any lost revenue
     24      1.1      cgd  * or profits or other special, indirect and consequential damages, even if
     25      1.1      cgd  * Sun has been advised of the possibility of such damages.
     26      1.1      cgd  *
     27      1.1      cgd  * Sun Microsystems, Inc.
     28      1.1      cgd  * 2550 Garcia Avenue
     29      1.1      cgd  * Mountain View, California  94043
     30      1.1      cgd  */
     31      1.1      cgd 
     32      1.1      cgd #if defined(LIBC_SCCS) && !defined(lint)
     33      1.1      cgd /*static char *sccsid = "from: @(#)clnt_simple.c 1.35 87/08/11 Copyr 1984 Sun Micro";*/
     34      1.1      cgd /*static char *sccsid = "from: @(#)clnt_simple.c	2.2 88/08/01 4.0 RPCSRC";*/
     35  1.6.2.1      jtc static char *rcsid = "$NetBSD: clnt_simple.c,v 1.6.2.1 1996/09/16 23:44:22 jtc Exp $";
     36      1.1      cgd #endif
     37      1.1      cgd 
     38      1.1      cgd /*
     39      1.1      cgd  * clnt_simple.c
     40      1.1      cgd  * Simplified front end to rpc.
     41      1.1      cgd  *
     42      1.1      cgd  * Copyright (C) 1984, Sun Microsystems, Inc.
     43      1.1      cgd  */
     44      1.1      cgd 
     45  1.6.2.1      jtc #include "namespace.h"
     46      1.1      cgd #include <stdio.h>
     47      1.1      cgd #include <stdlib.h>
     48      1.1      cgd #include <string.h>
     49      1.1      cgd #include <rpc/rpc.h>
     50      1.1      cgd #include <sys/socket.h>
     51      1.1      cgd #include <netdb.h>
     52  1.6.2.1      jtc 
     53  1.6.2.1      jtc #ifdef __weak_alias
     54  1.6.2.1      jtc __weak_alias(callrpc,_callrpc);
     55  1.6.2.1      jtc #endif
     56      1.1      cgd 
     57      1.1      cgd static struct callrpc_private {
     58      1.1      cgd 	CLIENT	*client;
     59      1.1      cgd 	int	socket;
     60      1.1      cgd 	int	oldprognum, oldversnum, valid;
     61      1.1      cgd 	char	*oldhost;
     62      1.1      cgd } *callrpc_private;
     63      1.1      cgd 
     64      1.6      jtc int
     65      1.1      cgd callrpc(host, prognum, versnum, procnum, inproc, in, outproc, out)
     66      1.1      cgd 	char *host;
     67      1.1      cgd 	xdrproc_t inproc, outproc;
     68      1.1      cgd 	char *in, *out;
     69      1.1      cgd {
     70      1.1      cgd 	register struct callrpc_private *crp = callrpc_private;
     71      1.1      cgd 	struct sockaddr_in server_addr;
     72      1.1      cgd 	enum clnt_stat clnt_stat;
     73      1.1      cgd 	struct hostent *hp;
     74      1.1      cgd 	struct timeval timeout, tottimeout;
     75      1.1      cgd 
     76      1.1      cgd 	if (crp == 0) {
     77      1.1      cgd 		crp = (struct callrpc_private *)calloc(1, sizeof (*crp));
     78      1.1      cgd 		if (crp == 0)
     79      1.1      cgd 			return (0);
     80      1.1      cgd 		callrpc_private = crp;
     81      1.1      cgd 	}
     82      1.1      cgd 	if (crp->oldhost == NULL) {
     83      1.1      cgd 		crp->oldhost = malloc(256);
     84      1.1      cgd 		crp->oldhost[0] = 0;
     85      1.1      cgd 		crp->socket = RPC_ANYSOCK;
     86      1.1      cgd 	}
     87      1.1      cgd 	if (crp->valid && crp->oldprognum == prognum && crp->oldversnum == versnum
     88      1.1      cgd 		&& strcmp(crp->oldhost, host) == 0) {
     89      1.1      cgd 		/* reuse old client */
     90      1.1      cgd 	} else {
     91      1.1      cgd 		crp->valid = 0;
     92      1.1      cgd 		(void)close(crp->socket);
     93      1.1      cgd 		crp->socket = RPC_ANYSOCK;
     94      1.1      cgd 		if (crp->client) {
     95      1.1      cgd 			clnt_destroy(crp->client);
     96      1.1      cgd 			crp->client = NULL;
     97      1.1      cgd 		}
     98      1.1      cgd 		if ((hp = gethostbyname(host)) == NULL)
     99      1.1      cgd 			return ((int) RPC_UNKNOWNHOST);
    100      1.1      cgd 		timeout.tv_usec = 0;
    101      1.1      cgd 		timeout.tv_sec = 5;
    102      1.4      jtc 		memset(&server_addr, 0, sizeof(server_addr));
    103      1.1      cgd 		bcopy(hp->h_addr, (char *)&server_addr.sin_addr, hp->h_length);
    104      1.5  mycroft 		server_addr.sin_len = sizeof(struct sockaddr_in);
    105      1.1      cgd 		server_addr.sin_family = AF_INET;
    106      1.1      cgd 		server_addr.sin_port =  0;
    107      1.1      cgd 		if ((crp->client = clntudp_create(&server_addr, (u_long)prognum,
    108      1.1      cgd 		    (u_long)versnum, timeout, &crp->socket)) == NULL)
    109      1.1      cgd 			return ((int) rpc_createerr.cf_stat);
    110      1.1      cgd 		crp->valid = 1;
    111      1.1      cgd 		crp->oldprognum = prognum;
    112      1.1      cgd 		crp->oldversnum = versnum;
    113      1.1      cgd 		(void) strcpy(crp->oldhost, host);
    114      1.1      cgd 	}
    115      1.1      cgd 	tottimeout.tv_sec = 25;
    116      1.1      cgd 	tottimeout.tv_usec = 0;
    117      1.1      cgd 	clnt_stat = clnt_call(crp->client, procnum, inproc, in,
    118      1.1      cgd 	    outproc, out, tottimeout);
    119      1.1      cgd 	/*
    120      1.1      cgd 	 * if call failed, empty cache
    121      1.1      cgd 	 */
    122      1.1      cgd 	if (clnt_stat != RPC_SUCCESS)
    123      1.1      cgd 		crp->valid = 0;
    124      1.1      cgd 	return ((int) clnt_stat);
    125      1.1      cgd }
    126