version 1.34, 2003/12/11 23:18:37
|
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(); |
|
$Socket->Tick(); |
|
} |
|
foreach my $item (keys %ActiveConnections) { |
foreach my $item (keys %ActiveConnections) { |
my $State = $ActiveConnections{$item}->data->GetState(); |
my $State = $ActiveConnections{$item}->data->GetState(); |
if ($State ne 'Idle' && $State ne 'SendingRequest' && |
if ($State ne 'Idle') { |
$State ne 'ReceivingReply') { |
|
Debug(5,"Ticking Socket $State $item"); |
Debug(5,"Ticking Socket $State $item"); |
$ActiveConnections{$item}->data->Tick(); |
$ActiveConnections{$item}->data->Tick(); |
} |
} |