X-Git-Url: http://git.indexdata.com/?p=irspy-moved-to-github.git;a=blobdiff_plain;f=test-pod.pl;h=f2b107b3bc1a541fbf90ddf018e451437184901b;hp=37d7fabebe6bc26cca03f3248c4b51e3d2c21217;hb=1ecc35b2c19ecc213607c941db9e4da4414698cc;hpb=23efd2b947c0381a176cd629c617cc373b699282 diff --git a/test-pod.pl b/test-pod.pl index 37d7fab..f2b107b 100644 --- a/test-pod.pl +++ b/test-pod.pl @@ -1,6 +1,6 @@ #!/usr/bin/perl -w -# $Id: test-pod.pl,v 1.6 2006-05-10 13:38:31 mike Exp $ +# $Id: test-pod.pl,v 1.9 2006-07-18 13:45:08 mike Exp $ # # Run like this: # YAZ_LOG=pod perl -I lib test-pod.pl "bagel.indexdata.com/gils" "bagel.indexdata.com/marc" @@ -9,27 +9,38 @@ use strict; use warnings; use ZOOM::Pod; -ZOOM::Log::mask_str("appl"); +if (@ARGV == 0) { + printf STDERR "Usage: $0 [ ...]\n"; + exit 1; +} + +ZOOM::Log::mask_str("appl"); my $pod = new ZOOM::Pod(@ARGV); $pod->option(elementSetName => "b"); $pod->callback(ZOOM::Event::RECV_SEARCH, \&completed_search); $pod->callback(ZOOM::Event::RECV_RECORD, \&got_record); +#$pod->callback(exception => \&exception_thrown); $pod->search_pqf("the"); -my $err = $pod->wait(); +my $err = $pod->wait({}); die "$pod->wait() failed with error $err" if $err; sub completed_search { - my($conn, $state, $rs, $event) = @_; - print $conn->option("host"), ": found ", $rs->size(), " records\n"; - $state->{next_to_fetch} = 0; - $state->{next_to_show} = 0; - request_records($conn, $rs, $state, 2); + my($conn, $arg, $rs, $event) = @_; + + my $host = $conn->option("host"); + print "$host : found ", $rs->size(), " records\n"; + my %state = (next_to_show => 0, next_to_fetch => 0); + request_records($conn, $rs, \%state, 2); + $arg->{$host} = \%state; return 0; } sub got_record { - my($conn, $state, $rs, $event) = @_; + my($conn, $arg, $rs, $event) = @_; + + my $host = $conn->option("host"); + my $state = $arg->{$host}; { # Sanity-checking assertions. These should be impossible @@ -44,18 +55,25 @@ sub got_record { my $i = $state->{next_to_show}++; my $rec = $rs->record($i); - print $conn->option("host"), ": record $i is ", render_record($rec), "\n"; + print "$host: record $i is ", render_record($rec), "\n"; request_records($conn, $rs, $state, 3) if $i == $state->{next_to_fetch}-1; return 0; } +sub exception_thrown { + my($conn, $arg, $rs, $exception) = @_; + print "Uh-oh! $exception\n"; + return 0; +} + sub request_records { my($conn, $rs, $state, $count) = @_; my $i = $state->{next_to_fetch}; - ZOOM::Log::log("appl", "requesting $count records from $i"); + ZOOM::Log::log("appl", "requesting $count records from $i for ", + $conn->option("host")); $rs->records($i, $count, 0); $state->{next_to_fetch} += $count; }