[ViewVC] Diff of: cvs/AnyEvent/lib/AnyEvent/DNS.pm

Comparing AnyEvent/lib/AnyEvent/DNS.pm (file contents):
Revision 1.43 by root, Thu May 29 06:19:22 2008 UTC vs.
Revision 1.103 by root, Thu Jul 9 08:31:16 2009 UTC

…		…
2		2
3	AnyEvent::DNS - fully asynchronous DNS resolution	3	AnyEvent::DNS - fully asynchronous DNS resolution
4		4
5	=head1 SYNOPSIS	5	=head1 SYNOPSIS
6		6
7	use AnyEvent::DNS;	7	use AnyEvent::DNS;
8		8
9	my $cv = AnyEvent->condvar;	9	my $cv = AnyEvent->condvar;
10	AnyEvent::DNS::a "www.google.de", $cv;	10	AnyEvent::DNS::a "www.google.de", $cv;
11	# ... later	11	# ... later
12	my @addrs = $cv->recv;	12	my @addrs = $cv->recv;
13		13
14	=head1 DESCRIPTION	14	=head1 DESCRIPTION
15		15
16	This module offers both a number of DNS convenience functions as well	16	This module offers both a number of DNS convenience functions as well
17	as a fully asynchronous and high-performance pure-perl stub resolver.	17	as a fully asynchronous and high-performance pure-perl stub resolver.
18		18
19	The stub resolver supports DNS over UDP, optional EDNS0 support for up to	19	The stub resolver supports DNS over IPv4 and IPv6, UDP and TCP, optional
20	4kiB datagrams and automatically falls back to virtual circuit mode for	20	EDNS0 support for up to 4kiB datagrams and automatically falls back to
21	large responses.	21	virtual circuit mode for large responses.
22		22
23	=head2 CONVENIENCE FUNCTIONS	23	=head2 CONVENIENCE FUNCTIONS
24		24
25	=over 4	25	=over 4
26		26
…		…
29	package AnyEvent::DNS;	29	package AnyEvent::DNS;
30		30
31	no warnings;	31	no warnings;
32	use strict;	32	use strict;
33		33
		34	use Carp ();
34	use Socket qw(AF_INET SOCK_DGRAM SOCK_STREAM);	35	use Socket qw(AF_INET SOCK_DGRAM SOCK_STREAM);
35		36
36	use AnyEvent ();	37	use AnyEvent ();
37	use AnyEvent::Handle ();
38	use AnyEvent::Util qw(AF_INET6);	38	use AnyEvent::Util qw(AF_INET6);
39		39
40	our $VERSION = '1.0';	40	our $VERSION = 4.81;
41		41
42	our @DNS_FALLBACK = (v208.67.220.220, v208.67.222.222);	42	our @DNS_FALLBACK = (v208.67.220.220, v208.67.222.222);
43		43
44	=item AnyEvent::DNS::a $domain, $cb->(@addrs)	44	=item AnyEvent::DNS::a $domain, $cb->(@addrs)
45		45
…		…
65	=item AnyEvent::DNS::srv $service, $proto, $domain, $cb->(@srv_rr)	65	=item AnyEvent::DNS::srv $service, $proto, $domain, $cb->(@srv_rr)
66		66
67	Tries to resolve the given service, protocol and domain name into a list	67	Tries to resolve the given service, protocol and domain name into a list
68	of service records.	68	of service records.
69		69
70	Each srv_rr is an array reference with the following contents:	70	Each C<$srv_rr> is an array reference with the following contents:
71	C<[$priority, $weight, $transport, $target]>.	71	C<[$priority, $weight, $transport, $target]>.
72		72
73	They will be sorted with lowest priority, highest weight first (TODO:	73	They will be sorted with lowest priority first, then randomly
74	should use the RFC algorithm to reorder same-priority records for weight).	74	distributed by weight as per RFC 2782.
75		75
76	Example:	76	Example:
77		77
78	AnyEvent::DNS::srv "sip", "udp", "schmorp.de", sub { ...	78	AnyEvent::DNS::srv "sip", "udp", "schmorp.de", sub { ...
79	# @_ = ( [10, 10, 5060, "sip1.schmorp.de" ] )	79	# @_ = ( [10, 10, 5060, "sip1.schmorp.de" ] )
80		80
81	=item AnyEvent::DNS::ptr $ipv4_or_6, $cb->(@hostnames)	81	=item AnyEvent::DNS::ptr $domain, $cb->(@hostnames)
		82
		83	Tries to make a PTR lookup on the given domain. See C<reverse_lookup>
		84	and C<reverse_verify> if you want to resolve an IP address to a hostname
		85	instead.
		86
		87	=item AnyEvent::DNS::any $domain, $cb->(@rrs)
		88
		89	Tries to resolve the given domain and passes all resource records found to
		90	the callback.
		91
		92	=item AnyEvent::DNS::reverse_lookup $ipv4_or_6, $cb->(@hostnames)
82		93
83	Tries to reverse-resolve the given IPv4 or IPv6 address (in textual form)	94	Tries to reverse-resolve the given IPv4 or IPv6 address (in textual form)
84	into it's hostname(s).	95	into it's hostname(s). Handles V4MAPPED and V4COMPAT IPv6 addresses
		96	transparently.
		97
		98	=item AnyEvent::DNS::reverse_verify $ipv4_or_6, $cb->(@hostnames)
		99
		100	The same as C<reverse_lookup>, but does forward-lookups to verify that
		101	the resolved hostnames indeed point to the address, which makes spoofing
		102	harder.
		103
		104	If you want to resolve an address into a hostname, this is the preferred
		105	method: The DNS records could still change, but at least this function
		106	verified that the hostname, at one point in the past, pointed at the IP
		107	address you originally resolved.
85		108
86	Example:	109	Example:
87		110
88	AnyEvent::DNS::ptr "2001:500:2f::f", sub { print shift };	111	AnyEvent::DNS::ptr "2001:500:2f::f", sub { print shift };
89	# => f.root-servers.net	112	# => f.root-servers.net
90
91	=item AnyEvent::DNS::any $domain, $cb->(@rrs)
92
93	Tries to resolve the given domain and passes all resource records found to
94	the callback.
95		113
96	=cut	114	=cut
97		115
98	sub MAX_PKT() { 4096 } # max packet size we advertise and accept	116	sub MAX_PKT() { 4096 } # max packet size we advertise and accept
99		117
…		…
144	sub srv($$$$) {	162	sub srv($$$$) {
145	my ($service, $proto, $domain, $cb) = @_;	163	my ($service, $proto, $domain, $cb) = @_;
146		164
147	# todo, ask for any and check glue records	165	# todo, ask for any and check glue records
148	resolver->resolve ("_$service._$proto.$domain" => "srv", sub {	166	resolver->resolve ("_$service._$proto.$domain" => "srv", sub {
149	$cb->(map [@$_[3,4,5,6]], sort { $a->[3] <=> $b->[3] \|\| $b->[4] <=> $a->[4] } @_);	167	my @res;
		168
		169	# classify by priority
		170	my %pri;
		171	push @{ $pri{$_->[3]} }, [ @$_[3,4,5,6] ]
		172	for @_;
		173
		174	# order by priority
		175	for my $pri (sort { $a <=> $b } keys %pri) {
		176	# order by weight
		177	my @rr = sort { $a->[1] <=> $b->[1] } @{ delete $pri{$pri} };
		178
		179	my $sum; $sum += $_->[1] for @rr;
		180
		181	while (@rr) {
		182	my $w = int rand $sum + 1;
		183	for (0 .. $#rr) {
		184	if (($w -= $rr[$_][1]) <= 0) {
		185	$sum -= $rr[$_][1];
		186	push @res, splice @rr, $_, 1, ();
		187	last;
		188	}
		189	}
		190	}
		191	}
		192
		193	$cb->(@res);
150	});	194	});
151	}	195	}
152		196
153	sub ptr($$) {	197	sub ptr($$) {
		198	my ($domain, $cb) = @_;
		199
		200	resolver->resolve ($domain => "ptr", sub {
		201	$cb->(map $_->[3], @_);
		202	});
		203	}
		204
		205	sub any($$) {
		206	my ($domain, $cb) = @_;
		207
		208	resolver->resolve ($domain => "*", $cb);
		209	}
		210
		211	# convert textual ip address into reverse lookup form
		212	sub _munge_ptr($) {
		213	my $ipn = $_[0]
		214	or return;
		215
		216	my $ptr;
		217
		218	my $af = AnyEvent::Socket::address_family ($ipn);
		219
		220	if ($af == AF_INET6) {
		221	$ipn = substr $ipn, 0, 16; # anticipate future expansion
		222
		223	# handle v4mapped and v4compat
		224	if ($ipn =~ s/^\x00{10}(?:\xff\xff\|\x00\x00)//) {
		225	$af = AF_INET;
		226	} else {
		227	$ptr = join ".", (reverse split //, unpack "H32", $ipn), "ip6.arpa.";
		228	}
		229	}
		230
		231	if ($af == AF_INET) {
		232	$ptr = join ".", (reverse unpack "C4", $ipn), "in-addr.arpa.";
		233	}
		234
		235	$ptr
		236	}
		237
		238	sub reverse_lookup($$) {
154	my ($ip, $cb) = @_;	239	my ($ip, $cb) = @_;
155		240
156	$ip = AnyEvent::Socket::parse_address ($ip)	241	$ip = _munge_ptr AnyEvent::Socket::parse_address ($ip)
157	or return $cb->();	242	or return $cb->();
158
159	my $af = AnyEvent::Socket::address_family ($ip);
160
161	if ($af == AF_INET) {
162	$ip = join ".", (reverse split /\./, $ip), "in-addr.arpa.";
163	} elsif ($af == AF_INET6) {
164	$ip = join ".", (reverse split //, unpack "H*", $ip), "ip6.arpa.";
165	} else {
166	return $cb->();
167	}
168		243
169	resolver->resolve ($ip => "ptr", sub {	244	resolver->resolve ($ip => "ptr", sub {
170	$cb->(map $_->[3], @_);	245	$cb->(map $_->[3], @_);
171	});	246	});
172	}	247	}
173		248
174	sub any($$) {	249	sub reverse_verify($$) {
175	my ($domain, $cb) = @_;	250	my ($ip, $cb) = @_;
		251
		252	my $ipn = AnyEvent::Socket::parse_address ($ip)
		253	or return $cb->();
176		254
177	resolver->resolve ($domain => "*", $cb);	255	my $af = AnyEvent::Socket::address_family ($ipn);
		256
		257	my @res;
		258	my $cnt;
		259
		260	my $ptr = _munge_ptr $ipn
		261	or return $cb->();
		262
		263	$ip = AnyEvent::Socket::format_address ($ipn); # normalise into the same form
		264
		265	ptr $ptr, sub {
		266	for my $name (@_) {
		267	++$cnt;
		268
		269	# () around AF_INET to work around bug in 5.8
		270	resolver->resolve ("$name." => ($af == (AF_INET) ? "a" : "aaaa"), sub {
		271	for (@_) {
		272	push @res, $name
		273	if $_->[3] eq $ip;
		274	}
		275	$cb->(@res) unless --$cnt;
		276	});
		277	}
		278
		279	$cb->() unless $cnt;
		280	};
178	}	281	}
179		282
180	#################################################################################	283	#################################################################################
181		284
182	=back	285	=back
…		…
192	C<$ENV{PERL_ANYEVENT_EDNS0}>, but when set to C<1>, AnyEvent::DNS will use	295	C<$ENV{PERL_ANYEVENT_EDNS0}>, but when set to C<1>, AnyEvent::DNS will use
193	EDNS0 in all requests.	296	EDNS0 in all requests.
194		297
195	=cut	298	=cut
196		299
197	our $EDNS0 = $ENV{PERL_ANYEVENT_EDNS0} * 1; # set to 1 to enable (partial) edns0	300	our $EDNS0 = $ENV{PERL_ANYEVENT_EDNS0}*1; # set to 1 to enable (partial) edns0
198		301
199	our %opcode_id = (	302	our %opcode_id = (
200	query => 0,	303	query => 0,
201	iquery => 1,	304	iquery => 1,
202	status => 2,	305	status => 2,
…		…
248	minfo => 14,	351	minfo => 14,
249	mx => 15,	352	mx => 15,
250	txt => 16,	353	txt => 16,
251	aaaa => 28,	354	aaaa => 28,
252	srv => 33,	355	srv => 33,
		356	naptr => 35, # rfc2915
		357	dname => 39, # rfc2672
253	opt => 41,	358	opt => 41,
254	spf => 99,	359	spf => 99,
255	tkey => 249,	360	tkey => 249,
256	tsig => 250,	361	tsig => 250,
257	ixfr => 251,	362	ixfr => 251,
…		…
270	"*" => 255,	375	"*" => 255,
271	);	376	);
272		377
273	our %class_str = reverse %class_id;	378	our %class_str = reverse %class_id;
274		379
275	# names MUST have a trailing dot
276	sub _enc_name($) {	380	sub _enc_name($) {
277	pack "(C/a)", (split /\./, shift), ""	381	pack "(C/a)", (split /\./, shift), ""
278	}	382	}
279		383
280	sub _enc_qd() {	384	sub _enc_qd() {
…		…
287	die "encoding of resource records is not supported";	391	die "encoding of resource records is not supported";
288	}	392	}
289		393
290	=item $pkt = AnyEvent::DNS::dns_pack $dns	394	=item $pkt = AnyEvent::DNS::dns_pack $dns
291		395
292	Packs a perl data structure into a DNS packet. Reading RFC1034 is strongly	396	Packs a perl data structure into a DNS packet. Reading RFC 1035 is strongly
293	recommended, then everything will be totally clear. Or maybe not.	397	recommended, then everything will be totally clear. Or maybe not.
294		398
295	Resource records are not yet encodable.	399	Resource records are not yet encodable.
296		400
297	Examples:	401	Examples:
298		402
299	# very simple request, using lots of default values:	403	# very simple request, using lots of default values:
300	{ rd => 1, qd => [ [ "host.domain", "a"] ] }	404	{ rd => 1, qd => [ [ "host.domain", "a"] ] }
301		405
302	# more complex example, showing how flags etc. are named:	406	# more complex example, showing how flags etc. are named:
303		407
304	{	408	{
305	id => 10000,	409	id => 10000,
306	op => "query",	410	op => "query",
307	rc => "nxdomain",	411	rc => "nxdomain",
308		412
309	# flags	413	# flags
310	qr => 1,	414	qr => 1,
311	aa => 0,	415	aa => 0,
312	tc => 0,	416	tc => 0,
313	rd => 0,	417	rd => 0,
314	ra => 0,	418	ra => 0,
315	ad => 0,	419	ad => 0,
316	cd => 0,	420	cd => 0,
317		421
318	qd => [@rr], # query section	422	qd => [@rr], # query section
319	an => [@rr], # answer section	423	an => [@rr], # answer section
320	ns => [@rr], # authority section	424	ns => [@rr], # authority section
321	ar => [@rr], # additional records section	425	ar => [@rr], # additional records section
322	}	426	}
323		427
324	=cut	428	=cut
325		429
326	sub dns_pack($) {	430	sub dns_pack($) {
327	my ($req) = @_;	431	my ($req) = @_;
…		…
340	+ $rcode_id{$req->{rc}} * 0x0001,	444	+ $rcode_id{$req->{rc}} * 0x0001,
341		445
342	scalar @{ $req->{qd} \|\| [] },	446	scalar @{ $req->{qd} \|\| [] },
343	scalar @{ $req->{an} \|\| [] },	447	scalar @{ $req->{an} \|\| [] },
344	scalar @{ $req->{ns} \|\| [] },	448	scalar @{ $req->{ns} \|\| [] },
345	$EDNS0 + scalar @{ $req->{ar} \|\| [] }, # include EDNS0 option here	449	$EDNS0 + scalar @{ $req->{ar} \|\| [] }, # EDNS0 option included here
346		450
347	(join "", map _enc_qd, @{ $req->{qd} \|\| [] }),	451	(join "", map _enc_qd, @{ $req->{qd} \|\| [] }),
348	(join "", map _enc_rr, @{ $req->{an} \|\| [] }),	452	(join "", map _enc_rr, @{ $req->{an} \|\| [] }),
349	(join "", map _enc_rr, @{ $req->{ns} \|\| [] }),	453	(join "", map _enc_rr, @{ $req->{ns} \|\| [] }),
350	(join "", map _enc_rr, @{ $req->{ar} \|\| [] }),	454	(join "", map _enc_rr, @{ $req->{ar} \|\| [] }),
351		455
352	($EDNS0 ? pack "C nnNn", 0, 41, MAX_PKT, 0, 0 : "") # EDNS0, 4kiB udp payload size	456	($EDNS0 ? pack "C nnNn", 0, 41, MAX_PKT, 0, 0 : "") # EDNS0 option
353	}	457	}
354		458
355	our $ofs;	459	our $ofs;
356	our $pkt;	460	our $pkt;
357		461
…		…
400	11 => sub { ((join ".", unpack "C4", $_), unpack "C a*", substr $_, 4) }, # wks	504	11 => sub { ((join ".", unpack "C4", $_), unpack "C a*", substr $_, 4) }, # wks
401	12 => sub { local $ofs = $ofs - length; _dec_name }, # ptr	505	12 => sub { local $ofs = $ofs - length; _dec_name }, # ptr
402	13 => sub { unpack "C/a* C/a*", $_ }, # hinfo	506	13 => sub { unpack "C/a* C/a*", $_ }, # hinfo
403	15 => sub { local $ofs = $ofs + 2 - length; ((unpack "n", $_), _dec_name) }, # mx	507	15 => sub { local $ofs = $ofs + 2 - length; ((unpack "n", $_), _dec_name) }, # mx
404	16 => sub { unpack "(C/a)", $_ }, # txt	508	16 => sub { unpack "(C/a)", $_ }, # txt
405	28 => sub { AnyEvent::Socket::format_address ($_) }, # aaaa	509	28 => sub { AnyEvent::Socket::format_ipv6 ($_) }, # aaaa
406	33 => sub { local $ofs = $ofs + 6 - length; ((unpack "nnn", $_), _dec_name) }, # srv	510	33 => sub { local $ofs = $ofs + 6 - length; ((unpack "nnn", $_), _dec_name) }, # srv
		511	35 => sub { # naptr
		512	# requires perl 5.10, sorry
		513	my ($order, $preference, $flags, $service, $regexp, $offset) = unpack "nn C/a* C/a* C/a* .", $_;
		514	local $ofs = $ofs + $offset - length;
		515	($order, $preference, $flags, $service, $regexp, _dec_name)
		516	},
		517	39 => sub { local $ofs = $ofs - length; _dec_name }, # dname
407	99 => sub { unpack "(C/a)", $_ }, # spf	518	99 => sub { unpack "(C/a)", $_ }, # spf
408	);	519	);
409		520
410	sub _dec_rr {	521	sub _dec_rr {
411	my $name = _dec_name;	522	my $name = _dec_name;
…		…
425		536
426	Unpacks a DNS packet into a perl data structure.	537	Unpacks a DNS packet into a perl data structure.
427		538
428	Examples:	539	Examples:
429		540
430	# an unsuccessful reply	541	# an unsuccessful reply
431	{	542	{
432	'qd' => [	543	'qd' => [
433	[ 'ruth.plan9.de.mach.uni-karlsruhe.de', '*', 'in' ]	544	[ 'ruth.plan9.de.mach.uni-karlsruhe.de', '*', 'in' ]
434	],	545	],
435	'rc' => 'nxdomain',	546	'rc' => 'nxdomain',
436	'ar' => [],	547	'ar' => [],
437	'ns' => [	548	'ns' => [
438	[	549	[
439	'uni-karlsruhe.de',	550	'uni-karlsruhe.de',
440	'soa',	551	'soa',
441	'in',	552	'in',
442	'netserv.rz.uni-karlsruhe.de',	553	'netserv.rz.uni-karlsruhe.de',
443	'hostmaster.rz.uni-karlsruhe.de',	554	'hostmaster.rz.uni-karlsruhe.de',
444	2008052201, 10800, 1800, 2592000, 86400	555	2008052201, 10800, 1800, 2592000, 86400
445	]	556	]
446	],	557	],
447	'tc' => '',	558	'tc' => '',
448	'ra' => 1,	559	'ra' => 1,
449	'qr' => 1,	560	'qr' => 1,
450	'id' => 45915,	561	'id' => 45915,
451	'aa' => '',	562	'aa' => '',
452	'an' => [],	563	'an' => [],
453	'rd' => 1,	564	'rd' => 1,
454	'op' => 'query'	565	'op' => 'query'
455	}	566	}
456		567
457	# a successful reply	568	# a successful reply
458		569
459	{	570	{
460	'qd' => [ [ 'www.google.de', 'a', 'in' ] ],	571	'qd' => [ [ 'www.google.de', 'a', 'in' ] ],
461	'rc' => 0,	572	'rc' => 0,
462	'ar' => [	573	'ar' => [
463	[ 'a.l.google.com', 'a', 'in', '209.85.139.9' ],	574	[ 'a.l.google.com', 'a', 'in', '209.85.139.9' ],
464	[ 'b.l.google.com', 'a', 'in', '64.233.179.9' ],	575	[ 'b.l.google.com', 'a', 'in', '64.233.179.9' ],
465	[ 'c.l.google.com', 'a', 'in', '64.233.161.9' ],	576	[ 'c.l.google.com', 'a', 'in', '64.233.161.9' ],
466	],	577	],
467	'ns' => [	578	'ns' => [
468	[ 'l.google.com', 'ns', 'in', 'a.l.google.com' ],	579	[ 'l.google.com', 'ns', 'in', 'a.l.google.com' ],
469	[ 'l.google.com', 'ns', 'in', 'b.l.google.com' ],	580	[ 'l.google.com', 'ns', 'in', 'b.l.google.com' ],
470	],	581	],
471	'tc' => '',	582	'tc' => '',
472	'ra' => 1,	583	'ra' => 1,
473	'qr' => 1,	584	'qr' => 1,
474	'id' => 64265,	585	'id' => 64265,
475	'aa' => '',	586	'aa' => '',
476	'an' => [	587	'an' => [
477	[ 'www.google.de', 'cname', 'in', 'www.google.com' ],	588	[ 'www.google.de', 'cname', 'in', 'www.google.com' ],
478	[ 'www.google.com', 'cname', 'in', 'www.l.google.com' ],	589	[ 'www.google.com', 'cname', 'in', 'www.l.google.com' ],
479	[ 'www.l.google.com', 'a', 'in', '66.249.93.104' ],	590	[ 'www.l.google.com', 'a', 'in', '66.249.93.104' ],
480	[ 'www.l.google.com', 'a', 'in', '66.249.93.147' ],	591	[ 'www.l.google.com', 'a', 'in', '66.249.93.147' ],
481	],	592	],
482	'rd' => 1,	593	'rd' => 1,
483	'op' => 0	594	'op' => 0
484	}	595	}
485		596
486	=cut	597	=cut
487		598
488	sub dns_unpack($) {	599	sub dns_unpack($) {
489	local $pkt = shift;	600	local $pkt = shift;
…		…
538	calls.	649	calls.
539		650
540	Unless you have special needs, prefer this function over creating your own	651	Unless you have special needs, prefer this function over creating your own
541	resolver object.	652	resolver object.
542		653
		654	The resolver is created with the following parameters:
		655
		656	untaint enabled
		657	max_outstanding $ENV{PERL_ANYEVENT_MAX_OUTSTANDING_DNS}
		658
		659	C<os_config> will be used for OS-specific configuration, unless
		660	C<$ENV{PERL_ANYEVENT_RESOLV_CONF}> is specified, in which case that file
		661	gets parsed.
		662
543	=cut	663	=cut
544		664
545	our $RESOLVER;	665	our $RESOLVER;
546		666
547	sub resolver() {	667	sub resolver() {
548	$RESOLVER \|\| do {	668	$RESOLVER \|\| do {
549	$RESOLVER = new AnyEvent::DNS;	669	$RESOLVER = new AnyEvent::DNS
		670	untaint => 1,
		671	exists $ENV{PERL_ANYEVENT_MAX_OUTSTANDING_DNS}
		672	? (max_outstanding => $ENV{PERL_ANYEVENT_MAX_OUTSTANDING_DNS}*1 \|\| 1) : (),
		673	;
		674
		675	exists $ENV{PERL_ANYEVENT_RESOLV_CONF}
		676	? length $ENV{PERL_ANYEVENT_RESOLV_CONF} && $RESOLVER->_parse_resolv_conf_file ($ENV{PERL_ANYEVENT_RESOLV_CONF})
550	$RESOLVER->os_config;	677	: $RESOLVER->os_config;
		678
551	$RESOLVER	679	$RESOLVER
552	}	680	}
553	}	681	}
554		682
555	=item $resolver = new AnyEvent::DNS key => value...	683	=item $resolver = new AnyEvent::DNS key => value...
…		…
590	been resolved.	718	been resolved.
591		719
592	=item reuse => $seconds	720	=item reuse => $seconds
593		721
594	The number of seconds (default: C<300>) that a query id cannot be re-used	722	The number of seconds (default: C<300>) that a query id cannot be re-used
595	after a timeout. If there as no time-out then query id's can be reused	723	after a timeout. If there was no time-out then query ids can be reused
596	immediately.	724	immediately.
		725
		726	=item untaint => $boolean
		727
		728	When true, then the resolver will automatically untaint results, and might
		729	also ignore certain environment variables.
597		730
598	=back	731	=back
599		732
600	=cut	733	=cut
601		734
602	sub new {	735	sub new {
603	my ($class, %arg) = @_;	736	my ($class, %arg) = @_;
604
605	# try to create a ipv4 and an ipv6 socket
606	# only fail when we cnanot create either
607
608	socket my $fh4, AF_INET , &Socket::SOCK_DGRAM, 0;
609	socket my $fh6, AF_INET6, &Socket::SOCK_DGRAM, 0;
610
611	$fh4 \|\| $fh6
612	or Carp::croak "unable to create either an IPv6 or an IPv4 socket";
613		737
614	my $self = bless {	738	my $self = bless {
615	server => [],	739	server => [],
616	timeout => [2, 5, 5],	740	timeout => [2, 5, 5],
617	search => [],	741	search => [],
618	ndots => 1,	742	ndots => 1,
619	max_outstanding => 10,	743	max_outstanding => 10,
620	reuse => 300, # reuse id's after 5 minutes only, if possible	744	reuse => 300,
621	%arg,	745	%arg,
622	reuse_q => [],	746	reuse_q => [],
623	}, $class;	747	}, $class;
624		748
625	# search should default to gethostname's domain	749	# search should default to gethostname's domain
626	# but perl lacks a good posix module	750	# but perl lacks a good posix module
627		751
		752	# try to create an ipv4 and an ipv6 socket
		753	# only fail when we cannot create either
		754	my $got_socket;
		755
628	Scalar::Util::weaken (my $wself = $self);	756	Scalar::Util::weaken (my $wself = $self);
629		757
630	if ($fh4) {	758	if (socket my $fh4, AF_INET , &Socket::SOCK_DGRAM, 0) {
		759	++$got_socket;
		760
631	AnyEvent::Util::fh_nonblocking $fh4, 1;	761	AnyEvent::Util::fh_nonblocking $fh4, 1;
632	$self->{fh4} = $fh4;	762	$self->{fh4} = $fh4;
633	$self->{rw4} = AnyEvent->io (fh => $fh4, poll => "r", cb => sub {	763	$self->{rw4} = AnyEvent->io (fh => $fh4, poll => "r", cb => sub {
634	if (my $peer = recv $fh4, my $pkt, MAX_PKT, 0) {	764	if (my $peer = recv $fh4, my $pkt, MAX_PKT, 0) {
635	$wself->_recv ($pkt, $peer);	765	$wself->_recv ($pkt, $peer);
636	}	766	}
637	});	767	});
638	}	768	}
639		769
640	if ($fh6) {	770	if (AF_INET6 && socket my $fh6, AF_INET6, &Socket::SOCK_DGRAM, 0) {
		771	++$got_socket;
		772
641	$self->{fh6} = $fh6;	773	$self->{fh6} = $fh6;
642	AnyEvent::Util::fh_nonblocking $fh6, 1;	774	AnyEvent::Util::fh_nonblocking $fh6, 1;
643	$self->{rw6} = AnyEvent->io (fh => $fh6, poll => "r", cb => sub {	775	$self->{rw6} = AnyEvent->io (fh => $fh6, poll => "r", cb => sub {
644	if (my $peer = recv $fh6, my $pkt, MAX_PKT, 0) {	776	if (my $peer = recv $fh6, my $pkt, MAX_PKT, 0) {
645	$wself->_recv ($pkt, $peer);	777	$wself->_recv ($pkt, $peer);
646	}	778	}
647	});	779	});
648	}	780	}
649		781
		782	$got_socket
		783	or Carp::croak "unable to create either an IPv4 or an IPv6 socket";
		784
650	$self->_compile;	785	$self->_compile;
651		786
652	$self	787	$self
653	}	788	}
654		789
655	=item $resolver->parse_resolv_conv ($string)	790	=item $resolver->parse_resolv_conf ($string)
656		791
657	Parses the given string as if it were a F<resolv.conf> file. The following	792	Parses the given string as if it were a F<resolv.conf> file. The following
658	directives are supported (but not necessarily implemented).	793	directives are supported (but not necessarily implemented).
659		794
660	C<#>-style comments, C<nameserver>, C<domain>, C<search>, C<sortlist>,	795	C<#>-style comments, C<nameserver>, C<domain>, C<search>, C<sortlist>,
…		…
707	if $attempts;	842	if $attempts;
708		843
709	$self->_compile;	844	$self->_compile;
710	}	845	}
711		846
		847	sub _parse_resolv_conf_file {
		848	my ($self, $resolv_conf) = @_;
		849
		850	open my $fh, "<:perlio", $resolv_conf
		851	or Carp::croak "$resolv_conf: $!";
		852
		853	local $/;
		854	$self->parse_resolv_conf (<$fh>);
		855	}
		856
712	=item $resolver->os_config	857	=item $resolver->os_config
713		858
714	Tries so load and parse F</etc/resolv.conf> on portable operating systems. Tries various	859	Tries so load and parse F</etc/resolv.conf> on portable operating
715	egregious hacks on windows to force the DNS servers and searchlist out of the system.	860	systems. Tries various egregious hacks on windows to force the DNS servers
		861	and searchlist out of the system.
716		862
717	=cut	863	=cut
718		864
719	sub os_config {	865	sub os_config {
720	my ($self) = @_;	866	my ($self) = @_;
721		867
722	$self->{server} = [];	868	$self->{server} = [];
723	$self->{search} = [];	869	$self->{search} = [];
724		870
725	if (AnyEvent::WIN32 \|\| $^O =~ /cygwin/i) {	871	if ((AnyEvent::WIN32 \|\| $^O =~ /cygwin/i)) {
726	no strict 'refs';	872	no strict 'refs';
727		873
728	# there are many options to find the current nameservers etc. on windows	874	# there are many options to find the current nameservers etc. on windows
729	# all of them don't work consistently:	875	# all of them don't work consistently:
730	# - the registry thing needs separate code on win32 native vs. cygwin	876	# - the registry thing needs separate code on win32 native vs. cygwin
731	# - the registry layout differs between windows versions	877	# - the registry layout differs between windows versions
732	# - calling windows api functions doesn't work on cygwin	878	# - calling windows api functions doesn't work on cygwin
733	# - ipconfig uses locale-specific messages	879	# - ipconfig uses locale-specific messages
734		880
735	# we use ipconfig parsing because, despite all it's brokenness,	881	# we use ipconfig parsing because, despite all its brokenness,
736	# it seems most stable in practise.	882	# it seems most stable in practise.
737	# for good measure, we append a fallback nameserver to our list.	883	# for good measure, we append a fallback nameserver to our list.
738		884
739	if (open my $fh, "ipconfig /all \|") {	885	if (open my $fh, "ipconfig /all \|") {
740	# parsing strategy: we go through the output and look for	886	# parsing strategy: we go through the output and look for
…		…
749	} elsif (/^\S/ \|\| /^\s[^:]{16,}: /) {	895	} elsif (/^\S/ \|\| /^\s[^:]{16,}: /) {
750	$dns = 0;	896	$dns = 0;
751	}	897	}
752	if ($dns && /^\s(\S+)\s$/) {	898	if ($dns && /^\s(\S+)\s$/) {
753	my $s = $1;	899	my $s = $1;
754	$s =~ s/%\d+(?!\S)//; # get rid of scope id	900	$s =~ s/%\d+(?!\S)//; # get rid of ipv6 scope id
755	if (my $ipn = AnyEvent::Socket::parse_address ($s)) {	901	if (my $ipn = AnyEvent::Socket::parse_address ($s)) {
756	push @{ $self->{server} }, $ipn;	902	push @{ $self->{server} }, $ipn;
757	} else {	903	} else {
758	push @{ $self->{search} }, $s;	904	push @{ $self->{search} }, $s;
759	}	905	}
…		…
764	push @{ $self->{server} }, $DNS_FALLBACK[rand @DNS_FALLBACK];	910	push @{ $self->{server} }, $DNS_FALLBACK[rand @DNS_FALLBACK];
765		911
766	$self->_compile;	912	$self->_compile;
767	}	913	}
768	} else {	914	} else {
769	# try resolv.conf everywhere	915	# try resolv.conf everywhere else
770		916
771	if (open my $fh, "</etc/resolv.conf") {	917	$self->_parse_resolv_conf_file ("/etc/resolv.conf")
772	local $/;	918	if -e "/etc/resolv.conf";
773	$self->parse_resolv_conf (<$fh>);
774	}
775	}	919	}
		920	}
		921
		922	=item $resolver->timeout ($timeout, ...)
		923
		924	Sets the timeout values. See the C<timeout> constructor argument (and note
		925	that this method uses the values itself, not an array-reference).
		926
		927	=cut
		928
		929	sub timeout {
		930	my ($self, @timeout) = @_;
		931
		932	$self->{timeout} = \@timeout;
		933	$self->_compile;
		934	}
		935
		936	=item $resolver->max_outstanding ($nrequests)
		937
		938	Sets the maximum number of outstanding requests to C<$nrequests>. See the
		939	C<max_outstanding> constructor argument.
		940
		941	=cut
		942
		943	sub max_outstanding {
		944	my ($self, $max) = @_;
		945
		946	$self->{max_outstanding} = $max;
		947	$self->_scheduler;
776	}	948	}
777		949
778	sub _compile {	950	sub _compile {
779	my $self = shift;	951	my $self = shift;
780		952
…		…
797	$self->{retry} = \@retry;	969	$self->{retry} = \@retry;
798	}	970	}
799		971
800	sub _feed {	972	sub _feed {
801	my ($self, $res) = @_;	973	my ($self, $res) = @_;
		974
		975	($res) = $res =~ /^(.*)$/s
		976	if AnyEvent::TAINT && $self->{untaint};
802		977
803	$res = dns_unpack $res	978	$res = dns_unpack $res
804	or return;	979	or return;
805		980
806	my $id = $self->{id}{$res->{id}};	981	my $id = $self->{id}{$res->{id}};
…		…
859		1034
860	$self->{id}{$req->[2]} = [AnyEvent->timer (after => $timeout, cb => sub {	1035	$self->{id}{$req->[2]} = [AnyEvent->timer (after => $timeout, cb => sub {
861	$NOW = time;	1036	$NOW = time;
862		1037
863	# timeout, try next	1038	# timeout, try next
864	&$do_retry;	1039	&$do_retry if $do_retry;
865	}), sub {	1040	}), sub {
866	my ($res) = @_;	1041	my ($res) = @_;
867		1042
868	if ($res->{tc}) {	1043	if ($res->{tc}) {
869	# success, but truncated, so use tcp	1044	# success, but truncated, so use tcp
870	AnyEvent::Socket::tcp_connect (AnyEvent::Socket::format_address ($server), DOMAIN_PORT, sub {	1045	AnyEvent::Socket::tcp_connect (AnyEvent::Socket::format_address ($server), DOMAIN_PORT, sub {
		1046	return unless $do_retry; # some other request could have invalidated us already
		1047
871	my ($fh) = @_	1048	my ($fh) = @_
872	or return &$do_retry;	1049	or return &$do_retry;
873		1050
		1051	require AnyEvent::Handle;
		1052
874	my $handle = new AnyEvent::Handle	1053	my $handle; $handle = new AnyEvent::Handle
875	fh => $fh,	1054	fh => $fh,
		1055	timeout => $timeout,
876	on_error => sub {	1056	on_error => sub {
		1057	undef $handle;
		1058	return unless $do_retry; # some other request could have invalidated us already
877	# failure, try next	1059	# failure, try next
878	&$do_retry;	1060	&$do_retry;
879	};	1061	};
880		1062
881	$handle->push_write (pack "n/a", $req->[0]);	1063	$handle->push_write (pack "n/a", $req->[0]);
882	$handle->push_read (chunk => 2, sub {	1064	$handle->push_read (chunk => 2, sub {
883	$handle->unshift_read (chunk => (unpack "n", $_[1]), sub {	1065	$handle->unshift_read (chunk => (unpack "n", $_[1]), sub {
		1066	undef $handle;
884	$self->_feed ($_[1]);	1067	$self->_feed ($_[1]);
885	});	1068	});
886	});	1069	});
887	shutdown $fh, 1;
888		1070
889	}, sub { $timeout });	1071	}, sub { $timeout });
890		1072
891	} else {	1073	} else {
892	# success	1074	# success
…		…
908	}	1090	}
909		1091
910	sub _scheduler {	1092	sub _scheduler {
911	my ($self) = @_;	1093	my ($self) = @_;
912		1094
		1095	no strict 'refs';
		1096
913	$NOW = time;	1097	$NOW = time;
914		1098
915	# first clear id reuse queue	1099	# first clear id reuse queue
916	delete $self->{id}{ (shift @{ $self->{reuse_q} })->[1] }	1100	delete $self->{id}{ (shift @{ $self->{reuse_q} })->[1] }
917	while @{ $self->{reuse_q} } && $self->{reuse_q}[0][0] <= $NOW;	1101	while @{ $self->{reuse_q} } && $self->{reuse_q}[0][0] <= $NOW;
…		…
925	$self->_scheduler;	1109	$self->_scheduler;
926	});	1110	});
927	last;	1111	last;
928	}	1112	}
929		1113
930	my $req = shift @{ $self->{queue} }	1114	if (my $req = shift @{ $self->{queue} }) {
931	or last;	1115	# found a request in the queue, execute it
932
933	while () {	1116	while () {
934	$req->[2] = int rand 65536;	1117	$req->[2] = int rand 65536;
935	last unless exists $self->{id}{$req->[2]};	1118	last unless exists $self->{id}{$req->[2]};
		1119	}
		1120
		1121	++$self->{outstanding};
		1122	$self->{id}{$req->[2]} = 1;
		1123	substr $req->[0], 0, 2, pack "n", $req->[2];
		1124
		1125	$self->_exec ($req);
		1126
		1127	} elsif (my $cb = shift @{ $self->{wait} }) {
		1128	# found a wait_for_slot callback, call that one first
		1129	$cb->($self);
		1130
		1131	} else {
		1132	# nothing to do, just exit
		1133	last;
936	}	1134	}
937
938	++$self->{outstanding};
939	$self->{id}{$req->[2]} = 1;
940	substr $req->[0], 0, 2, pack "n", $req->[2];
941
942	$self->_exec ($req);
943	}	1135	}
944	}	1136	}
945		1137
946	=item $resolver->request ($req, $cb->($res))	1138	=item $resolver->request ($req, $cb->($res))
947		1139
		1140	This is the main low-level workhorse for sending DNS requests.
		1141
948	Sends a single request (a hash-ref formated as specified for	1142	This function sends a single request (a hash-ref formated as specified
949	C<dns_pack>) to the configured nameservers including	1143	for C<dns_pack>) to the configured nameservers in turn until it gets a
		1144	response. It handles timeouts, retries and automatically falls back to
		1145	virtual circuit mode (TCP) when it receives a truncated reply.
		1146
950	retries. Calls the callback with the decoded response packet if a reply	1147	Calls the callback with the decoded response packet if a reply was
951	was received, or no arguments on timeout.	1148	received, or no arguments in case none of the servers answered.
952		1149
953	=cut	1150	=cut
954		1151
955	sub request($$) {	1152	sub request($$) {
956	my ($self, $req, $cb) = @_;	1153	my ($self, $req, $cb) = @_;
957		1154
958	push @{ $self->{queue} }, [dns_pack $req, $cb];	1155	push @{ $self->{queue} }, [dns_pack $req, $cb];
959	$self->_scheduler;	1156	$self->_scheduler;
960	}	1157	}
961		1158
962	=item $resolver->resolve ($qname, $qtype, %options, $cb->($rcode, @rr))	1159	=item $resolver->resolve ($qname, $qtype, %options, $cb->(@rr))
963		1160
964	Queries the DNS for the given domain name C<$qname> of type C<$qtype> (a	1161	Queries the DNS for the given domain name C<$qname> of type C<$qtype>.
965	qtype of "*" is supported and means "any").	1162
		1163	A C<$qtype> is either a numerical query type (e.g. C<1> for A records) or
		1164	a lowercase name (you have to look at the source to see which aliases are
		1165	supported, but all types from RFC 1035, C<aaaa>, C<srv>, C<spf> and a few
		1166	more are known to this module). A C<$qtype> of "*" is supported and means
		1167	"any" record type.
966		1168
967	The callback will be invoked with a list of matching result records or	1169	The callback will be invoked with a list of matching result records or
968	none on any error or if the name could not be found.	1170	none on any error or if the name could not be found.
969		1171
970	CNAME chains (although illegal) are followed up to a length of 8.	1172	CNAME chains (although illegal) are followed up to a length of 10.
		1173
		1174	The callback will be invoked with arraryefs of the form C<[$name, $type,
		1175	$class, @data>], where C<$name> is the domain name, C<$type> a type string
		1176	or number, C<$class> a class name and @data is resource-record-dependent
		1177	data. For C<a> records, this will be the textual IPv4 addresses, for C<ns>
		1178	or C<cname> records this will be a domain name, for C<txt> records these
		1179	are all the strings and so on.
		1180
		1181	All types mentioned in RFC 1035, C<aaaa>, C<srv>, C<naptr> and C<spf> are
		1182	decoded. All resource records not known to this module will have
		1183	the raw C<rdata> field as fourth entry.
971		1184
972	Note that this resolver is just a stub resolver: it requires a name server	1185	Note that this resolver is just a stub resolver: it requires a name server
973	supporting recursive queries, will not do any recursive queries itself and	1186	supporting recursive queries, will not do any recursive queries itself and
974	is not secure when used against an untrusted name server.	1187	is not secure when used against an untrusted name server.
975		1188
…		…
979		1192
980	=item search => [$suffix...]	1193	=item search => [$suffix...]
981		1194
982	Use the given search list (which might be empty), by appending each one	1195	Use the given search list (which might be empty), by appending each one
983	in turn to the C<$qname>. If this option is missing then the configured	1196	in turn to the C<$qname>. If this option is missing then the configured
984	C<ndots> and C<search> define its value. If the C<$qname> ends in a dot,	1197	C<ndots> and C<search> values define its value (depending on C<ndots>, the
985	then the searchlist will be ignored.	1198	empty suffix will be prepended or appended to that C<search> value). If
		1199	the C<$qname> ends in a dot, then the searchlist will be ignored.
986		1200
987	=item accept => [$type...]	1201	=item accept => [$type...]
988		1202
989	Lists the acceptable result types: only result types in this set will be	1203	Lists the acceptable result types: only result types in this set will be
990	accepted and returned. The default includes the C<$qtype> and nothing	1204	accepted and returned. The default includes the C<$qtype> and nothing
991	else.	1205	else. If this list includes C<cname>, then CNAME-chains will not be
		1206	followed (because you asked for the CNAME record).
992		1207
993	=item class => "class"	1208	=item class => "class"
994		1209
995	Specify the query class ("in" for internet, "ch" for chaosnet and "hs" for	1210	Specify the query class ("in" for internet, "ch" for chaosnet and "hs" for
996	hesiod are the only ones making sense). The default is "in", of course.	1211	hesiod are the only ones making sense). The default is "in", of course.
997		1212
998	=back	1213	=back
999		1214
1000	Examples:	1215	Examples:
1001		1216
1002	$res->resolve ("ruth.plan9.de", "a", sub {	1217	# full example, you can paste this into perl:
1003	warn Dumper [@_];	1218	use Data::Dumper;
1004	});	1219	use AnyEvent::DNS;
		1220	AnyEvent::DNS::resolver->resolve (
		1221	"google.com", "*", my $cv = AnyEvent->condvar);
		1222	warn Dumper [$cv->recv];
1005		1223
		1224	# shortened result:
1006	[	1225	# [
		1226	# [ 'google.com', 'soa', 'in', 'ns1.google.com', 'dns-admin.google.com',
		1227	# 2008052701, 7200, 1800, 1209600, 300 ],
1007	[	1228	# [
1008	'ruth.schmorp.de',	1229	# 'google.com', 'txt', 'in',
1009	'a',	1230	# 'v=spf1 include:_netblocks.google.com ~all'
1010	'in',	1231	# ],
1011	'129.13.162.95'	1232	# [ 'google.com', 'a', 'in', '64.233.187.99' ],
		1233	# [ 'google.com', 'mx', 'in', 10, 'smtp2.google.com' ],
		1234	# [ 'google.com', 'ns', 'in', 'ns2.google.com' ],
1012	]	1235	# ]
		1236
		1237	# resolve a records:
		1238	$res->resolve ("ruth.plan9.de", "a", sub { warn Dumper [@_] });
		1239
		1240	# result:
		1241	# [
		1242	# [ 'ruth.schmorp.de', 'a', 'in', '129.13.162.95' ]
1013	]	1243	# ]
1014		1244
		1245	# resolve any records, but return only a and aaaa records:
1015	$res->resolve ("test1.laendle", "*",	1246	$res->resolve ("test1.laendle", "*",
1016	accept => ["a", "aaaa"],	1247	accept => ["a", "aaaa"],
1017	sub {	1248	sub {
1018	warn Dumper [@_];	1249	warn Dumper [@_];
1019	}	1250	}
1020	);	1251	);
1021		1252
1022	[	1253	# result:
1023	[	1254	# [
1024	'test1.laendle',	1255	# [ 'test1.laendle', 'a', 'in', '10.0.0.255' ],
1025	'a',	1256	# [ 'test1.laendle', 'aaaa', 'in', '3ffe:1900:4545:0002:0240:0000:0000:f7e1' ]
1026	'in',
1027	'10.0.0.255'
1028	],
1029	[
1030	'test1.laendle',
1031	'aaaa',
1032	'in',
1033	'3ffe:1900:4545:0002:0240:0000:0000:f7e1'
1034	]	1257	# ]
1035	]
1036		1258
1037	=cut	1259	=cut
1038		1260
1039	sub resolve($%) {	1261	sub resolve($%) {
1040	my $cb = pop;	1262	my $cb = pop;
…		…
1060	$do_search = sub {	1282	$do_search = sub {
1061	@search	1283	@search
1062	or (undef $do_search), (undef $do_req), return $cb->();	1284	or (undef $do_search), (undef $do_req), return $cb->();
1063		1285
1064	(my $name = lc "$qname." . shift @search) =~ s/\.$//;	1286	(my $name = lc "$qname." . shift @search) =~ s/\.$//;
1065	my $depth = 2;	1287	my $depth = 10;
1066		1288
1067	# advance in cname-chain	1289	# advance in cname-chain
1068	$do_req = sub {	1290	$do_req = sub {
1069	$self->request ({	1291	$self->request ({
1070	rd => 1,	1292	rd => 1,
…		…
1088	if (@rr) {	1310	if (@rr) {
1089	$depth--	1311	$depth--
1090	or return $do_search->(); # cname chain too long	1312	or return $do_search->(); # cname chain too long
1091		1313
1092	$cname = 1;	1314	$cname = 1;
1093	$name = $rr[0][3];	1315	$name = lc $rr[0][3];
1094		1316
1095	} elsif ($cname) {	1317	} elsif ($cname) {
1096	# follow the cname	1318	# follow the cname
1097	return $do_req->();	1319	return $do_req->();
1098		1320
…		…
1108	};	1330	};
1109		1331
1110	$do_search->();	1332	$do_search->();
1111	}	1333	}
1112		1334
		1335	=item $resolver->wait_for_slot ($cb->($resolver))
		1336
		1337	Wait until a free request slot is available and call the callback with the
		1338	resolver object.
		1339
		1340	A request slot is used each time a request is actually sent to the
		1341	nameservers: There are never more than C<max_outstanding> of them.
		1342
		1343	Although you can submit more requests (they will simply be queued until
		1344	a request slot becomes available), sometimes, usually for rate-limiting
		1345	purposes, it is useful to instead wait for a slot before generating the
		1346	request (or simply to know when the request load is low enough so one can
		1347	submit requests again).
		1348
		1349	This is what this method does: The callback will be called when submitting
		1350	a DNS request will not result in that request being queued. The callback
		1351	may or may not generate any requests in response.
		1352
		1353	Note that the callback will only be invoked when the request queue is
		1354	empty, so this does not play well if somebody else keeps the request queue
		1355	full at all times.
		1356
		1357	=cut
		1358
		1359	sub wait_for_slot {
		1360	my ($self, $cb) = @_;
		1361
		1362	push @{ $self->{wait} }, $cb;
		1363	$self->_scheduler;
		1364	}
		1365
1113	use AnyEvent::Socket (); # circular dependency, so do not import anything and do it at the end	1366	use AnyEvent::Socket (); # circular dependency, so do not import anything and do it at the end
1114		1367
1115	1;	1368	1;
1116		1369
1117	=back	1370	=back
1118		1371
1119	=head1 AUTHOR	1372	=head1 AUTHOR
1120		1373
1121	Marc Lehmann <schmorp@schmorp.de>	1374	Marc Lehmann <schmorp@schmorp.de>
1122	http://home.schmorp.de/	1375	http://home.schmorp.de/
1123		1376
1124	=cut	1377	=cut
1125		1378

Diff Legend

-–
+Removed lines
-+
+Added lines
-<
+Changed lines
->
+Changed lines

Comparing AnyEvent/lib/AnyEvent/DNS.pm (file contents): Revision 1.43 by root, Thu May 29 06:19:22 2008 UTC vs. Revision 1.103 by root, Thu Jul 9 08:31:16 2009 UTC

Diff Legend

Comparing AnyEvent/lib/AnyEvent/DNS.pm (file contents):
Revision 1.43 by root, Thu May 29 06:19:22 2008 UTC vs.
Revision 1.103 by root, Thu Jul 9 08:31:16 2009 UTC