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