version 1.33, 2003/11/25 10:14:40
|
version 1.35, 2003/12/12 09:57:28
|
Line 210 sub GetPeername {
|
Line 210 sub GetPeername {
|
return $peerfile; |
return $peerfile; |
} |
} |
} |
} |
#----------------------------- Timer management ------------------------ |
|
=pod |
=pod |
|
|
=head2 Debug |
=head2 Debug |
Line 267 sub SocketTimeout {
|
Line 266 sub SocketTimeout {
|
# a connection failure: |
# a connection failure: |
$ConnectionRetriesLeft--; |
$ConnectionRetriesLeft--; |
} |
} |
|
#----------------------------- Timer management ------------------------ |
|
|
=pod |
=pod |
|
|
Line 301 sub Tick {
|
Line 301 sub Tick {
|
# |
# |
# For each inflight transaction, tick down its timeout counter. |
# For each inflight transaction, tick down its timeout counter. |
# |
# |
foreach my $item (keys %ActiveTransactions) { |
|
my $Socket = $ActiveTransactions{$item}->getServer(); |
foreach my $item (keys %ActiveConnections) { |
$Socket->Tick(); |
my $State = $ActiveConnections{$item}->data->GetState(); |
|
if ($State ne 'Idle') { |
|
Debug(5,"Ticking Socket $State $item"); |
|
$ActiveConnections{$item}->data->Tick(); |
|
} |
} |
} |
# Do we have work in the queue, but no connections to service them? |
# Do we have work in the queue, but no connections to service them? |
# If so, try to make some new connections to get things going again. |
# If so, try to make some new connections to get things going again. |