rpcinfo.c revision 1.29 1 1.29 drochner /* $NetBSD: rpcinfo.c,v 1.29 2009/11/17 18:31:13 drochner Exp $ */
2 1.1 glass
3 1.1 glass /*
4 1.1 glass * Sun RPC is a product of Sun Microsystems, Inc. and is provided for
5 1.1 glass * unrestricted use provided that this legend is included on all tape
6 1.1 glass * media and as a part of the software program in whole or part. Users
7 1.1 glass * may copy or modify Sun RPC without charge, but are not authorized
8 1.1 glass * to license or distribute it to anyone else except as part of a product or
9 1.1 glass * program developed by the user.
10 1.1 glass *
11 1.1 glass * SUN RPC IS PROVIDED AS IS WITH NO WARRANTIES OF ANY KIND INCLUDING THE
12 1.1 glass * WARRANTIES OF DESIGN, MERCHANTIBILITY AND FITNESS FOR A PARTICULAR
13 1.1 glass * PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE OR TRADE PRACTICE.
14 1.1 glass *
15 1.1 glass * Sun RPC is provided with no support and without any obligation on the
16 1.1 glass * part of Sun Microsystems, Inc. to assist in its use, correction,
17 1.1 glass * modification or enhancement.
18 1.1 glass *
19 1.1 glass * SUN MICROSYSTEMS, INC. SHALL HAVE NO LIABILITY WITH RESPECT TO THE
20 1.1 glass * INFRINGEMENT OF COPYRIGHTS, TRADE SECRETS OR ANY PATENTS BY SUN RPC
21 1.1 glass * OR ANY PART THEREOF.
22 1.1 glass *
23 1.1 glass * In no event will Sun Microsystems, Inc. be liable for any lost revenue
24 1.1 glass * or profits or other special, indirect and consequential damages, even if
25 1.1 glass * Sun has been advised of the possibility of such damages.
26 1.1 glass *
27 1.1 glass * Sun Microsystems, Inc.
28 1.1 glass * 2550 Garcia Avenue
29 1.1 glass * Mountain View, California 94043
30 1.1 glass */
31 1.1 glass
32 1.12 fvdl /*
33 1.12 fvdl * Copyright (c) 1986 - 1991 by Sun Microsystems, Inc.
34 1.12 fvdl */
35 1.12 fvdl
36 1.12 fvdl /* #ident "@(#)rpcinfo.c 1.18 93/07/05 SMI" */
37 1.12 fvdl
38 1.12 fvdl #if 0
39 1.12 fvdl #ifndef lint
40 1.12 fvdl static char sccsid[] = "@(#)rpcinfo.c 1.16 89/04/05 Copyr 1986 Sun Micro";
41 1.12 fvdl #endif
42 1.12 fvdl #endif
43 1.12 fvdl
44 1.12 fvdl /*
45 1.12 fvdl * rpcinfo: ping a particular rpc program
46 1.20 simonb * or dump the registered programs on the remote machine.
47 1.12 fvdl */
48 1.12 fvdl
49 1.12 fvdl /*
50 1.12 fvdl * We are for now defining PORTMAP here. It doesnt even compile
51 1.12 fvdl * unless it is defined.
52 1.12 fvdl */
53 1.12 fvdl #ifndef PORTMAP
54 1.12 fvdl #define PORTMAP
55 1.12 fvdl #endif
56 1.12 fvdl
57 1.12 fvdl /*
58 1.12 fvdl * If PORTMAP is defined, rpcinfo will talk to both portmapper and
59 1.12 fvdl * rpcbind programs; else it talks only to rpcbind. In the latter case
60 1.12 fvdl * all the portmapper specific options such as -u, -t, -p become void.
61 1.12 fvdl */
62 1.6 lukem #include <sys/types.h>
63 1.1 glass #include <sys/socket.h>
64 1.17 agc #include <sys/param.h>
65 1.12 fvdl #include <sys/un.h>
66 1.12 fvdl #include <rpc/rpc.h>
67 1.6 lukem #include <stdio.h>
68 1.12 fvdl #include <rpc/rpcb_prot.h>
69 1.12 fvdl #include <rpc/rpcent.h>
70 1.14 itojun #include <rpc/nettype.h>
71 1.6 lukem #include <stdlib.h>
72 1.6 lukem #include <string.h>
73 1.6 lukem #include <unistd.h>
74 1.12 fvdl #include <err.h>
75 1.12 fvdl #include <ctype.h>
76 1.12 fvdl
77 1.12 fvdl #ifdef PORTMAP /* Support for version 2 portmapper */
78 1.12 fvdl #include <netinet/in.h>
79 1.12 fvdl #include <netdb.h>
80 1.12 fvdl #include <arpa/inet.h>
81 1.12 fvdl #include <rpc/pmap_prot.h>
82 1.6 lukem #include <rpc/pmap_clnt.h>
83 1.12 fvdl #endif
84 1.1 glass
85 1.12 fvdl #define MIN_VERS ((u_long)0)
86 1.12 fvdl #define MAX_VERS ((u_long)4294967295UL)
87 1.12 fvdl #define UNKNOWN "unknown"
88 1.1 glass
89 1.1 glass /*
90 1.1 glass * Functions to be performed.
91 1.1 glass */
92 1.1 glass #define NONE 0 /* no function */
93 1.1 glass #define PMAPDUMP 1 /* dump portmapper registrations */
94 1.1 glass #define TCPPING 2 /* ping TCP service */
95 1.1 glass #define UDPPING 3 /* ping UDP service */
96 1.12 fvdl #define BROADCAST 4 /* ping broadcast service */
97 1.12 fvdl #define DELETES 5 /* delete registration for the service */
98 1.12 fvdl #define ADDRPING 6 /* pings at the given address */
99 1.12 fvdl #define PROGPING 7 /* pings a program on a given host */
100 1.12 fvdl #define RPCBDUMP 8 /* dump rpcbind registrations */
101 1.12 fvdl #define RPCBDUMP_SHORT 9 /* dump rpcbind registrations - short version */
102 1.12 fvdl #define RPCBADDRLIST 10 /* dump addr list about one prog */
103 1.12 fvdl #define RPCBGETSTAT 11 /* Get statistics */
104 1.12 fvdl
105 1.12 fvdl struct netidlist {
106 1.12 fvdl char *netid;
107 1.12 fvdl struct netidlist *next;
108 1.12 fvdl };
109 1.12 fvdl
110 1.12 fvdl struct verslist {
111 1.12 fvdl int vers;
112 1.12 fvdl struct verslist *next;
113 1.12 fvdl };
114 1.12 fvdl
115 1.12 fvdl struct rpcbdump_short {
116 1.12 fvdl u_long prog;
117 1.12 fvdl struct verslist *vlist;
118 1.12 fvdl struct netidlist *nlist;
119 1.12 fvdl struct rpcbdump_short *next;
120 1.12 fvdl char *owner;
121 1.12 fvdl };
122 1.12 fvdl
123 1.12 fvdl
124 1.12 fvdl
125 1.12 fvdl #ifdef PORTMAP
126 1.29 drochner static void ip_ping(u_short, const char *, int, char **);
127 1.12 fvdl static CLIENT *clnt_com_create(struct sockaddr_in *, u_long, u_long, int *,
128 1.29 drochner const char *);
129 1.12 fvdl static void pmapdump(int, char **);
130 1.29 drochner static void get_inet_address(struct sockaddr_in *, const char *);
131 1.12 fvdl #endif
132 1.12 fvdl
133 1.12 fvdl static bool_t reply_proc(void *, struct netbuf *, struct netconfig *);
134 1.12 fvdl static void brdcst(int, char **);
135 1.12 fvdl static void addrping(char *, char *, int, char **);
136 1.12 fvdl static void progping(char *, int, char **);
137 1.12 fvdl static CLIENT *clnt_addr_create(char *, struct netconfig *, u_long, u_long);
138 1.12 fvdl static CLIENT *clnt_rpcbind_create(char *, int, struct netbuf **);
139 1.12 fvdl static CLIENT *getclnthandle(char *, struct netconfig *, u_long,
140 1.12 fvdl struct netbuf **);
141 1.12 fvdl static CLIENT *local_rpcb(u_long, u_long);
142 1.12 fvdl static int pstatus(CLIENT *, u_long, u_long);
143 1.12 fvdl static void rpcbdump(int, char *, int, char **);
144 1.12 fvdl static void rpcbgetstat(int, char **);
145 1.12 fvdl static void rpcbaddrlist(char *, int, char **);
146 1.12 fvdl static void deletereg(char *, int, char **);
147 1.12 fvdl static void print_rmtcallstat(int, rpcb_stat *);
148 1.12 fvdl static void print_getaddrstat(int, rpcb_stat *);
149 1.12 fvdl static void usage(void);
150 1.12 fvdl static u_long getprognum(char *);
151 1.12 fvdl static u_long getvers(char *);
152 1.12 fvdl static char *spaces(int);
153 1.12 fvdl static bool_t add_version(struct rpcbdump_short *, u_long);
154 1.12 fvdl static bool_t add_netid(struct rpcbdump_short *, char *);
155 1.12 fvdl
156 1.12 fvdl int main(int argc, char **argv);
157 1.1 glass
158 1.1 glass int
159 1.29 drochner main(int argc, char **argv)
160 1.1 glass {
161 1.12 fvdl register int c;
162 1.1 glass int errflg;
163 1.1 glass int function;
164 1.12 fvdl char *netid = NULL;
165 1.12 fvdl char *address = NULL;
166 1.12 fvdl #ifdef PORTMAP
167 1.12 fvdl char *strptr;
168 1.12 fvdl u_short portnum = 0;
169 1.12 fvdl #endif
170 1.1 glass
171 1.1 glass function = NONE;
172 1.1 glass errflg = 0;
173 1.12 fvdl #ifdef PORTMAP
174 1.15 mjl while ((c = getopt(argc, argv, "a:bdlmn:pstT:u")) != -1) {
175 1.12 fvdl #else
176 1.15 mjl while ((c = getopt(argc, argv, "a:bdlmn:sT:")) != -1) {
177 1.12 fvdl #endif
178 1.1 glass switch (c) {
179 1.12 fvdl #ifdef PORTMAP
180 1.1 glass case 'p':
181 1.1 glass if (function != NONE)
182 1.1 glass errflg = 1;
183 1.1 glass else
184 1.1 glass function = PMAPDUMP;
185 1.1 glass break;
186 1.1 glass
187 1.1 glass case 't':
188 1.1 glass if (function != NONE)
189 1.1 glass errflg = 1;
190 1.1 glass else
191 1.1 glass function = TCPPING;
192 1.1 glass break;
193 1.1 glass
194 1.1 glass case 'u':
195 1.1 glass if (function != NONE)
196 1.1 glass errflg = 1;
197 1.1 glass else
198 1.1 glass function = UDPPING;
199 1.1 glass break;
200 1.1 glass
201 1.12 fvdl case 'n':
202 1.12 fvdl portnum = (u_short) strtol(optarg, &strptr, 10);
203 1.24 christos if (strptr == optarg || *strptr != '\0')
204 1.24 christos errx(1, "Illegal port number `%s'", optarg);
205 1.12 fvdl break;
206 1.12 fvdl #endif
207 1.12 fvdl case 'a':
208 1.12 fvdl address = optarg;
209 1.12 fvdl if (function != NONE)
210 1.12 fvdl errflg = 1;
211 1.12 fvdl else
212 1.12 fvdl function = ADDRPING;
213 1.12 fvdl break;
214 1.1 glass case 'b':
215 1.1 glass if (function != NONE)
216 1.1 glass errflg = 1;
217 1.1 glass else
218 1.12 fvdl function = BROADCAST;
219 1.12 fvdl break;
220 1.12 fvdl
221 1.12 fvdl case 'd':
222 1.12 fvdl if (function != NONE)
223 1.12 fvdl errflg = 1;
224 1.12 fvdl else
225 1.12 fvdl function = DELETES;
226 1.12 fvdl break;
227 1.12 fvdl
228 1.12 fvdl case 'l':
229 1.12 fvdl if (function != NONE)
230 1.12 fvdl errflg = 1;
231 1.12 fvdl else
232 1.12 fvdl function = RPCBADDRLIST;
233 1.1 glass break;
234 1.1 glass
235 1.12 fvdl case 'm':
236 1.12 fvdl if (function != NONE)
237 1.12 fvdl errflg = 1;
238 1.12 fvdl else
239 1.12 fvdl function = RPCBGETSTAT;
240 1.1 glass break;
241 1.1 glass
242 1.12 fvdl case 's':
243 1.1 glass if (function != NONE)
244 1.1 glass errflg = 1;
245 1.1 glass else
246 1.12 fvdl function = RPCBDUMP_SHORT;
247 1.1 glass break;
248 1.1 glass
249 1.12 fvdl case 'T':
250 1.12 fvdl netid = optarg;
251 1.12 fvdl break;
252 1.1 glass case '?':
253 1.1 glass errflg = 1;
254 1.12 fvdl break;
255 1.1 glass }
256 1.1 glass }
257 1.1 glass
258 1.12 fvdl if (errflg || ((function == ADDRPING) && !netid)) {
259 1.1 glass usage();
260 1.1 glass return (1);
261 1.1 glass }
262 1.1 glass
263 1.12 fvdl if (function == NONE) {
264 1.12 fvdl if (argc - optind > 1)
265 1.12 fvdl function = PROGPING;
266 1.12 fvdl else
267 1.12 fvdl function = RPCBDUMP;
268 1.12 fvdl }
269 1.12 fvdl
270 1.1 glass switch (function) {
271 1.12 fvdl #ifdef PORTMAP
272 1.1 glass case PMAPDUMP:
273 1.1 glass if (portnum != 0) {
274 1.1 glass usage();
275 1.1 glass return (1);
276 1.1 glass }
277 1.1 glass pmapdump(argc - optind, argv + optind);
278 1.1 glass break;
279 1.1 glass
280 1.1 glass case UDPPING:
281 1.12 fvdl ip_ping(portnum, "udp", argc - optind, argv + optind);
282 1.1 glass break;
283 1.1 glass
284 1.1 glass case TCPPING:
285 1.12 fvdl ip_ping(portnum, "tcp", argc - optind, argv + optind);
286 1.1 glass break;
287 1.12 fvdl #endif
288 1.12 fvdl case BROADCAST:
289 1.1 glass brdcst(argc - optind, argv + optind);
290 1.1 glass break;
291 1.1 glass case DELETES:
292 1.12 fvdl deletereg(netid, argc - optind, argv + optind);
293 1.12 fvdl break;
294 1.12 fvdl case ADDRPING:
295 1.12 fvdl addrping(address, netid, argc - optind, argv + optind);
296 1.12 fvdl break;
297 1.12 fvdl case PROGPING:
298 1.12 fvdl progping(netid, argc - optind, argv + optind);
299 1.12 fvdl break;
300 1.12 fvdl case RPCBDUMP:
301 1.12 fvdl case RPCBDUMP_SHORT:
302 1.12 fvdl rpcbdump(function, netid, argc - optind, argv + optind);
303 1.12 fvdl break;
304 1.12 fvdl case RPCBGETSTAT:
305 1.12 fvdl rpcbgetstat(argc - optind, argv + optind);
306 1.12 fvdl break;
307 1.12 fvdl case RPCBADDRLIST:
308 1.12 fvdl rpcbaddrlist(netid, argc - optind, argv + optind);
309 1.1 glass break;
310 1.1 glass }
311 1.12 fvdl return (0);
312 1.12 fvdl }
313 1.1 glass
314 1.12 fvdl static CLIENT *
315 1.29 drochner local_rpcb(u_long prog, u_long vers)
316 1.12 fvdl {
317 1.12 fvdl struct netbuf nbuf;
318 1.12 fvdl struct sockaddr_un sun;
319 1.12 fvdl int sock;
320 1.12 fvdl
321 1.12 fvdl memset(&sun, 0, sizeof sun);
322 1.12 fvdl sock = socket(AF_LOCAL, SOCK_STREAM, 0);
323 1.12 fvdl if (sock < 0)
324 1.12 fvdl return NULL;
325 1.12 fvdl
326 1.12 fvdl sun.sun_family = AF_LOCAL;
327 1.12 fvdl strcpy(sun.sun_path, _PATH_RPCBINDSOCK);
328 1.12 fvdl nbuf.len = sun.sun_len = SUN_LEN(&sun);
329 1.12 fvdl nbuf.maxlen = sizeof (struct sockaddr_un);
330 1.12 fvdl nbuf.buf = &sun;
331 1.12 fvdl
332 1.12 fvdl return clnt_vc_create(sock, &nbuf, prog, vers, 0, 0);
333 1.1 glass }
334 1.12 fvdl
335 1.12 fvdl #ifdef PORTMAP
336 1.12 fvdl static CLIENT *
337 1.29 drochner clnt_com_create(struct sockaddr_in *addr, u_long prog, u_long vers,
338 1.29 drochner int *fdp, const char *trans)
339 1.1 glass {
340 1.12 fvdl CLIENT *clnt;
341 1.12 fvdl
342 1.12 fvdl if (strcmp(trans, "tcp") == 0) {
343 1.12 fvdl clnt = clnttcp_create(addr, prog, vers, fdp, 0, 0);
344 1.12 fvdl } else {
345 1.12 fvdl struct timeval to;
346 1.12 fvdl
347 1.1 glass to.tv_sec = 5;
348 1.1 glass to.tv_usec = 0;
349 1.12 fvdl clnt = clntudp_create(addr, prog, vers, to, fdp);
350 1.1 glass }
351 1.24 christos if (clnt == NULL) {
352 1.24 christos clnt_pcreateerror(getprogname());
353 1.12 fvdl if (vers == MIN_VERS)
354 1.12 fvdl printf("program %lu is not available\n", prog);
355 1.12 fvdl else
356 1.1 glass printf("program %lu version %lu is not available\n",
357 1.12 fvdl prog, vers);
358 1.12 fvdl exit(1);
359 1.1 glass }
360 1.12 fvdl return (clnt);
361 1.1 glass }
362 1.1 glass
363 1.12 fvdl /*
364 1.12 fvdl * If portnum is 0, then go and get the address from portmapper, which happens
365 1.12 fvdl * transparently through clnt*_create(); If version number is not given, it
366 1.12 fvdl * tries to find out the version number by making a call to version 0 and if
367 1.12 fvdl * that fails, it obtains the high order and the low order version number. If
368 1.12 fvdl * version 0 calls succeeds, it tries for MAXVERS call and repeats the same.
369 1.12 fvdl */
370 1.1 glass static void
371 1.29 drochner ip_ping(u_short portnum, const char *trans, int argc, char **argv)
372 1.1 glass {
373 1.12 fvdl CLIENT *client;
374 1.12 fvdl int fd = RPC_ANYFD;
375 1.1 glass struct timeval to;
376 1.1 glass struct sockaddr_in addr;
377 1.1 glass enum clnt_stat rpc_stat;
378 1.1 glass u_long prognum, vers, minvers, maxvers;
379 1.1 glass struct rpc_err rpcerr;
380 1.12 fvdl int failure = 0;
381 1.1 glass
382 1.1 glass if (argc < 2 || argc > 3) {
383 1.1 glass usage();
384 1.1 glass exit(1);
385 1.1 glass }
386 1.12 fvdl to.tv_sec = 10;
387 1.12 fvdl to.tv_usec = 0;
388 1.1 glass prognum = getprognum(argv[1]);
389 1.1 glass get_inet_address(&addr, argv[0]);
390 1.12 fvdl if (argc == 2) { /* Version number not known */
391 1.1 glass /*
392 1.1 glass * A call to version 0 should fail with a program/version
393 1.1 glass * mismatch, and give us the range of versions supported.
394 1.1 glass */
395 1.12 fvdl vers = MIN_VERS;
396 1.12 fvdl } else {
397 1.12 fvdl vers = getvers(argv[2]);
398 1.12 fvdl }
399 1.12 fvdl addr.sin_port = htons(portnum);
400 1.12 fvdl client = clnt_com_create(&addr, prognum, vers, &fd, trans);
401 1.12 fvdl rpc_stat = CLNT_CALL(client, NULLPROC, (xdrproc_t) xdr_void,
402 1.24 christos NULL, (xdrproc_t) xdr_void, NULL, to);
403 1.12 fvdl if (argc != 2) {
404 1.12 fvdl /* Version number was known */
405 1.12 fvdl if (pstatus(client, prognum, vers) < 0)
406 1.12 fvdl exit(1);
407 1.12 fvdl (void) CLNT_DESTROY(client);
408 1.12 fvdl return;
409 1.12 fvdl }
410 1.12 fvdl /* Version number not known */
411 1.24 christos (void) CLNT_CONTROL(client, CLSET_FD_NCLOSE, NULL);
412 1.12 fvdl if (rpc_stat == RPC_PROGVERSMISMATCH) {
413 1.12 fvdl clnt_geterr(client, &rpcerr);
414 1.12 fvdl minvers = rpcerr.re_vers.low;
415 1.12 fvdl maxvers = rpcerr.re_vers.high;
416 1.12 fvdl } else if (rpc_stat == RPC_SUCCESS) {
417 1.12 fvdl /*
418 1.12 fvdl * Oh dear, it DOES support version 0.
419 1.12 fvdl * Let's try version MAX_VERS.
420 1.12 fvdl */
421 1.12 fvdl (void) CLNT_DESTROY(client);
422 1.1 glass addr.sin_port = htons(portnum);
423 1.12 fvdl client = clnt_com_create(&addr, prognum, MAX_VERS, &fd, trans);
424 1.12 fvdl rpc_stat = CLNT_CALL(client, NULLPROC, (xdrproc_t) xdr_void,
425 1.24 christos NULL, (xdrproc_t) xdr_void, NULL, to);
426 1.1 glass if (rpc_stat == RPC_PROGVERSMISMATCH) {
427 1.1 glass clnt_geterr(client, &rpcerr);
428 1.1 glass minvers = rpcerr.re_vers.low;
429 1.1 glass maxvers = rpcerr.re_vers.high;
430 1.1 glass } else if (rpc_stat == RPC_SUCCESS) {
431 1.1 glass /*
432 1.12 fvdl * It also supports version MAX_VERS.
433 1.12 fvdl * Looks like we have a wise guy.
434 1.12 fvdl * OK, we give them information on all
435 1.12 fvdl * 4 billion versions they support...
436 1.1 glass */
437 1.12 fvdl minvers = 0;
438 1.12 fvdl maxvers = MAX_VERS;
439 1.1 glass } else {
440 1.12 fvdl (void) pstatus(client, prognum, MAX_VERS);
441 1.1 glass exit(1);
442 1.1 glass }
443 1.12 fvdl } else {
444 1.12 fvdl (void) pstatus(client, prognum, (u_long)0);
445 1.12 fvdl exit(1);
446 1.1 glass }
447 1.12 fvdl (void) CLNT_DESTROY(client);
448 1.12 fvdl for (vers = minvers; vers <= maxvers; vers++) {
449 1.1 glass addr.sin_port = htons(portnum);
450 1.12 fvdl client = clnt_com_create(&addr, prognum, vers, &fd, trans);
451 1.12 fvdl rpc_stat = CLNT_CALL(client, NULLPROC, (xdrproc_t) xdr_void,
452 1.24 christos NULL, (xdrproc_t) xdr_void, NULL, to);
453 1.1 glass if (pstatus(client, prognum, vers) < 0)
454 1.12 fvdl failure = 1;
455 1.12 fvdl (void) CLNT_DESTROY(client);
456 1.1 glass }
457 1.1 glass if (failure)
458 1.1 glass exit(1);
459 1.12 fvdl (void) close(fd);
460 1.12 fvdl return;
461 1.1 glass }
462 1.1 glass
463 1.1 glass /*
464 1.12 fvdl * Dump all the portmapper registerations
465 1.1 glass */
466 1.1 glass static void
467 1.29 drochner pmapdump(int argc, char **argv)
468 1.1 glass {
469 1.1 glass struct sockaddr_in server_addr;
470 1.1 glass struct pmaplist *head = NULL;
471 1.28 lukem int sock = RPC_ANYSOCK;
472 1.1 glass struct timeval minutetimeout;
473 1.12 fvdl register CLIENT *client;
474 1.1 glass struct rpcent *rpc;
475 1.12 fvdl enum clnt_stat clnt_st;
476 1.24 christos struct rpc_err error;
477 1.22 lukem char *host = NULL;
478 1.12 fvdl
479 1.1 glass if (argc > 1) {
480 1.1 glass usage();
481 1.1 glass exit(1);
482 1.1 glass }
483 1.12 fvdl if (argc == 1) {
484 1.12 fvdl host = argv[0];
485 1.12 fvdl get_inet_address(&server_addr, host);
486 1.12 fvdl server_addr.sin_port = htons(PMAPPORT);
487 1.12 fvdl client = clnttcp_create(&server_addr, PMAPPROG, PMAPVERS,
488 1.28 lukem &sock, 50, 500);
489 1.12 fvdl } else
490 1.12 fvdl client = local_rpcb(PMAPPROG, PMAPVERS);
491 1.12 fvdl
492 1.12 fvdl if (client == NULL) {
493 1.12 fvdl if (rpc_createerr.cf_stat == RPC_TLIERROR) {
494 1.12 fvdl /*
495 1.12 fvdl * "Misc. TLI error" is not too helpful. Most likely
496 1.12 fvdl * the connection to the remote server timed out, so
497 1.12 fvdl * this error is at least less perplexing.
498 1.12 fvdl */
499 1.12 fvdl rpc_createerr.cf_stat = RPC_PMAPFAILURE;
500 1.12 fvdl rpc_createerr.cf_error.re_status = RPC_FAILED;
501 1.12 fvdl }
502 1.12 fvdl clnt_pcreateerror("rpcinfo: can't contact portmapper");
503 1.12 fvdl exit(1);
504 1.1 glass }
505 1.12 fvdl
506 1.1 glass minutetimeout.tv_sec = 60;
507 1.1 glass minutetimeout.tv_usec = 0;
508 1.12 fvdl
509 1.12 fvdl clnt_st = CLNT_CALL(client, PMAPPROC_DUMP, (xdrproc_t) xdr_void,
510 1.12 fvdl NULL, (xdrproc_t) xdr_pmaplist_ptr, (char *)&head,
511 1.12 fvdl minutetimeout);
512 1.12 fvdl if (clnt_st != RPC_SUCCESS) {
513 1.12 fvdl if ((clnt_st == RPC_PROGVERSMISMATCH) ||
514 1.12 fvdl (clnt_st == RPC_PROGUNAVAIL)) {
515 1.24 christos CLNT_GETERR(client, &error);
516 1.24 christos if (error.re_vers.low > PMAPVERS) {
517 1.22 lukem if (host)
518 1.22 lukem fprintf(stderr,
519 1.22 lukem "%s does not support portmapper. Try 'rpcinfo %s' instead\n",
520 1.22 lukem host, host);
521 1.22 lukem else
522 1.22 lukem fprintf(stderr,
523 1.22 lukem "local host does not support portmapper. Try 'rpcinfo' instead\n");
524 1.22 lukem }
525 1.12 fvdl exit(1);
526 1.12 fvdl }
527 1.12 fvdl clnt_perror(client, "rpcinfo: can't contact portmapper");
528 1.1 glass exit(1);
529 1.1 glass }
530 1.1 glass if (head == NULL) {
531 1.1 glass printf("No remote programs registered.\n");
532 1.1 glass } else {
533 1.12 fvdl printf(" program vers proto port service\n");
534 1.1 glass for (; head != NULL; head = head->pml_next) {
535 1.9 lukem printf("%10ld%5ld",
536 1.12 fvdl head->pml_map.pm_prog,
537 1.12 fvdl head->pml_map.pm_vers);
538 1.1 glass if (head->pml_map.pm_prot == IPPROTO_UDP)
539 1.12 fvdl printf("%6s", "udp");
540 1.1 glass else if (head->pml_map.pm_prot == IPPROTO_TCP)
541 1.1 glass printf("%6s", "tcp");
542 1.1 glass else
543 1.12 fvdl printf("%6ld", head->pml_map.pm_prot);
544 1.12 fvdl printf("%7ld", head->pml_map.pm_port);
545 1.1 glass rpc = getrpcbynumber(head->pml_map.pm_prog);
546 1.1 glass if (rpc)
547 1.1 glass printf(" %s\n", rpc->r_name);
548 1.1 glass else
549 1.1 glass printf("\n");
550 1.1 glass }
551 1.1 glass }
552 1.1 glass }
553 1.1 glass
554 1.12 fvdl static void
555 1.29 drochner get_inet_address(struct sockaddr_in *addr, const char *host)
556 1.12 fvdl {
557 1.12 fvdl struct netconfig *nconf;
558 1.12 fvdl struct addrinfo hints, *res;
559 1.12 fvdl int error;
560 1.12 fvdl
561 1.12 fvdl (void) memset((char *)addr, 0, sizeof (*addr));
562 1.12 fvdl addr->sin_addr.s_addr = inet_addr(host);
563 1.12 fvdl if (addr->sin_addr.s_addr == -1 || addr->sin_addr.s_addr == 0) {
564 1.12 fvdl if ((nconf = __rpc_getconfip("udp")) == NULL &&
565 1.12 fvdl (nconf = __rpc_getconfip("tcp")) == NULL) {
566 1.24 christos errx(1, "Couldn't find a suitable transport");
567 1.12 fvdl } else {
568 1.12 fvdl memset(&hints, 0, sizeof hints);
569 1.12 fvdl hints.ai_family = AF_INET;
570 1.12 fvdl if ((error = getaddrinfo(host, "rpcbind", &hints, &res))
571 1.12 fvdl != 0) {
572 1.24 christos errx(1, "%s: %s", host, gai_strerror(error));
573 1.12 fvdl } else {
574 1.12 fvdl memcpy(addr, res->ai_addr, res->ai_addrlen);
575 1.12 fvdl freeaddrinfo(res);
576 1.12 fvdl }
577 1.12 fvdl (void) freenetconfigent(nconf);
578 1.12 fvdl }
579 1.12 fvdl } else {
580 1.12 fvdl addr->sin_family = AF_INET;
581 1.12 fvdl }
582 1.12 fvdl }
583 1.12 fvdl #endif /* PORTMAP */
584 1.12 fvdl
585 1.12 fvdl /*
586 1.12 fvdl * reply_proc collects replies from the broadcast.
587 1.1 glass * to get a unique list of responses the output of rpcinfo should
588 1.1 glass * be piped through sort(1) and then uniq(1).
589 1.1 glass */
590 1.1 glass
591 1.12 fvdl /*ARGSUSED*/
592 1.1 glass static bool_t
593 1.12 fvdl reply_proc(res, who, nconf)
594 1.12 fvdl void *res; /* Nothing comes back */
595 1.12 fvdl struct netbuf *who; /* Who sent us the reply */
596 1.12 fvdl struct netconfig *nconf; /* On which transport the reply came */
597 1.12 fvdl {
598 1.12 fvdl char *uaddr;
599 1.12 fvdl char hostbuf[NI_MAXHOST];
600 1.12 fvdl char *hostname;
601 1.12 fvdl struct sockaddr *sa = (struct sockaddr *)who->buf;
602 1.12 fvdl
603 1.12 fvdl if (getnameinfo(sa, sa->sa_len, hostbuf, NI_MAXHOST, NULL, 0, 0)) {
604 1.12 fvdl hostname = UNKNOWN;
605 1.12 fvdl } else {
606 1.12 fvdl hostname = hostbuf;
607 1.12 fvdl }
608 1.12 fvdl if (!(uaddr = taddr2uaddr(nconf, who))) {
609 1.12 fvdl uaddr = UNKNOWN;
610 1.12 fvdl }
611 1.12 fvdl printf("%s\t%s\n", uaddr, hostname);
612 1.12 fvdl if (strcmp(uaddr, UNKNOWN))
613 1.12 fvdl free((char *)uaddr);
614 1.12 fvdl return (FALSE);
615 1.1 glass }
616 1.1 glass
617 1.1 glass static void
618 1.1 glass brdcst(argc, argv)
619 1.1 glass int argc;
620 1.1 glass char **argv;
621 1.1 glass {
622 1.1 glass enum clnt_stat rpc_stat;
623 1.1 glass u_long prognum, vers;
624 1.1 glass
625 1.1 glass if (argc != 2) {
626 1.1 glass usage();
627 1.1 glass exit(1);
628 1.1 glass }
629 1.1 glass prognum = getprognum(argv[0]);
630 1.1 glass vers = getvers(argv[1]);
631 1.12 fvdl rpc_stat = rpc_broadcast(prognum, vers, NULLPROC,
632 1.24 christos (xdrproc_t) xdr_void, NULL, (xdrproc_t) xdr_void,
633 1.24 christos NULL, (resultproc_t) reply_proc, NULL);
634 1.24 christos if ((rpc_stat != RPC_SUCCESS) && (rpc_stat != RPC_TIMEDOUT))
635 1.24 christos errx(1, "broadcast failed: %s", clnt_sperrno(rpc_stat));
636 1.1 glass exit(0);
637 1.1 glass }
638 1.1 glass
639 1.12 fvdl static bool_t
640 1.12 fvdl add_version(rs, vers)
641 1.12 fvdl struct rpcbdump_short *rs;
642 1.12 fvdl u_long vers;
643 1.12 fvdl {
644 1.12 fvdl struct verslist *vl;
645 1.12 fvdl
646 1.12 fvdl for (vl = rs->vlist; vl; vl = vl->next)
647 1.12 fvdl if (vl->vers == vers)
648 1.12 fvdl break;
649 1.12 fvdl if (vl)
650 1.12 fvdl return (TRUE);
651 1.24 christos vl = malloc(sizeof (struct verslist));
652 1.12 fvdl if (vl == NULL)
653 1.12 fvdl return (FALSE);
654 1.12 fvdl vl->vers = vers;
655 1.12 fvdl vl->next = rs->vlist;
656 1.12 fvdl rs->vlist = vl;
657 1.12 fvdl return (TRUE);
658 1.12 fvdl }
659 1.12 fvdl
660 1.12 fvdl static bool_t
661 1.12 fvdl add_netid(rs, netid)
662 1.12 fvdl struct rpcbdump_short *rs;
663 1.12 fvdl char *netid;
664 1.12 fvdl {
665 1.12 fvdl struct netidlist *nl;
666 1.12 fvdl
667 1.12 fvdl for (nl = rs->nlist; nl; nl = nl->next)
668 1.12 fvdl if (strcmp(nl->netid, netid) == 0)
669 1.12 fvdl break;
670 1.12 fvdl if (nl)
671 1.12 fvdl return (TRUE);
672 1.24 christos nl = malloc(sizeof (struct netidlist));
673 1.12 fvdl if (nl == NULL)
674 1.12 fvdl return (FALSE);
675 1.12 fvdl nl->netid = netid;
676 1.12 fvdl nl->next = rs->nlist;
677 1.12 fvdl rs->nlist = nl;
678 1.12 fvdl return (TRUE);
679 1.12 fvdl }
680 1.12 fvdl
681 1.1 glass static void
682 1.12 fvdl rpcbdump(dumptype, netid, argc, argv)
683 1.12 fvdl int dumptype;
684 1.12 fvdl char *netid;
685 1.1 glass int argc;
686 1.1 glass char **argv;
687 1.12 fvdl {
688 1.26 christos rpcblist_ptr head = NULL, p;
689 1.12 fvdl struct timeval minutetimeout;
690 1.24 christos register CLIENT *client = NULL;
691 1.12 fvdl struct rpcent *rpc;
692 1.12 fvdl char *host;
693 1.12 fvdl struct netidlist *nl;
694 1.12 fvdl struct verslist *vl;
695 1.22 lukem struct rpcbdump_short *rs, *rs_tail = NULL;
696 1.12 fvdl char buf[256];
697 1.12 fvdl enum clnt_stat clnt_st;
698 1.24 christos struct rpc_err error;
699 1.12 fvdl struct rpcbdump_short *rs_head = NULL;
700 1.12 fvdl
701 1.12 fvdl if (argc > 1) {
702 1.12 fvdl usage();
703 1.12 fvdl exit(1);
704 1.12 fvdl }
705 1.12 fvdl if (argc == 1) {
706 1.12 fvdl host = argv[0];
707 1.12 fvdl if (netid == NULL) {
708 1.12 fvdl client = clnt_rpcbind_create(host, RPCBVERS, NULL);
709 1.12 fvdl } else {
710 1.12 fvdl struct netconfig *nconf;
711 1.12 fvdl
712 1.12 fvdl nconf = getnetconfigent(netid);
713 1.12 fvdl if (nconf == NULL) {
714 1.12 fvdl nc_perror("rpcinfo: invalid transport");
715 1.12 fvdl exit(1);
716 1.12 fvdl }
717 1.12 fvdl client = getclnthandle(host, nconf, RPCBVERS, NULL);
718 1.12 fvdl if (nconf)
719 1.12 fvdl (void) freenetconfigent(nconf);
720 1.12 fvdl }
721 1.12 fvdl } else
722 1.12 fvdl client = local_rpcb(PMAPPROG, RPCBVERS);
723 1.12 fvdl
724 1.24 christos if (client == NULL) {
725 1.12 fvdl clnt_pcreateerror("rpcinfo: can't contact rpcbind");
726 1.12 fvdl exit(1);
727 1.12 fvdl }
728 1.12 fvdl minutetimeout.tv_sec = 60;
729 1.12 fvdl minutetimeout.tv_usec = 0;
730 1.12 fvdl clnt_st = CLNT_CALL(client, RPCBPROC_DUMP, (xdrproc_t) xdr_void,
731 1.12 fvdl NULL, (xdrproc_t) xdr_rpcblist_ptr, (char *) &head,
732 1.12 fvdl minutetimeout);
733 1.12 fvdl if (clnt_st != RPC_SUCCESS) {
734 1.12 fvdl if ((clnt_st == RPC_PROGVERSMISMATCH) ||
735 1.12 fvdl (clnt_st == RPC_PROGUNAVAIL)) {
736 1.12 fvdl int vers;
737 1.12 fvdl
738 1.24 christos CLNT_GETERR(client, &error);
739 1.24 christos if (error.re_vers.low == RPCBVERS4) {
740 1.12 fvdl vers = RPCBVERS4;
741 1.12 fvdl clnt_control(client, CLSET_VERS, (char *)&vers);
742 1.12 fvdl clnt_st = CLNT_CALL(client, RPCBPROC_DUMP,
743 1.12 fvdl (xdrproc_t) xdr_void, NULL,
744 1.12 fvdl (xdrproc_t) xdr_rpcblist_ptr, (char *) &head,
745 1.12 fvdl minutetimeout);
746 1.12 fvdl if (clnt_st != RPC_SUCCESS)
747 1.12 fvdl goto failed;
748 1.12 fvdl } else {
749 1.24 christos if (error.re_vers.high == PMAPVERS) {
750 1.12 fvdl int high, low;
751 1.12 fvdl struct pmaplist *pmaphead = NULL;
752 1.22 lukem rpcblist_ptr list, prev = NULL;
753 1.12 fvdl
754 1.12 fvdl vers = PMAPVERS;
755 1.12 fvdl clnt_control(client, CLSET_VERS, (char *)&vers);
756 1.12 fvdl clnt_st = CLNT_CALL(client, PMAPPROC_DUMP,
757 1.12 fvdl (xdrproc_t) xdr_void, NULL,
758 1.12 fvdl (xdrproc_t) xdr_pmaplist_ptr,
759 1.12 fvdl (char *)&pmaphead, minutetimeout);
760 1.12 fvdl if (clnt_st != RPC_SUCCESS)
761 1.12 fvdl goto failed;
762 1.12 fvdl /*
763 1.12 fvdl * convert to rpcblist_ptr format
764 1.12 fvdl */
765 1.12 fvdl for (head = NULL; pmaphead != NULL;
766 1.12 fvdl pmaphead = pmaphead->pml_next) {
767 1.24 christos list = malloc(sizeof (rpcblist));
768 1.12 fvdl if (list == NULL)
769 1.12 fvdl goto error;
770 1.12 fvdl if (head == NULL)
771 1.12 fvdl head = list;
772 1.12 fvdl else
773 1.12 fvdl prev->rpcb_next = (rpcblist_ptr) list;
774 1.12 fvdl
775 1.12 fvdl list->rpcb_next = NULL;
776 1.12 fvdl list->rpcb_map.r_prog = pmaphead->pml_map.pm_prog;
777 1.12 fvdl list->rpcb_map.r_vers = pmaphead->pml_map.pm_vers;
778 1.12 fvdl if (pmaphead->pml_map.pm_prot == IPPROTO_UDP)
779 1.25 christos list->rpcb_map.r_netid = strdup("udp");
780 1.12 fvdl else if (pmaphead->pml_map.pm_prot == IPPROTO_TCP)
781 1.25 christos list->rpcb_map.r_netid = strdup("tcp");
782 1.12 fvdl else {
783 1.12 fvdl #define MAXLONG_AS_STRING "2147483648"
784 1.12 fvdl list->rpcb_map.r_netid =
785 1.12 fvdl malloc(strlen(MAXLONG_AS_STRING) + 1);
786 1.12 fvdl if (list->rpcb_map.r_netid == NULL)
787 1.12 fvdl goto error;
788 1.12 fvdl sprintf(list->rpcb_map.r_netid, "%6ld",
789 1.12 fvdl pmaphead->pml_map.pm_prot);
790 1.12 fvdl }
791 1.12 fvdl list->rpcb_map.r_owner = UNKNOWN;
792 1.12 fvdl low = pmaphead->pml_map.pm_port & 0xff;
793 1.12 fvdl high = (pmaphead->pml_map.pm_port >> 8) & 0xff;
794 1.12 fvdl list->rpcb_map.r_addr = strdup("0.0.0.0.XXX.XXX");
795 1.12 fvdl sprintf(&list->rpcb_map.r_addr[8], "%d.%d",
796 1.12 fvdl high, low);
797 1.12 fvdl prev = list;
798 1.12 fvdl }
799 1.12 fvdl }
800 1.12 fvdl }
801 1.12 fvdl } else { /* any other error */
802 1.12 fvdl failed:
803 1.12 fvdl clnt_perror(client, "rpcinfo: can't contact rpcbind: ");
804 1.12 fvdl exit(1);
805 1.12 fvdl }
806 1.12 fvdl }
807 1.12 fvdl if (head == NULL) {
808 1.12 fvdl printf("No remote programs registered.\n");
809 1.12 fvdl } else if (dumptype == RPCBDUMP) {
810 1.12 fvdl printf(
811 1.13 fvdl " program version netid address service owner\n");
812 1.26 christos for (p = head; p != NULL; p = p->rpcb_next) {
813 1.12 fvdl printf("%10u%5u ",
814 1.26 christos p->rpcb_map.r_prog, p->rpcb_map.r_vers);
815 1.26 christos printf("%-9s ", p->rpcb_map.r_netid);
816 1.26 christos printf("%-22s", p->rpcb_map.r_addr);
817 1.26 christos rpc = getrpcbynumber(p->rpcb_map.r_prog);
818 1.12 fvdl if (rpc)
819 1.12 fvdl printf(" %-10s", rpc->r_name);
820 1.12 fvdl else
821 1.12 fvdl printf(" %-10s", "-");
822 1.26 christos printf(" %s\n", p->rpcb_map.r_owner);
823 1.12 fvdl }
824 1.12 fvdl } else if (dumptype == RPCBDUMP_SHORT) {
825 1.26 christos for (p = head; p != NULL; p = p->rpcb_next) {
826 1.12 fvdl for (rs = rs_head; rs; rs = rs->next)
827 1.26 christos if (p->rpcb_map.r_prog == rs->prog)
828 1.12 fvdl break;
829 1.12 fvdl if (rs == NULL) {
830 1.24 christos rs = malloc(sizeof (struct rpcbdump_short));
831 1.12 fvdl if (rs == NULL)
832 1.12 fvdl goto error;
833 1.12 fvdl rs->next = NULL;
834 1.12 fvdl if (rs_head == NULL) {
835 1.12 fvdl rs_head = rs;
836 1.12 fvdl rs_tail = rs;
837 1.12 fvdl } else {
838 1.12 fvdl rs_tail->next = rs;
839 1.12 fvdl rs_tail = rs;
840 1.12 fvdl }
841 1.27 christos rs->prog = p->rpcb_map.r_prog;
842 1.27 christos rs->owner = p->rpcb_map.r_owner;
843 1.12 fvdl rs->nlist = NULL;
844 1.12 fvdl rs->vlist = NULL;
845 1.12 fvdl }
846 1.26 christos if (add_version(rs, p->rpcb_map.r_vers) == FALSE)
847 1.12 fvdl goto error;
848 1.26 christos if (add_netid(rs, p->rpcb_map.r_netid) == FALSE)
849 1.12 fvdl goto error;
850 1.12 fvdl }
851 1.12 fvdl printf(
852 1.12 fvdl " program version(s) netid(s) service owner\n");
853 1.12 fvdl for (rs = rs_head; rs; rs = rs->next) {
854 1.28 lukem char *bp = buf;
855 1.12 fvdl
856 1.12 fvdl printf("%10ld ", rs->prog);
857 1.12 fvdl for (vl = rs->vlist; vl; vl = vl->next) {
858 1.28 lukem sprintf(bp, "%d", vl->vers);
859 1.28 lukem bp = bp + strlen(bp);
860 1.12 fvdl if (vl->next)
861 1.28 lukem sprintf(bp++, ",");
862 1.12 fvdl }
863 1.12 fvdl printf("%-10s", buf);
864 1.18 fvdl buf[0] = 0;
865 1.12 fvdl for (nl = rs->nlist; nl; nl = nl->next) {
866 1.12 fvdl strcat(buf, nl->netid);
867 1.12 fvdl if (nl->next)
868 1.12 fvdl strcat(buf, ",");
869 1.12 fvdl }
870 1.12 fvdl printf("%-32s", buf);
871 1.12 fvdl rpc = getrpcbynumber(rs->prog);
872 1.12 fvdl if (rpc)
873 1.12 fvdl printf(" %-11s", rpc->r_name);
874 1.12 fvdl else
875 1.12 fvdl printf(" %-11s", "-");
876 1.12 fvdl printf(" %s\n", rs->owner);
877 1.12 fvdl }
878 1.12 fvdl }
879 1.24 christos if (client)
880 1.24 christos clnt_destroy(client);
881 1.24 christos while (head != NULL) {
882 1.24 christos rpcblist_ptr list = head->rpcb_next;
883 1.24 christos if (head->rpcb_map.r_addr)
884 1.24 christos free(head->rpcb_map.r_addr);
885 1.24 christos if (head->rpcb_map.r_netid)
886 1.24 christos free(head->rpcb_map.r_netid);
887 1.24 christos free(head);
888 1.24 christos head = list;
889 1.23 christos }
890 1.23 christos while (rs_head) {
891 1.23 christos rs = rs_head;
892 1.23 christos rs_head = rs_head->next;
893 1.23 christos free(rs);
894 1.23 christos }
895 1.12 fvdl return;
896 1.24 christos error: err(1, "Cannot allocate memory");
897 1.12 fvdl }
898 1.12 fvdl
899 1.12 fvdl static char nullstring[] = "\000";
900 1.12 fvdl
901 1.12 fvdl static void
902 1.12 fvdl rpcbaddrlist(netid, argc, argv)
903 1.12 fvdl char *netid;
904 1.12 fvdl int argc;
905 1.12 fvdl char **argv;
906 1.12 fvdl {
907 1.12 fvdl rpcb_entry_list_ptr head = NULL;
908 1.12 fvdl struct timeval minutetimeout;
909 1.12 fvdl register CLIENT *client;
910 1.12 fvdl struct rpcent *rpc;
911 1.12 fvdl char *host;
912 1.12 fvdl RPCB parms;
913 1.12 fvdl struct netbuf *targaddr;
914 1.12 fvdl
915 1.12 fvdl if (argc != 3) {
916 1.12 fvdl usage();
917 1.12 fvdl exit(1);
918 1.12 fvdl }
919 1.12 fvdl host = argv[0];
920 1.12 fvdl if (netid == NULL) {
921 1.12 fvdl client = clnt_rpcbind_create(host, RPCBVERS4, &targaddr);
922 1.12 fvdl } else {
923 1.12 fvdl struct netconfig *nconf;
924 1.12 fvdl
925 1.12 fvdl nconf = getnetconfigent(netid);
926 1.12 fvdl if (nconf == NULL) {
927 1.12 fvdl nc_perror("rpcinfo: invalid transport");
928 1.12 fvdl exit(1);
929 1.12 fvdl }
930 1.12 fvdl client = getclnthandle(host, nconf, RPCBVERS4, &targaddr);
931 1.12 fvdl if (nconf)
932 1.12 fvdl (void) freenetconfigent(nconf);
933 1.12 fvdl }
934 1.24 christos if (client == NULL) {
935 1.12 fvdl clnt_pcreateerror("rpcinfo: can't contact rpcbind");
936 1.12 fvdl exit(1);
937 1.12 fvdl }
938 1.12 fvdl minutetimeout.tv_sec = 60;
939 1.12 fvdl minutetimeout.tv_usec = 0;
940 1.12 fvdl
941 1.12 fvdl parms.r_prog = getprognum(argv[1]);
942 1.12 fvdl parms.r_vers = getvers(argv[2]);
943 1.12 fvdl parms.r_netid = client->cl_netid;
944 1.12 fvdl if (targaddr == NULL) {
945 1.12 fvdl parms.r_addr = nullstring; /* for XDRing */
946 1.12 fvdl } else {
947 1.12 fvdl /*
948 1.12 fvdl * We also send the remote system the address we
949 1.12 fvdl * used to contact it in case it can help it
950 1.12 fvdl * connect back with us
951 1.12 fvdl */
952 1.12 fvdl struct netconfig *nconf;
953 1.12 fvdl
954 1.12 fvdl nconf = getnetconfigent(client->cl_netid);
955 1.12 fvdl if (nconf != NULL) {
956 1.12 fvdl parms.r_addr = taddr2uaddr(nconf, targaddr);
957 1.12 fvdl if (parms.r_addr == NULL)
958 1.12 fvdl parms.r_addr = nullstring;
959 1.12 fvdl freenetconfigent(nconf);
960 1.12 fvdl } else {
961 1.12 fvdl parms.r_addr = nullstring; /* for XDRing */
962 1.12 fvdl }
963 1.12 fvdl free(targaddr->buf);
964 1.12 fvdl free(targaddr);
965 1.12 fvdl }
966 1.12 fvdl parms.r_owner = nullstring;
967 1.12 fvdl
968 1.12 fvdl if (CLNT_CALL(client, RPCBPROC_GETADDRLIST, (xdrproc_t) xdr_rpcb,
969 1.12 fvdl (char *) &parms, (xdrproc_t) xdr_rpcb_entry_list_ptr,
970 1.12 fvdl (char *) &head, minutetimeout) != RPC_SUCCESS) {
971 1.12 fvdl clnt_perror(client, "rpcinfo: can't contact rpcbind: ");
972 1.12 fvdl exit(1);
973 1.12 fvdl }
974 1.12 fvdl if (head == NULL) {
975 1.12 fvdl printf("No remote programs registered.\n");
976 1.12 fvdl } else {
977 1.12 fvdl printf(
978 1.12 fvdl " program vers tp_family/name/class address\t\t service\n");
979 1.12 fvdl for (; head != NULL; head = head->rpcb_entry_next) {
980 1.12 fvdl rpcb_entry *re;
981 1.12 fvdl char buf[128];
982 1.12 fvdl
983 1.12 fvdl re = &head->rpcb_entry_map;
984 1.12 fvdl printf("%10u%3u ",
985 1.12 fvdl parms.r_prog, parms.r_vers);
986 1.12 fvdl sprintf(buf, "%s/%s/%s ",
987 1.12 fvdl re->r_nc_protofmly, re->r_nc_proto,
988 1.12 fvdl re->r_nc_semantics == NC_TPI_CLTS ? "clts" :
989 1.12 fvdl re->r_nc_semantics == NC_TPI_COTS ? "cots" :
990 1.12 fvdl "cots_ord");
991 1.12 fvdl printf("%-24s", buf);
992 1.12 fvdl printf("%-24s", re->r_maddr);
993 1.12 fvdl rpc = getrpcbynumber(parms.r_prog);
994 1.12 fvdl if (rpc)
995 1.12 fvdl printf(" %-13s", rpc->r_name);
996 1.12 fvdl else
997 1.12 fvdl printf(" %-13s", "-");
998 1.12 fvdl printf("\n");
999 1.12 fvdl }
1000 1.12 fvdl }
1001 1.12 fvdl clnt_destroy(client);
1002 1.12 fvdl return;
1003 1.12 fvdl }
1004 1.12 fvdl
1005 1.12 fvdl /*
1006 1.12 fvdl * monitor rpcbind
1007 1.12 fvdl */
1008 1.12 fvdl static void
1009 1.12 fvdl rpcbgetstat(argc, argv)
1010 1.12 fvdl int argc;
1011 1.12 fvdl char **argv;
1012 1.12 fvdl {
1013 1.12 fvdl rpcb_stat_byvers inf;
1014 1.12 fvdl struct timeval minutetimeout;
1015 1.12 fvdl register CLIENT *client;
1016 1.12 fvdl char *host;
1017 1.12 fvdl int i, j;
1018 1.12 fvdl rpcbs_addrlist *pa;
1019 1.12 fvdl rpcbs_rmtcalllist *pr;
1020 1.12 fvdl int cnt, flen;
1021 1.12 fvdl #define MAXFIELD 64
1022 1.12 fvdl char fieldbuf[MAXFIELD];
1023 1.12 fvdl #define MAXLINE 256
1024 1.12 fvdl char linebuf[MAXLINE];
1025 1.12 fvdl char *cp, *lp;
1026 1.12 fvdl char *pmaphdr[] = {
1027 1.12 fvdl "NULL", "SET", "UNSET", "GETPORT",
1028 1.12 fvdl "DUMP", "CALLIT"
1029 1.12 fvdl };
1030 1.12 fvdl char *rpcb3hdr[] = {
1031 1.12 fvdl "NULL", "SET", "UNSET", "GETADDR", "DUMP", "CALLIT", "TIME",
1032 1.12 fvdl "U2T", "T2U"
1033 1.12 fvdl };
1034 1.12 fvdl char *rpcb4hdr[] = {
1035 1.12 fvdl "NULL", "SET", "UNSET", "GETADDR", "DUMP", "CALLIT", "TIME",
1036 1.12 fvdl "U2T", "T2U", "VERADDR", "INDRECT", "GETLIST", "GETSTAT"
1037 1.12 fvdl };
1038 1.12 fvdl
1039 1.12 fvdl #define TABSTOP 8
1040 1.12 fvdl
1041 1.12 fvdl if (argc >= 1) {
1042 1.12 fvdl host = argv[0];
1043 1.12 fvdl client = clnt_rpcbind_create(host, RPCBVERS4, NULL);
1044 1.12 fvdl } else
1045 1.12 fvdl client = local_rpcb(PMAPPROG, RPCBVERS4);
1046 1.24 christos if (client == NULL) {
1047 1.12 fvdl clnt_pcreateerror("rpcinfo: can't contact rpcbind");
1048 1.12 fvdl exit(1);
1049 1.12 fvdl }
1050 1.12 fvdl minutetimeout.tv_sec = 60;
1051 1.12 fvdl minutetimeout.tv_usec = 0;
1052 1.12 fvdl memset((char *)&inf, 0, sizeof (rpcb_stat_byvers));
1053 1.12 fvdl if (CLNT_CALL(client, RPCBPROC_GETSTAT, (xdrproc_t) xdr_void, NULL,
1054 1.12 fvdl (xdrproc_t) xdr_rpcb_stat_byvers, (char *)&inf, minutetimeout)
1055 1.12 fvdl != RPC_SUCCESS) {
1056 1.12 fvdl clnt_perror(client, "rpcinfo: can't contact rpcbind: ");
1057 1.12 fvdl exit(1);
1058 1.12 fvdl }
1059 1.12 fvdl printf("PORTMAP (version 2) statistics\n");
1060 1.12 fvdl lp = linebuf;
1061 1.12 fvdl for (i = 0; i <= rpcb_highproc_2; i++) {
1062 1.12 fvdl fieldbuf[0] = '\0';
1063 1.12 fvdl switch (i) {
1064 1.12 fvdl case PMAPPROC_SET:
1065 1.12 fvdl sprintf(fieldbuf, "%d/", inf[RPCBVERS_2_STAT].setinfo);
1066 1.12 fvdl break;
1067 1.12 fvdl case PMAPPROC_UNSET:
1068 1.12 fvdl sprintf(fieldbuf, "%d/",
1069 1.12 fvdl inf[RPCBVERS_2_STAT].unsetinfo);
1070 1.12 fvdl break;
1071 1.12 fvdl case PMAPPROC_GETPORT:
1072 1.12 fvdl cnt = 0;
1073 1.12 fvdl for (pa = inf[RPCBVERS_2_STAT].addrinfo; pa;
1074 1.12 fvdl pa = pa->next)
1075 1.12 fvdl cnt += pa->success;
1076 1.12 fvdl sprintf(fieldbuf, "%d/", cnt);
1077 1.12 fvdl break;
1078 1.12 fvdl case PMAPPROC_CALLIT:
1079 1.12 fvdl cnt = 0;
1080 1.12 fvdl for (pr = inf[RPCBVERS_2_STAT].rmtinfo; pr;
1081 1.12 fvdl pr = pr->next)
1082 1.12 fvdl cnt += pr->success;
1083 1.12 fvdl sprintf(fieldbuf, "%d/", cnt);
1084 1.12 fvdl break;
1085 1.12 fvdl default: break; /* For the remaining ones */
1086 1.12 fvdl }
1087 1.12 fvdl cp = &fieldbuf[0] + strlen(fieldbuf);
1088 1.12 fvdl sprintf(cp, "%d", inf[RPCBVERS_2_STAT].info[i]);
1089 1.12 fvdl flen = strlen(fieldbuf);
1090 1.12 fvdl printf("%s%s", pmaphdr[i],
1091 1.12 fvdl spaces((TABSTOP * (1 + flen / TABSTOP))
1092 1.12 fvdl - strlen(pmaphdr[i])));
1093 1.12 fvdl sprintf(lp, "%s%s", fieldbuf,
1094 1.12 fvdl spaces(cnt = ((TABSTOP * (1 + flen / TABSTOP))
1095 1.12 fvdl - flen)));
1096 1.12 fvdl lp += (flen + cnt);
1097 1.12 fvdl }
1098 1.12 fvdl printf("\n%s\n\n", linebuf);
1099 1.12 fvdl
1100 1.12 fvdl if (inf[RPCBVERS_2_STAT].info[PMAPPROC_CALLIT]) {
1101 1.12 fvdl printf("PMAP_RMTCALL call statistics\n");
1102 1.12 fvdl print_rmtcallstat(RPCBVERS_2_STAT, &inf[RPCBVERS_2_STAT]);
1103 1.12 fvdl printf("\n");
1104 1.12 fvdl }
1105 1.12 fvdl
1106 1.12 fvdl if (inf[RPCBVERS_2_STAT].info[PMAPPROC_GETPORT]) {
1107 1.12 fvdl printf("PMAP_GETPORT call statistics\n");
1108 1.12 fvdl print_getaddrstat(RPCBVERS_2_STAT, &inf[RPCBVERS_2_STAT]);
1109 1.12 fvdl printf("\n");
1110 1.12 fvdl }
1111 1.12 fvdl
1112 1.12 fvdl printf("RPCBIND (version 3) statistics\n");
1113 1.12 fvdl lp = linebuf;
1114 1.12 fvdl for (i = 0; i <= rpcb_highproc_3; i++) {
1115 1.12 fvdl fieldbuf[0] = '\0';
1116 1.12 fvdl switch (i) {
1117 1.12 fvdl case RPCBPROC_SET:
1118 1.12 fvdl sprintf(fieldbuf, "%d/", inf[RPCBVERS_3_STAT].setinfo);
1119 1.12 fvdl break;
1120 1.12 fvdl case RPCBPROC_UNSET:
1121 1.12 fvdl sprintf(fieldbuf, "%d/",
1122 1.12 fvdl inf[RPCBVERS_3_STAT].unsetinfo);
1123 1.12 fvdl break;
1124 1.12 fvdl case RPCBPROC_GETADDR:
1125 1.12 fvdl cnt = 0;
1126 1.12 fvdl for (pa = inf[RPCBVERS_3_STAT].addrinfo; pa;
1127 1.12 fvdl pa = pa->next)
1128 1.12 fvdl cnt += pa->success;
1129 1.12 fvdl sprintf(fieldbuf, "%d/", cnt);
1130 1.12 fvdl break;
1131 1.12 fvdl case RPCBPROC_CALLIT:
1132 1.12 fvdl cnt = 0;
1133 1.12 fvdl for (pr = inf[RPCBVERS_3_STAT].rmtinfo; pr;
1134 1.12 fvdl pr = pr->next)
1135 1.12 fvdl cnt += pr->success;
1136 1.12 fvdl sprintf(fieldbuf, "%d/", cnt);
1137 1.12 fvdl break;
1138 1.12 fvdl default: break; /* For the remaining ones */
1139 1.12 fvdl }
1140 1.12 fvdl cp = &fieldbuf[0] + strlen(fieldbuf);
1141 1.12 fvdl sprintf(cp, "%d", inf[RPCBVERS_3_STAT].info[i]);
1142 1.12 fvdl flen = strlen(fieldbuf);
1143 1.12 fvdl printf("%s%s", rpcb3hdr[i],
1144 1.12 fvdl spaces((TABSTOP * (1 + flen / TABSTOP))
1145 1.12 fvdl - strlen(rpcb3hdr[i])));
1146 1.12 fvdl sprintf(lp, "%s%s", fieldbuf,
1147 1.12 fvdl spaces(cnt = ((TABSTOP * (1 + flen / TABSTOP))
1148 1.12 fvdl - flen)));
1149 1.12 fvdl lp += (flen + cnt);
1150 1.12 fvdl }
1151 1.12 fvdl printf("\n%s\n\n", linebuf);
1152 1.12 fvdl
1153 1.12 fvdl if (inf[RPCBVERS_3_STAT].info[RPCBPROC_CALLIT]) {
1154 1.12 fvdl printf("RPCB_RMTCALL (version 3) call statistics\n");
1155 1.12 fvdl print_rmtcallstat(RPCBVERS_3_STAT, &inf[RPCBVERS_3_STAT]);
1156 1.12 fvdl printf("\n");
1157 1.12 fvdl }
1158 1.12 fvdl
1159 1.12 fvdl if (inf[RPCBVERS_3_STAT].info[RPCBPROC_GETADDR]) {
1160 1.12 fvdl printf("RPCB_GETADDR (version 3) call statistics\n");
1161 1.12 fvdl print_getaddrstat(RPCBVERS_3_STAT, &inf[RPCBVERS_3_STAT]);
1162 1.12 fvdl printf("\n");
1163 1.12 fvdl }
1164 1.12 fvdl
1165 1.12 fvdl printf("RPCBIND (version 4) statistics\n");
1166 1.12 fvdl
1167 1.12 fvdl for (j = 0; j <= 9; j += 9) { /* Just two iterations for printing */
1168 1.12 fvdl lp = linebuf;
1169 1.12 fvdl for (i = j; i <= MAX(8, rpcb_highproc_4 - 9 + j); i++) {
1170 1.12 fvdl fieldbuf[0] = '\0';
1171 1.12 fvdl switch (i) {
1172 1.12 fvdl case RPCBPROC_SET:
1173 1.12 fvdl sprintf(fieldbuf, "%d/",
1174 1.12 fvdl inf[RPCBVERS_4_STAT].setinfo);
1175 1.12 fvdl break;
1176 1.12 fvdl case RPCBPROC_UNSET:
1177 1.12 fvdl sprintf(fieldbuf, "%d/",
1178 1.12 fvdl inf[RPCBVERS_4_STAT].unsetinfo);
1179 1.12 fvdl break;
1180 1.12 fvdl case RPCBPROC_GETADDR:
1181 1.12 fvdl cnt = 0;
1182 1.12 fvdl for (pa = inf[RPCBVERS_4_STAT].addrinfo; pa;
1183 1.12 fvdl pa = pa->next)
1184 1.12 fvdl cnt += pa->success;
1185 1.12 fvdl sprintf(fieldbuf, "%d/", cnt);
1186 1.12 fvdl break;
1187 1.12 fvdl case RPCBPROC_CALLIT:
1188 1.12 fvdl cnt = 0;
1189 1.12 fvdl for (pr = inf[RPCBVERS_4_STAT].rmtinfo; pr;
1190 1.12 fvdl pr = pr->next)
1191 1.12 fvdl cnt += pr->success;
1192 1.12 fvdl sprintf(fieldbuf, "%d/", cnt);
1193 1.12 fvdl break;
1194 1.12 fvdl default: break; /* For the remaining ones */
1195 1.12 fvdl }
1196 1.12 fvdl cp = &fieldbuf[0] + strlen(fieldbuf);
1197 1.12 fvdl /*
1198 1.12 fvdl * XXX: We also add RPCBPROC_GETADDRLIST queries to
1199 1.12 fvdl * RPCB_GETADDR because rpcbind includes the
1200 1.12 fvdl * RPCB_GETADDRLIST successes in RPCB_GETADDR.
1201 1.12 fvdl */
1202 1.12 fvdl if (i != RPCBPROC_GETADDR)
1203 1.12 fvdl sprintf(cp, "%d", inf[RPCBVERS_4_STAT].info[i]);
1204 1.12 fvdl else
1205 1.12 fvdl sprintf(cp, "%d", inf[RPCBVERS_4_STAT].info[i] +
1206 1.12 fvdl inf[RPCBVERS_4_STAT].info[RPCBPROC_GETADDRLIST]);
1207 1.12 fvdl flen = strlen(fieldbuf);
1208 1.12 fvdl printf("%s%s", rpcb4hdr[i],
1209 1.12 fvdl spaces((TABSTOP * (1 + flen / TABSTOP))
1210 1.12 fvdl - strlen(rpcb4hdr[i])));
1211 1.12 fvdl sprintf(lp, "%s%s", fieldbuf,
1212 1.12 fvdl spaces(cnt = ((TABSTOP * (1 + flen / TABSTOP))
1213 1.12 fvdl - flen)));
1214 1.12 fvdl lp += (flen + cnt);
1215 1.12 fvdl }
1216 1.12 fvdl printf("\n%s\n", linebuf);
1217 1.12 fvdl }
1218 1.12 fvdl
1219 1.12 fvdl if (inf[RPCBVERS_4_STAT].info[RPCBPROC_CALLIT] ||
1220 1.12 fvdl inf[RPCBVERS_4_STAT].info[RPCBPROC_INDIRECT]) {
1221 1.12 fvdl printf("\n");
1222 1.12 fvdl printf("RPCB_RMTCALL (version 4) call statistics\n");
1223 1.12 fvdl print_rmtcallstat(RPCBVERS_4_STAT, &inf[RPCBVERS_4_STAT]);
1224 1.12 fvdl }
1225 1.12 fvdl
1226 1.12 fvdl if (inf[RPCBVERS_4_STAT].info[RPCBPROC_GETADDR]) {
1227 1.12 fvdl printf("\n");
1228 1.12 fvdl printf("RPCB_GETADDR (version 4) call statistics\n");
1229 1.12 fvdl print_getaddrstat(RPCBVERS_4_STAT, &inf[RPCBVERS_4_STAT]);
1230 1.12 fvdl }
1231 1.12 fvdl clnt_destroy(client);
1232 1.12 fvdl }
1233 1.12 fvdl
1234 1.12 fvdl /*
1235 1.12 fvdl * Delete registeration for this (prog, vers, netid)
1236 1.12 fvdl */
1237 1.12 fvdl static void
1238 1.12 fvdl deletereg(netid, argc, argv)
1239 1.12 fvdl char *netid;
1240 1.12 fvdl int argc;
1241 1.12 fvdl char **argv;
1242 1.12 fvdl {
1243 1.12 fvdl struct netconfig *nconf = NULL;
1244 1.1 glass
1245 1.1 glass if (argc != 2) {
1246 1.7 lukem usage();
1247 1.7 lukem exit(1);
1248 1.1 glass }
1249 1.12 fvdl if (netid) {
1250 1.12 fvdl nconf = getnetconfigent(netid);
1251 1.12 fvdl if (nconf == NULL) {
1252 1.12 fvdl fprintf(stderr, "rpcinfo: netid %s not supported\n",
1253 1.12 fvdl netid);
1254 1.12 fvdl exit(1);
1255 1.12 fvdl }
1256 1.12 fvdl }
1257 1.12 fvdl if ((rpcb_unset(getprognum(argv[0]), getvers(argv[1]), nconf)) == 0) {
1258 1.12 fvdl fprintf(stderr,
1259 1.12 fvdl "rpcinfo: Could not delete registration for prog %s version %s\n",
1260 1.12 fvdl argv[0], argv[1]);
1261 1.12 fvdl exit(1);
1262 1.12 fvdl }
1263 1.12 fvdl }
1264 1.12 fvdl
1265 1.12 fvdl /*
1266 1.12 fvdl * Create and return a handle for the given nconf.
1267 1.12 fvdl * Exit if cannot create handle.
1268 1.12 fvdl */
1269 1.12 fvdl static CLIENT *
1270 1.12 fvdl clnt_addr_create(address, nconf, prog, vers)
1271 1.12 fvdl char *address;
1272 1.12 fvdl struct netconfig *nconf;
1273 1.12 fvdl u_long prog;
1274 1.12 fvdl u_long vers;
1275 1.12 fvdl {
1276 1.12 fvdl CLIENT *client;
1277 1.12 fvdl static struct netbuf *nbuf;
1278 1.12 fvdl static int fd = RPC_ANYFD;
1279 1.12 fvdl
1280 1.12 fvdl if (fd == RPC_ANYFD) {
1281 1.12 fvdl if ((fd = __rpc_nconf2fd(nconf)) == -1) {
1282 1.12 fvdl rpc_createerr.cf_stat = RPC_TLIERROR;
1283 1.12 fvdl clnt_pcreateerror("rpcinfo");
1284 1.12 fvdl exit(1);
1285 1.12 fvdl }
1286 1.12 fvdl /* Convert the uaddr to taddr */
1287 1.12 fvdl nbuf = uaddr2taddr(nconf, address);
1288 1.12 fvdl if (nbuf == NULL) {
1289 1.24 christos errx(1, "No address for client handle");
1290 1.12 fvdl exit(1);
1291 1.12 fvdl }
1292 1.12 fvdl }
1293 1.12 fvdl client = clnt_tli_create(fd, nconf, nbuf, prog, vers, 0, 0);
1294 1.24 christos if (client == NULL) {
1295 1.24 christos clnt_pcreateerror(getprogname());
1296 1.12 fvdl exit(1);
1297 1.12 fvdl }
1298 1.12 fvdl return (client);
1299 1.12 fvdl }
1300 1.12 fvdl
1301 1.12 fvdl /*
1302 1.12 fvdl * If the version number is given, ping that (prog, vers); else try to find
1303 1.12 fvdl * the version numbers supported for that prog and ping all the versions.
1304 1.12 fvdl * Remote rpcbind is not contacted for this service. The requests are
1305 1.12 fvdl * sent directly to the services themselves.
1306 1.12 fvdl */
1307 1.12 fvdl static void
1308 1.12 fvdl addrping(address, netid, argc, argv)
1309 1.12 fvdl char *address;
1310 1.12 fvdl char *netid;
1311 1.12 fvdl int argc;
1312 1.12 fvdl char **argv;
1313 1.12 fvdl {
1314 1.12 fvdl CLIENT *client;
1315 1.12 fvdl struct timeval to;
1316 1.12 fvdl enum clnt_stat rpc_stat;
1317 1.12 fvdl u_long prognum, versnum, minvers, maxvers;
1318 1.12 fvdl struct rpc_err rpcerr;
1319 1.12 fvdl int failure = 0;
1320 1.12 fvdl struct netconfig *nconf;
1321 1.12 fvdl int fd;
1322 1.12 fvdl
1323 1.12 fvdl if (argc < 1 || argc > 2 || (netid == NULL)) {
1324 1.12 fvdl usage();
1325 1.12 fvdl exit(1);
1326 1.12 fvdl }
1327 1.12 fvdl nconf = getnetconfigent(netid);
1328 1.24 christos if (nconf == NULL)
1329 1.24 christos errx(1, "Could not find %s", netid);
1330 1.12 fvdl to.tv_sec = 10;
1331 1.12 fvdl to.tv_usec = 0;
1332 1.12 fvdl prognum = getprognum(argv[0]);
1333 1.12 fvdl if (argc == 1) { /* Version number not known */
1334 1.12 fvdl /*
1335 1.12 fvdl * A call to version 0 should fail with a program/version
1336 1.12 fvdl * mismatch, and give us the range of versions supported.
1337 1.12 fvdl */
1338 1.12 fvdl versnum = MIN_VERS;
1339 1.12 fvdl } else {
1340 1.12 fvdl versnum = getvers(argv[1]);
1341 1.12 fvdl }
1342 1.12 fvdl client = clnt_addr_create(address, nconf, prognum, versnum);
1343 1.12 fvdl rpc_stat = CLNT_CALL(client, NULLPROC, (xdrproc_t) xdr_void,
1344 1.24 christos NULL, (xdrproc_t) xdr_void, NULL, to);
1345 1.12 fvdl if (argc == 2) {
1346 1.12 fvdl /* Version number was known */
1347 1.12 fvdl if (pstatus(client, prognum, versnum) < 0)
1348 1.12 fvdl failure = 1;
1349 1.12 fvdl (void) CLNT_DESTROY(client);
1350 1.12 fvdl if (failure)
1351 1.12 fvdl exit(1);
1352 1.12 fvdl return;
1353 1.12 fvdl }
1354 1.12 fvdl /* Version number not known */
1355 1.24 christos (void) CLNT_CONTROL(client, CLSET_FD_NCLOSE, NULL);
1356 1.12 fvdl (void) CLNT_CONTROL(client, CLGET_FD, (char *)&fd);
1357 1.12 fvdl if (rpc_stat == RPC_PROGVERSMISMATCH) {
1358 1.12 fvdl clnt_geterr(client, &rpcerr);
1359 1.12 fvdl minvers = rpcerr.re_vers.low;
1360 1.12 fvdl maxvers = rpcerr.re_vers.high;
1361 1.12 fvdl } else if (rpc_stat == RPC_SUCCESS) {
1362 1.12 fvdl /*
1363 1.12 fvdl * Oh dear, it DOES support version 0.
1364 1.12 fvdl * Let's try version MAX_VERS.
1365 1.12 fvdl */
1366 1.12 fvdl (void) CLNT_DESTROY(client);
1367 1.12 fvdl client = clnt_addr_create(address, nconf, prognum, MAX_VERS);
1368 1.12 fvdl rpc_stat = CLNT_CALL(client, NULLPROC, (xdrproc_t) xdr_void,
1369 1.24 christos NULL, (xdrproc_t) xdr_void, NULL, to);
1370 1.12 fvdl if (rpc_stat == RPC_PROGVERSMISMATCH) {
1371 1.12 fvdl clnt_geterr(client, &rpcerr);
1372 1.12 fvdl minvers = rpcerr.re_vers.low;
1373 1.12 fvdl maxvers = rpcerr.re_vers.high;
1374 1.12 fvdl } else if (rpc_stat == RPC_SUCCESS) {
1375 1.12 fvdl /*
1376 1.12 fvdl * It also supports version MAX_VERS.
1377 1.12 fvdl * Looks like we have a wise guy.
1378 1.12 fvdl * OK, we give them information on all
1379 1.12 fvdl * 4 billion versions they support...
1380 1.12 fvdl */
1381 1.12 fvdl minvers = 0;
1382 1.12 fvdl maxvers = MAX_VERS;
1383 1.12 fvdl } else {
1384 1.12 fvdl (void) pstatus(client, prognum, MAX_VERS);
1385 1.12 fvdl exit(1);
1386 1.12 fvdl }
1387 1.12 fvdl } else {
1388 1.12 fvdl (void) pstatus(client, prognum, (u_long)0);
1389 1.12 fvdl exit(1);
1390 1.12 fvdl }
1391 1.12 fvdl (void) CLNT_DESTROY(client);
1392 1.12 fvdl for (versnum = minvers; versnum <= maxvers; versnum++) {
1393 1.12 fvdl client = clnt_addr_create(address, nconf, prognum, versnum);
1394 1.12 fvdl rpc_stat = CLNT_CALL(client, NULLPROC, (xdrproc_t) xdr_void,
1395 1.24 christos NULL, (xdrproc_t) xdr_void, NULL, to);
1396 1.12 fvdl if (pstatus(client, prognum, versnum) < 0)
1397 1.12 fvdl failure = 1;
1398 1.12 fvdl (void) CLNT_DESTROY(client);
1399 1.12 fvdl }
1400 1.12 fvdl (void) close(fd);
1401 1.12 fvdl if (failure)
1402 1.12 fvdl exit(1);
1403 1.12 fvdl return;
1404 1.12 fvdl }
1405 1.12 fvdl
1406 1.12 fvdl /*
1407 1.12 fvdl * If the version number is given, ping that (prog, vers); else try to find
1408 1.12 fvdl * the version numbers supported for that prog and ping all the versions.
1409 1.12 fvdl * Remote rpcbind is *contacted* for this service. The requests are
1410 1.12 fvdl * then sent directly to the services themselves.
1411 1.12 fvdl */
1412 1.12 fvdl static void
1413 1.12 fvdl progping(netid, argc, argv)
1414 1.12 fvdl char *netid;
1415 1.12 fvdl int argc;
1416 1.12 fvdl char **argv;
1417 1.12 fvdl {
1418 1.12 fvdl CLIENT *client;
1419 1.12 fvdl struct timeval to;
1420 1.12 fvdl enum clnt_stat rpc_stat;
1421 1.12 fvdl u_long prognum, versnum, minvers, maxvers;
1422 1.12 fvdl struct rpc_err rpcerr;
1423 1.12 fvdl int failure = 0;
1424 1.12 fvdl struct netconfig *nconf;
1425 1.12 fvdl
1426 1.12 fvdl if (argc < 2 || argc > 3 || (netid == NULL)) {
1427 1.12 fvdl usage();
1428 1.12 fvdl exit(1);
1429 1.12 fvdl }
1430 1.12 fvdl prognum = getprognum(argv[1]);
1431 1.12 fvdl if (argc == 2) { /* Version number not known */
1432 1.12 fvdl /*
1433 1.12 fvdl * A call to version 0 should fail with a program/version
1434 1.12 fvdl * mismatch, and give us the range of versions supported.
1435 1.12 fvdl */
1436 1.12 fvdl versnum = MIN_VERS;
1437 1.12 fvdl } else {
1438 1.12 fvdl versnum = getvers(argv[2]);
1439 1.12 fvdl }
1440 1.12 fvdl if (netid) {
1441 1.12 fvdl nconf = getnetconfigent(netid);
1442 1.24 christos if (nconf == NULL)
1443 1.24 christos errx(1, "Could not find `%s'", netid);
1444 1.12 fvdl client = clnt_tp_create(argv[0], prognum, versnum, nconf);
1445 1.12 fvdl } else {
1446 1.12 fvdl client = clnt_create(argv[0], prognum, versnum, "NETPATH");
1447 1.12 fvdl }
1448 1.24 christos if (client == NULL) {
1449 1.24 christos clnt_pcreateerror(getprogname());
1450 1.12 fvdl exit(1);
1451 1.12 fvdl }
1452 1.12 fvdl to.tv_sec = 10;
1453 1.12 fvdl to.tv_usec = 0;
1454 1.12 fvdl rpc_stat = CLNT_CALL(client, NULLPROC, (xdrproc_t) xdr_void,
1455 1.24 christos NULL, (xdrproc_t) xdr_void, NULL, to);
1456 1.12 fvdl if (argc == 3) {
1457 1.12 fvdl /* Version number was known */
1458 1.12 fvdl if (pstatus(client, prognum, versnum) < 0)
1459 1.12 fvdl failure = 1;
1460 1.12 fvdl (void) CLNT_DESTROY(client);
1461 1.12 fvdl if (failure)
1462 1.12 fvdl exit(1);
1463 1.12 fvdl return;
1464 1.12 fvdl }
1465 1.12 fvdl /* Version number not known */
1466 1.12 fvdl if (rpc_stat == RPC_PROGVERSMISMATCH) {
1467 1.12 fvdl clnt_geterr(client, &rpcerr);
1468 1.12 fvdl minvers = rpcerr.re_vers.low;
1469 1.12 fvdl maxvers = rpcerr.re_vers.high;
1470 1.12 fvdl } else if (rpc_stat == RPC_SUCCESS) {
1471 1.12 fvdl /*
1472 1.12 fvdl * Oh dear, it DOES support version 0.
1473 1.12 fvdl * Let's try version MAX_VERS.
1474 1.12 fvdl */
1475 1.12 fvdl versnum = MAX_VERS;
1476 1.12 fvdl (void) CLNT_CONTROL(client, CLSET_VERS, (char *)&versnum);
1477 1.12 fvdl rpc_stat = CLNT_CALL(client, NULLPROC,
1478 1.24 christos (xdrproc_t) xdr_void, NULL, (xdrproc_t) xdr_void, NULL, to);
1479 1.12 fvdl if (rpc_stat == RPC_PROGVERSMISMATCH) {
1480 1.12 fvdl clnt_geterr(client, &rpcerr);
1481 1.12 fvdl minvers = rpcerr.re_vers.low;
1482 1.12 fvdl maxvers = rpcerr.re_vers.high;
1483 1.12 fvdl } else if (rpc_stat == RPC_SUCCESS) {
1484 1.12 fvdl /*
1485 1.12 fvdl * It also supports version MAX_VERS.
1486 1.12 fvdl * Looks like we have a wise guy.
1487 1.12 fvdl * OK, we give them information on all
1488 1.12 fvdl * 4 billion versions they support...
1489 1.12 fvdl */
1490 1.12 fvdl minvers = 0;
1491 1.12 fvdl maxvers = MAX_VERS;
1492 1.12 fvdl } else {
1493 1.12 fvdl (void) pstatus(client, prognum, MAX_VERS);
1494 1.12 fvdl exit(1);
1495 1.12 fvdl }
1496 1.12 fvdl } else {
1497 1.12 fvdl (void) pstatus(client, prognum, (u_long)0);
1498 1.12 fvdl exit(1);
1499 1.12 fvdl }
1500 1.12 fvdl for (versnum = minvers; versnum <= maxvers; versnum++) {
1501 1.12 fvdl (void) CLNT_CONTROL(client, CLSET_VERS, (char *)&versnum);
1502 1.12 fvdl rpc_stat = CLNT_CALL(client, NULLPROC, (xdrproc_t) xdr_void,
1503 1.24 christos NULL, (xdrproc_t) xdr_void, NULL, to);
1504 1.12 fvdl if (pstatus(client, prognum, versnum) < 0)
1505 1.12 fvdl failure = 1;
1506 1.12 fvdl }
1507 1.12 fvdl (void) CLNT_DESTROY(client);
1508 1.12 fvdl if (failure)
1509 1.12 fvdl exit(1);
1510 1.12 fvdl return;
1511 1.1 glass }
1512 1.1 glass
1513 1.1 glass static void
1514 1.1 glass usage()
1515 1.1 glass {
1516 1.19 jmmv fprintf(stderr, "usage: rpcinfo [-m | -s] [host]\n");
1517 1.12 fvdl #ifdef PORTMAP
1518 1.12 fvdl fprintf(stderr, " rpcinfo -p [host]\n");
1519 1.12 fvdl #endif
1520 1.12 fvdl fprintf(stderr, " rpcinfo -T netid host prognum [versnum]\n");
1521 1.12 fvdl fprintf(stderr, " rpcinfo -l host prognum versnum\n");
1522 1.12 fvdl #ifdef PORTMAP
1523 1.12 fvdl fprintf(stderr,
1524 1.12 fvdl " rpcinfo [-n portnum] -u | -t host prognum [versnum]\n");
1525 1.12 fvdl #endif
1526 1.12 fvdl fprintf(stderr,
1527 1.12 fvdl " rpcinfo -a serv_address -T netid prognum [version]\n");
1528 1.1 glass fprintf(stderr, " rpcinfo -b prognum versnum\n");
1529 1.12 fvdl fprintf(stderr, " rpcinfo -d [-T netid] prognum versnum\n");
1530 1.1 glass }
1531 1.1 glass
1532 1.1 glass static u_long
1533 1.12 fvdl getprognum (arg)
1534 1.1 glass char *arg;
1535 1.1 glass {
1536 1.12 fvdl char *strptr;
1537 1.12 fvdl register struct rpcent *rpc;
1538 1.12 fvdl register u_long prognum;
1539 1.12 fvdl char *tptr = arg;
1540 1.1 glass
1541 1.21 dsl while (*tptr && isdigit((unsigned char)*tptr++));
1542 1.21 dsl if (*tptr || isalpha((unsigned char)*(tptr - 1))) {
1543 1.1 glass rpc = getrpcbyname(arg);
1544 1.24 christos if (rpc == NULL)
1545 1.24 christos errx(1, "Unknown service `%s'", arg);
1546 1.1 glass prognum = rpc->r_number;
1547 1.1 glass } else {
1548 1.12 fvdl prognum = strtol(arg, &strptr, 10);
1549 1.24 christos if (strptr == arg || *strptr != '\0')
1550 1.24 christos errx(1, "Illegal program number `%s'", arg);
1551 1.1 glass }
1552 1.1 glass return (prognum);
1553 1.1 glass }
1554 1.1 glass
1555 1.1 glass static u_long
1556 1.1 glass getvers(arg)
1557 1.1 glass char *arg;
1558 1.1 glass {
1559 1.12 fvdl char *strptr;
1560 1.12 fvdl register u_long vers;
1561 1.12 fvdl
1562 1.12 fvdl vers = (int) strtol(arg, &strptr, 10);
1563 1.24 christos if (strptr == arg || *strptr != '\0')
1564 1.24 christos errx(1, "Illegal version number `%s'", arg);
1565 1.12 fvdl return (vers);
1566 1.12 fvdl }
1567 1.12 fvdl
1568 1.12 fvdl /*
1569 1.12 fvdl * This routine should take a pointer to an "rpc_err" structure, rather than
1570 1.12 fvdl * a pointer to a CLIENT structure, but "clnt_perror" takes a pointer to
1571 1.12 fvdl * a CLIENT structure rather than a pointer to an "rpc_err" structure.
1572 1.12 fvdl * As such, we have to keep the CLIENT structure around in order to print
1573 1.12 fvdl * a good error message.
1574 1.12 fvdl */
1575 1.12 fvdl static int
1576 1.12 fvdl pstatus(client, prog, vers)
1577 1.12 fvdl register CLIENT *client;
1578 1.12 fvdl u_long prog;
1579 1.6 lukem u_long vers;
1580 1.12 fvdl {
1581 1.12 fvdl struct rpc_err rpcerr;
1582 1.1 glass
1583 1.12 fvdl clnt_geterr(client, &rpcerr);
1584 1.12 fvdl if (rpcerr.re_status != RPC_SUCCESS) {
1585 1.24 christos clnt_perror(client, getprogname());
1586 1.12 fvdl printf("program %lu version %lu is not available\n",
1587 1.12 fvdl prog, vers);
1588 1.12 fvdl return (-1);
1589 1.12 fvdl } else {
1590 1.12 fvdl printf("program %lu version %lu ready and waiting\n",
1591 1.12 fvdl prog, vers);
1592 1.12 fvdl return (0);
1593 1.12 fvdl }
1594 1.1 glass }
1595 1.1 glass
1596 1.12 fvdl static CLIENT *
1597 1.12 fvdl clnt_rpcbind_create(host, rpcbversnum, targaddr)
1598 1.1 glass char *host;
1599 1.12 fvdl int rpcbversnum;
1600 1.12 fvdl struct netbuf **targaddr;
1601 1.1 glass {
1602 1.12 fvdl static char *tlist[3] = {
1603 1.12 fvdl "circuit_n", "circuit_v", "datagram_v"
1604 1.12 fvdl };
1605 1.12 fvdl int i;
1606 1.12 fvdl struct netconfig *nconf;
1607 1.12 fvdl CLIENT *clnt = NULL;
1608 1.12 fvdl void *handle;
1609 1.12 fvdl
1610 1.12 fvdl rpc_createerr.cf_stat = RPC_SUCCESS;
1611 1.12 fvdl for (i = 0; i < 3; i++) {
1612 1.12 fvdl if ((handle = __rpc_setconf(tlist[i])) == NULL)
1613 1.12 fvdl continue;
1614 1.24 christos while (clnt == NULL) {
1615 1.12 fvdl if ((nconf = __rpc_getconf(handle)) == NULL) {
1616 1.12 fvdl if (rpc_createerr.cf_stat == RPC_SUCCESS)
1617 1.12 fvdl rpc_createerr.cf_stat = RPC_UNKNOWNPROTO;
1618 1.12 fvdl break;
1619 1.12 fvdl }
1620 1.12 fvdl clnt = getclnthandle(host, nconf, rpcbversnum,
1621 1.12 fvdl targaddr);
1622 1.12 fvdl }
1623 1.12 fvdl if (clnt)
1624 1.12 fvdl break;
1625 1.12 fvdl __rpc_endconf(handle);
1626 1.12 fvdl }
1627 1.12 fvdl return (clnt);
1628 1.12 fvdl }
1629 1.1 glass
1630 1.12 fvdl static CLIENT*
1631 1.12 fvdl getclnthandle(host, nconf, rpcbversnum, targaddr)
1632 1.12 fvdl char *host;
1633 1.12 fvdl struct netconfig *nconf;
1634 1.12 fvdl u_long rpcbversnum;
1635 1.12 fvdl struct netbuf **targaddr;
1636 1.12 fvdl {
1637 1.12 fvdl struct netbuf addr;
1638 1.12 fvdl struct addrinfo hints, *res;
1639 1.12 fvdl CLIENT *client = NULL;
1640 1.12 fvdl
1641 1.12 fvdl /* Get the address of the rpcbind */
1642 1.12 fvdl memset(&hints, 0, sizeof hints);
1643 1.12 fvdl if (getaddrinfo(host, "rpcbind", &hints, &res) != 0) {
1644 1.12 fvdl rpc_createerr.cf_stat = RPC_N2AXLATEFAILURE;
1645 1.12 fvdl return (NULL);
1646 1.12 fvdl }
1647 1.12 fvdl addr.len = addr.maxlen = res->ai_addrlen;
1648 1.12 fvdl addr.buf = res->ai_addr;
1649 1.12 fvdl client = clnt_tli_create(RPC_ANYFD, nconf, &addr, RPCBPROG,
1650 1.12 fvdl rpcbversnum, 0, 0);
1651 1.12 fvdl if (client) {
1652 1.12 fvdl if (targaddr != NULL) {
1653 1.24 christos *targaddr = malloc(sizeof (struct netbuf));
1654 1.12 fvdl if (*targaddr != NULL) {
1655 1.12 fvdl (*targaddr)->maxlen = addr.maxlen;
1656 1.12 fvdl (*targaddr)->len = addr.len;
1657 1.24 christos (*targaddr)->buf = malloc(addr.len);
1658 1.12 fvdl if ((*targaddr)->buf != NULL) {
1659 1.12 fvdl memcpy((*targaddr)->buf, addr.buf,
1660 1.12 fvdl addr.len);
1661 1.12 fvdl }
1662 1.12 fvdl }
1663 1.12 fvdl }
1664 1.12 fvdl } else {
1665 1.12 fvdl if (rpc_createerr.cf_stat == RPC_TLIERROR) {
1666 1.12 fvdl /*
1667 1.12 fvdl * Assume that the other system is dead; this is a
1668 1.12 fvdl * better error to display to the user.
1669 1.12 fvdl */
1670 1.12 fvdl rpc_createerr.cf_stat = RPC_RPCBFAILURE;
1671 1.12 fvdl rpc_createerr.cf_error.re_status = RPC_FAILED;
1672 1.1 glass }
1673 1.1 glass }
1674 1.12 fvdl freeaddrinfo(res);
1675 1.12 fvdl return (client);
1676 1.12 fvdl }
1677 1.12 fvdl
1678 1.12 fvdl static void
1679 1.12 fvdl print_rmtcallstat(rtype, infp)
1680 1.12 fvdl int rtype;
1681 1.12 fvdl rpcb_stat *infp;
1682 1.12 fvdl {
1683 1.12 fvdl register rpcbs_rmtcalllist_ptr pr;
1684 1.12 fvdl struct rpcent *rpc;
1685 1.12 fvdl
1686 1.12 fvdl if (rtype == RPCBVERS_4_STAT)
1687 1.12 fvdl printf(
1688 1.12 fvdl "prog\t\tvers\tproc\tnetid\tindirect success failure\n");
1689 1.12 fvdl else
1690 1.12 fvdl printf("prog\t\tvers\tproc\tnetid\tsuccess\tfailure\n");
1691 1.12 fvdl for (pr = infp->rmtinfo; pr; pr = pr->next) {
1692 1.12 fvdl rpc = getrpcbynumber(pr->prog);
1693 1.12 fvdl if (rpc)
1694 1.12 fvdl printf("%-16s", rpc->r_name);
1695 1.12 fvdl else
1696 1.12 fvdl printf("%-16d", pr->prog);
1697 1.12 fvdl printf("%d\t%d\t%s\t",
1698 1.12 fvdl pr->vers, pr->proc, pr->netid);
1699 1.12 fvdl if (rtype == RPCBVERS_4_STAT)
1700 1.12 fvdl printf("%d\t ", pr->indirect);
1701 1.12 fvdl printf("%d\t%d\n", pr->success, pr->failure);
1702 1.12 fvdl }
1703 1.12 fvdl }
1704 1.12 fvdl
1705 1.12 fvdl static void
1706 1.12 fvdl print_getaddrstat(rtype, infp)
1707 1.12 fvdl int rtype;
1708 1.12 fvdl rpcb_stat *infp;
1709 1.12 fvdl {
1710 1.12 fvdl rpcbs_addrlist_ptr al;
1711 1.12 fvdl register struct rpcent *rpc;
1712 1.12 fvdl
1713 1.12 fvdl printf("prog\t\tvers\tnetid\t success\tfailure\n");
1714 1.12 fvdl for (al = infp->addrinfo; al; al = al->next) {
1715 1.12 fvdl rpc = getrpcbynumber(al->prog);
1716 1.12 fvdl if (rpc)
1717 1.12 fvdl printf("%-16s", rpc->r_name);
1718 1.12 fvdl else
1719 1.12 fvdl printf("%-16d", al->prog);
1720 1.12 fvdl printf("%d\t%s\t %-12d\t%d\n",
1721 1.12 fvdl al->vers, al->netid,
1722 1.12 fvdl al->success, al->failure);
1723 1.12 fvdl }
1724 1.12 fvdl }
1725 1.12 fvdl
1726 1.12 fvdl static char *
1727 1.12 fvdl spaces(howmany)
1728 1.12 fvdl int howmany;
1729 1.12 fvdl {
1730 1.12 fvdl static char space_array[] = /* 64 spaces */
1731 1.12 fvdl " ";
1732 1.12 fvdl
1733 1.12 fvdl if (howmany <= 0 || howmany > sizeof (space_array)) {
1734 1.12 fvdl return ("");
1735 1.12 fvdl }
1736 1.12 fvdl return (&space_array[sizeof (space_array) - howmany - 1]);
1737 1.1 glass }
1738