90 |
my $msg=$::CONF{'PingMessage'}; |
my $msg=$::CONF{'PingMessage'}; |
91 |
my @cons=values %PersistentConnections; |
my @cons=values %PersistentConnections; |
92 |
|
|
93 |
map { $_->write($msg.chr(0)) } @cons; |
map { $_->write($msg) } @cons; |
94 |
} |
} |
95 |
|
|
96 |
sub checkPersistentConnectionsForMaxTime { |
sub checkPersistentConnectionsForMaxTime { |
273 |
} |
} |
274 |
/gex; |
/gex; |
275 |
|
|
276 |
$self->write($header.chr(0)); |
$self->write($header); |
277 |
} |
} |
278 |
|
|
279 |
sub sendMessage { |
sub sendMessage { |
283 |
|
|
284 |
$numMsgInThisBatch=1 unless(defined($numMsgInThisBatch)); |
$numMsgInThisBatch=1 unless(defined($numMsgInThisBatch)); |
285 |
|
|
286 |
$self->write($msg.chr(0)); |
$self->write($msg); |
287 |
|
|
288 |
$::Statistics->{'messages_served'}+=$numMsgInThisBatch; |
$::Statistics->{'messages_served'}+=$numMsgInThisBatch; |
289 |
|
|