projects
/
spider.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
hide route changes, increase sh/ann cache to 130.
[spider.git]
/
perl
/
EphMsg.pm
diff --git
a/perl/EphMsg.pm
b/perl/EphMsg.pm
index 2fa7a593e960bf4edb61333f33831b74b317084f..3117aabaee61aba69c9d187fffc35e0635b21742 100644
(file)
--- a/
perl/EphMsg.pm
+++ b/
perl/EphMsg.pm
@@
-18,6
+18,8
@@
use Msg;
use DXVars;
use DXUtil;
use DXDebug;
use DXVars;
use DXUtil;
use DXDebug;
+use DXTimer;
+
use IO::File;
use IO::Socket;
use IPC::Open3;
use IO::File;
use IO::Socket;
use IPC::Open3;
@@
-61,6
+63,8
@@
sub dequeue
$conn->{msg} =~ s/([^\cM\cJ]*)\cM?\cJ//g;
}
$conn->{msg} =~ s/([^\cM\cJ]*)\cM?\cJ//g;
}
+ $conn->{linesin} += @lines;
+ $Msg::total_lines_in += @lines;
while (defined ($msg = shift @lines)) {
dbg("connect $conn->{cnum}: $msg") if $conn->{state} ne 'C' && isdbg('connect');
while (defined ($msg = shift @lines)) {
dbg("connect $conn->{cnum}: $msg") if $conn->{state} ne 'C' && isdbg('connect');
@@
-127,7
+131,7
@@
sub _dotimeout
dbg("connect $conn->{cnum}: timeout set to $val") if isdbg('connect');
$conn->{timeout}->del if $conn->{timeout};
$conn->{timeval} = $val;
dbg("connect $conn->{cnum}: timeout set to $val") if isdbg('connect');
$conn->{timeout}->del if $conn->{timeout};
$conn->{timeval} = $val;
- $conn->{timeout} = Timer->new($val, sub{ &_timedout($conn) });
+ $conn->{timeout} =
DX
Timer->new($val, sub{ &_timedout($conn) });
}
}