1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
#!/usr/local/bin/perl
# icp-test.pl
#
# Duane Wessels, Nov 1996
#
# Usage: icp-test.pl host:port ... < url-list
#
# Sends a continuous stream of ICP queries to a set of caches. Stdin is
# a list of URLs to request.
require 'getopts.pl';
$|=1;
&Getopts('n');
# just copy this from src/proto.c
@CODES=(
"ICP_INVALID",
"ICP_QUERY",
"UDP_HIT",
"UDP_MISS",
"ICP_ERR",
"ICP_SEND",
"ICP_SENDA",
"ICP_DATABEG",
"ICP_DATA",
"ICP_DATAEND",
"ICP_SECHO",
"ICP_DECHO",
"ICP_OP_UNUSED0",
"ICP_OP_UNUSED1",
"ICP_OP_UNUSED2",
"ICP_OP_UNUSED3",
"ICP_OP_UNUSED4",
"ICP_OP_UNUSED5",
"ICP_OP_UNUSED6",
"ICP_OP_UNUSED7",
"ICP_OP_UNUSED8",
"UDP_RELOADING",
"UDP_DENIED",
"UDP_HIT_OBJ",
"ICP_END"
);
require 'sys/socket.ph';
$sockaddr = 'S n a4 x8';
($name, $aliases, $proto) = getprotobyname("udp");
$thissock = pack($sockaddr, &AF_INET, 0, "\0\0\0\0");
chop($me=`uname -a|cut -f2 -d' '`);
$myip=(gethostbyname($me))[4];
die "socket: $!\n" unless
socket (SOCK, &AF_INET, &SOCK_DGRAM, $proto);
$flags = 0;
$flags |= 0x80000000;
$flags |= 0x40000000 if ($opt_n);
$flags = ~0;
while ($ARGV[0] =~ /([^:]+):(\d+)/) {
$host = $1;
$port = $2;
($fqdn, $aliases, $type, $len, $themaddr) = gethostbyname($host);
$ADDR{$host} = pack('Sna4x8', &AF_INET, $port, $themaddr);
$ip = join('.', unpack('C4', $themaddr));
$FQDN{$ip} = $fqdn;
shift;
}
$rn = 0;
while (<>) {
print;
chop;
$len = length($_) + 1;
$request_template = sprintf 'CCnNNa4a4x4a%d', $len;
$request = pack($request_template,
1, # C opcode
2, # C version
24 + $len, # n length
++$rn, # N reqnum
$flags, # N flags
'', # a4 pad
$myip, # a4 shostid
$_); # a%d payload
$n = 0;
foreach $host (keys %ADDR) {
$port = $PORT{$host};
@ip = split('\.', $IP{$host});
$them = pack('SnC4x8', &AF_INET, $port, @ip);
($sport,@IP) = unpack('x2nC4x8', $ADDR{$host});
die "send: $!\n" unless send(SOCK, $request, 0, $ADDR{$host});
$n++;
}
while ($n > 0) {
$rin = '';
vec($rin,fileno(SOCK),1) = 1;
($nfound,$timeleft) = select($rout=$rin, undef, undef, 2.0);
last if ($nfound == 0);
die "recv: $!\n" unless
$theiraddr = recv(SOCK, $reply, 1024, 0);
($junk, $junk, $sourceaddr, $junk) = unpack($sockaddr, $theiraddr);
$ip = join('.', unpack('C4', $sourceaddr));
($type,$ver,$len,$flag,$p1,$p2,$payload) = unpack('CCnx4Nnnx4A', $reply);
printf "\t%-20.20s %-10.10s",
$FQDN{$ip},
$CODES[$type];
print " hop=$p1" if ($opt_n);
print " rtt=$p2" if ($opt_n);
print "\n";
$n--;
}
}
|
