#include <sys/param.h>
#include <sys/file.h>
#include <sys/ioctl.h>
#include <sys/socket.h>
#include <sys/time.h>
#include <sys/sysmacros.h>
#include <netinet/in_systm.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <netinet/ip_var.h>
#include <netinet/ip_icmp.h>
#include <netinet/udp.h>
#include <netinet/udp_var.h>
#include <netinet/ip6.h>
#include <netinet/icmp6.h>
#include <arpa/inet.h>
#include <ctype.h>
#include <errno.h>
#include <malloc.h>
#include <memory.h>
#include <netdb.h>
#include <stdio.h>
#include <stdlib.h>
#include <strings.h>
#include <unistd.h>
#include <libintl.h>
#include <locale.h>
#include <signal.h>
#include <setjmp.h>
#include <limits.h>
#include <zone.h>
#include <thread.h>
#include <synch.h>
#include <priv_utils.h>
#include <libinetutil.h>
#include "traceroute.h"
#define MAX_SEQ 65535
#define MAX_TRAFFIC_CLASS 255
#define MAX_FLOW_LABEL 0xFFFFF
#define MAX_TOS 255
#define STR_LEN 30
struct hostinfo {
char *name;
int family;
int num_addr;
union any_in_addr *addrs;
};
struct pr_set {
int family;
char name[STR_LEN];
char icmp[STR_LEN];
int icmp_minlen;
int addr_len;
int ip_hdr_len;
int packlen;
int sock_size;
struct sockaddr *to;
struct sockaddr *from;
void *from_sin_addr;
union any_in_addr *gwIPlist;
struct ip *(*set_buffers_fn) (int);
int (*check_reply_fn)(struct msghdr *, int, int, uchar_t *, uchar_t *);
boolean_t (*print_icmp_other_fn)(uchar_t, uchar_t);
void (*print_addr_fn)(uchar_t *, int, struct sockaddr *);
};
static uint64_t packet[(IP_MAXPACKET + 1)/8];
static struct ip *outip4;
static struct ip *outip6;
static uint64_t ancillary_data[(IP_MAXPACKET + 1)/8];
static char *gwlist[MAXMAX_GWS];
static union any_in_addr gwIPlist[MAX_GWS];
static union any_in_addr gwIP6list[MAX_GWS6];
static int family_input = AF_UNSPEC;
static int rcvsock4;
static int sndsock4;
static int rcvsock6;
static int sndsock6;
int gw_count = 0;
static struct sockaddr_in whereto;
static struct sockaddr_in6 whereto6;
static struct sockaddr_in wherefrom;
static struct sockaddr_in6 wherefrom6;
static int packlen_input = 0;
char *prog;
static char *source_input = NULL;
static char *source = NULL;
char *hostname;
static char *device = NULL;
static struct pr_set *pr4;
static struct pr_set *pr6;
static struct ifaddrlist *al4;
static struct ifaddrlist *al6;
static uint_t if_index = 0;
static int num_v4 = 0;
static int num_v6 = 0;
static int num_ifs4 = 0;
static int num_ifs6 = 0;
static int nprobes = 3;
static int max_ttl = 30;
static int first_ttl = 1;
ushort_t ident;
ushort_t port = 32768 + 666;
static int options = 0;
boolean_t verbose = _B_FALSE;
static int waittime = 5;
static struct timeval delay = {0, 0};
boolean_t nflag = _B_FALSE;
static boolean_t showttl = _B_FALSE;
boolean_t useicmp = _B_FALSE;
boolean_t docksum = _B_TRUE;
static boolean_t collect_stat = _B_FALSE;
boolean_t settos = _B_FALSE;
int dontfrag = 0;
static int max_timeout = 5;
static boolean_t probe_all = _B_FALSE;
static boolean_t pick_src = _B_FALSE;
static uint_t flow = 0;
static uint_t class = 0;
uchar_t tos = 0;
ushort_t off = 0;
static jmp_buf env;
boolean_t raw_req;
static mutex_t tr_nslock = ERRORCHECKMUTEX;
static boolean_t tr_nsactive = _B_FALSE;
static hrtime_t tr_nsstarttime;
static int tr_nssleeptime = 2;
static int tr_nswarntime = 2;
static uint_t calc_packetlen(int, struct pr_set *);
extern int check_reply(struct msghdr *, int, int, uchar_t *, uchar_t *);
extern int check_reply6(struct msghdr *, int, int, uchar_t *, uchar_t *);
static double deltaT(struct timeval *, struct timeval *);
static char *device_name(struct ifaddrlist *, int, union any_in_addr *,
struct pr_set *);
extern void *find_ancillary_data(struct msghdr *, int, int);
static boolean_t has_addr(struct addrinfo *, union any_in_addr *);
static struct ifaddrlist *find_device(struct ifaddrlist *, int, char *);
static struct ifaddrlist *find_ifaddr(struct ifaddrlist *, int,
union any_in_addr *, int);
static void get_gwaddrs(char **, int, union any_in_addr *,
union any_in_addr *, int *, int *);
static void get_hostinfo(char *, int, struct addrinfo **);
char *inet_name(union any_in_addr *, int);
ushort_t in_cksum(ushort_t *, int);
extern int ip_hdr_length_v6(ip6_t *, int, uint8_t *);
extern char *pr_type(uchar_t);
extern char *pr_type6(uchar_t);
extern void print_addr(uchar_t *, int, struct sockaddr *);
extern void print_addr6(uchar_t *, int, struct sockaddr *);
extern boolean_t print_icmp_other(uchar_t, uchar_t);
extern boolean_t print_icmp_other6(uchar_t, uchar_t);
static void print_stats(int, int, double, double, double, double);
static void print_unknown_host_msg(const char *, const char *);
static void record_stats(double, int *, double *, double *, double *, double *);
static void resolve_nodes(int *, struct addrinfo **);
static void select_src_addr(union any_in_addr *, union any_in_addr *, int);
extern void send_probe(int, struct sockaddr *, struct ip *, int, int,
struct timeval *, int);
extern void send_probe6(int, struct msghdr *, struct ip *, int, int,
struct timeval *, int);
extern void set_ancillary_data(struct msghdr *, int, union any_in_addr *, int,
uint_t);
extern struct ip *set_buffers(int);
extern struct ip *set_buffers6(int);
extern void set_IPv4opt_sourcerouting(int, union any_in_addr *,
union any_in_addr *);
static void set_sin(struct sockaddr *, union any_in_addr *, int);
static int set_src_addr(struct pr_set *, struct ifaddrlist **);
static void setup_protocol(struct pr_set *, int);
static void setup_socket(struct pr_set *, int);
static void sig_handler(int);
static int str2int(const char *, const char *, int, int);
static double str2dbl(const char *, const char *, double, double);
static void trace_it(struct addrinfo *);
static void traceroute(union any_in_addr *, struct msghdr *, struct pr_set *,
int, struct ifaddrlist *);
static void tv_sub(struct timeval *, struct timeval *);
static void usage(void);
static int wait_for_reply(int, struct msghdr *, struct timeval *);
static double xsqrt(double);
static void *ns_warning_thr(void *);
int
main(int argc, char **argv)
{
struct addrinfo *ai_dst = NULL;
boolean_t probing_successful = _B_FALSE;
int longjmp_return;
int i = 0;
char *cp;
int op;
char *ep;
char temp_buf[INET6_ADDRSTRLEN];
double pause;
raw_req = priv_ineffect(PRIV_NET_RAWACCESS);
(void) __init_suid_priv(PU_CLEARLIMITSET, PRIV_NET_ICMPACCESS,
raw_req ? PRIV_NET_RAWACCESS : NULL, NULL);
(void) setlinebuf(stdout);
if ((cp = strrchr(argv[0], '/')) != NULL)
prog = cp + 1;
else
prog = argv[0];
opterr = 0;
while ((op = getopt(argc, argv, "adFIlnrSvxA:c:f:g:i:L:m:P:p:Q:q:s:"
"t:w:")) != EOF) {
switch (op) {
case 'A':
if (strcmp(optarg, "inet") == 0) {
family_input = AF_INET;
} else if (strcmp(optarg, "inet6") == 0) {
family_input = AF_INET6;
} else {
Fprintf(stderr,
"%s: unknown address family %s\n",
prog, optarg);
exit(EXIT_FAILURE);
}
break;
case 'a':
probe_all = _B_TRUE;
break;
case 'c':
class = str2int(optarg, "traffic class", 0,
MAX_TRAFFIC_CLASS);
break;
case 'd':
options |= SO_DEBUG;
break;
case 'f':
first_ttl = str2int(optarg, "first ttl", 1, MAXTTL);
break;
case 'F':
off = IP_DF;
dontfrag = 1;
break;
case 'g':
if (!raw_req) {
Fprintf(stderr,
"%s: privilege to specify a loose source "
"route gateway is unavailable\n",
prog);
exit(EXIT_FAILURE);
}
if (gw_count >= MAXMAX_GWS) {
Fprintf(stderr,
"%s: Too many gateways\n", prog);
exit(EXIT_FAILURE);
}
gwlist[gw_count] = strdup(optarg);
if (gwlist[gw_count] == NULL) {
Fprintf(stderr, "%s: strdup %s\n", prog,
strerror(errno));
exit(EXIT_FAILURE);
}
++gw_count;
break;
case 'l':
showttl = _B_TRUE;
break;
case 'i':
if_index = (uint_t)strtol(optarg, &ep, 10);
if (errno != 0 || *ep != '\0') {
device = optarg;
if_index = if_nametoindex((const char *)device);
if (if_index == 0 && errno != ENXIO) {
Fprintf(stderr, "%s: if_nametoindex:"
"%s\n", prog, strerror(errno));
exit(EXIT_FAILURE);
}
} else {
device = (char *)malloc(LIFNAMSIZ + 1);
if (device == NULL) {
Fprintf(stderr, "%s: malloc: %s\n",
prog, strerror(errno));
exit(EXIT_FAILURE);
}
device = if_indextoname(if_index, device);
if (device != NULL) {
device[LIFNAMSIZ] = '\0';
} else if (errno != ENXIO) {
Fprintf(stderr, "%s: if_indextoname:"
"%s\n", prog, strerror(errno));
exit(EXIT_FAILURE);
}
}
if (device == NULL || if_index == 0) {
Fprintf(stderr, "%s: interface %s "
"doesn't match any actual interfaces\n",
prog, optarg);
exit(EXIT_FAILURE);
}
break;
case 'I':
useicmp = _B_TRUE;
break;
case 'L':
flow = str2int(optarg, "flow label", 0, MAX_FLOW_LABEL);
break;
case 'm':
max_ttl = str2int(optarg, "max ttl(hop limit)", 1,
MAXTTL);
break;
case 'n':
nflag = _B_TRUE;
break;
case 'P':
pause = str2dbl(optarg, "pause", 0, INT_MAX);
delay.tv_sec = (time_t)pause;
delay.tv_usec = (suseconds_t)((pause - delay.tv_sec) *
1000000);
break;
case 'p':
port = str2int(optarg, "port", 1, MAX_PORT);
break;
case 'Q':
max_timeout = str2int(optarg, "max timeout", 1, -1);
break;
case 'q':
nprobes = str2int(optarg, "nprobes", 1, -1);
break;
case 'r':
options |= SO_DONTROUTE;
break;
case 'S':
collect_stat = _B_TRUE;
break;
case 's':
source_input = optarg;
break;
case 't':
tos = (uchar_t)str2int(optarg, "tos", 0, MAX_TOS);
settos = _B_TRUE;
break;
case 'v':
verbose = _B_TRUE;
break;
case 'x':
docksum = _B_FALSE;
break;
case 'w':
waittime = str2int(optarg, "wait time", 2, -1);
break;
default:
usage();
break;
}
}
if (probe_all) {
if ((longjmp_return = setjmp(env)) != 0) {
if (longjmp_return == SIGQUIT) {
Printf("(exiting)\n");
exit(EXIT_SUCCESS);
} else {
exit(EXIT_FAILURE);
}
}
(void) signal(SIGQUIT, sig_handler);
}
if ((gw_count > 0) && (options & SO_DONTROUTE)) {
Fprintf(stderr, "%s: loose source route gateways (-g)"
" cannot be specified when probe packets are sent"
" directly to a host on an attached network (-r)\n",
prog);
exit(EXIT_FAILURE);
}
i = argc - optind;
if (i == 1 || i == 2) {
hostname = argv[optind];
if (i == 2) {
packlen_input = str2int(argv[optind + 1],
"packet length", 0, -1);
}
} else {
usage();
}
if (first_ttl > max_ttl) {
Fprintf(stderr,
"%s: first ttl(hop limit) (%d) may not be greater"
" than max ttl(hop limit) (%d)\n",
prog, first_ttl, max_ttl);
exit(EXIT_FAILURE);
}
if (thr_create(NULL, 0, ns_warning_thr, NULL,
THR_DETACHED | THR_DAEMON, NULL) != 0) {
Fprintf(stderr, "%s: failed to create name services "
"thread: %s\n", prog, strerror(errno));
exit(EXIT_FAILURE);
}
resolve_nodes(&family_input, &ai_dst);
if (ai_dst == NULL) {
exit(EXIT_FAILURE);
}
if (probe_all)
(void) signal(SIGINT, SIG_IGN);
ident = (getpid() & 0xffff) | 0x8000;
switch (family_input) {
case AF_UNSPEC:
pr4 = (struct pr_set *)malloc(sizeof (struct pr_set));
if (pr4 == NULL) {
Fprintf(stderr,
"%s: malloc %s\n", prog, strerror(errno));
exit(EXIT_FAILURE);
}
pr6 = (struct pr_set *)malloc(sizeof (struct pr_set));
if (pr6 == NULL) {
Fprintf(stderr,
"%s: malloc %s\n", prog, strerror(errno));
exit(EXIT_FAILURE);
}
setup_protocol(pr6, AF_INET6);
setup_protocol(pr4, AF_INET);
outip6 = (*pr6->set_buffers_fn)(pr6->packlen);
setup_socket(pr6, pr6->packlen);
outip4 = (*pr4->set_buffers_fn)(pr4->packlen);
setup_socket(pr4, pr4->packlen);
num_ifs6 = set_src_addr(pr6, &al6);
num_ifs4 = set_src_addr(pr4, &al4);
break;
case AF_INET6:
pr6 = (struct pr_set *)malloc(sizeof (struct pr_set));
if (pr6 == NULL) {
Fprintf(stderr,
"%s: malloc %s\n", prog, strerror(errno));
exit(EXIT_FAILURE);
}
setup_protocol(pr6, AF_INET6);
outip6 = (*pr6->set_buffers_fn)(pr6->packlen);
setup_socket(pr6, pr6->packlen);
num_ifs6 = set_src_addr(pr6, &al6);
break;
case AF_INET:
pr4 = (struct pr_set *)malloc(sizeof (struct pr_set));
if (pr4 == NULL) {
Fprintf(stderr,
"%s: malloc %s\n", prog, strerror(errno));
exit(EXIT_FAILURE);
}
setup_protocol(pr4, AF_INET);
outip4 = (*pr4->set_buffers_fn)(pr4->packlen);
setup_socket(pr4, pr4->packlen);
num_ifs4 = set_src_addr(pr4, &al4);
break;
default:
Fprintf(stderr, "%s: unknow address family.\n", prog);
exit(EXIT_FAILURE);
}
if (num_v4 + num_v6 > 1 && !probe_all) {
if (ai_dst->ai_family == AF_INET) {
Fprintf(stderr,
"%s: Warning: %s has multiple addresses;"
" using %s\n", prog, hostname,
inet_ntop(AF_INET,
(void *)&((struct sockaddr_in *)
ai_dst->ai_addr)->sin_addr,
temp_buf, sizeof (temp_buf)));
} else {
Fprintf(stderr,
"%s: Warning: %s has multiple addresses;"
" using %s\n", prog, hostname,
inet_ntop(AF_INET6,
(void *)&((struct sockaddr_in6 *)
ai_dst->ai_addr)->sin6_addr,
temp_buf, sizeof (temp_buf)));
}
}
if (num_ifs4 + num_ifs6 > 0) {
trace_it(ai_dst);
probing_successful = _B_TRUE;
}
(void) close(rcvsock4);
(void) close(sndsock4);
(void) close(rcvsock6);
(void) close(sndsock6);
if (probing_successful)
return (EXIT_SUCCESS);
else
return (EXIT_FAILURE);
}
static void
print_unknown_host_msg(const char *protocol, const char *host)
{
Fprintf(stderr, "%s: unknown%s host %s\n", prog, protocol, host);
}
static void
resolve_nodes(int *family, struct addrinfo **ai_dstp)
{
struct addrinfo *ai_dst = NULL;
struct addrinfo *aip = NULL;
int num_resolved_gw = 0;
int num_resolved_gw6 = 0;
get_hostinfo(hostname, *family, &ai_dst);
if (ai_dst == NULL) {
print_unknown_host_msg("", hostname);
exit(EXIT_FAILURE);
}
for (aip = ai_dst; aip != NULL; aip = aip->ai_next) {
switch (aip->ai_family) {
case AF_INET:
num_v4++;
break;
case AF_INET6:
num_v6++;
break;
}
}
if (*family == AF_UNSPEC && !probe_all) {
*family = ai_dst->ai_family;
}
if (gw_count > 0) {
get_gwaddrs(gwlist, *family, gwIPlist, gwIP6list,
&num_resolved_gw, &num_resolved_gw6);
if (num_resolved_gw6 != gw_count && num_v6 != 0) {
if (*family == AF_INET6 || *family == AF_UNSPEC)
print_unknown_host_msg(" IPv6",
gwlist[num_resolved_gw6]);
num_v6 = 0;
}
if (num_resolved_gw != gw_count && num_v4 != 0) {
if (*family == AF_INET || *family == AF_UNSPEC)
print_unknown_host_msg(" IPv4",
gwlist[num_resolved_gw]);
num_v4 = 0;
}
}
*ai_dstp = (num_v4 + num_v6 > 0) ? ai_dst : NULL;
}
static void
get_hostinfo(char *host, int family, struct addrinfo **aipp)
{
struct addrinfo hints, *ai;
struct in6_addr addr6;
struct in_addr addr;
char abuf[INET6_ADDRSTRLEN];
int rc;
if ((inet_pton(AF_INET6, host, &addr6) > 0) &&
IN6_IS_ADDR_V4MAPPED(&addr6)) {
IN6_V4MAPPED_TO_INADDR(&addr6, &addr);
(void) inet_ntop(AF_INET, &addr, abuf, sizeof (abuf));
(void) strcpy(host, abuf);
if (family == AF_INET6) {
return;
}
}
(void) memset(&hints, 0, sizeof (hints));
hints.ai_family = family;
hints.ai_flags = AI_ADDRCONFIG | AI_CANONNAME;
rc = getaddrinfo(host, NULL, &hints, &ai);
if (rc != 0) {
if (rc != EAI_NONAME)
Fprintf(stderr, "%s: getaddrinfo: %s\n", prog,
gai_strerror(rc));
*aipp = NULL;
return;
}
*aipp = ai;
}
static uint_t
calc_packetlen(int plen_input, struct pr_set *pr)
{
int minpacket;
int optlen;
int plen;
if (gw_count > 0) {
optlen = 8 + gw_count * pr->addr_len;
} else {
optlen = 0;
}
minpacket = pr->ip_hdr_len + sizeof (struct outdata) + optlen;
if (useicmp)
minpacket += pr->icmp_minlen;
else
minpacket += sizeof (struct udphdr);
plen = plen_input;
if (plen == 0) {
plen = minpacket;
} else if (minpacket > plen || plen > IP_MAXPACKET) {
Fprintf(stderr, "%s: %s packet size must be >= %d and <= %d\n",
prog, pr->name, minpacket, IP_MAXPACKET);
return (0);
}
return (plen);
}
static int
set_src_addr(struct pr_set *pr, struct ifaddrlist **alp)
{
union any_in_addr *ap;
struct ifaddrlist *al = NULL;
struct ifaddrlist *tmp1_al = NULL;
struct ifaddrlist *tmp2_al = NULL;
struct sockaddr_in *sin_from = (struct sockaddr_in *)pr->from;
struct sockaddr_in6 *sin6_from = (struct sockaddr_in6 *)pr->from;
struct addrinfo *aip;
char errbuf[ERRBUFSIZE];
char abuf[INET6_ADDRSTRLEN];
int num_ifs;
int num_src_ifs;
int i;
uint_t ifaddrflags = 0;
source = source_input;
if (device != NULL)
ifaddrflags |= LIFC_UNDER_IPMP;
num_ifs = ifaddrlist(&al, pr->family, ifaddrflags, errbuf);
if (num_ifs < 0) {
Fprintf(stderr, "%s: ifaddrlist: %s\n", prog, errbuf);
exit(EXIT_FAILURE);
}
num_src_ifs = 0;
for (i = 0; i < num_ifs; i++) {
if (!(al[i].flags & IFF_LOOPBACK) && (al[i].flags & IFF_UP))
num_src_ifs++;
}
if (num_src_ifs == 0) {
Fprintf(stderr, "%s: can't find any %s network interfaces\n",
prog, pr->name);
return (0);
}
if (device != NULL) {
tmp1_al = find_device(al, num_ifs, device);
if (tmp1_al == NULL) {
Fprintf(stderr, "%s: %s (index %d) is an invalid %s"
" interface\n", prog, device, if_index, pr->name);
free(al);
return (0);
}
}
if (source != NULL) {
get_hostinfo(source, pr->family, &aip);
if (aip == NULL) {
Fprintf(stderr,
"%s: %s is an invalid %s source address\n",
prog, source, pr->name);
free(al);
return (0);
}
source = aip->ai_canonname;
if (pr->family == AF_INET)
ap = (union any_in_addr *)
&((struct sockaddr_in *)aip->ai_addr)->sin_addr;
else
ap = (union any_in_addr *)
&((struct sockaddr_in6 *)aip->ai_addr)->sin6_addr;
tmp2_al = find_ifaddr(al, num_ifs, ap, pr->family);
if (tmp2_al == NULL) {
(void) inet_ntop(pr->family, ap, abuf, sizeof (abuf));
Fprintf(stderr, "%s: %s is not a local %s address\n",
prog, abuf, pr->name);
free(al);
freeaddrinfo(aip);
return (0);
}
}
pick_src = _B_FALSE;
if (source == NULL) {
if (device == NULL) {
pick_src = _B_TRUE;
} else {
if (pr->family == AF_INET)
set_sin(pr->from, &(tmp1_al->addr), pr->family);
else
pick_src = _B_TRUE;
}
} else {
if (device == NULL) {
set_sin(pr->from, ap, pr->family);
if (aip->ai_next != NULL) {
(void) inet_ntop(pr->family, pr->from_sin_addr,
abuf, sizeof (abuf));
Fprintf(stderr, "%s: Warning: %s has multiple "
"addresses; using %s\n", prog, source,
abuf);
}
} else {
if (pr->family == AF_INET) {
if (!has_addr(aip, &tmp1_al->addr)) {
Fprintf(stderr,
"%s: %s is not on interface %s\n",
prog, source, device);
exit(EXIT_FAILURE);
}
*ap = tmp1_al->addr;
}
set_sin(pr->from, ap, pr->family);
}
}
if (pr->family == AF_INET && !raw_req) {
sin_from->sin_family = AF_INET;
sin_from->sin_port = htons(ident);
if (bind(sndsock4, (struct sockaddr *)pr->from,
sizeof (struct sockaddr_in)) < 0) {
Fprintf(stderr, "%s: bind: %s\n", prog,
strerror(errno));
exit(EXIT_FAILURE);
}
} else if (pr->family == AF_INET6) {
sin6_from->sin6_family = AF_INET6;
sin6_from->sin6_port = htons(ident);
if (bind(sndsock6, (struct sockaddr *)pr->from,
sizeof (struct sockaddr_in6)) < 0) {
Fprintf(stderr, "%s: bind: %s\n", prog,
strerror(errno));
exit(EXIT_FAILURE);
}
whereto6.sin6_flowinfo = htonl((class << 20) | flow);
}
*alp = al;
return (num_ifs);
}
static struct ifaddrlist *
find_ifaddr(struct ifaddrlist *al, int len, union any_in_addr *addr,
int family)
{
struct ifaddrlist *tmp_al = al;
int i;
size_t addr_len = (family == AF_INET) ? sizeof (struct in_addr) :
sizeof (struct in6_addr);
for (i = 0; i < len; i++, tmp_al++) {
if ((!(tmp_al->flags & IFF_LOOPBACK) &&
(tmp_al->flags & IFF_UP)) &&
(memcmp(&tmp_al->addr, addr, addr_len) == 0))
break;
}
if (i < len) {
return (tmp_al);
} else {
return (NULL);
}
}
static struct ifaddrlist *
find_device(struct ifaddrlist *al, int len, char *device)
{
struct ifaddrlist *tmp_al = al;
int i;
for (i = 0; i < len; i++, tmp_al++) {
if ((!(tmp_al->flags & IFF_LOOPBACK) &&
(tmp_al->flags & IFF_UP)) &&
(strcmp(tmp_al->device, device) == 0))
break;
}
if (i < len) {
return (tmp_al);
} else {
return (NULL);
}
}
static boolean_t
has_addr(struct addrinfo *ai, union any_in_addr *addr)
{
struct addrinfo *ai_tmp = NULL;
union any_in_addr *ap;
for (ai_tmp = ai; ai_tmp != NULL; ai_tmp = ai_tmp->ai_next) {
if (ai_tmp->ai_family == AF_INET6)
continue;
ap = (union any_in_addr *)
&((struct sockaddr_in *)ai_tmp->ai_addr)->sin_addr;
if (memcmp(ap, addr, sizeof (struct in_addr)) == 0)
break;
}
if (ai_tmp != NULL) {
return (_B_TRUE);
} else {
return (_B_FALSE);
}
}
static void
get_gwaddrs(char **gwlist, int family, union any_in_addr *gwIPlist,
union any_in_addr *gwIPlist6, int *resolved, int *resolved6)
{
int i;
boolean_t check_v4 = _B_TRUE, check_v6 = _B_TRUE;
struct addrinfo *ai = NULL;
struct addrinfo *aip = NULL;
*resolved = *resolved6 = 0;
switch (family) {
case AF_UNSPEC:
break;
case AF_INET:
check_v6 = _B_FALSE;
break;
case AF_INET6:
check_v4 = _B_FALSE;
break;
default:
return;
}
if (check_v4 && gw_count >= MAX_GWS) {
check_v4 = _B_FALSE;
Fprintf(stderr, "%s: too many IPv4 gateways\n", prog);
num_v4 = 0;
}
if (check_v6 && gw_count >= MAX_GWS6) {
check_v6 = _B_FALSE;
Fprintf(stderr, "%s: too many IPv6 gateways\n", prog);
num_v6 = 0;
}
for (i = 0; i < gw_count; i++) {
if (!check_v4 && !check_v6)
return;
get_hostinfo(gwlist[i], family, &ai);
if (ai == NULL)
return;
if (check_v4 && num_v4 != 0) {
check_v4 = _B_FALSE;
for (aip = ai; aip != NULL; aip = aip->ai_next) {
if (aip->ai_family == AF_INET) {
bcopy(&((struct sockaddr_in *)
aip->ai_addr)->sin_addr,
&gwIPlist[i].addr,
aip->ai_addrlen);
(*resolved)++;
check_v4 = _B_TRUE;
break;
}
}
} else if (check_v4) {
check_v4 = _B_FALSE;
}
if (check_v6 && num_v6 != 0) {
check_v6 = _B_FALSE;
for (aip = ai; aip != NULL; aip = aip->ai_next) {
if (aip->ai_family == AF_INET6) {
bcopy(&((struct sockaddr_in6 *)
aip->ai_addr)->sin6_addr,
&gwIPlist6[i].addr6,
aip->ai_addrlen);
(*resolved6)++;
check_v6 = _B_TRUE;
break;
}
}
} else if (check_v6) {
check_v6 = _B_FALSE;
}
}
freeaddrinfo(ai);
}
static void
setup_protocol(struct pr_set *pr, int family)
{
pr->family = family;
if (family == AF_INET) {
if (!docksum) {
Fprintf(stderr,
"%s: Warning: checksums disabled\n", prog);
}
(void) strcpy(pr->name, "IPv4");
(void) strcpy(pr->icmp, "icmp");
pr->icmp_minlen = ICMP_MINLEN;
pr->addr_len = sizeof (struct in_addr);
pr->ip_hdr_len = sizeof (struct ip);
pr->sock_size = sizeof (struct sockaddr_in);
pr->to = (struct sockaddr *)&whereto;
pr->from = (struct sockaddr *)&wherefrom;
pr->from_sin_addr = (void *)&wherefrom.sin_addr;
pr->gwIPlist = gwIPlist;
pr->set_buffers_fn = set_buffers;
pr->check_reply_fn = check_reply;
pr->print_icmp_other_fn = print_icmp_other;
pr->print_addr_fn = print_addr;
pr->packlen = calc_packetlen(packlen_input, pr);
} else {
(void) strcpy(pr->name, "IPv6");
(void) strcpy(pr->icmp, "ipv6-icmp");
pr->icmp_minlen = ICMP6_MINLEN;
pr->addr_len = sizeof (struct in6_addr);
pr->ip_hdr_len = sizeof (struct ip6_hdr);
pr->sock_size = sizeof (struct sockaddr_in6);
pr->to = (struct sockaddr *)&whereto6;
pr->from = (struct sockaddr *)&wherefrom6;
pr->from_sin_addr = (void *)&wherefrom6.sin6_addr;
pr->gwIPlist = gwIP6list;
pr->set_buffers_fn = set_buffers6;
pr->check_reply_fn = check_reply6;
pr->print_icmp_other_fn = print_icmp_other6;
pr->print_addr_fn = print_addr6;
pr->packlen = calc_packetlen(packlen_input, pr);
}
if (pr->packlen == 0)
exit(EXIT_FAILURE);
}
static void
setup_socket(struct pr_set *pr, int packet_len)
{
int on = 1;
struct protoent *pe;
int type;
int proto;
int int_op;
int rsock;
int ssock;
if ((pe = getprotobyname(pr->icmp)) == NULL) {
Fprintf(stderr, "%s: unknown protocol %s\n", prog, pr->icmp);
exit(EXIT_FAILURE);
}
(void) __priv_bracket(PRIV_ON);
if ((rsock = socket(pr->family, SOCK_RAW, pe->p_proto)) < 0) {
Fprintf(stderr, "%s: icmp socket: %s\n", prog, strerror(errno));
exit(EXIT_FAILURE);
}
if (options & SO_DEBUG) {
if (setsockopt(rsock, SOL_SOCKET, SO_DEBUG, (char *)&on,
sizeof (on)) < 0) {
Fprintf(stderr, "%s: SO_DEBUG: %s\n", prog,
strerror(errno));
exit(EXIT_FAILURE);
}
}
if (options & SO_DONTROUTE) {
if (setsockopt(rsock, SOL_SOCKET, SO_DONTROUTE, (char *)&on,
sizeof (on)) < 0) {
Fprintf(stderr, "%s: SO_DONTROUTE: %s\n", prog,
strerror(errno));
exit(EXIT_FAILURE);
}
}
if (pr->family == AF_INET6) {
if (setsockopt(rsock, IPPROTO_IPV6, IPV6_RECVPKTINFO,
(char *)&on, sizeof (on)) < 0) {
Fprintf(stderr, "%s: IPV6_RECVPKTINFO: %s\n", prog,
strerror(errno));
exit(EXIT_FAILURE);
}
if (setsockopt(rsock, IPPROTO_IPV6, IPV6_RECVHOPLIMIT,
(char *)&on, sizeof (on)) < 0) {
Fprintf(stderr, "%s: IPV6_RECVHOPLIMIT: %s\n", prog,
strerror(errno));
exit(EXIT_FAILURE);
}
}
if (pr->family == AF_INET && raw_req) {
type = SOCK_RAW;
proto = IPPROTO_RAW;
} else if (useicmp) {
type = SOCK_RAW;
if (pr->family == AF_INET)
proto = IPPROTO_ICMP;
else
proto = IPPROTO_ICMPV6;
} else {
type = SOCK_DGRAM;
proto = IPPROTO_UDP;
}
ssock = socket(pr->family, type, proto);
if (ssock < 0) {
if (proto == IPPROTO_RAW) {
Fprintf(stderr, "%s: raw socket: %s\n", prog,
strerror(errno));
} else if (proto == IPPROTO_UDP) {
Fprintf(stderr, "%s: udp socket: %s\n", prog,
strerror(errno));
} else {
Fprintf(stderr, "%s: icmp socket: %s\n", prog,
strerror(errno));
}
exit(EXIT_FAILURE);
}
if (setsockopt(ssock, SOL_SOCKET, SO_SNDBUF, (char *)&packet_len,
sizeof (packet_len)) < 0) {
Fprintf(stderr, "%s: SO_SNDBUF: %s\n", prog, strerror(errno));
exit(EXIT_FAILURE);
}
if (pr->family == AF_INET && raw_req) {
if (setsockopt(ssock, IPPROTO_IP, IP_HDRINCL, (char *)&on,
sizeof (on)) < 0) {
Fprintf(stderr, "%s: IP_HDRINCL: %s\n", prog,
strerror(errno));
exit(EXIT_FAILURE);
}
}
if (options & SO_DEBUG) {
if (setsockopt(ssock, SOL_SOCKET, SO_DEBUG, (char *)&on,
sizeof (on)) < 0) {
Fprintf(stderr, "%s: SO_DEBUG: %s\n", prog,
strerror(errno));
exit(EXIT_FAILURE);
}
}
if (options & SO_DONTROUTE) {
if (setsockopt(ssock, SOL_SOCKET, SO_DONTROUTE,
(char *)&on, sizeof (on)) < 0) {
Fprintf(stderr, "%s: SO_DONTROUTE: %s\n", prog,
strerror(errno));
exit(EXIT_FAILURE);
}
}
if (settos && !raw_req) {
int_op = tos;
if (setsockopt(ssock, IPPROTO_IP, IP_TOS, (char *)&int_op,
sizeof (int_op)) < 0) {
Fprintf(stderr, "%s: IP_TOS: %s\n", prog,
strerror(errno));
exit(EXIT_FAILURE);
}
}
if (pr->family == AF_INET) {
if (setsockopt(ssock, IPPROTO_IP, IP_DONTFRAG,
(char *)&dontfrag, sizeof (dontfrag)) == -1) {
Fprintf(stderr, "%s: IP_DONTFRAG %s\n", prog,
strerror(errno));
exit(EXIT_FAILURE);
}
} else {
if (setsockopt(ssock, IPPROTO_IPV6, IPV6_DONTFRAG,
(char *)&dontfrag, sizeof (dontfrag)) == -1) {
Fprintf(stderr, "%s: IPV6_DONTFRAG %s\n", prog,
strerror(errno));
exit(EXIT_FAILURE);
}
}
if (pr->family == AF_INET) {
rcvsock4 = rsock;
sndsock4 = ssock;
} else {
rcvsock6 = rsock;
sndsock6 = ssock;
}
(void) __priv_bracket(PRIV_OFF);
}
static void
trace_it(struct addrinfo *ai_dst)
{
struct msghdr msg6;
int num_dst_IPaddrs;
struct addrinfo *aip;
int i;
if (!probe_all)
num_dst_IPaddrs = 1;
else
num_dst_IPaddrs = num_v4 + num_v6;
if (ai_dst->ai_family == AF_INET6 || (probe_all && num_v6)) {
msg6.msg_control = NULL;
msg6.msg_controllen = 0;
set_ancillary_data(&msg6, first_ttl, pr6->gwIPlist, gw_count,
if_index);
}
for (aip = ai_dst, i = 0; i < num_dst_IPaddrs && aip != NULL; i++) {
union any_in_addr *addrp;
if (aip->ai_family == AF_INET) {
addrp = (union any_in_addr *)
&((struct sockaddr_in *)
aip->ai_addr)->sin_addr;
set_sin((struct sockaddr *)pr4->to, addrp,
aip->ai_family);
traceroute(addrp, &msg6, pr4, num_ifs4, al4);
} else {
addrp = (union any_in_addr *)
&((struct sockaddr_in6 *)
aip->ai_addr)->sin6_addr;
set_sin((struct sockaddr *)pr6->to, addrp,
aip->ai_family);
traceroute(addrp, &msg6, pr6, num_ifs6, al6);
}
aip = aip->ai_next;
if (i < (num_dst_IPaddrs - 1))
(void) putchar('\n');
}
}
static void
set_sin(struct sockaddr *sock, union any_in_addr *addr, int family)
{
sock->sa_family = family;
if (family == AF_INET)
((struct sockaddr_in *)sock)->sin_addr = addr->addr;
else
((struct sockaddr_in6 *)sock)->sin6_addr = addr->addr6;
}
static char *
device_name(struct ifaddrlist *al, int len, union any_in_addr *ip_addr,
struct pr_set *pr)
{
int i;
struct ifaddrlist *tmp_al;
tmp_al = al;
for (i = 0; i < len; i++, tmp_al++) {
if (memcmp(&tmp_al->addr, ip_addr, pr->addr_len) == 0) {
return (tmp_al->device);
}
}
return (NULL);
}
static void
traceroute(union any_in_addr *ip_addr, struct msghdr *msg6, struct pr_set *pr,
int num_ifs, struct ifaddrlist *al)
{
int ttl;
int probe;
uchar_t type;
uchar_t code;
int reply;
int seq = 0;
char abuf[INET6_ADDRSTRLEN];
int longjmp_return;
struct ip *ip = (struct ip *)packet;
boolean_t got_there = _B_FALSE;
static boolean_t first_pkt = _B_TRUE;
int hoplimit;
struct in6_addr addr6;
int num_src_ifs;
struct msghdr in_msg;
struct iovec iov;
int *intp;
int sndsock;
int rcvsock;
msg6->msg_name = pr->to;
msg6->msg_namelen = sizeof (struct sockaddr_in6);
sndsock = (pr->family == AF_INET) ? sndsock4 : sndsock6;
rcvsock = (pr->family == AF_INET) ? rcvsock4 : rcvsock6;
if (pick_src) {
union any_in_addr src_addr;
char *dev_name;
int i;
if (gw_count > 0) {
(void) select_src_addr(pr->gwIPlist, &src_addr,
pr->family);
} else {
(void) select_src_addr(ip_addr, &src_addr, pr->family);
}
set_sin(pr->from, &src_addr, pr->family);
num_src_ifs = 0;
for (i = 0; i < num_ifs; i++) {
if (!(al[i].flags & IFF_LOOPBACK) &&
(al[i].flags & IFF_UP))
num_src_ifs++;
}
if (num_src_ifs > 1) {
dev_name = device_name(al, num_ifs, &src_addr, pr);
if (dev_name == NULL)
dev_name = "?";
(void) inet_ntop(pr->family, pr->from_sin_addr, abuf,
sizeof (abuf));
Fprintf(stderr,
"%s: Warning: Multiple interfaces found;"
" using %s @ %s\n", prog, abuf, dev_name);
}
}
if (pr->family == AF_INET) {
outip4->ip_src = *(struct in_addr *)pr->from_sin_addr;
outip4->ip_dst = ip_addr->addr;
}
if (pr->family == AF_INET6 &&
inet_pton(AF_INET6, hostname, &addr6) > 0) {
Fprintf(stderr, "%s to %s", prog, hostname);
} else {
Fprintf(stderr, "%s to %s (%s)", prog, hostname,
inet_ntop(pr->family, ip_addr, abuf, sizeof (abuf)));
}
if (source)
Fprintf(stderr, " from %s", source);
Fprintf(stderr, ", %d hops max, %d byte packets\n", max_ttl,
pr->packlen);
(void) fflush(stderr);
if (pr->family == AF_INET && gw_count > 0)
set_IPv4opt_sourcerouting(sndsock, ip_addr, pr->gwIPlist);
if (probe_all) {
if ((longjmp_return = setjmp(env)) != 0) {
switch (longjmp_return) {
case SIGINT:
Printf("(skipping)\n");
return;
case SIGQUIT:
Printf("(exiting)\n");
exit(EXIT_SUCCESS);
default:
exit(EXIT_FAILURE);
}
}
(void) signal(SIGINT, sig_handler);
}
for (ttl = first_ttl; ttl <= max_ttl; ++ttl) {
union any_in_addr lastaddr;
int timeouts = 0;
double rtt;
int nreceived = 0;
double rttmin, rttmax;
double rttsum, rttssq;
int unreachable;
got_there = _B_FALSE;
unreachable = 0;
lastaddr.addr6 = in6addr_any;
if ((ttl == (first_ttl + 1)) && (options & SO_DONTROUTE)) {
Fprintf(stderr,
"%s: host %s is not on a directly-attached"
" network\n", prog, hostname);
break;
}
Printf("%2d ", ttl);
(void) fflush(stdout);
for (probe = 0; (probe < nprobes) && (timeouts < max_timeout);
++probe) {
int cc;
struct timeval t1, t2;
if (!first_pkt) {
if (delay.tv_sec > 0)
(void) sleep((uint_t)delay.tv_sec);
if (delay.tv_usec > 0)
(void) usleep(delay.tv_usec);
} else {
first_pkt = _B_FALSE;
}
(void) gettimeofday(&t1, NULL);
if (pr->family == AF_INET) {
send_probe(sndsock, pr->to, outip4, seq, ttl,
&t1, pr->packlen);
} else {
send_probe6(sndsock, msg6, outip6, seq, ttl,
&t1, pr->packlen);
}
in_msg.msg_name = pr->from;
in_msg.msg_namelen = pr->sock_size;
iov.iov_base = (char *)packet;
iov.iov_len = sizeof (packet);
in_msg.msg_iov = &iov;
in_msg.msg_iovlen = 1;
in_msg.msg_control = ancillary_data;
in_msg.msg_controllen = sizeof (ancillary_data);
while ((cc = wait_for_reply(rcvsock, &in_msg,
&t1)) != 0) {
(void) gettimeofday(&t2, NULL);
reply = (*pr->check_reply_fn) (&in_msg, cc, seq,
&type, &code);
in_msg.msg_controllen =
sizeof (ancillary_data);
if (reply == REPLY_SHORT_PKT) {
continue;
}
timeouts = 0;
if (memcmp(pr->from_sin_addr, &lastaddr,
pr->addr_len) != 0) {
(*pr->print_addr_fn) ((uchar_t *)packet,
cc, pr->from);
(void) memcpy(&lastaddr,
pr->from_sin_addr, pr->addr_len);
}
rtt = deltaT(&t1, &t2);
if (collect_stat) {
record_stats(rtt, &nreceived, &rttmin,
&rttmax, &rttsum, &rttssq);
} else {
Printf(" %.3f ms", rtt);
}
if (pr->family == AF_INET6) {
intp = find_ancillary_data(&in_msg,
IPPROTO_IPV6, IPV6_HOPLIMIT);
if (intp == NULL) {
Fprintf(stderr,
"%s: can't find "
"IPV6_HOPLIMIT ancillary "
"data\n", prog);
exit(EXIT_FAILURE);
}
hoplimit = *intp;
}
if (reply == REPLY_GOT_TARGET) {
got_there = _B_TRUE;
if (((pr->family == AF_INET) &&
(ip->ip_ttl <= 1)) ||
((pr->family == AF_INET6) &&
(hoplimit <= 1)))
Printf(" !");
}
if (!collect_stat && showttl) {
if (pr->family == AF_INET) {
Printf(" (ttl=%d)",
(int)ip->ip_ttl);
} else if (hoplimit != -1) {
Printf(" (hop limit=%d)",
hoplimit);
}
}
if (reply == REPLY_GOT_OTHER) {
if ((*pr->print_icmp_other_fn)
(type, code)) {
unreachable++;
}
}
if (pr->family == AF_INET &&
type == ICMP_UNREACH &&
code == ICMP_UNREACH_PROTOCOL)
got_there = _B_TRUE;
break;
}
seq = (seq + 1) % (MAX_SEQ + 1);
if (cc == 0) {
Printf(" *");
timeouts++;
}
(void) fflush(stdout);
}
if (collect_stat) {
print_stats(probe, nreceived, rttmin, rttmax, rttsum,
rttssq);
}
(void) putchar('\n');
if (got_there ||
(unreachable > 0 && unreachable >= nprobes - 1))
break;
}
if (probe_all)
(void) signal(SIGINT, SIG_IGN);
}
static void
select_src_addr(union any_in_addr *dst_addr, union any_in_addr *src_addr,
int family)
{
int tmp_fd;
struct sockaddr *sock;
struct sockaddr_in *sin;
struct sockaddr_in6 *sin6;
size_t sock_len;
sock = (struct sockaddr *)malloc(sizeof (struct sockaddr_in6));
if (sock == NULL) {
Fprintf(stderr, "%s: malloc %s\n", prog, strerror(errno));
exit(EXIT_FAILURE);
}
(void) bzero(sock, sizeof (struct sockaddr_in6));
if (family == AF_INET) {
sin = (struct sockaddr_in *)sock;
sin->sin_family = AF_INET;
sin->sin_addr = dst_addr->addr;
sin->sin_port = IPPORT_ECHO;
sock_len = sizeof (struct sockaddr_in);
} else {
sin6 = (struct sockaddr_in6 *)sock;
sin6->sin6_family = AF_INET6;
sin6->sin6_addr = dst_addr->addr6;
sin6->sin6_port = IPPORT_ECHO;
sock_len = sizeof (struct sockaddr_in6);
}
if ((tmp_fd = socket(family, SOCK_DGRAM, 0)) < 0) {
Fprintf(stderr, "%s: udp socket: %s\n", prog,
strerror(errno));
exit(EXIT_FAILURE);
}
if (connect(tmp_fd, sock, sock_len) < 0) {
if (family == AF_INET)
src_addr->addr.s_addr = INADDR_ANY;
else
src_addr->addr6 = in6addr_any;
free(sock);
return;
}
if (getsockname(tmp_fd, sock, &sock_len) < 0) {
Fprintf(stderr, "%s: getsockname: %s\n", prog,
strerror(errno));
exit(EXIT_FAILURE);
}
if (family == AF_INET) {
sin = (struct sockaddr_in *)sock;
src_addr->addr = sin->sin_addr;
} else {
sin6 = (struct sockaddr_in6 *)sock;
src_addr->addr6 = sin6->sin6_addr;
}
free(sock);
(void) close(tmp_fd);
}
ushort_t
in_cksum(ushort_t *addr, int len)
{
int nleft = len;
ushort_t *w = addr;
ushort_t answer;
int sum = 0;
while (nleft > 1) {
sum += *w++;
nleft -= 2;
}
if (nleft == 1)
sum += *(uchar_t *)w;
sum = (sum >> 16) + (sum & 0xffff);
sum += (sum >> 16);
answer = ~sum;
return (answer);
}
static int
wait_for_reply(int sock, struct msghdr *msg, struct timeval *tp)
{
fd_set fds;
struct timeval now, wait;
int cc = 0;
int result;
(void) FD_ZERO(&fds);
FD_SET(sock, &fds);
wait.tv_sec = tp->tv_sec + waittime;
wait.tv_usec = tp->tv_usec;
(void) gettimeofday(&now, NULL);
tv_sub(&wait, &now);
if (wait.tv_sec < 0 || wait.tv_usec < 0)
return (0);
result = select(sock + 1, &fds, (fd_set *)NULL, (fd_set *)NULL, &wait);
if (result == -1) {
if (errno != EINTR) {
Fprintf(stderr, "%s: select: %s\n", prog,
strerror(errno));
}
} else if (result > 0)
cc = recvmsg(sock, msg, 0);
return (cc);
}
char *
inet_name(union any_in_addr *in, int family)
{
char *cp;
static boolean_t first = _B_TRUE;
static char domain[NI_MAXHOST + 1];
static char line[NI_MAXHOST + 1];
char hbuf[NI_MAXHOST];
socklen_t slen;
struct sockaddr_in sin;
struct sockaddr_in6 sin6;
struct sockaddr *sa;
int flags;
switch (family) {
case AF_INET:
slen = sizeof (struct sockaddr_in);
sin.sin_addr = in->addr;
sin.sin_port = 0;
sa = (struct sockaddr *)&sin;
break;
case AF_INET6:
slen = sizeof (struct sockaddr_in6);
sin6.sin6_addr = in->addr6;
sin6.sin6_port = 0;
sin6.sin6_scope_id = 0;
sa = (struct sockaddr *)&sin6;
break;
default:
(void) snprintf(line, sizeof (line),
"<invalid address family>");
return (line);
}
sa->sa_family = family;
if (first && !nflag) {
first = _B_FALSE;
mutex_enter(&tr_nslock);
tr_nsactive = _B_TRUE;
tr_nsstarttime = gethrtime();
mutex_exit(&tr_nslock);
if (gethostname(domain, MAXHOSTNAMELEN) == 0 &&
(cp = strchr(domain, '.')) != NULL) {
(void) strncpy(domain, cp + 1, sizeof (domain) - 1);
domain[sizeof (domain) - 1] = '\0';
} else {
domain[0] = '\0';
}
mutex_enter(&tr_nslock);
tr_nsactive = _B_FALSE;
mutex_exit(&tr_nslock);
}
flags = (nflag) ? NI_NUMERICHOST : NI_NAMEREQD;
mutex_enter(&tr_nslock);
tr_nsactive = _B_TRUE;
tr_nsstarttime = gethrtime();
mutex_exit(&tr_nslock);
if (getnameinfo(sa, slen, hbuf, sizeof (hbuf), NULL, 0, flags) != 0) {
if (inet_ntop(family, (const void *)&in->addr6,
hbuf, sizeof (hbuf)) == NULL)
hbuf[0] = 0;
} else if (!nflag && (cp = strchr(hbuf, '.')) != NULL &&
strcmp(cp + 1, domain) == 0) {
*cp = '\0';
}
mutex_enter(&tr_nslock);
tr_nsactive = _B_FALSE;
mutex_exit(&tr_nslock);
(void) strlcpy(line, hbuf, sizeof (line));
return (line);
}
static double
deltaT(struct timeval *t1p, struct timeval *t2p)
{
double dt;
dt = (double)(t2p->tv_sec - t1p->tv_sec) * 1000.0 +
(double)(t2p->tv_usec - t1p->tv_usec) / 1000.0;
return (dt);
}
static void
tv_sub(struct timeval *out, struct timeval *in)
{
if ((out->tv_usec -= in->tv_usec) < 0) {
--out->tv_sec;
out->tv_usec += 1000000;
}
out->tv_sec -= in->tv_sec;
}
static void
record_stats(double rtt, int *nreceived, double *rttmin, double *rttmax,
double *rttsum, double *rttssq)
{
if (*nreceived == 0) {
*rttmin = rtt;
*rttmax = rtt;
*rttsum = rtt;
*rttssq = rtt * rtt;
} else {
if (rtt < *rttmin)
*rttmin = rtt;
if (rtt > *rttmax)
*rttmax = rtt;
*rttsum += rtt;
*rttssq += rtt * rtt;
}
(*nreceived)++;
}
static void
print_stats(int ntransmitted, int nreceived, double rttmin, double rttmax,
double rttsum, double rttssq)
{
double rttavg;
double rttstd;
if (ntransmitted > 0 && ntransmitted >= nreceived) {
int missed = ntransmitted - nreceived;
double loss = 100 * (double)missed / (double)ntransmitted;
if (nreceived > 0) {
rttavg = rttsum / nreceived;
rttstd = rttssq - (rttavg * rttsum);
rttstd = xsqrt(rttstd / nreceived);
Printf(" %.3f", rttmin);
Printf("/%.3f", rttavg);
Printf("/%.3f", rttmax);
Printf(" (%.3f) ms ", rttstd);
}
Printf(" %d/%d pkts", nreceived, ntransmitted);
if (nreceived == 0)
Printf(" (100%% loss)");
else
Printf(" (%.2g%% loss)", loss);
}
}
double
xsqrt(double y)
{
double t, x;
if (y <= 0) {
return (0.0);
}
x = (y < 1.0) ? 1.0 : y;
do {
t = x;
x = (t + (y/t))/2.0;
} while (0 < x && x < t);
return (x);
}
static double
str2dbl(const char *str, const char *what, double mi, double ma)
{
double val;
char *ep;
errno = 0;
val = strtod(str, &ep);
if (errno != 0 || *ep != '\0') {
Fprintf(stderr, "%s: \"%s\" bad value for %s \n",
prog, str, what);
exit(EXIT_FAILURE);
}
if (val < mi && mi >= 0) {
Fprintf(stderr, "%s: %s must be >= %f\n", prog, what, mi);
exit(EXIT_FAILURE);
}
if (val > ma && ma >= 0) {
Fprintf(stderr, "%s: %s must be <= %f\n", prog, what, ma);
exit(EXIT_FAILURE);
}
return (val);
}
static int
str2int(const char *str, const char *what, int mi, int ma)
{
const char *cp;
int val;
char *ep;
errno = 0;
if (str[0] == '0' && (str[1] == 'x' || str[1] == 'X')) {
cp = str + 2;
val = (int)strtol(cp, &ep, 16);
} else {
val = (int)strtol(str, &ep, 10);
}
if (errno != 0 || *ep != '\0') {
Fprintf(stderr, "%s: \"%s\" bad value for %s \n",
prog, str, what);
exit(EXIT_FAILURE);
}
if (val < mi && mi >= 0) {
if (mi == 0) {
Fprintf(stderr, "%s: %s must be >= %d\n",
prog, what, mi);
} else {
Fprintf(stderr, "%s: %s must be > %d\n",
prog, what, mi - 1);
}
exit(EXIT_FAILURE);
}
if (val > ma && ma >= 0) {
Fprintf(stderr, "%s: %s must be <= %d\n", prog, what, ma);
exit(EXIT_FAILURE);
}
return (val);
}
static void
sig_handler(int sig)
{
longjmp(env, sig);
}
static void
usage(void)
{
Fprintf(stderr, "Usage: %s [-adFIlnSvx] [-A address_family] "
"[-c traffic_class]\n"
"\t[-f first_hop] [-g gateway [-g gateway ...]| -r] [-i iface]\n"
"\t[-L flow_label] [-m max_hop] [-P pause_sec] [-p port] "
"[-Q max_timeout]\n"
"\t[-q nqueries] [-s src_addr] [-t tos] [-w wait_time] host "
"[packetlen]\n", prog);
exit(EXIT_FAILURE);
}
static void *
ns_warning_thr(void *unused)
{
for (;;) {
hrtime_t now;
(void) sleep(tr_nssleeptime);
now = gethrtime();
mutex_enter(&tr_nslock);
if (tr_nsactive && now - tr_nsstarttime >=
tr_nswarntime * NANOSEC) {
Fprintf(stderr, "%s: warning: responses "
"received, but name service lookups are "
"taking a while. Use %s -n to disable "
"name service lookups.\n",
prog, prog);
mutex_exit(&tr_nslock);
return (NULL);
}
mutex_exit(&tr_nslock);
}
return (NULL);
}