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

Comparing Coro/Event/Event.pm (file contents):
Revision 1.5 by root, Sat Aug 18 02:58:38 2001 UTC vs.
Revision 1.13 by root, Sat Mar 22 18:50:32 2003 UTC

… …
16 print "data> "; 16 print "data> ";
17 my $ev = $w->next; my $data = <STDIN>; 17 my $ev = $w->next; my $data = <STDIN>;
18 } 18 }
19 } 19 }
20 20
21 &loop; 21 loop;
22 22
23=head1 DESCRIPTION 23=head1 DESCRIPTION
24 24
25This module enables you to create programs using the powerful Event model 25This module enables you to create programs using the powerful Event model
26(and module), while retaining the linear style known from simple or 26(and module), while retaining the linear style known from simple or
… …
30(I<flavour>) (see L<Event>). The only difference between these and the 30(I<flavour>) (see L<Event>). The only difference between these and the
31watcher constructors from Event is that you do not specify a callback 31watcher constructors from Event is that you do not specify a callback
32function - it will be managed by this module. 32function - it will be managed by this module.
33 33
34Your application should just create all necessary coroutines and then call 34Your application should just create all necessary coroutines and then call
35Coro::Event->main. 35Coro::Event::loop.
36 36
37=over 4 37=over 4
38 38
39=cut 39=cut
40 40
41package Coro::Event; 41package Coro::Event;
42 42
43no warnings; 43no warnings qw(uninitialized);
44 44
45use Carp; 45use Carp;
46 46
47use Coro; 47use Coro;
48use Event qw(unloop); # we are re-exporting this, cooool! 48use Event qw(loop unloop); # we are re-exporting this, cooool!
49 49
50use base 'Exporter'; 50use base 'Exporter';
51 51
52@EXPORT = qw(loop unloop sweep reschedule); 52@EXPORT = qw(loop unloop sweep reschedule);
53 53
54BEGIN { 54BEGIN {
55 $VERSION = 0.45; 55 $VERSION = 0.6;
56 56
57 local $^W = 0; # avoid redefine warning for Coro::ready;
57 require XSLoader; 58 require XSLoader;
58 XSLoader::load Coro::Event, $VERSION; 59 XSLoader::load Coro::Event, $VERSION;
59} 60}
60 61
61=item $w = Coro::Event->flavour(args...) 62=item $w = Coro::Event->flavour(args...)
… …
91 @{"${class}::ISA"} = (Coro::Event::, "Event::$flavour"); 92 @{"${class}::ISA"} = (Coro::Event::, "Event::$flavour");
92 my $coronew = sub { 93 my $coronew = sub {
93 # how does one do method-call-by-name? 94 # how does one do method-call-by-name?
94 # my $w = $class->SUPER::$flavour(@_); 95 # my $w = $class->SUPER::$flavour(@_);
95 96
96 $_[0] eq Coro::Event:: 97 shift eq Coro::Event::
97 or croak "event constructor \"Coro::Event->$flavour\" must be called as a static method"; 98 or croak "event constructor \"Coro::Event->$flavour\" must be called as a static method";
98 99
99 my $q = []; # [$coro, $event]
100 my $w = $new->( 100 my $w = $new->($class,
101 desc => $flavour, 101 desc => $flavour,
102 @_, 102 @_,
103 parked => 1, 103 parked => 1,
104 ); 104 );
105 _install_std_cb($w, $type); 105 _install_std_cb($w, $type);
… …
107 }; 107 };
108 *{ $flavour } = $coronew; 108 *{ $flavour } = $coronew;
109 *{"do_$flavour"} = sub { 109 *{"do_$flavour"} = sub {
110 unshift @_, Coro::Event::; 110 unshift @_, Coro::Event::;
111 my $e = (&$coronew)->next; 111 my $e = (&$coronew)->next;
112 $e->cancel; # $e = $e->w 112 $e->cancel; # $e = $e->w->cancel ($e == $e->w!)
113 $e; 113 $e;
114 }; 114 };
115} 115}
116 116
117# double calls to avoid stack-cloning ;() 117# double calls to avoid stack-cloning ;()
… …
137into the Event dispatcher. 137into the Event dispatcher.
138 138
139=cut 139=cut
140 140
141sub sweep { 141sub sweep {
142 one_event(0); # for now 142 Event::one_event(0); # for now
143} 143}
144 144
145=item $result = loop([$timeout]) 145=item $result = loop([$timeout])
146 146
147This is the version of C<loop> you should use instead of C<Event::loop> 147This is the version of C<loop> you should use instead of C<Event::loop>
… …
155 155
156=end comment 156=end comment
157 157
158=cut 158=cut
159 159
160# no longer do something special - it's done internally now
161
160sub loop(;$) { 162#sub loop(;$) {
161 local $Coro::idle = $Coro::current; 163# #local $Coro::idle = $Coro::current;
162 Coro::schedule; # become idle task, which is implicitly ready 164# #Coro::schedule; # become idle task, which is implicitly ready
163 &Event::loop; 165# &Event::loop;
164} 166#}
165 167
166=item unloop([$result]) 168=item unloop([$result])
167 169
168Same as Event::unloop (provided here for your convinience only). 170Same as Event::unloop (provided here for your convinience only).
169 171
… …
174 Event::one_event; # inefficient 176 Event::one_event; # inefficient
175 Coro::schedule; 177 Coro::schedule;
176 } 178 }
177}; 179};
178 180
181# provide hooks for Coro::Timer
182
183package Coro::Timer;
184
185unless ($override) {
186 $override = 1;
187 *_new_timer = sub {
188 Event->timer(at => $_[0], cb => $_[1]);
189 };
190}
191
1791; 1921;
180 193
181=head1 AUTHOR 194=head1 AUTHOR
182 195
183 Marc Lehmann <pcg@goof.com> 196 Marc Lehmann <pcg@goof.com>

Diff Legend

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