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.4 by root, Fri Aug 17 04:08:58 2001 UTC vs.
Revision 1.26 by root, Tue Feb 22 19:51:58 2005 UTC

… …
6 6
7 use Coro; 7 use Coro;
8 use Coro::Event; 8 use Coro::Event;
9 9
10 sub keyboard : Coro { 10 sub keyboard : Coro {
11 my $w = Coro::Event->io(fd => *STDIN, poll => 'r'); 11 my $w = Coro::Event->io(fd => \*STDIN, poll => 'r');
12 while() { 12 while() {
13 print "cmd> "; 13 print "cmd> ";
14 my $ev = $w->next; my $cmd = <STDIN>; 14 my $ev = $w->next; my $cmd = <STDIN>;
15 unloop unless $cmd ne ""; 15 unloop unless $cmd ne "";
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; 43BEGIN { eval { require warnings } && warnings->unimport ("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); 52@EXPORT = qw(loop unloop sweep reschedule);
53 53
54BEGIN { 54BEGIN {
55 $VERSION = 0.45; 55 $VERSION = 1.1;
56 56
57 local $^W = 0; # avoid redefine warning for Coro::ready;
58
57 require XSLoader; 59 require DynaLoader;
58 XSLoader::load Coro::Event, $VERSION; 60 push @ISA, 'DynaLoader';
61 bootstrap Coro::Event $VERSION;
59} 62}
60 63
61=item $w = Coro::Event->flavour(args...) 64=item $w = Coro::Event->flavour(args...)
62 65
63Create and return a watcher of the given type. 66Create and return a watcher of the given type.
… …
91 @{"${class}::ISA"} = (Coro::Event::, "Event::$flavour"); 94 @{"${class}::ISA"} = (Coro::Event::, "Event::$flavour");
92 my $coronew = sub { 95 my $coronew = sub {
93 # how does one do method-call-by-name? 96 # how does one do method-call-by-name?
94 # my $w = $class->SUPER::$flavour(@_); 97 # my $w = $class->SUPER::$flavour(@_);
95 98
96 $_[0] eq Coro::Event:: 99 shift eq Coro::Event::
97 or croak "event constructor \"Coro::Event->$flavour\" must be called as a static method"; 100 or croak "event constructor \"Coro::Event->$flavour\" must be called as a static method";
98 101
99 my $q = []; # [$coro, $event]
100 my $w = $new->( 102 my $w = $new->($class,
101 desc => $flavour, 103 desc => $flavour,
102 @_, 104 @_,
103 parked => 1, 105 parked => 1,
104 ); 106 );
105 _install_std_cb($w, $type); 107 _install_std_cb($w, $type);
… …
107 }; 109 };
108 *{ $flavour } = $coronew; 110 *{ $flavour } = $coronew;
109 *{"do_$flavour"} = sub { 111 *{"do_$flavour"} = sub {
110 unshift @_, Coro::Event::; 112 unshift @_, Coro::Event::;
111 my $e = (&$coronew)->next; 113 my $e = (&$coronew)->next;
112 $e->cancel; # $e = $e->w 114 $e->cancel; # $e === $e->w
113 $e; 115 $e;
114 }; 116 };
115} 117}
116 118
117# double calls to avoid stack-cloning ;() 119# double calls to avoid stack-cloning ;()
… …
119sub next($) { 121sub next($) {
120 &Coro::schedule if &_next; $_[0]; 122 &Coro::schedule if &_next; $_[0];
121} 123}
122 124
123sub Coro::Event::w { $_[0] } 125sub Coro::Event::w { $_[0] }
126sub Coro::Event::prio { $_[0]{Coro::Event}[3] }
127sub Coro::Event::hits { $_[0]{Coro::Event}[4] }
124sub Coro::Event::got { $_[0]{Coro::Event}[3] } 128sub Coro::Event::got { $_[0]{Coro::Event}[5] }
125sub Coro::Event::prio { croak "prio not supported yet, please mail to pcg\@goof.com" }
126sub Coro::Event::hits { croak "hits not supported yet, please mail to pcg\@goof.com" }
127 129
128=item sweep 130=item sweep
129 131
130Similar to Event::one_event and Event::sweep: The idle task is called once 132Similar to Event::one_event and Event::sweep: The idle task is called once
131(this has the effect of jumping back into the Event loop once to serve new 133(this has the effect of jumping back into the Event loop once to serve new
… …
137into the Event dispatcher. 139into the Event dispatcher.
138 140
139=cut 141=cut
140 142
141sub sweep { 143sub sweep {
142 one_event(0); # for now 144 Event::one_event(0); # for now
143} 145}
144 146
145=item $result = loop([$timeout]) 147=item $result = loop([$timeout])
146 148
147This is the version of C<loop> you should use instead of C<Event::loop> 149This is the version of C<loop> you should use instead of C<Event::loop>
… …
155 157
156=end comment 158=end comment
157 159
158=cut 160=cut
159 161
162# no longer do something special - it's done internally now
163
160sub loop(;$) { 164#sub loop(;$) {
161 local $Coro::idle = $Coro::current; 165# #local $Coro::idle = $Coro::current;
162 Coro::schedule; # become idle task, which is implicitly ready 166# #Coro::schedule; # become idle task, which is implicitly ready
163 &Event::loop; 167# &Event::loop;
164} 168#}
165 169
166=item unloop([$result]) 170=item unloop([$result])
167 171
168Same as Event::unloop (provided here for your convinience only). 172Same as Event::unloop (provided here for your convinience only).
169 173
… …
174 Event::one_event; # inefficient 178 Event::one_event; # inefficient
175 Coro::schedule; 179 Coro::schedule;
176 } 180 }
177}; 181};
178 182
183# provide hooks for Coro::Timer
184
185package Coro::Timer;
186
187unless ($override) {
188 $override = 1;
189 *_new_timer = sub {
190 Event->timer(at => $_[0], cb => $_[1]);
191 };
192}
193
1791; 1941;
180 195
181=head1 AUTHOR 196=head1 AUTHOR
182 197
183 Marc Lehmann <pcg@goof.com> 198 Marc Lehmann <pcg@goof.com>
184 http://www.goof.com/pcg/marc/ 199 http://home.schmorp.de/
185 200
186=cut 201=cut
187 202

Diff Legend

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