/* $OpenBSD: rpcinfo.c,v 1.14 2010/09/01 14:43:34 millert Exp $ */ /* * Copyright (c) 2010, Oracle America, Inc. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions are * met: * * * Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * * Redistributions in binary form must reproduce the above * copyright notice, this list of conditions and the following * disclaimer in the documentation and/or other materials * provided with the distribution. * * Neither the name of the "Oracle America, Inc." nor the names of its * contributors may be used to endorse or promote products derived * from this software without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE * COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE * GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. */ /* * rpcinfo: ping a particular rpc program * or dump the portmapper */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #define MAXHOSTLEN 256 #define MIN_VERS ((u_long) 0) #define MAX_VERS ((u_long) 4294967295UL) void udpping(u_short portflag, int argc, char **argv); void tcpping(u_short portflag, int argc, char **argv); int pstatus(CLIENT *client, u_long prognum, u_long vers); void pmapdump(int argc, char **argv); bool_t reply_proc(caddr_t res, struct sockaddr_in *who); void brdcst(int argc, char **argv); void deletereg(int argc, char **argv); void setreg(int argc, char **argv); void usage(char *); int getprognum(char *arg, u_long *ulp); int getul(char *arg, u_long *ulp); void get_inet_address(struct sockaddr_in *addr, char *host); /* * Functions to be performed. */ #define NONE 0 /* no function */ #define PMAPDUMP 1 /* dump portmapper registrations */ #define TCPPING 2 /* ping TCP service */ #define UDPPING 3 /* ping UDP service */ #define BRDCST 4 /* ping broadcast UDP service */ #define DELETES 5 /* delete registration for the service */ #define SETS 6 /* set registration for the service */ int main(int argc, char *argv[]) { int c; extern char *optarg; extern int optind; int errflg; int function; u_short portnum; u_long tmp; function = NONE; portnum = 0; errflg = 0; while ((c = getopt(argc, argv, "ptubdsn:")) != -1) { switch (c) { case 'p': if (function != NONE) errflg = 1; else function = PMAPDUMP; break; case 't': if (function != NONE) errflg = 1; else function = TCPPING; break; case 'u': if (function != NONE) errflg = 1; else function = UDPPING; break; case 'b': if (function != NONE) errflg = 1; else function = BRDCST; break; case 'n': if (getul(optarg, &tmp)) usage("invalid port number"); if (tmp >= 65536) usage("port number out of range"); portnum = (u_short)tmp; break; case 'd': if (function != NONE) errflg = 1; else function = DELETES; break; case 's': if (function != NONE) errflg = 1; else function = SETS; break; case '?': errflg = 1; } } if (errflg || function == NONE) usage(NULL); switch (function) { case PMAPDUMP: if (portnum != 0) usage(NULL); pmapdump(argc - optind, argv + optind); break; case UDPPING: udpping(portnum, argc - optind, argv + optind); break; case TCPPING: tcpping(portnum, argc - optind, argv + optind); break; case BRDCST: if (portnum != 0) usage(NULL); brdcst(argc - optind, argv + optind); break; case DELETES: deletereg(argc - optind, argv + optind); break; case SETS: setreg(argc - optind, argv + optind); break; } return (0); } void udpping(u_short portnum, int argc, char **argv) { struct timeval to; struct sockaddr_in addr; enum clnt_stat rpc_stat; CLIENT *client; u_long prognum, vers, minvers, maxvers; int sock = RPC_ANYSOCK; struct rpc_err rpcerr; int failure; if (argc < 2) usage("too few arguments"); if (argc > 3) usage("too many arguments"); if (getprognum(argv[1], &prognum)) usage("program number out of range"); get_inet_address(&addr, argv[0]); /* Open the socket here so it will survive calls to clnt_destroy */ sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP); if (sock < 0) { perror("rpcinfo: socket"); exit(1); } if (getuid() == 0) bindresvport(sock, NULL); failure = 0; if (argc == 2) { /* * A call to version 0 should fail with a program/version * mismatch, and give us the range of versions supported. */ addr.sin_port = htons(portnum); to.tv_sec = 5; to.tv_usec = 0; if ((client = clntudp_create(&addr, prognum, (u_long)0, to, &sock)) == NULL) { clnt_pcreateerror("rpcinfo"); printf("program %lu is not available\n", prognum); exit(1); } to.tv_sec = 10; to.tv_usec = 0; rpc_stat = clnt_call(client, NULLPROC, xdr_void, (char *)NULL, xdr_void, (char *)NULL, to); if (rpc_stat == RPC_PROGVERSMISMATCH) { clnt_geterr(client, &rpcerr); minvers = rpcerr.re_vers.low; maxvers = rpcerr.re_vers.high; } else if (rpc_stat == RPC_SUCCESS) { /* * Oh dear, it DOES support version 0. * Let's try version MAX_VERS. */ addr.sin_port = htons(portnum); to.tv_sec = 5; to.tv_usec = 0; if ((client = clntudp_create(&addr, prognum, MAX_VERS, to, &sock)) == NULL) { clnt_pcreateerror("rpcinfo"); printf("program %lu version %lu is not available\n", prognum, MAX_VERS); exit(1); } to.tv_sec = 10; to.tv_usec = 0; rpc_stat = clnt_call(client, NULLPROC, xdr_void, (char *)NULL, xdr_void, (char *)NULL, to); if (rpc_stat == RPC_PROGVERSMISMATCH) { clnt_geterr(client, &rpcerr); minvers = rpcerr.re_vers.low; maxvers = rpcerr.re_vers.high; } else if (rpc_stat == RPC_SUCCESS) { /* * It also supports version MAX_VERS. * Looks like we have a wise guy. * OK, we give them information on all * 4 billion versions they support... */ minvers = 0; maxvers = MAX_VERS; } else { (void) pstatus(client, prognum, MAX_VERS); exit(1); } } else { (void) pstatus(client, prognum, (u_long)0); exit(1); } clnt_destroy(client); for (vers = minvers; vers <= maxvers; vers++) { addr.sin_port = htons(portnum); to.tv_sec = 5; to.tv_usec = 0; if ((client = clntudp_create(&addr, prognum, vers, to, &sock)) == NULL) { clnt_pcreateerror("rpcinfo"); printf("program %lu version %lu is not available\n", prognum, vers); exit(1); } to.tv_sec = 10; to.tv_usec = 0; rpc_stat = clnt_call(client, NULLPROC, xdr_void, (char *)NULL, xdr_void, (char *)NULL, to); if (pstatus(client, prognum, vers) < 0) failure = 1; clnt_destroy(client); } } else { getul(argv[2], &vers); /* XXX */ addr.sin_port = htons(portnum); to.tv_sec = 5; to.tv_usec = 0; if ((client = clntudp_create(&addr, prognum, vers, to, &sock)) == NULL) { clnt_pcreateerror("rpcinfo"); printf("program %lu version %lu is not available\n", prognum, vers); exit(1); } to.tv_sec = 10; to.tv_usec = 0; rpc_stat = clnt_call(client, 0, xdr_void, (char *)NULL, xdr_void, (char *)NULL, to); if (pstatus(client, prognum, vers) < 0) failure = 1; } (void) close(sock); /* Close it up again */ if (failure) exit(1); } void tcpping(u_short portnum, int argc, char **argv) { struct timeval to; struct sockaddr_in addr; enum clnt_stat rpc_stat; CLIENT *client; u_long prognum, vers, minvers, maxvers; int sock = RPC_ANYSOCK; struct rpc_err rpcerr; int failure; if (argc < 2) usage("too few arguments"); if (argc > 3) usage("too many arguments"); if (getprognum(argv[1], &prognum)) usage("program number out of range"); get_inet_address(&addr, argv[0]); failure = 0; if (argc == 2) { /* * A call to version 0 should fail with a program/version * mismatch, and give us the range of versions supported. */ addr.sin_port = htons(portnum); if ((client = clnttcp_create(&addr, prognum, MIN_VERS, &sock, 0, 0)) == NULL) { clnt_pcreateerror("rpcinfo"); printf("program %lu is not available\n", prognum); exit(1); } to.tv_sec = 10; to.tv_usec = 0; rpc_stat = clnt_call(client, NULLPROC, xdr_void, (char *)NULL, xdr_void, (char *)NULL, to); if (rpc_stat == RPC_PROGVERSMISMATCH) { clnt_geterr(client, &rpcerr); minvers = rpcerr.re_vers.low; maxvers = rpcerr.re_vers.high; } else if (rpc_stat == RPC_SUCCESS) { /* * Oh dear, it DOES support version 0. * Let's try version MAX_VERS. */ addr.sin_port = htons(portnum); if ((client = clnttcp_create(&addr, prognum, MAX_VERS, &sock, 0, 0)) == NULL) { clnt_pcreateerror("rpcinfo"); printf("program %lu version %lu is not available\n", prognum, MAX_VERS); exit(1); } to.tv_sec = 10; to.tv_usec = 0; rpc_stat = clnt_call(client, NULLPROC, xdr_void, (char *)NULL, xdr_void, (char *)NULL, to); if (rpc_stat == RPC_PROGVERSMISMATCH) { clnt_geterr(client, &rpcerr); minvers = rpcerr.re_vers.low; maxvers = rpcerr.re_vers.high; } else if (rpc_stat == RPC_SUCCESS) { /* * It also supports version MAX_VERS. * Looks like we have a wise guy. * OK, we give them information on all * 4 billion versions they support... */ minvers = 0; maxvers = MAX_VERS; } else { (void) pstatus(client, prognum, MAX_VERS); exit(1); } } else { (void) pstatus(client, prognum, MIN_VERS); exit(1); } clnt_destroy(client); (void) close(sock); sock = RPC_ANYSOCK; /* Re-initialize it for later */ for (vers = minvers; vers <= maxvers; vers++) { addr.sin_port = htons(portnum); if ((client = clnttcp_create(&addr, prognum, vers, &sock, 0, 0)) == NULL) { clnt_pcreateerror("rpcinfo"); printf("program %lu version %lu is not available\n", prognum, vers); exit(1); } to.tv_usec = 0; to.tv_sec = 10; rpc_stat = clnt_call(client, 0, xdr_void, (char *)NULL, xdr_void, (char *)NULL, to); if (pstatus(client, prognum, vers) < 0) failure = 1; clnt_destroy(client); (void) close(sock); sock = RPC_ANYSOCK; } } else { getul(argv[2], &vers); /* XXX */ addr.sin_port = htons(portnum); if ((client = clnttcp_create(&addr, prognum, vers, &sock, 0, 0)) == NULL) { clnt_pcreateerror("rpcinfo"); printf("program %lu version %lu is not available\n", prognum, vers); exit(1); } to.tv_usec = 0; to.tv_sec = 10; rpc_stat = clnt_call(client, 0, xdr_void, (char *)NULL, xdr_void, (char *)NULL, to); if (pstatus(client, prognum, vers) < 0) failure = 1; } if (failure) exit(1); } /* * This routine should take a pointer to an "rpc_err" structure, rather than * a pointer to a CLIENT structure, but "clnt_perror" takes a pointer to * a CLIENT structure rather than a pointer to an "rpc_err" structure. * As such, we have to keep the CLIENT structure around in order to print * a good error message. */ int pstatus(CLIENT *client, u_long prognum, u_long vers) { struct rpc_err rpcerr; clnt_geterr(client, &rpcerr); if (rpcerr.re_status != RPC_SUCCESS) { clnt_perror(client, "rpcinfo"); printf("program %lu version %lu is not available\n", prognum, vers); return (-1); } else { printf("program %lu version %lu ready and waiting\n", prognum, vers); return (0); } } void pmapdump(int argc, char **argv) { struct sockaddr_in server_addr; struct hostent *hp; struct pmaplist *head = NULL; int socket = RPC_ANYSOCK; struct timeval minutetimeout; CLIENT *client; struct rpcent *rpc; if (argc > 1) usage("too many arguments"); if (argc == 1) get_inet_address(&server_addr, argv[0]); else { bzero((char *)&server_addr, sizeof server_addr); server_addr.sin_family = AF_INET; if ((hp = gethostbyname("localhost")) != NULL) bcopy(hp->h_addr, (caddr_t)&server_addr.sin_addr, hp->h_length); else (void) inet_aton("0.0.0.0", &server_addr.sin_addr); } minutetimeout.tv_sec = 60; minutetimeout.tv_usec = 0; server_addr.sin_port = htons(PMAPPORT); if ((client = clnttcp_create(&server_addr, PMAPPROG, PMAPVERS, &socket, 50, 500)) == NULL) { clnt_pcreateerror("rpcinfo: can't contact portmapper"); exit(1); } if (clnt_call(client, PMAPPROC_DUMP, xdr_void, NULL, xdr_pmaplist, &head, minutetimeout) != RPC_SUCCESS) { fprintf(stderr, "rpcinfo: can't contact portmapper: "); clnt_perror(client, "rpcinfo"); exit(1); } if (head == NULL) { printf("No remote programs registered.\n"); } else { printf(" program vers proto port\n"); for (; head != NULL; head = head->pml_next) { printf("%10ld%5ld", head->pml_map.pm_prog, head->pml_map.pm_vers); if (head->pml_map.pm_prot == IPPROTO_UDP) printf("%6s", "udp"); else if (head->pml_map.pm_prot == IPPROTO_TCP) printf("%6s", "tcp"); else printf("%6ld", head->pml_map.pm_prot); printf("%7ld", head->pml_map.pm_port); rpc = getrpcbynumber(head->pml_map.pm_prog); if (rpc) printf(" %s\n", rpc->r_name); else printf("\n"); } } } /* * reply_proc collects replies from the broadcast. * to get a unique list of responses the output of rpcinfo should * be piped through sort(1) and then uniq(1). */ /*ARGSUSED*/ bool_t reply_proc(caddr_t res, struct sockaddr_in *who) { struct hostent *hp; hp = gethostbyaddr((char *) &who->sin_addr, sizeof who->sin_addr, AF_INET); printf("%s %s\n", inet_ntoa(who->sin_addr), (hp == NULL) ? "(unknown)" : hp->h_name); return(FALSE); } void brdcst(int argc, char **argv) { enum clnt_stat rpc_stat; u_long prognum, vers_num; if (argc != 2) usage("incorrect number of arguments"); if (getprognum(argv[1], &prognum)) usage("program number out of range"); if (getul(argv[1], &vers_num)) usage("version number out of range"); rpc_stat = clnt_broadcast(prognum, vers_num, NULLPROC, xdr_void, (char *)NULL, xdr_void, (char *)NULL, reply_proc); if ((rpc_stat != RPC_SUCCESS) && (rpc_stat != RPC_TIMEDOUT)) { fprintf(stderr, "rpcinfo: broadcast failed: %s\n", clnt_sperrno(rpc_stat)); exit(1); } exit(0); } void deletereg(int argc, char **argv) { u_long prog_num, version_num; if (argc != 2) usage("incorrect number of arguments"); if (getprognum(argv[0], &prog_num)) usage("program number out of range"); if (getul(argv[1], &version_num)) usage("version number out of range"); if ((pmap_unset(prog_num, version_num)) == 0) { fprintf(stderr, "rpcinfo: Could not delete " "registration for prog %s version %s\n", argv[0], argv[1]); exit(1); } } void setreg(int argc, char **argv) { u_long prog_num, version_num, port_num; if (argc != 3) usage("incorrect number of arguments"); if (getprognum(argv[0], &prog_num)) usage("cannot parse program number"); if (getul(argv[1], &version_num)) usage("cannot parse version number"); if (getul(argv[2], &port_num)) usage("cannot parse port number"); if (port_num >= 65536) usage("port number out of range"); if ((pmap_set(prog_num, version_num, IPPROTO_TCP, (u_short)port_num)) == 0) { fprintf(stderr, "rpcinfo: Could not set registration " "for prog %s version %s port %s protocol IPPROTO_TCP\n", argv[0], argv[1], argv[2]); exit(1); } if ((pmap_set(prog_num, version_num, IPPROTO_UDP, (u_short)port_num)) == 0) { fprintf(stderr, "rpcinfo: Could not set registration " "for prog %s version %s port %s protocol IPPROTO_UDP\n", argv[0], argv[1], argv[2]); exit(1); } } void usage(char *msg) { if (msg) fprintf(stderr, "rpcinfo: %s\n", msg); fprintf(stderr, "usage: rpcinfo -b program version\n"); fprintf(stderr, " rpcinfo -d program version\n"); fprintf(stderr, " rpcinfo -p [host]\n"); fprintf(stderr, " rpcinfo -s program version port\n"); fprintf(stderr, " rpcinfo [-n portnum] -t host program [version]\n"); fprintf(stderr, " rpcinfo [-n portnum] -u host program [version]\n"); exit(1); } int getprognum(char *arg, u_long *ulp) { struct rpcent *rpc; if (isalpha(*arg)) { rpc = getrpcbyname(arg); if (rpc == NULL) { fprintf(stderr, "rpcinfo: %s is unknown service\n", arg); exit(1); } *ulp = rpc->r_number; return 0; } return getul(arg, ulp); } int getul(char *arg, u_long *ulp) { u_long ul; int save_errno = errno; char *ep; int ret = 1; errno = 0; ul = strtoul(arg, &ep, 10); if (arg[0] == '\0' || *ep != '\0') goto fail; if (errno == ERANGE && ul == ULONG_MAX) goto fail; *ulp = ul; ret = 0; fail: errno = save_errno; return (ret); } void get_inet_address(struct sockaddr_in *addr, char *host) { struct hostent *hp; bzero((char *)addr, sizeof *addr); if (inet_aton(host, &addr->sin_addr) == 0) { if ((hp = gethostbyname(host)) == NULL) { fprintf(stderr, "rpcinfo: %s is unknown host\n", host); exit(1); } bcopy(hp->h_addr, (char *)&addr->sin_addr, hp->h_length); } addr->sin_family = AF_INET; }