Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
simplify queue
  • Loading branch information
kraih committed May 13, 2014
1 parent 8d278d5 commit 00e767a
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions lib/Mojo/UserAgent.pm
Expand Up @@ -79,9 +79,9 @@ sub _cleanup {
$self->_handle($_, 1) for keys %{$self->{connections} || {}};

# Clean up keep-alive connections
$loop->remove($_->[1]) for @{delete $self->{queue}[0] || []};
$loop->remove($_->[1]) for @{delete $self->{queue} || []};
$loop = Mojo::IOLoop->singleton;
$loop->remove($_->[1]) for @{delete $self->{queue}[1] || []};
$loop->remove($_->[1]) for @{delete $self->{nb_queue} || []};

return $self;
}
Expand Down Expand Up @@ -207,8 +207,8 @@ sub _dequeue {

my $found;
my $loop = $self->_loop($nb);
my $old = $self->{queue}[$nb] || [];
my $new = $self->{queue}[$nb] = [];
my $old = $self->{$nb ? 'nb_queue' : 'queue'} || [];
my $new = $self->{$nb ? 'nb_queue' : 'queue'} = [];
for my $queued (@$old) {
push @$new, $queued and next if $found || !grep { $_ eq $name } @$queued;

Expand All @@ -224,7 +224,7 @@ sub _enqueue {
my ($self, $nb, $name, $id) = @_;

# Enforce connection limit
my $queue = $self->{queue}[$nb] ||= [];
my $queue = $self->{$nb ? 'nb_queue' : 'queue'} ||= [];
my $max = $self->max_connections;
$self->_remove(shift(@$queue)->[1]) while @$queue > $max;
push @$queue, [$name, $id] if $max;
Expand Down

0 comments on commit 00e767a

Please sign in to comment.