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.200 by root, Wed Apr 1 14:02:27 2009 UTC vs.
Revision 1.205 by root, Sun Apr 19 12:09:46 2009 UTC

… …
319 319
320In either case, if you care (and in most cases, you don't), then you 320In either case, if you care (and in most cases, you don't), then you
321can get whatever behaviour you want with any event loop, by taking the 321can get whatever behaviour you want with any event loop, by taking the
322difference between C<< AnyEvent->time >> and C<< AnyEvent->now >> into 322difference between C<< AnyEvent->time >> and C<< AnyEvent->now >> into
323account. 323account.
324
325=item AnyEvent->now_update
326
327Some event loops (such as L<EV> or L<AnyEvent::Impl::Perl>) cache
328the current time for each loop iteration (see the discussion of L<<
329AnyEvent->now >>, above).
330
331When a callback runs for a long time (or when the process sleeps), then
332this "current" time will differ substantially from the real time, which
333might affect timers and time-outs.
334
335When this is the case, you can call this method, which will update the
336event loop's idea of "current time".
337
338Note that updating the time I<might> cause some events to be handled.
324 339
325=back 340=back
326 341
327=head2 SIGNAL WATCHERS 342=head2 SIGNAL WATCHERS
328 343
… …
873no warnings; 888no warnings;
874use strict qw(vars subs); 889use strict qw(vars subs);
875 890
876use Carp; 891use Carp;
877 892
878our $VERSION = 4.35; 893our $VERSION = 4.351;
879our $MODEL; 894our $MODEL;
880 895
881our $AUTOLOAD; 896our $AUTOLOAD;
882our @ISA; 897our @ISA;
883 898
… …
915 [POE::Kernel:: => AnyEvent::Impl::POE::], # lasciate ogni speranza 930 [POE::Kernel:: => AnyEvent::Impl::POE::], # lasciate ogni speranza
916 [Wx:: => AnyEvent::Impl::POE::], 931 [Wx:: => AnyEvent::Impl::POE::],
917 [Prima:: => AnyEvent::Impl::POE::], 932 [Prima:: => AnyEvent::Impl::POE::],
918); 933);
919 934
920our %method = map +($_ => 1), qw(io timer time now signal child condvar one_event DESTROY); 935our %method = map +($_ => 1),
936 qw(io timer time now now_update signal child condvar one_event DESTROY);
921 937
922our @post_detect; 938our @post_detect;
923 939
924sub post_detect(&) { 940sub post_detect(&) {
925 my ($cb) = @_; 941 my ($cb) = @_;
… …
982 last; 998 last;
983 } 999 }
984 } 1000 }
985 1001
986 $MODEL 1002 $MODEL
987 or die "No event module selected for AnyEvent and autodetect failed. Install any one of these modules: EV, Event or Glib."; 1003 or die "No event module selected for AnyEvent and autodetect failed. Install any one of these modules: EV, Event or Glib.\n";
988 } 1004 }
989 } 1005 }
990 1006
991 push @{"$MODEL\::ISA"}, "AnyEvent::Base"; 1007 push @{"$MODEL\::ISA"}, "AnyEvent::Base";
992 1008
… …
1022 my ($rw, $mode) = $poll eq "r" ? ($r, "<") 1038 my ($rw, $mode) = $poll eq "r" ? ($r, "<")
1023 : $poll eq "w" ? ($w, ">") 1039 : $poll eq "w" ? ($w, ">")
1024 : Carp::croak "AnyEvent->io requires poll set to either 'r' or 'w'"; 1040 : Carp::croak "AnyEvent->io requires poll set to either 'r' or 'w'";
1025 1041
1026 open my $fh2, "$mode&" . fileno $fh 1042 open my $fh2, "$mode&" . fileno $fh
1027 or die "cannot dup() filehandle: $!"; 1043 or die "cannot dup() filehandle: $!,";
1028 1044
1029 # we assume CLOEXEC is already set by perl in all important cases 1045 # we assume CLOEXEC is already set by perl in all important cases
1030 1046
1031 ($fh2, $rw) 1047 ($fh2, $rw)
1032} 1048}
1033 1049
1034package AnyEvent::Base; 1050package AnyEvent::Base;
1035 1051
1036# default implementation for now and time 1052# default implementations for many methods
1037 1053
1038BEGIN { 1054BEGIN {
1039 if (eval "use Time::HiRes (); time (); 1") { 1055 if (eval "use Time::HiRes (); time (); 1") {
1040 *_time = \&Time::HiRes::time; 1056 *_time = \&Time::HiRes::time;
1041 # if (eval "use POSIX (); (POSIX::times())... 1057 # if (eval "use POSIX (); (POSIX::times())...
… …
1044 } 1060 }
1045} 1061}
1046 1062
1047sub time { _time } 1063sub time { _time }
1048sub now { _time } 1064sub now { _time }
1065sub now_update { }
1049 1066
1050# default implementation for ->condvar 1067# default implementation for ->condvar
1051 1068
1052sub condvar { 1069sub condvar {
1053 bless { @_ == 3 ? (_ae_cb => $_[2]) : () }, AnyEvent::CondVar:: 1070 bless { @_ == 3 ? (_ae_cb => $_[2]) : () }, AnyEvent::CondVar::
… …
1087 } 1104 }
1088 1105
1089 $SIGPIPE_R 1106 $SIGPIPE_R
1090 or Carp::croak "AnyEvent: unable to create a signal reporting pipe: $!\n"; 1107 or Carp::croak "AnyEvent: unable to create a signal reporting pipe: $!\n";
1091 1108
1109 # not strictly required, as $^F is normally 2, but let's make sure...
1092 fcntl $SIGPIPE_R, &Fcntl::F_SETFD, &Fcntl::FD_CLOEXEC; 1110 fcntl $SIGPIPE_R, &Fcntl::F_SETFD, &Fcntl::FD_CLOEXEC;
1093 fcntl $SIGPIPE_W, &Fcntl::F_SETFD, &Fcntl::FD_CLOEXEC; 1111 fcntl $SIGPIPE_W, &Fcntl::F_SETFD, &Fcntl::FD_CLOEXEC;
1094 1112
1095 $SIG_IO = AnyEvent->io (fh => $SIGPIPE_R, poll => "r", cb => \&_signal_exec); 1113 $SIG_IO = AnyEvent->io (fh => $SIGPIPE_R, poll => "r", cb => \&_signal_exec);
1096 } 1114 }
… …
1098 my $signal = uc $arg{signal} 1116 my $signal = uc $arg{signal}
1099 or Carp::croak "required option 'signal' is missing"; 1117 or Carp::croak "required option 'signal' is missing";
1100 1118
1101 $SIG_CB{$signal}{$arg{cb}} = $arg{cb}; 1119 $SIG_CB{$signal}{$arg{cb}} = $arg{cb};
1102 $SIG{$signal} ||= sub { 1120 $SIG{$signal} ||= sub {
1121 local $!;
1103 syswrite $SIGPIPE_W, "\x00", 1 unless %SIG_EV; 1122 syswrite $SIGPIPE_W, "\x00", 1 unless %SIG_EV;
1104 undef $SIG_EV{$signal}; 1123 undef $SIG_EV{$signal};
1105 }; 1124 };
1106 1125
1107 bless [$signal, $arg{cb}], "AnyEvent::Base::Signal" 1126 bless [$signal, $arg{cb}], "AnyEvent::Base::Signal"

Diff Legend

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