From e6ea6876f9a2a4f7a09956bde816fda10e0d3443 Mon Sep 17 00:00:00 2001 From: erickson Date: Fri, 21 Apr 2006 13:04:47 +0000 Subject: [PATCH] added some more diagnostic logging if we have no data to send to the unixserver, we don't try git-svn-id: svn://svn.open-ils.org/ILS/trunk@3807 dcc99617-32d9-48b4-a31d-7c20da2025e4 --- .../OpenSRF/Transport/SlimJabber/Inbound.pm | 18 ++++++++++++++---- 1 file changed, 14 insertions(+), 4 deletions(-) diff --git a/OpenSRF/src/perlmods/OpenSRF/Transport/SlimJabber/Inbound.pm b/OpenSRF/src/perlmods/OpenSRF/Transport/SlimJabber/Inbound.pm index 2bae137178..81240bc609 100644 --- a/OpenSRF/src/perlmods/OpenSRF/Transport/SlimJabber/Inbound.pm +++ b/OpenSRF/src/perlmods/OpenSRF/Transport/SlimJabber/Inbound.pm @@ -144,23 +144,33 @@ sub listen { my $sock = $self->unix_sock(); my $o; + $logger->debug("Inbound listener calling process()"); + try { $o = $self->process( -1 ); + $logger->debug("Inbound listener received ".length($o)." bytes of data"); + + if(!$o){$logger->error( + "Inbound received no data from the Jabber socket in process()")} + } catch OpenSRF::EX::JabberDisconnected with { + $logger->error("Inbound process lost its ". "jabber connection. Attempting to reconnect..."); $self->initialize; + $o = undef; }; - if(defined $o) { + + if($o) { my $socket = IO::Socket::UNIX->new( Peer => $sock ); - throw OpenSRF::EX::Socket( "Unable to connect to UnixServer: socket-file: $sock \n :=> $! " ) + throw OpenSRF::EX::Socket( + "Unable to connect to UnixServer: socket-file: $sock \n :=> $! " ) unless ($socket->connected); print $socket $o; $socket->close; - } - + } } throw OpenSRF::EX::Socket( "How did we get here?!?!" ); -- 2.43.2