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.199 by root, Fri Mar 27 10:49:50 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::
… …
1070 1087
1071sub signal { 1088sub signal {
1072 my (undef, %arg) = @_; 1089 my (undef, %arg) = @_;
1073 1090
1074 unless ($SIGPIPE_R) { 1091 unless ($SIGPIPE_R) {
1092 require Fcntl;
1093
1075 if (AnyEvent::WIN32) { 1094 if (AnyEvent::WIN32) {
1095 require AnyEvent::Util;
1096
1076 ($SIGPIPE_R, $SIGPIPE_W) = AnyEvent::Util::portable_pipe (); 1097 ($SIGPIPE_R, $SIGPIPE_W) = AnyEvent::Util::portable_pipe ();
1077 AnyEvent::Util::fh_nonblocking ($SIGPIPE_R) if $SIGPIPE_R; 1098 AnyEvent::Util::fh_nonblocking ($SIGPIPE_R) if $SIGPIPE_R;
1078 AnyEvent::Util::fh_nonblocking ($SIGPIPE_W) if $SIGPIPE_W; # just in case 1099 AnyEvent::Util::fh_nonblocking ($SIGPIPE_W) if $SIGPIPE_W; # just in case
1079 } else { 1100 } else {
1080 pipe $SIGPIPE_R, $SIGPIPE_W; 1101 pipe $SIGPIPE_R, $SIGPIPE_W;
1081 require Fcntl;
1082 fcntl $SIGPIPE_R, &Fcntl::F_SETFL, &Fcntl::O_NONBLOCK if $SIGPIPE_R; 1102 fcntl $SIGPIPE_R, &Fcntl::F_SETFL, &Fcntl::O_NONBLOCK if $SIGPIPE_R;
1083 fcntl $SIGPIPE_W, &Fcntl::F_SETFL, &Fcntl::O_NONBLOCK if $SIGPIPE_W; # just in case 1103 fcntl $SIGPIPE_W, &Fcntl::F_SETFL, &Fcntl::O_NONBLOCK if $SIGPIPE_W; # just in case
1084 } 1104 }
1085 1105
1086 $SIGPIPE_R 1106 $SIGPIPE_R
1087 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";
1088 1108
1109 # not strictly required, as $^F is normally 2, but let's make sure...
1110 fcntl $SIGPIPE_R, &Fcntl::F_SETFD, &Fcntl::FD_CLOEXEC;
1111 fcntl $SIGPIPE_W, &Fcntl::F_SETFD, &Fcntl::FD_CLOEXEC;
1112
1089 $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);
1090 } 1114 }
1091 1115
1092 my $signal = uc $arg{signal} 1116 my $signal = uc $arg{signal}
1093 or Carp::croak "required option 'signal' is missing"; 1117 or Carp::croak "required option 'signal' is missing";
1094 1118
1095 $SIG_CB{$signal}{$arg{cb}} = $arg{cb}; 1119 $SIG_CB{$signal}{$arg{cb}} = $arg{cb};
1096 $SIG{$signal} ||= sub { 1120 $SIG{$signal} ||= sub {
1121 local $!;
1097 syswrite $SIGPIPE_W, "\x00", 1 unless %SIG_EV; 1122 syswrite $SIGPIPE_W, "\x00", 1 unless %SIG_EV;
1098 undef $SIG_EV{$signal}; 1123 undef $SIG_EV{$signal};
1099 }; 1124 };
1100 1125
1101 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