$cnum = 0;
$connect_timeout = 5;
$disc_waittime = 1.5;
+%conns;
our %delqueue;
return $ref;
}
+# this is called as a FUNCTION i.e my $conn = Msg::get($call);
+sub get
+{
+ return $conns{shift};
+}
+
# this is only called by any dependent processes going away unexpectedly
sub pid_gone
{
if ($sock->{buffer}) {
my $lth = length $sock->{buffer};
Mojo::IOLoop->timer($disc_waittime, sub {
- dbg("Buffer contained $lth data , coordinated for $disc_waittime secs, now disconnecting $call") if $dbg;
+ dbg("Buffer contained $lth characters, coordinated for $disc_waittime secs, now disconnecting $call") if $dbg;
_close_it($conn);
});
} else {