ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/Coro/myhttpd/access.pl
(Generate patch)

Comparing Coro/myhttpd/access.pl (file contents):
Revision 1.15 by root, Fri Nov 30 03:06:37 2001 UTC vs.
Revision 1.16 by root, Fri Nov 30 05:11:23 2001 UTC

14 Scalar::Util::weaken($trans->[0]); 14 Scalar::Util::weaken($trans->[0]);
15 15
16 push @{$self->{wait}}, $trans; 16 push @{$self->{wait}}, $trans;
17 Scalar::Util::weaken($self->{wait}[-1]); 17 Scalar::Util::weaken($self->{wait}[-1]);
18 18
19 if (--$self->{conns} >= 0) { 19 --$self->{conns};
20 $self->wake_next; 20 $self->wake_next;
21 }
22 21
23 $trans; 22 $trans;
24} 23}
25 24
26sub wake_next { 25sub wake_next {
43 42
44package transfer; 43package transfer;
45 44
46use Coro::Timer (); 45use Coro::Timer ();
47 46
48sub try {
49 my $self = shift;
50 my $timeout = Coro::Timer::timeout $_[0];
51
52 unless ($self->[2]) {
53 local $self->[1] = $Coro::current;
54 Coro::schedule;
55 }
56
57 return $self->[2];
58}
59
60sub wake { 47sub wake {
61 my $self = shift; 48 my $self = shift;
62 $self->[2] = 1; 49 $self->[2] = 1;
63 ref $self->[1] and $self->[1]->ready; 50 ref $self->[1] and $self->[1]->ready;
51}
52
53sub try {
54 my $self = shift;
55
56 unless ($self->[2]) {
57 my $timeout = Coro::Timer::timeout $_[0];
58 $self->[1] = $Coro::current;
59
60 Coro::schedule;
61
62 undef $self->[1];
63 }
64
65 return $self->[2];
64} 66}
65 67
66sub DESTROY { 68sub DESTROY {
67 my $self = shift; 69 my $self = shift;
68 $self->[0]{conns}++; 70 $self->[0]{conns}++;

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines