xref: /dragonfly/include/rpc/clnt.h (revision d4ef6694)
1 /*
2  * The contents of this file are subject to the Sun Standards
3  * License Version 1.0 the (the "License";) You may not use
4  * this file except in compliance with the License.  You may
5  * obtain a copy of the License at lib/libc/rpc/LICENSE
6  *
7  * Software distributed under the License is distributed on
8  * an "AS IS" basis, WITHOUT WARRANTY OF ANY KIND, either
9  * express or implied.  See the License for the specific
10  * language governing rights and limitations under the License.
11  *
12  * The Original Code is Copyright 1998 by Sun Microsystems, Inc
13  *
14  * The Initial Developer of the Original Code is:  Sun
15  * Microsystems, Inc.
16  *
17  * All Rights Reserved.
18  *
19  * Sun RPC is a product of Sun Microsystems, Inc. and is provided for
20  * unrestricted use provided that this legend is included on all tape
21  * media and as a part of the software program in whole or part.  Users
22  * may copy or modify Sun RPC without charge, but are not authorized
23  * to license or distribute it to anyone else except as part of a product or
24  * program developed by the user.
25  *
26  * SUN RPC IS PROVIDED AS IS WITH NO WARRANTIES OF ANY KIND INCLUDING THE
27  * WARRANTIES OF DESIGN, MERCHANTABILITY AND FITNESS FOR A PARTICULAR
28  * PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE OR TRADE PRACTICE.
29  *
30  * Sun RPC is provided with no support and without any obligation on the
31  * part of Sun Microsystems, Inc. to assist in its use, correction,
32  * modification or enhancement.
33  *
34  * SUN MICROSYSTEMS, INC. SHALL HAVE NO LIABILITY WITH RESPECT TO THE
35  * INFRINGEMENT OF COPYRIGHTS, TRADE SECRETS OR ANY PATENTS BY SUN RPC
36  * OR ANY PART THEREOF.
37  *
38  * In no event will Sun Microsystems, Inc. be liable for any lost revenue
39  * or profits or other special, indirect and consequential damages, even if
40  * Sun has been advised of the possibility of such damages.
41  *
42  * Sun Microsystems, Inc.
43  * 2550 Garcia Avenue
44  * Mountain View, California  94043
45  *
46  *	from: @(#)clnt.h 1.31 94/04/29 SMI
47  *	from: @(#)clnt.h	2.1 88/07/29 4.0 RPCSRC
48  * $NetBSD: clnt.h,v 1.14 2000/06/02 22:57:55 fvdl Exp $
49  * $FreeBSD: src/include/rpc/clnt.h,v 1.21 2003/01/24 01:47:55 fjoe Exp $
50  * $DragonFly: src/include/rpc/clnt.h,v 1.6 2005/11/13 12:27:04 swildner Exp $
51  */
52 
53 /*
54  * clnt.h - Client side remote procedure call interface.
55  *
56  * Copyright (c) 1986-1991,1994-1999 by Sun Microsystems, Inc.
57  * All rights reserved.
58  */
59 
60 #ifndef _RPC_CLNT_H_
61 #define _RPC_CLNT_H_
62 #include <rpc/clnt_stat.h>
63 #include <sys/cdefs.h>
64 #include <netconfig.h>
65 #include <sys/un.h>
66 
67 /*
68  * Well-known IPV6 RPC broadcast address.
69  */
70 #define RPCB_MULTICAST_ADDR "ff02::202"
71 
72 /*
73  * the following errors are in general unrecoverable.  The caller
74  * should give up rather than retry.
75  */
76 #define IS_UNRECOVERABLE_RPC(s) (((s) == RPC_AUTHERROR) || \
77 	((s) == RPC_CANTENCODEARGS) || \
78 	((s) == RPC_CANTDECODERES) || \
79 	((s) == RPC_VERSMISMATCH) || \
80 	((s) == RPC_PROCUNAVAIL) || \
81 	((s) == RPC_PROGUNAVAIL) || \
82 	((s) == RPC_PROGVERSMISMATCH) || \
83 	((s) == RPC_CANTDECODEARGS))
84 
85 /*
86  * Error info.
87  */
88 struct rpc_err {
89 	enum clnt_stat re_status;
90 	union {
91 		int RE_errno;		/* related system error */
92 		enum auth_stat RE_why;	/* why the auth error occurred */
93 		struct {
94 			rpcvers_t low;	/* lowest version supported */
95 			rpcvers_t high;	/* highest version supported */
96 		} RE_vers;
97 		struct {		/* maybe meaningful if RPC_FAILED */
98 			int32_t s1;
99 			int32_t s2;
100 		} RE_lb;		/* life boot & debugging only */
101 	} ru;
102 #define	re_errno	ru.RE_errno
103 #define	re_why		ru.RE_why
104 #define	re_vers		ru.RE_vers
105 #define	re_lb		ru.RE_lb
106 };
107 
108 
109 /*
110  * Client rpc handle.
111  * Created by individual implementations
112  * Client is responsible for initializing auth, see e.g. auth_none.c.
113  */
114 typedef struct __rpc_client {
115 	AUTH	*cl_auth;			/* authenticator */
116 	struct clnt_ops {
117 		/* call remote procedure */
118 		enum clnt_stat	(*cl_call)(struct __rpc_client *,
119 				    rpcproc_t, xdrproc_t, void *, xdrproc_t,
120 				        void *, struct timeval);
121 		/* abort a call */
122 		void		(*cl_abort)(struct __rpc_client *);
123 		/* get specific error code */
124 		void		(*cl_geterr)(struct __rpc_client *,
125 					struct rpc_err *);
126 		/* frees results */
127 		bool_t		(*cl_freeres)(struct __rpc_client *,
128 					xdrproc_t, void *);
129 		/* destroy this structure */
130 		void		(*cl_destroy)(struct __rpc_client *);
131 		/* the ioctl() of rpc */
132 		bool_t          (*cl_control)(struct __rpc_client *, u_int,
133 				    void *);
134 	} *cl_ops;
135 	void 			*cl_private;	/* private stuff */
136 	char			*cl_netid;	/* network token */
137 	char			*cl_tp;		/* device name */
138 } CLIENT;
139 
140 
141 /*
142  * Timers used for the pseudo-transport protocol when using datagrams
143  */
144 struct rpc_timers {
145 	u_short		rt_srtt;	/* smoothed round-trip time */
146 	u_short		rt_deviate;	/* estimated deviation */
147 	u_long		rt_rtxcur;	/* current (backed-off) rto */
148 };
149 
150 /*
151  * Feedback values used for possible congestion and rate control
152  */
153 #define FEEDBACK_REXMIT1	1	/* first retransmit */
154 #define FEEDBACK_OK		2	/* no retransmits */
155 
156 /* Used to set version of portmapper used in broadcast */
157 
158 #define CLCR_SET_LOWVERS	3
159 #define CLCR_GET_LOWVERS	4
160 
161 #define RPCSMALLMSGSIZE 400	/* a more reasonable packet size */
162 
163 /*
164  * client side rpc interface ops
165  *
166  * Parameter types are:
167  *
168  */
169 
170 /*
171  * enum clnt_stat
172  * CLNT_CALL(rh, proc, xargs, argsp, xres, resp, timeout)
173  * 	CLIENT *rh;
174  *	rpcproc_t proc;
175  *	xdrproc_t xargs;
176  *	void *argsp;
177  *	xdrproc_t xres;
178  *	void *resp;
179  *	struct timeval timeout;
180  */
181 #define	CLNT_CALL(rh, proc, xargs, argsp, xres, resp, secs) \
182 	((*(rh)->cl_ops->cl_call)(rh, proc, xargs, \
183 		argsp, xres, resp, secs))
184 #define	clnt_call(rh, proc, xargs, argsp, xres, resp, secs) \
185 	((*(rh)->cl_ops->cl_call)(rh, proc, xargs, \
186 		argsp, xres, resp, secs))
187 
188 /*
189  * void
190  * CLNT_ABORT(rh);
191  * 	CLIENT *rh;
192  */
193 #define	CLNT_ABORT(rh)	((*(rh)->cl_ops->cl_abort)(rh))
194 #define	clnt_abort(rh)	((*(rh)->cl_ops->cl_abort)(rh))
195 
196 /*
197  * struct rpc_err
198  * CLNT_GETERR(rh);
199  * 	CLIENT *rh;
200  */
201 #define	CLNT_GETERR(rh,errp)	((*(rh)->cl_ops->cl_geterr)(rh, errp))
202 #define	clnt_geterr(rh,errp)	((*(rh)->cl_ops->cl_geterr)(rh, errp))
203 
204 
205 /*
206  * bool_t
207  * CLNT_FREERES(rh, xres, resp);
208  * 	CLIENT *rh;
209  *	xdrproc_t xres;
210  *	void *resp;
211  */
212 #define	CLNT_FREERES(rh,xres,resp) ((*(rh)->cl_ops->cl_freeres)(rh,xres,resp))
213 #define	clnt_freeres(rh,xres,resp) ((*(rh)->cl_ops->cl_freeres)(rh,xres,resp))
214 
215 /*
216  * bool_t
217  * CLNT_CONTROL(cl, request, info)
218  *      CLIENT *cl;
219  *      u_int request;
220  *      char *info;
221  */
222 #define	CLNT_CONTROL(cl,rq,in) ((*(cl)->cl_ops->cl_control)(cl,rq,in))
223 #define	clnt_control(cl,rq,in) ((*(cl)->cl_ops->cl_control)(cl,rq,in))
224 
225 /*
226  * control operations that apply to both udp and tcp transports
227  */
228 #define CLSET_TIMEOUT		1	/* set timeout (timeval) */
229 #define CLGET_TIMEOUT		2	/* get timeout (timeval) */
230 #define CLGET_SERVER_ADDR	3	/* get server's address (sockaddr) */
231 #define CLGET_FD		6	/* get connections file descriptor */
232 #define CLGET_SVC_ADDR		7	/* get server's address (netbuf) */
233 #define CLSET_FD_CLOSE		8	/* close fd while clnt_destroy */
234 #define CLSET_FD_NCLOSE		9	/* Do not close fd while clnt_destroy */
235 #define CLGET_XID 		10	/* Get xid */
236 #define CLSET_XID		11	/* Set xid */
237 #define CLGET_VERS		12	/* Get version number */
238 #define CLSET_VERS		13	/* Set version number */
239 #define CLGET_PROG		14	/* Get program number */
240 #define CLSET_PROG		15	/* Set program number */
241 #define CLSET_SVC_ADDR		16	/* get server's address (netbuf) */
242 #define CLSET_PUSH_TIMOD	17	/* push timod if not already present */
243 #define CLSET_POP_TIMOD		18	/* pop timod */
244 /*
245  * Connectionless only control operations
246  */
247 #define CLSET_RETRY_TIMEOUT 4   /* set retry timeout (timeval) */
248 #define CLGET_RETRY_TIMEOUT 5   /* get retry timeout (timeval) */
249 #define CLSET_ASYNC		19
250 #define CLSET_CONNECT		20	/* Use connect() for UDP. (int) */
251 
252 /*
253  * void
254  * CLNT_DESTROY(rh);
255  * 	CLIENT *rh;
256  */
257 #define	CLNT_DESTROY(rh)	((*(rh)->cl_ops->cl_destroy)(rh))
258 #define	clnt_destroy(rh)	((*(rh)->cl_ops->cl_destroy)(rh))
259 
260 
261 /*
262  * RPCTEST is a test program which is accessible on every rpc
263  * transport/port.  It is used for testing, performance evaluation,
264  * and network administration.
265  */
266 
267 #define RPCTEST_PROGRAM		((rpcprog_t)1)
268 #define RPCTEST_VERSION		((rpcvers_t)1)
269 #define RPCTEST_NULL_PROC	((rpcproc_t)2)
270 #define RPCTEST_NULL_BATCH_PROC	((rpcproc_t)3)
271 
272 /*
273  * By convention, procedure 0 takes null arguments and returns them
274  */
275 
276 #define NULLPROC ((rpcproc_t)0)
277 
278 /*
279  * Below are the client handle creation routines for the various
280  * implementations of client side rpc.  They can return NULL if a
281  * creation failure occurs.
282  */
283 
284 /*
285  * Generic client creation routine. Supported protocols are those that
286  * belong to the nettype namespace (/etc/netconfig).
287  */
288 __BEGIN_DECLS
289 extern CLIENT *clnt_create(const char *, const rpcprog_t, const rpcvers_t,
290 			   const char *);
291 /*
292  *
293  * 	const char *hostname;			-- hostname
294  *	const rpcprog_t prog;			-- program number
295  *	const rpcvers_t vers;			-- version number
296  *	const char *nettype;			-- network type
297  */
298 
299  /*
300  * Generic client creation routine. Just like clnt_create(), except
301  * it takes an additional timeout parameter.
302  */
303 extern CLIENT * clnt_create_timed(const char *, const rpcprog_t,
304 	const rpcvers_t, const char *, const struct timeval *);
305 /*
306  *
307  *	const char *hostname;			-- hostname
308  *	const rpcprog_t prog;			-- program number
309  *	const rpcvers_t vers;			-- version number
310  *	const char *nettype;			-- network type
311  *	const struct timeval *tp;		-- timeout
312  */
313 
314 /*
315  * Generic client creation routine. Supported protocols are which belong
316  * to the nettype name space.
317  */
318 extern CLIENT *clnt_create_vers(const char *, const rpcprog_t, rpcvers_t *,
319 				const rpcvers_t, const rpcvers_t,
320 				const char *);
321 /*
322  *	const char *host;		-- hostname
323  *	const rpcprog_t prog;		-- program number
324  *	rpcvers_t *vers_out;		-- servers highest available version
325  *	const rpcvers_t vers_low;	-- low version number
326  *	const rpcvers_t vers_high;	-- high version number
327  *	const char *nettype;		-- network type
328  */
329 
330 /*
331  * Generic client creation routine. Supported protocols are which belong
332  * to the nettype name space.
333  */
334 extern CLIENT * clnt_create_vers_timed(const char *, const rpcprog_t,
335 	rpcvers_t *, const rpcvers_t, const rpcvers_t, const char *,
336 	const struct timeval *);
337 /*
338  *	const char *host;		-- hostname
339  *	const rpcprog_t prog;		-- program number
340  *	rpcvers_t *vers_out;		-- servers highest available version
341  *	const rpcvers_t vers_low;	-- low version number
342  *	const rpcvers_t vers_high;	-- high version number
343  *	const char *nettype;		-- network type
344  *	const struct timeval *tp	-- timeout
345  */
346 
347 /*
348  * Generic client creation routine. It takes a netconfig structure
349  * instead of nettype
350  */
351 extern CLIENT *clnt_tp_create(const char *, const rpcprog_t,
352 			      const rpcvers_t, const struct netconfig *);
353 /*
354  *	const char *hostname;			-- hostname
355  *	const rpcprog_t prog;			-- program number
356  *	const rpcvers_t vers;			-- version number
357  *	const struct netconfig *netconf; 	-- network config structure
358  */
359 
360 /*
361  * Generic client creation routine. Just like clnt_tp_create(), except
362  * it takes an additional timeout parameter.
363  */
364 extern CLIENT * clnt_tp_create_timed(const char *, const rpcprog_t,
365 	const rpcvers_t, const struct netconfig *, const struct timeval *);
366 /*
367  *	const char *hostname;			-- hostname
368  *	const rpcprog_t prog;			-- program number
369  *	const rpcvers_t vers;			-- version number
370  *	const struct netconfig *netconf; 	-- network config structure
371  *	const struct timeval *tp		-- timeout
372  */
373 
374 /*
375  * Generic TLI create routine. Only provided for compatibility.
376  */
377 
378 extern CLIENT *clnt_tli_create(const int, const struct netconfig *,
379 			       struct netbuf *, const rpcprog_t,
380 			       const rpcvers_t, const u_int, const u_int);
381 /*
382  *	const register int fd;		-- fd
383  *	const struct netconfig *nconf;	-- netconfig structure
384  *	struct netbuf *svcaddr;		-- servers address
385  *	const u_long prog;			-- program number
386  *	const u_long vers;			-- version number
387  *	const u_int sendsz;			-- send size
388  *	const u_int recvsz;			-- recv size
389  */
390 
391 /*
392  * Low level clnt create routine for connectionful transports, e.g. tcp.
393  */
394 extern CLIENT *clnt_vc_create(const int, const struct netbuf *,
395 			      const rpcprog_t, const rpcvers_t,
396 			      u_int, u_int);
397 /*
398  * Added for compatibility to old rpc 4.0. Obsoleted by clnt_vc_create().
399  */
400 extern CLIENT *clntunix_create(struct sockaddr_un *,
401 			       u_long, u_long, int *, u_int, u_int);
402 /*
403  *	const int fd;				-- open file descriptor
404  *	const struct netbuf *svcaddr;		-- servers address
405  *	const rpcprog_t prog;			-- program number
406  *	const rpcvers_t vers;			-- version number
407  *	const u_int sendsz;			-- buffer recv size
408  *	const u_int recvsz;			-- buffer send size
409  */
410 
411 /*
412  * Low level clnt create routine for connectionless transports, e.g. udp.
413  */
414 extern CLIENT *clnt_dg_create(const int, const struct netbuf *,
415 			      const rpcprog_t, const rpcvers_t,
416 			      const u_int, const u_int);
417 /*
418  *	const int fd;				-- open file descriptor
419  *	const struct netbuf *svcaddr;		-- servers address
420  *	const rpcprog_t program;		-- program number
421  *	const rpcvers_t version;		-- version number
422  *	const u_int sendsz;			-- buffer recv size
423  *	const u_int recvsz;			-- buffer send size
424  */
425 
426 /*
427  * Memory based rpc (for speed check and testing)
428  * CLIENT *
429  * clnt_raw_create(prog, vers)
430  *	u_long prog;
431  *	u_long vers;
432  */
433 extern CLIENT *clnt_raw_create(rpcprog_t, rpcvers_t);
434 
435 __END_DECLS
436 
437 
438 /*
439  * Print why creation failed
440  */
441 __BEGIN_DECLS
442 extern void clnt_pcreateerror(const char *);			/* stderr */
443 extern char *clnt_spcreateerror(const char *);			/* string */
444 __END_DECLS
445 
446 /*
447  * Like clnt_perror(), but is more verbose in its output
448  */
449 __BEGIN_DECLS
450 extern void clnt_perrno(enum clnt_stat);		/* stderr */
451 extern char *clnt_sperrno(enum clnt_stat);		/* string */
452 __END_DECLS
453 
454 /*
455  * Print an English error message, given the client error code
456  */
457 __BEGIN_DECLS
458 extern void clnt_perror(CLIENT *, const char *);	 	/* stderr */
459 extern char *clnt_sperror(CLIENT *, const char *);		/* string */
460 __END_DECLS
461 
462 
463 /*
464  * If a creation fails, the following allows the user to figure out why.
465  */
466 struct rpc_createerr {
467 	enum clnt_stat cf_stat;
468 	struct rpc_err cf_error; /* useful when cf_stat == RPC_PMAPFAILURE */
469 };
470 
471 __BEGIN_DECLS
472 extern struct rpc_createerr	*__rpc_createerr(void);
473 __END_DECLS
474 #define rpc_createerr		(*(__rpc_createerr()))
475 
476 /*
477  * The simplified interface:
478  * enum clnt_stat
479  * rpc_call(host, prognum, versnum, procnum, inproc, in, outproc, out, nettype)
480  *	const char *host;
481  *	const rpcprog_t prognum;
482  *	const rpcvers_t versnum;
483  *	const rpcproc_t procnum;
484  *	const xdrproc_t inproc, outproc;
485  *	const char *in;
486  *	char *out;
487  *	const char *nettype;
488  */
489 __BEGIN_DECLS
490 extern enum clnt_stat rpc_call(const char *, const rpcprog_t,
491 			       const rpcvers_t, const rpcproc_t,
492 			       const xdrproc_t, const char *,
493 			       const xdrproc_t, char *, const char *);
494 __END_DECLS
495 
496 /*
497  * RPC broadcast interface
498  * The call is broadcasted to all locally connected nets.
499  *
500  * extern enum clnt_stat
501  * rpc_broadcast(prog, vers, proc, xargs, argsp, xresults, resultsp,
502  *			eachresult, nettype)
503  *	const rpcprog_t		prog;		-- program number
504  *	const rpcvers_t		vers;		-- version number
505  *	const rpcproc_t		proc;		-- procedure number
506  *	const xdrproc_t	xargs;		-- xdr routine for args
507  *	caddr_t		argsp;		-- pointer to args
508  *	const xdrproc_t	xresults;	-- xdr routine for results
509  *	caddr_t		resultsp;	-- pointer to results
510  *	const resultproc_t	eachresult;	-- call with each result
511  *	const char		*nettype;	-- Transport type
512  *
513  * For each valid response received, the procedure eachresult is called.
514  * Its form is:
515  *		done = eachresult(resp, raddr, nconf)
516  *			bool_t done;
517  *			caddr_t resp;
518  *			struct netbuf *raddr;
519  *			struct netconfig *nconf;
520  * where resp points to the results of the call and raddr is the
521  * address if the responder to the broadcast.  nconf is the transport
522  * on which the response was received.
523  *
524  * extern enum clnt_stat
525  * rpc_broadcast_exp(prog, vers, proc, xargs, argsp, xresults, resultsp,
526  *			eachresult, inittime, waittime, nettype)
527  *	const rpcprog_t		prog;		-- program number
528  *	const rpcvers_t		vers;		-- version number
529  *	const rpcproc_t		proc;		-- procedure number
530  *	const xdrproc_t	xargs;		-- xdr routine for args
531  *	caddr_t		argsp;		-- pointer to args
532  *	const xdrproc_t	xresults;	-- xdr routine for results
533  *	caddr_t		resultsp;	-- pointer to results
534  *	const resultproc_t	eachresult;	-- call with each result
535  *	const int 		inittime;	-- how long to wait initially
536  *	const int 		waittime;	-- maximum time to wait
537  *	const char		*nettype;	-- Transport type
538  */
539 
540 typedef bool_t (*resultproc_t)(caddr_t, ...);
541 
542 __BEGIN_DECLS
543 extern enum clnt_stat rpc_broadcast(const rpcprog_t, const rpcvers_t,
544 				    const rpcproc_t, const xdrproc_t,
545 				    caddr_t, const xdrproc_t, caddr_t,
546 				    const resultproc_t, const char *);
547 extern enum clnt_stat rpc_broadcast_exp(const rpcprog_t, const rpcvers_t,
548 					const rpcproc_t, const xdrproc_t,
549 					caddr_t, const xdrproc_t, caddr_t,
550 					const resultproc_t, const int,
551 					const int, const char *);
552 __END_DECLS
553 
554 /* For backward compatibility */
555 #include <rpc/clnt_soc.h>
556 
557 #endif /* !_RPC_CLNT_H_ */
558