X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FEphMsg.pm;h=bf43a334872be9fbede5aebfc5abb56a8284011e;hb=cbb522ef802d48991734a4ce803fa6ffa9774588;hp=a6da8a2df2b54962f69dfa8e6e0c0a1726f52277;hpb=c02dc2d8b544b9d682c9a068ba13bdedf40ed3bf;p=spider.git diff --git a/perl/EphMsg.pm b/perl/EphMsg.pm index a6da8a2d..bf43a334 100644 --- a/perl/EphMsg.pm +++ b/perl/EphMsg.pm @@ -61,6 +61,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'); @@ -71,19 +73,6 @@ sub dequeue } } -sub to_connected -{ - my ($conn, $call, $dir, $sort) = @_; - $conn->{state} = 'C'; - $conn->conns($call); - delete $conn->{cmd}; - $conn->{timeout}->del if $conn->{timeout}; - delete $conn->{timeout}; - $conn->nolinger; - &{$conn->{rproc}}($conn, "$dir$call|$sort"); -} - - sub start_connect { my $call = shift;