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