X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;ds=sidebyside;f=perl%2FExtMsg.pm;h=74a2cfcd0dc8ea0c18956b005574899930ad91f2;hb=dec0e10eb89ce1800f7814b80326e1a827eafeab;hp=6b3a30b1c0f00624fa573fc79c35cba28eb314a4;hpb=a153b8df39668d98f01238e1c49d9e9a51ec5484;p=spider.git diff --git a/perl/ExtMsg.pm b/perl/ExtMsg.pm index 6b3a30b1..74a2cfcd 100644 --- a/perl/ExtMsg.pm +++ b/perl/ExtMsg.pm @@ -19,6 +19,8 @@ use Msg; use DXVars; use DXUtil; use DXDebug; +use DXTimer; + use IO::File; use IO::Socket; use IPC::Open3; @@ -107,6 +109,8 @@ sub dequeue } else { $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'); @@ -300,7 +304,7 @@ sub _dotimeout 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} = DXTimer->new($val, sub{ &_timedout($conn) }); } sub _dolineend