X-Git-Url: http://git.indexdata.com/?p=irspy-moved-to-github.git;a=blobdiff_plain;f=lib%2FZOOM%2FPod.pm;h=a59d3b119b25fb661dd4245571dfa3b8c1444882;hp=122a108cd36178cda141b68fa39668f60fd447a5;hb=bcac6b011cc4e33e99383d434a62cb6a5f52ff56;hpb=712a9074fbda10988360c398aba4f0a101f6d26e diff --git a/lib/ZOOM/Pod.pm b/lib/ZOOM/Pod.pm index 122a108..a59d3b1 100644 --- a/lib/ZOOM/Pod.pm +++ b/lib/ZOOM/Pod.pm @@ -1,4 +1,4 @@ -# $Id: Pod.pm,v 1.9 2006-05-12 13:28:40 mike Exp $ +# $Id: Pod.pm,v 1.12 2006-06-07 10:43:22 mike Exp $ package ZOOM::Pod; @@ -72,7 +72,6 @@ handle errors. $pod = new ZOOM::Pod("bagel.indexdata.com/gils", "bagel.indexdata.com/marc"); - Creates a new pod containing one or more connections. Each connection may be specified either by an existing C object, which I be asynchronous; or by a ZOOM target string, in which @@ -82,6 +81,15 @@ Returns the new pod. =cut +# Functionality to be added: +# +# If the constructor's first argument is a number, then it is +# taken as a limit on the number of connections to handle at any +# one time. In this case, the pod initially multiplexes between +# the first I connections, and brings further connections +# into the active subset whenever already-active connections are +# closed. + sub new { my $class = shift(); my(@conn) = @_; @@ -267,7 +275,7 @@ sub wait { my $conn = $this->{conn}->[$i-1]; my $ev = $conn->last_event(); my $evstr = ZOOM::event_str($ev); - ZOOM::Log::log("pod", "connection ", $i-1, ": $evstr"); + ZOOM::Log::log("pod", "connection ", $i-1, ": event $ev ($evstr)"); eval { $conn->_check(); @@ -286,7 +294,7 @@ sub wait { $this->{rs}->[$i-1], $ev); last if $res != 0; } else { - ZOOM::Log::log("pod_unhandled", "unhandled event $ev ($evstr)"); + ZOOM::Log::log("pod_unhandled", "connection ", $i-1, ": unhandled event $ev ($evstr)"); } }