ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/AnyEvent/lib/AnyEvent.pm
(Generate patch)

Comparing AnyEvent/lib/AnyEvent.pm (file contents):
Revision 1.269 by root, Fri Jul 31 20:16:29 2009 UTC vs.
Revision 1.274 by root, Sun Aug 9 00:20:35 2009 UTC

1115 1115
1116BEGIN { AnyEvent::common_sense } 1116BEGIN { AnyEvent::common_sense }
1117 1117
1118use Carp (); 1118use Carp ();
1119 1119
1120our $VERSION = 4.9; 1120our $VERSION = 4.92;
1121our $MODEL; 1121our $MODEL;
1122 1122
1123our $AUTOLOAD; 1123our $AUTOLOAD;
1124our @ISA; 1124our @ISA;
1125 1125
1287 # we assume CLOEXEC is already set by perl in all important cases 1287 # we assume CLOEXEC is already set by perl in all important cases
1288 1288
1289 ($fh2, $rw) 1289 ($fh2, $rw)
1290} 1290}
1291 1291
1292#############################################################################
1293# "new" API, currently only emulation of it
1294#############################################################################
1295
1296package AE;
1297
1298sub io($$$) {
1299 AnyEvent->io (fh => $_[0], poll => $_[1] ? "w" : "r", cb => $_[2])
1300}
1301
1302sub timer($$$) {
1303 AnyEvent->timer (after => $_[0], interval => $_[1], cb => $_[2]);
1304}
1305
1306sub signal($$) {
1307 AnyEvent->signal (signal => $_[0], cb => $_[1]);
1308}
1309
1310sub child($$) {
1311 AnyEvent->child (pid => $_[0], cb => $_[1]);
1312}
1313
1314sub idle($) {
1315 AnyEvent->idle (cb => $_[0]);
1316}
1317
1318sub cv(;&) {
1319 AnyEvent->condvar (@_ ? (cb => $_[0]) : ())
1320}
1321
1322sub now() {
1323 AnyEvent->now
1324}
1325
1326sub now_update() {
1327 AnyEvent->now_update
1328}
1329
1330sub time() {
1331 AnyEvent->time
1332}
1333
1292package AnyEvent::Base; 1334package AnyEvent::Base;
1293 1335
1294# default implementations for many methods 1336# default implementations for many methods
1295 1337
1296sub _time { 1338sub _time {
1348 1390
1349# install a dummy wakeup watcher to reduce signal catching latency 1391# install a dummy wakeup watcher to reduce signal catching latency
1350sub _sig_add() { 1392sub _sig_add() {
1351 unless ($SIG_COUNT++) { 1393 unless ($SIG_COUNT++) {
1352 # try to align timer on a full-second boundary, if possible 1394 # try to align timer on a full-second boundary, if possible
1353 my $NOW = AnyEvent->now; 1395 my $NOW = AE::now;
1354 1396
1355 $SIG_TW = AnyEvent->timer ( 1397 $SIG_TW = AE::timer
1356 after => $MAX_SIGNAL_LATENCY - ($NOW - int $NOW), 1398 $MAX_SIGNAL_LATENCY - ($NOW - int $NOW),
1357 interval => $MAX_SIGNAL_LATENCY, 1399 $MAX_SIGNAL_LATENCY,
1358 cb => sub { }, # just for the PERL_ASYNC_CHECK 1400 sub { } # just for the PERL_ASYNC_CHECK
1359 ); 1401 ;
1360 } 1402 }
1361} 1403}
1362 1404
1363sub _sig_del { 1405sub _sig_del {
1364 undef $SIG_TW 1406 undef $SIG_TW
1401 # probe for availability of Async::Interrupt 1443 # probe for availability of Async::Interrupt
1402 if (_have_async_interrupt) { 1444 if (_have_async_interrupt) {
1403 warn "AnyEvent: using Async::Interrupt for race-free signal handling.\n" if $VERBOSE >= 8; 1445 warn "AnyEvent: using Async::Interrupt for race-free signal handling.\n" if $VERBOSE >= 8;
1404 1446
1405 $SIGPIPE_R = new Async::Interrupt::EventPipe; 1447 $SIGPIPE_R = new Async::Interrupt::EventPipe;
1406 $SIG_IO = AnyEvent->io (fh => $SIGPIPE_R->fileno, poll => "r", cb => \&_signal_exec); 1448 $SIG_IO = AE::io $SIGPIPE_R->fileno, 0, \&_signal_exec;
1407 1449
1408 } else { 1450 } else {
1409 warn "AnyEvent: using emulated perl signal handling with latency timer.\n" if $VERBOSE >= 8; 1451 warn "AnyEvent: using emulated perl signal handling with latency timer.\n" if $VERBOSE >= 8;
1410 1452
1411 require Fcntl; 1453 require Fcntl;
1427 } 1469 }
1428 1470
1429 $SIGPIPE_R 1471 $SIGPIPE_R
1430 or Carp::croak "AnyEvent: unable to create a signal reporting pipe: $!\n"; 1472 or Carp::croak "AnyEvent: unable to create a signal reporting pipe: $!\n";
1431 1473
1432 $SIG_IO = AnyEvent->io (fh => $SIGPIPE_R, poll => "r", cb => \&_signal_exec); 1474 $SIG_IO = AE::io $SIGPIPE_R, 0, \&_signal_exec;
1433 } 1475 }
1434 1476
1435 *signal = sub { 1477 *signal = sub {
1436 my (undef, %arg) = @_; 1478 my (undef, %arg) = @_;
1437 1479
1526 $WNOHANG ||= $^O =~ /^(?:openbsd|netbsd|linux|freebsd|cygwin|MSWin32)$/ 1568 $WNOHANG ||= $^O =~ /^(?:openbsd|netbsd|linux|freebsd|cygwin|MSWin32)$/
1527 ? 1 1569 ? 1
1528 : eval { local $SIG{__DIE__}; require POSIX; &POSIX::WNOHANG } || 1; 1570 : eval { local $SIG{__DIE__}; require POSIX; &POSIX::WNOHANG } || 1;
1529 1571
1530 unless ($CHLD_W) { 1572 unless ($CHLD_W) {
1531 $CHLD_W = AnyEvent->signal (signal => 'CHLD', cb => \&_sigchld); 1573 $CHLD_W = AE::signal CHLD => \&_sigchld;
1532 # child could be a zombie already, so make at least one round 1574 # child could be a zombie already, so make at least one round
1533 &_sigchld; 1575 &_sigchld;
1534 } 1576 }
1535 1577
1536 bless [$pid, $arg{cb}], "AnyEvent::Base::child" 1578 bless [$pid, $arg{cb}], "AnyEvent::Base::child"
1562 # never use more then 50% of the time for the idle watcher, 1604 # never use more then 50% of the time for the idle watcher,
1563 # within some limits 1605 # within some limits
1564 $w = 0.0001 if $w < 0.0001; 1606 $w = 0.0001 if $w < 0.0001;
1565 $w = 5 if $w > 5; 1607 $w = 5 if $w > 5;
1566 1608
1567 $w = AnyEvent->timer (after => $w, cb => $rcb); 1609 $w = AE::timer $w, 0, $rcb;
1568 } else { 1610 } else {
1569 # clean up... 1611 # clean up...
1570 undef $w; 1612 undef $w;
1571 undef $rcb; 1613 undef $rcb;
1572 } 1614 }
1573 }; 1615 };
1574 1616
1575 $w = AnyEvent->timer (after => 0.05, cb => $rcb); 1617 $w = AE::timer 0.05, 0, $rcb;
1576 1618
1577 bless \\$cb, "AnyEvent::Base::idle" 1619 bless \\$cb, "AnyEvent::Base::idle"
1578} 1620}
1579 1621
1580sub AnyEvent::Base::idle::DESTROY { 1622sub AnyEvent::Base::idle::DESTROY {
1640 1682
1641 @_ 1683 @_
1642 and $cv->{_ae_cb} = shift 1684 and $cv->{_ae_cb} = shift
1643 and $cv->{_ae_sent} 1685 and $cv->{_ae_sent}
1644 and (delete $cv->{_ae_cb})->($cv); 1686 and (delete $cv->{_ae_cb})->($cv);
1687
1645 $cv->{_ae_cb} 1688 $cv->{_ae_cb}
1646} 1689}
1647 1690
1648sub begin { 1691sub begin {
1649 ++$_[0]{_ae_counter}; 1692 ++$_[0]{_ae_counter};
1656} 1699}
1657 1700
1658# undocumented/compatibility with pre-3.4 1701# undocumented/compatibility with pre-3.4
1659*broadcast = \&send; 1702*broadcast = \&send;
1660*wait = \&_wait; 1703*wait = \&_wait;
1661
1662#############################################################################
1663# "new" API, currently only emulation of it
1664#############################################################################
1665
1666package AE;
1667
1668sub io($$$) {
1669 AnyEvent->io (fh => $_[0], poll => $_[1] ? "w" : "r", cb => $_[2])
1670}
1671
1672sub timer($$$) {
1673 AnyEvent->timer (after => $_[0], interval => $_[1], cb => $_[2]);
1674}
1675
1676sub signal($$) {
1677 AnyEvent->signal (signal => $_[0], cb => $_[1]);
1678}
1679
1680sub child($$) {
1681 AnyEvent->child (pid => $_[0], cb => $_[1]);
1682}
1683
1684sub idle($) {
1685 AnyEvent->idle (cb => $_[0]);
1686}
1687
1688sub cv() {
1689 AnyEvent->condvar
1690}
1691
1692sub now() {
1693 AnyEvent->now
1694}
1695
1696sub now_update() {
1697 AnyEvent->now_update
1698}
1699
1700sub time() {
1701 AnyEvent->time
1702}
1703 1704
1704=head1 ERROR AND EXCEPTION HANDLING 1705=head1 ERROR AND EXCEPTION HANDLING
1705 1706
1706In general, AnyEvent does not do any error handling - it relies on the 1707In general, AnyEvent does not do any error handling - it relies on the
1707caller to do that if required. The L<AnyEvent::Strict> module (see also 1708caller to do that if required. The L<AnyEvent::Strict> module (see also

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines