X-Git-Url: http://gb7djk.dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FEphMsg.pm;h=3117aabaee61aba69c9d187fffc35e0635b21742;hb=a24cc09d8262093df92c767d3010c0a5fd6e42d7;hp=2fa7a593e960bf4edb61333f33831b74b317084f;hpb=44ac4cfc87f3d628417502609668eaeb86d80976;p=spider.git diff --git a/perl/EphMsg.pm b/perl/EphMsg.pm index 2fa7a593..3117aaba 100644 --- a/perl/EphMsg.pm +++ b/perl/EphMsg.pm @@ -18,6 +18,8 @@ use Msg; use DXVars; use DXUtil; use DXDebug; +use DXTimer; + use IO::File; use IO::Socket; use IPC::Open3; @@ -61,6 +63,8 @@ sub dequeue $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'); @@ -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; - $conn->{timeout} = Timer->new($val, sub{ &_timedout($conn) }); + $conn->{timeout} = DXTimer->new($val, sub{ &_timedout($conn) }); }