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

Comparing AnyEvent/lib/AnyEvent.pm (file contents):
Revision 1.354 by root, Thu Aug 11 21:26:39 2011 UTC vs.
Revision 1.367 by root, Wed Aug 17 02:14:17 2011 UTC

…		…
878	AnyEvent::Impl::EventLib based on Event::Lib, leaks memory and worse.	878	AnyEvent::Impl::EventLib based on Event::Lib, leaks memory and worse.
879	AnyEvent::Impl::POE based on POE, very slow, some limitations.	879	AnyEvent::Impl::POE based on POE, very slow, some limitations.
880	AnyEvent::Impl::Irssi used when running within irssi.	880	AnyEvent::Impl::Irssi used when running within irssi.
881	AnyEvent::Impl::IOAsync based on IO::Async.	881	AnyEvent::Impl::IOAsync based on IO::Async.
882	AnyEvent::Impl::Cocoa based on Cocoa::EventLoop.	882	AnyEvent::Impl::Cocoa based on Cocoa::EventLoop.
883	AnyEvent::Impl::FLTK based on FLTK.	883	AnyEvent::Impl::FLTK2 based on FLTK (fltk 2 binding).
884		884
885	=item Backends with special needs.	885	=item Backends with special needs.
886		886
887	Qt requires the Qt::Application to be instantiated first, but will	887	Qt requires the Qt::Application to be instantiated first, but will
888	otherwise be picked up automatically. As long as the main program	888	otherwise be picked up automatically. As long as the main program
…		…
933		933
934	Returns C<$AnyEvent::MODEL>, forcing autodetection of the event model	934	Returns C<$AnyEvent::MODEL>, forcing autodetection of the event model
935	if necessary. You should only call this function right before you would	935	if necessary. You should only call this function right before you would
936	have created an AnyEvent watcher anyway, that is, as late as possible at	936	have created an AnyEvent watcher anyway, that is, as late as possible at
937	runtime, and not e.g. during initialisation of your module.	937	runtime, and not e.g. during initialisation of your module.
		938
		939	The effect of calling this function is as if a watcher had been created
		940	(specifically, actions that happen "when the first watcher is created"
		941	happen when calling detetc as well).
938		942
939	If you need to do some initialisation before AnyEvent watchers are	943	If you need to do some initialisation before AnyEvent watchers are
940	created, use C<post_detect>.	944	created, use C<post_detect>.
941		945
942	=item $guard = AnyEvent::post_detect { BLOCK }	946	=item $guard = AnyEvent::post_detect { BLOCK }
…		…
1045	It should use C<postpone>:	1049	It should use C<postpone>:
1046		1050
1047	AnyEvent::postpone { $cb->(undef) }, return # signal error to callback, later	1051	AnyEvent::postpone { $cb->(undef) }, return # signal error to callback, later
1048	if $some_error_condition;	1052	if $some_error_condition;
1049		1053
		1054	=item AnyEvent::log $level, $msg[, @args]
		1055
		1056	Log the given C<$msg> at the given C<$level>.
		1057
		1058	Loads AnyEvent::Log on first use and calls C<AnyEvent::Log::log> -
		1059	consequently, look at the L<AnyEvent::Log> documentation for details.
		1060
		1061	If you want to sprinkle loads of logging calls around your code, consider
		1062	creating a logger callback with the C<AnyEvent::Log::logger< function.
		1063
1050	=back	1064	=back
1051		1065
1052	=head1 WHAT TO DO IN A MODULE	1066	=head1 WHAT TO DO IN A MODULE
1053		1067
1054	As a module author, you should C<use AnyEvent> and call AnyEvent methods	1068	As a module author, you should C<use AnyEvent> and call AnyEvent methods
…		…
1202		1216
1203	BEGIN { AnyEvent::common_sense }	1217	BEGIN { AnyEvent::common_sense }
1204		1218
1205	use Carp ();	1219	use Carp ();
1206		1220
1207	our $VERSION = '5.34';	1221	our $VERSION = '6.01';
1208	our $MODEL;	1222	our $MODEL;
1209		1223
1210	our $AUTOLOAD;
1211	our @ISA;	1224	our @ISA;
1212		1225
1213	our @REGISTRY;	1226	our @REGISTRY;
1214		1227
1215	our $VERBOSE;	1228	our $VERBOSE;
…		…
1221		1234
1222	delete @ENV{grep /^PERL_ANYEVENT_/, keys %ENV}	1235	delete @ENV{grep /^PERL_ANYEVENT_/, keys %ENV}
1223	if ${^TAINT};	1236	if ${^TAINT};
1224		1237
1225	$VERBOSE = $ENV{PERL_ANYEVENT_VERBOSE}*1;	1238	$VERBOSE = $ENV{PERL_ANYEVENT_VERBOSE}*1;
1226
1227	}	1239	}
1228		1240
1229	our $MAX_SIGNAL_LATENCY = 10;	1241	our $MAX_SIGNAL_LATENCY = 10;
1230		1242
1231	our %PROTOCOL; # (ipv4\|ipv6) => (1\|2), higher numbers are preferred	1243	our %PROTOCOL; # (ipv4\|ipv6) => (1\|2), higher numbers are preferred
…		…
1235	$PROTOCOL{$_} = ++$idx	1247	$PROTOCOL{$_} = ++$idx
1236	for reverse split /\s,\s/,	1248	for reverse split /\s,\s/,
1237	$ENV{PERL_ANYEVENT_PROTOCOLS} \|\| "ipv4,ipv6";	1249	$ENV{PERL_ANYEVENT_PROTOCOLS} \|\| "ipv4,ipv6";
1238	}	1250	}
1239		1251
		1252	our @post_detect;
		1253
		1254	sub post_detect(&) {
		1255	my ($cb) = @_;
		1256
		1257	push @post_detect, $cb;
		1258
		1259	defined wantarray
		1260	? bless \$cb, "AnyEvent::Util::postdetect"
		1261	: ()
		1262	}
		1263
		1264	sub AnyEvent::Util::postdetect::DESTROY {
		1265	@post_detect = grep $_ != ${$_[0]}, @post_detect;
		1266	}
		1267
		1268	our $POSTPONE_W;
		1269	our @POSTPONE;
		1270
		1271	sub _postpone_exec {
		1272	undef $POSTPONE_W;
		1273
		1274	&{ shift @POSTPONE }
		1275	while @POSTPONE;
		1276	}
		1277
		1278	sub postpone(&) {
		1279	push @POSTPONE, shift;
		1280
		1281	$POSTPONE_W \|\|= AE::timer (0, 0, \&_postpone_exec);
		1282
		1283	()
		1284	}
		1285
		1286	sub log($$;@) {
		1287	require AnyEvent::Log;
		1288	# AnyEvent::Log overwrites this function
		1289	goto &log;
		1290	}
		1291
1240	my @models = (	1292	our @models = (
1241	[EV:: => AnyEvent::Impl::EV:: , 1],	1293	[EV:: => AnyEvent::Impl::EV:: , 1],
1242	[AnyEvent::Loop:: => AnyEvent::Impl::Perl:: , 1],	1294	[AnyEvent::Loop:: => AnyEvent::Impl::Perl:: , 1],
1243	# everything below here will not (normally) be autoprobed	1295	# everything below here will not (normally) be autoprobed
1244	# as the pure perl backend should work everywhere	1296	# as the pure perl backend should work everywhere
1245	# and is usually faster	1297	# and is usually faster
…		…
1250	[Tk:: => AnyEvent::Impl::Tk::], # crashes with many handles	1302	[Tk:: => AnyEvent::Impl::Tk::], # crashes with many handles
1251	[Qt:: => AnyEvent::Impl::Qt::], # requires special main program	1303	[Qt:: => AnyEvent::Impl::Qt::], # requires special main program
1252	[POE::Kernel:: => AnyEvent::Impl::POE::], # lasciate ogni speranza	1304	[POE::Kernel:: => AnyEvent::Impl::POE::], # lasciate ogni speranza
1253	[Wx:: => AnyEvent::Impl::POE::],	1305	[Wx:: => AnyEvent::Impl::POE::],
1254	[Prima:: => AnyEvent::Impl::POE::],	1306	[Prima:: => AnyEvent::Impl::POE::],
1255	[IO::Async::Loop:: => AnyEvent::Impl::IOAsync::],	1307	[IO::Async::Loop:: => AnyEvent::Impl::IOAsync::], # a bitch to autodetect
1256	[Cocoa::EventLoop:: => AnyEvent::Impl::Cocoa::],	1308	[Cocoa::EventLoop:: => AnyEvent::Impl::Cocoa::],
1257	[FLTK:: => AnyEvent::Impl::FLTK::],	1309	[FLTK:: => AnyEvent::Impl::FLTK2::],
1258	);	1310	);
1259		1311
1260	our %method = map +($_ => 1),	1312	our @isa_hook;
		1313
		1314	sub _isa_set {
		1315	my @pkg = ("AnyEvent", (map $_->[0], grep defined, @isa_hook), $MODEL);
		1316
		1317	@{"$pkg[$_-1]::ISA"} = $pkg[$_]
		1318	for 1 .. $#pkg;
		1319
		1320	grep $_ && $_->[1], @isa_hook
		1321	and AE::_reset ();
		1322	}
		1323
		1324	# used for hooking AnyEvent::Strict and AnyEvent::Debug::Wrap into the class hierarchy
		1325	sub _isa_hook($$;$) {
		1326	my ($i, $pkg, $reset_ae) = @_;
		1327
		1328	$isa_hook[$i] = $pkg ? [$pkg, $reset_ae] : undef;
		1329
		1330	_isa_set;
		1331	}
		1332
		1333	# all autoloaded methods reserve the complete glob, not just the method slot.
		1334	# due to bugs in perls method cache implementation.
1261	qw(io timer time now now_update signal child idle condvar DESTROY);	1335	our @methods = qw(io timer time now now_update signal child idle condvar);
1262
1263	our @post_detect;
1264
1265	sub post_detect(&) {
1266	my ($cb) = @_;
1267
1268	push @post_detect, $cb;
1269
1270	defined wantarray
1271	? bless \$cb, "AnyEvent::Util::postdetect"
1272	: ()
1273	}
1274
1275	sub AnyEvent::Util::postdetect::DESTROY {
1276	@post_detect = grep $_ != ${$_[0]}, @post_detect;
1277	}
1278		1336
1279	sub detect() {	1337	sub detect() {
		1338	return $MODEL if $MODEL; # some programs keep references to detect
		1339
		1340	local $!; # for good measure
		1341	local $SIG{__DIE__}; # we use eval
		1342
1280	# free some memory	1343	# free some memory
1281	*detect = sub () { $MODEL };	1344	*detect = sub () { $MODEL };
		1345	# undef &func doesn't correctly update the method cache. grmbl.
		1346	# so we delete the whole glob. grmbl.
		1347	# otoh, perl doesn't let me undef an active usb, but it lets me free
		1348	# a glob with an active sub. hrm. i hope it works, but perl is
		1349	# usually buggy in this department. sigh.
		1350	delete @{"AnyEvent::"}{@methods};
		1351	undef @methods;
1282		1352
1283	local $!; # for good measure
1284	local $SIG{__DIE__};
1285
1286	if ($ENV{PERL_ANYEVENT_MODEL} =~ /^([a-zA-Z]+)$/) {	1353	if ($ENV{PERL_ANYEVENT_MODEL} =~ /^([a-zA-Z0-9:]+)$/) {
1287	my $model = "AnyEvent::Impl::$1";	1354	my $model = $1;
		1355	$model = "AnyEvent::Impl::$model" unless $model =~ s/::$//;
1288	if (eval "require $model") {	1356	if (eval "require $model") {
1289	$MODEL = $model;	1357	$MODEL = $model;
1290	warn "AnyEvent: loaded model '$model' (forced by \$ENV{PERL_ANYEVENT_MODEL}), using it.\n" if $VERBOSE >= 2;	1358	AnyEvent::log 7 => "loaded model '$model' (forced by \$ENV{PERL_ANYEVENT_MODEL}), using it."
		1359	if $VERBOSE >= 7;
1291	} else {	1360	} else {
1292	warn "AnyEvent: unable to load model '$model' (from \$ENV{PERL_ANYEVENT_MODEL}):\n$@" if $VERBOSE;	1361	AnyEvent::log warn => "unable to load model '$model' (from \$ENV{PERL_ANYEVENT_MODEL}):\n$@";
1293	}	1362	}
1294	}	1363	}
1295		1364
1296	# check for already loaded models	1365	# check for already loaded models
1297	unless ($MODEL) {	1366	unless ($MODEL) {
1298	for (@REGISTRY, @models) {	1367	for (@REGISTRY, @models) {
1299	my ($package, $model) = @$_;	1368	my ($package, $model) = @$_;
1300	if (${"$package\::VERSION"} > 0) {	1369	if (${"$package\::VERSION"} > 0) {
1301	if (eval "require $model") {	1370	if (eval "require $model") {
1302	$MODEL = $model;	1371	$MODEL = $model;
1303	warn "AnyEvent: autodetected model '$model', using it.\n" if $VERBOSE >= 2;	1372	AnyEvent::log 7 => "autodetected model '$model', using it."
		1373	if $VERBOSE >= 7;
1304	last;	1374	last;
1305	}	1375	}
1306	}	1376	}
1307	}	1377	}
1308		1378
…		…
1315	and eval "require $package"	1385	and eval "require $package"
1316	and ${"$package\::VERSION"} > 0	1386	and ${"$package\::VERSION"} > 0
1317	and eval "require $model"	1387	and eval "require $model"
1318	) {	1388	) {
1319	$MODEL = $model;	1389	$MODEL = $model;
1320	warn "AnyEvent: autoloaded model '$model', using it.\n" if $VERBOSE >= 2;	1390	AnyEvent::log 7 => "autoloaded model '$model', using it."
		1391	if $VERBOSE >= 7;
1321	last;	1392	last;
1322	}	1393	}
1323	}	1394	}
1324		1395
1325	$MODEL	1396	$MODEL
1326	or die "AnyEvent: backend autodetection failed - did you properly install AnyEvent?\n";	1397	or die "AnyEvent: backend autodetection failed - did you properly install AnyEvent?";
1327	}	1398	}
1328	}	1399	}
1329		1400
1330	@models = (); # free probe data	1401	# free memory only needed for probing
		1402	undef @models;
		1403	undef @REGISTRY;
1331		1404
1332	push @{"$MODEL\::ISA"}, "AnyEvent::Base";	1405	push @{"$MODEL\::ISA"}, "AnyEvent::Base";
1333	unshift @ISA, $MODEL;
1334		1406
1335	# now nuke some methods that are overridden by the backend.	1407	# now nuke some methods that are overridden by the backend.
1336	# SUPER is not allowed.	1408	# SUPER usage is not allowed in these.
1337	for (qw(time signal child idle)) {	1409	for (qw(time signal child idle)) {
1338	undef &{"AnyEvent::Base::$_"}	1410	undef &{"AnyEvent::Base::$_"}
1339	if defined &{"$MODEL\::$_"};	1411	if defined &{"$MODEL\::$_"};
1340	}	1412	}
1341		1413
		1414	_isa_set;
		1415
		1416	# we're officially open!
		1417
1342	if ($ENV{PERL_ANYEVENT_STRICT}) {	1418	if ($ENV{PERL_ANYEVENT_STRICT}) {
1343	eval { require AnyEvent::Strict };	1419	require AnyEvent::Strict;
1344	warn "AnyEvent: cannot load AnyEvent::Strict: $@"
1345	if $@ && $VERBOSE;
1346	}	1420	}
1347		1421
		1422	if ($ENV{PERL_ANYEVENT_DEBUG_WRAP}) {
		1423	require AnyEvent::Debug;
		1424	AnyEvent::Debug::wrap ($ENV{PERL_ANYEVENT_DEBUG_WRAP});
		1425	}
		1426
		1427	if (length $ENV{PERL_ANYEVENT_DEBUG_SHELL}) {
		1428	require AnyEvent::Socket;
		1429	require AnyEvent::Debug;
		1430
		1431	my $shell = $ENV{PERL_ANYEVENT_DEBUG_SHELL};
		1432	$shell =~ s/\$\$/$$/g;
		1433
		1434	my ($host, $service) = AnyEvent::Socket::parse_hostport ($shell);
		1435	$AnyEvent::Debug::SHELL = AnyEvent::Debug::shell ($host, $service);
		1436	}
		1437
		1438	# now the anyevent environment is set up as the user told us to, so
		1439	# call the actual user code - post detects
		1440
1348	(shift @post_detect)->() while @post_detect;	1441	(shift @post_detect)->() while @post_detect;
		1442	undef @post_detect;
1349		1443
1350	*post_detect = sub(&) {	1444	*post_detect = sub(&) {
1351	shift->();	1445	shift->();
1352		1446
1353	undef	1447	undef
1354	};	1448	};
1355		1449
1356	$MODEL	1450	$MODEL
1357	}	1451	}
1358		1452
1359	sub AUTOLOAD {	1453	for my $name (@methods) {
1360	(my $func = $AUTOLOAD) =~ s/.*://;	1454	*$name = sub {
1361
1362	$method{$func}
1363	or Carp::croak "$func: not a valid AnyEvent class method";
1364
1365	detect;	1455	detect;
1366		1456	# we use goto because
1367	my $class = shift;	1457	# a) it makes the thunk more transparent
1368	$class->$func (@_);	1458	# b) it allows us to delete the thunk later
1369	}	1459	goto &{ UNIVERSAL::can AnyEvent => "SUPER::$name" }
1370		1460	};
1371	our $POSTPONE_W;
1372	our @POSTPONE;
1373
1374	sub _postpone_exec {
1375	undef $POSTPONE_W;
1376	(pop @POSTPONE)->()
1377	while @POSTPONE;
1378	}
1379
1380	sub postpone(&) {
1381	push @POSTPONE, shift;
1382
1383	$POSTPONE_W \|\|= AE::timer (0, 0, \&_postpone_exec);
1384
1385	()
1386	}	1461	}
1387		1462
1388	# utility function to dup a filehandle. this is used by many backends	1463	# utility function to dup a filehandle. this is used by many backends
1389	# to support binding more than one watcher per filehandle (they usually	1464	# to support binding more than one watcher per filehandle (they usually
1390	# allow only one watcher per fd, so we dup it to get a different one).	1465	# allow only one watcher per fd, so we dup it to get a different one).
…		…
1414		1489
1415	package AE;	1490	package AE;
1416		1491
1417	our $VERSION = $AnyEvent::VERSION;	1492	our $VERSION = $AnyEvent::VERSION;
1418		1493
		1494	sub _reset() {
		1495	eval q{
1419	# fall back to the main API by default - backends and AnyEvent::Base	1496	# fall back to the main API by default - backends and AnyEvent::Base
1420	# implementations can overwrite these.	1497	# implementations can overwrite these.
1421		1498
1422	sub io($$$) {	1499	sub io($$$) {
1423	AnyEvent->io (fh => $_[0], poll => $_[1] ? "w" : "r", cb => $_[2])	1500	AnyEvent->io (fh => $_[0], poll => $_[1] ? "w" : "r", cb => $_[2])
1424	}	1501	}
1425		1502
1426	sub timer($$$) {	1503	sub timer($$$) {
1427	AnyEvent->timer (after => $_[0], interval => $_[1], cb => $_[2])	1504	AnyEvent->timer (after => $_[0], interval => $_[1], cb => $_[2])
1428	}	1505	}
1429		1506
1430	sub signal($$) {	1507	sub signal($$) {
1431	AnyEvent->signal (signal => $_[0], cb => $_[1])	1508	AnyEvent->signal (signal => $_[0], cb => $_[1])
1432	}	1509	}
1433		1510
1434	sub child($$) {	1511	sub child($$) {
1435	AnyEvent->child (pid => $_[0], cb => $_[1])	1512	AnyEvent->child (pid => $_[0], cb => $_[1])
1436	}	1513	}
1437		1514
1438	sub idle($) {	1515	sub idle($) {
1439	AnyEvent->idle (cb => $_[0])	1516	AnyEvent->idle (cb => $_[0]);
1440	}	1517	}
1441		1518
1442	sub cv(;&) {	1519	sub cv(;&) {
1443	AnyEvent->condvar (@_ ? (cb => $_[0]) : ())	1520	AnyEvent->condvar (@_ ? (cb => $_[0]) : ())
1444	}	1521	}
1445		1522
1446	sub now() {	1523	sub now() {
1447	AnyEvent->now	1524	AnyEvent->now
1448	}	1525	}
1449		1526
1450	sub now_update() {	1527	sub now_update() {
1451	AnyEvent->now_update	1528	AnyEvent->now_update
1452	}	1529	}
1453		1530
1454	sub time() {	1531	sub time() {
1455	AnyEvent->time	1532	AnyEvent->time
1456	}	1533	}
1457		1534
1458	*postpone = \&AnyEvent::postpone;	1535	*postpone = \&AnyEvent::postpone;
		1536	*log = \&AnyEvent::log;
		1537	};
		1538	die if $@;
		1539	}
		1540
		1541	BEGIN { _reset }
1459		1542
1460	package AnyEvent::Base;	1543	package AnyEvent::Base;
1461		1544
1462	# default implementations for many methods	1545	# default implementations for many methods
1463		1546
1464	sub time {	1547	sub time {
1465	eval q{ # poor man's autoloading {}	1548	eval q{ # poor man's autoloading {}
1466	# probe for availability of Time::HiRes	1549	# probe for availability of Time::HiRes
1467	if (eval "use Time::HiRes (); Time::HiRes::time (); 1") {	1550	if (eval "use Time::HiRes (); Time::HiRes::time (); 1") {
1468	warn "AnyEvent: using Time::HiRes for sub-second timing accuracy.\n" if $VERBOSE >= 8;	1551	AnyEvent::log 8 => "AnyEvent: using Time::HiRes for sub-second timing accuracy."
		1552	if $AnyEvent::VERBOSE >= 8;
		1553	*time = sub { Time::HiRes::time () };
1469	*AE::time = \&Time::HiRes::time;	1554	*AE::time = \& Time::HiRes::time ;
1470	# if (eval "use POSIX (); (POSIX::times())...	1555	# if (eval "use POSIX (); (POSIX::times())...
1471	} else {	1556	} else {
1472	warn "AnyEvent: using built-in time(), WARNING, no sub-second resolution!\n" if $VERBOSE;	1557	AnyEvent::log critical => "using built-in time(), WARNING, no sub-second resolution!";
		1558	*time = sub { CORE::time };
1473	*AE::time = sub (){ time }; # epic fail	1559	*AE::time = sub (){ CORE::time };
1474	}	1560	}
1475		1561
1476	*time = sub { AE::time }; # different prototypes	1562	*now = \&time;
1477	};	1563	};
1478	die if $@;	1564	die if $@;
1479		1565
1480	&time	1566	&time
1481	}	1567	}
1482		1568
1483	*now = \&time;	1569	*now = \&time;
1484
1485	sub now_update { }	1570	sub now_update { }
1486		1571
1487	sub _poll {	1572	sub _poll {
1488	Carp::croak "$AnyEvent::MODEL does not support blocking waits. Caught";	1573	Carp::croak "$AnyEvent::MODEL does not support blocking waits. Caught";
1489	}	1574	}
…		…
1575		1660
1576	sub signal {	1661	sub signal {
1577	eval q{ # poor man's autoloading {}	1662	eval q{ # poor man's autoloading {}
1578	# probe for availability of Async::Interrupt	1663	# probe for availability of Async::Interrupt
1579	if (_have_async_interrupt) {	1664	if (_have_async_interrupt) {
1580	warn "AnyEvent: using Async::Interrupt for race-free signal handling.\n" if $VERBOSE >= 8;	1665	AnyEvent::log 8 => "using Async::Interrupt for race-free signal handling."
		1666	if $AnyEvent::VERBOSE >= 8;
1581		1667
1582	$SIGPIPE_R = new Async::Interrupt::EventPipe;	1668	$SIGPIPE_R = new Async::Interrupt::EventPipe;
1583	$SIG_IO = AE::io $SIGPIPE_R->fileno, 0, \&_signal_exec;	1669	$SIG_IO = AE::io $SIGPIPE_R->fileno, 0, \&_signal_exec;
1584		1670
1585	} else {	1671	} else {
1586	warn "AnyEvent: using emulated perl signal handling with latency timer.\n" if $VERBOSE >= 8;	1672	AnyEvent::log 8 => "using emulated perl signal handling with latency timer."
		1673	if $AnyEvent::VERBOSE >= 8;
1587		1674
1588	if (AnyEvent::WIN32) {	1675	if (AnyEvent::WIN32) {
1589	require AnyEvent::Util;	1676	require AnyEvent::Util;
1590		1677
1591	($SIGPIPE_R, $SIGPIPE_W) = AnyEvent::Util::portable_pipe ();	1678	($SIGPIPE_R, $SIGPIPE_W) = AnyEvent::Util::portable_pipe ();
…		…
1667	: sysread $SIGPIPE_R, (my $dummy), 9;	1754	: sysread $SIGPIPE_R, (my $dummy), 9;
1668		1755
1669	while (%SIG_EV) {	1756	while (%SIG_EV) {
1670	for (keys %SIG_EV) {	1757	for (keys %SIG_EV) {
1671	delete $SIG_EV{$_};	1758	delete $SIG_EV{$_};
1672	$_->() for values %{ $SIG_CB{$_} \|\| {} };	1759	&$_ for values %{ $SIG_CB{$_} \|\| {} };
1673	}	1760	}
1674	}	1761	}
1675	};	1762	};
1676	};	1763	};
1677	die if $@;	1764	die if $@;
…		…
1744		1831
1745	my ($cb, $w, $rcb) = $arg{cb};	1832	my ($cb, $w, $rcb) = $arg{cb};
1746		1833
1747	$rcb = sub {	1834	$rcb = sub {
1748	if ($cb) {	1835	if ($cb) {
1749	$w = _time;	1836	$w = AE::time;
1750	&$cb;	1837	&$cb;
1751	$w = _time - $w;	1838	$w = AE::time - $w;
1752		1839
1753	# never use more then 50% of the time for the idle watcher,	1840	# never use more then 50% of the time for the idle watcher,
1754	# within some limits	1841	# within some limits
1755	$w = 0.0001 if $w < 0.0001;	1842	$w = 0.0001 if $w < 0.0001;
1756	$w = 5 if $w > 5;	1843	$w = 5 if $w > 5;
…		…
1900		1987
1901	By default, AnyEvent will be completely silent except in fatal	1988	By default, AnyEvent will be completely silent except in fatal
1902	conditions. You can set this environment variable to make AnyEvent more	1989	conditions. You can set this environment variable to make AnyEvent more
1903	talkative.	1990	talkative.
1904		1991
1905	When set to C<1> or higher, causes AnyEvent to warn about unexpected	1992	When set to C<5> or higher, causes AnyEvent to warn about unexpected
1906	conditions, such as not being able to load the event model specified by	1993	conditions, such as not being able to load the event model specified by
1907	C<PERL_ANYEVENT_MODEL>.	1994	C<PERL_ANYEVENT_MODEL>.
1908		1995
1909	When set to C<2> or higher, cause AnyEvent to report to STDERR which event	1996	When set to C<7> or higher, cause AnyEvent to report to STDERR which event
1910	model it chooses.	1997	model it chooses.
1911		1998
1912	When set to C<8> or higher, then AnyEvent will report extra information on	1999	When set to C<8> or higher, then AnyEvent will report extra information on
1913	which optional modules it loads and how it implements certain features.	2000	which optional modules it loads and how it implements certain features.
1914		2001
…		…
1925	Unlike C<use strict> (or its modern cousin, C<< use L<common::sense>	2012	Unlike C<use strict> (or its modern cousin, C<< use L<common::sense>
1926	>>, it is definitely recommended to keep it off in production. Keeping	2013	>>, it is definitely recommended to keep it off in production. Keeping
1927	C<PERL_ANYEVENT_STRICT=1> in your environment while developing programs	2014	C<PERL_ANYEVENT_STRICT=1> in your environment while developing programs
1928	can be very useful, however.	2015	can be very useful, however.
1929		2016
		2017	=item C<PERL_ANYEVENT_DEBUG_SHELL>
		2018
		2019	If this env variable is set, then its contents will be interpreted by
		2020	C<AnyEvent::Socket::parse_hostport> (after replacing every occurance of
		2021	C<$$> by the process pid) and an C<AnyEvent::Debug::shell> is bound on
		2022	that port. The shell object is saved in C<$AnyEvent::Debug::SHELL>.
		2023
		2024	This takes place when the first watcher is created.
		2025
		2026	For example, to bind a debug shell on a unix domain socket in
		2027	F<< /tmp/debug<pid>.sock >>, you could use this:
		2028
		2029	PERL_ANYEVENT_DEBUG_SHELL=/tmp/debug\$\$.sock perlprog
		2030
		2031	Note that creating sockets in F</tmp> is very unsafe on multiuser
		2032	systems.
		2033
		2034	=item C<PERL_ANYEVENT_DEBUG_WRAP>
		2035
		2036	Can be set to C<0>, C<1> or C<2> and enables wrapping of all watchers for
		2037	debugging purposes. See C<AnyEvent::Debug::wrap> for details.
		2038
1930	=item C<PERL_ANYEVENT_MODEL>	2039	=item C<PERL_ANYEVENT_MODEL>
1931		2040
1932	This can be used to specify the event model to be used by AnyEvent, before	2041	This can be used to specify the event model to be used by AnyEvent, before
1933	auto detection and -probing kicks in. It must be a string consisting	2042	auto detection and -probing kicks in.
1934	entirely of ASCII letters. The string C<AnyEvent::Impl::> gets prepended	2043
		2044	It normally is a string consisting entirely of ASCII letters (e.g. C<EV>
		2045	or C<IOAsync>). The string C<AnyEvent::Impl::> gets prepended and the
1935	and the resulting module name is loaded and if the load was successful,	2046	resulting module name is loaded and - if the load was successful - used as
1936	used as event model. If it fails to load AnyEvent will proceed with	2047	event model backend. If it fails to load then AnyEvent will proceed with
1937	auto detection and -probing.	2048	auto detection and -probing.
1938		2049
1939	This functionality might change in future versions.	2050	If the string ends with C<::> instead (e.g. C<AnyEvent::Impl::EV::>) then
		2051	nothing gets prepended and the module name is used as-is (hint: C<::> at
		2052	the end of a string designates a module name and quotes it appropriately).
1940		2053
1941	For example, to force the pure perl model (L<AnyEvent::Loop::Perl>) you	2054	For example, to force the pure perl model (L<AnyEvent::Loop::Perl>) you
1942	could start your program like this:	2055	could start your program like this:
1943		2056
1944	PERL_ANYEVENT_MODEL=Perl perl ...	2057	PERL_ANYEVENT_MODEL=Perl perl ...
…		…
2336	(even when used without AnyEvent), but most event loops have acceptable	2449	(even when used without AnyEvent), but most event loops have acceptable
2337	performance with or without AnyEvent.	2450	performance with or without AnyEvent.
2338		2451
2339	=item * The overhead AnyEvent adds is usually much smaller than the overhead of	2452	=item * The overhead AnyEvent adds is usually much smaller than the overhead of
2340	the actual event loop, only with extremely fast event loops such as EV	2453	the actual event loop, only with extremely fast event loops such as EV
2341	adds AnyEvent significant overhead.	2454	does AnyEvent add significant overhead.
2342		2455
2343	=item * You should avoid POE like the plague if you want performance or	2456	=item * You should avoid POE like the plague if you want performance or
2344	reasonable memory usage.	2457	reasonable memory usage.
2345		2458
2346	=back	2459	=back
…		…
2721		2834
2722	Tutorial/Introduction: L<AnyEvent::Intro>.	2835	Tutorial/Introduction: L<AnyEvent::Intro>.
2723		2836
2724	FAQ: L<AnyEvent::FAQ>.	2837	FAQ: L<AnyEvent::FAQ>.
2725		2838
2726	Utility functions: L<AnyEvent::Util>.	2839	Utility functions: L<AnyEvent::Util> (misc. grab-bag), L<AnyEvent::Log>
		2840	(simply logging).
2727		2841
		2842	Development/Debugging: L<AnyEvent::Strict> (stricter checking),
		2843	L<AnyEvent::Debug> (interactive shell, watcher tracing).
		2844
2728	Event modules: L<AnyEvent::Loop>, L<EV>, L<EV::Glib>, L<Glib::EV>,	2845	Supported event modules: L<AnyEvent::Loop>, L<EV>, L<EV::Glib>,
2729	L<Event>, L<Glib::Event>, L<Glib>, L<Tk>, L<Event::Lib>, L<Qt>, L<POE>.	2846	L<Glib::EV>, L<Event>, L<Glib::Event>, L<Glib>, L<Tk>, L<Event::Lib>,
		2847	L<Qt>, L<POE>, L<FLTK>.
2730		2848
2731	Implementations: L<AnyEvent::Impl::EV>, L<AnyEvent::Impl::Event>,	2849	Implementations: L<AnyEvent::Impl::EV>, L<AnyEvent::Impl::Event>,
2732	L<AnyEvent::Impl::Glib>, L<AnyEvent::Impl::Tk>, L<AnyEvent::Impl::Perl>,	2850	L<AnyEvent::Impl::Glib>, L<AnyEvent::Impl::Tk>, L<AnyEvent::Impl::Perl>,
2733	L<AnyEvent::Impl::EventLib>, L<AnyEvent::Impl::Qt>,	2851	L<AnyEvent::Impl::EventLib>, L<AnyEvent::Impl::Qt>,
2734	L<AnyEvent::Impl::POE>, L<AnyEvent::Impl::IOAsync>, L<Anyevent::Impl::Irssi>.	2852	L<AnyEvent::Impl::POE>, L<AnyEvent::Impl::IOAsync>, L<Anyevent::Impl::Irssi>,
		2853	L<AnyEvent::Impl::FLTK>.
2735		2854
2736	Non-blocking file handles, sockets, TCP clients and	2855	Non-blocking handles, pipes, stream sockets, TCP clients and
2737	servers: L<AnyEvent::Handle>, L<AnyEvent::Socket>, L<AnyEvent::TLS>.	2856	servers: L<AnyEvent::Handle>, L<AnyEvent::Socket>, L<AnyEvent::TLS>.
2738		2857
2739	Asynchronous DNS: L<AnyEvent::DNS>.	2858	Asynchronous DNS: L<AnyEvent::DNS>.
2740		2859
2741	Thread support: L<Coro>, L<Coro::AnyEvent>, L<Coro::EV>, L<Coro::Event>.	2860	Thread support: L<Coro>, L<Coro::AnyEvent>, L<Coro::EV>, L<Coro::Event>.

Diff Legend

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

Comparing AnyEvent/lib/AnyEvent.pm (file contents): Revision 1.354 by root, Thu Aug 11 21:26:39 2011 UTC vs. Revision 1.367 by root, Wed Aug 17 02:14:17 2011 UTC

Diff Legend

Comparing AnyEvent/lib/AnyEvent.pm (file contents):
Revision 1.354 by root, Thu Aug 11 21:26:39 2011 UTC vs.
Revision 1.367 by root, Wed Aug 17 02:14:17 2011 UTC