From: Mike Taylor <mike@indexdata.com>
Date: Wed, 19 Jul 2006 16:29:51 +0000 (+0000)
Subject: New, derived from test-net-z3950-zoom.pl
X-Git-Tag: CPAN-v1.02~1176
X-Git-Url: http://git.indexdata.com/?p=irspy-moved-to-github.git;a=commitdiff_plain;h=00d5adca7117fa9e27173dfb50d06d7886a573b5

New, derived from test-net-z3950-zoom.pl
---

diff --git a/bin/test-zoom-c.c b/bin/test-zoom-c.c
new file mode 100644
index 0000000..9c6d645
--- /dev/null
+++ b/bin/test-zoom-c.c
@@ -0,0 +1,122 @@
+/*
+ * $Id: test-zoom-c.c,v 1.1 2006-07-19 16:29:51 mike Exp $
+ *
+ * Run the same way as "test-pod.pl".  This is supposed to be an
+ * exactly equivalent program but written using the ZOOM-C imperative
+ * API for asynchronous events directly rather than through the
+ * intermediary of Net::Z3950::ZOOM, ZOOM::Pod and ZOOM-Perl.
+ */
+
+#include <assert.h>
+#include <stdio.h>
+#include <yaz/zoom.h>
+#include <yaz/log.h>
+
+
+struct conn_and_state {
+    ZOOM_connection conn;
+    ZOOM_resultset rs;
+    int next_to_show, next_to_fetch;
+};
+
+
+static void completed_search(struct conn_and_state *csp);
+static void got_record(struct conn_and_state *csp);
+static void request_records(struct conn_and_state *csp, int count);
+static const char *render_record(ZOOM_record rec);
+
+
+int main (int argc, char *argv[]) {
+    struct conn_and_state cs[100];
+    ZOOM_connection zconn[100];
+    int i, n;
+
+    if (argc == 1) {
+	fprintf(stderr, "Usage: %s <target1> [<target2> ...]\n", argv[0]);
+	return 1;
+    }
+
+    yaz_log_mask_str("appl");
+    n = argc-1;
+    for (i = 0; i < n; i++) {
+	char *target = argv[i+1];
+	ZOOM_options options = ZOOM_options_create();
+	ZOOM_options_set_int(options, "async", 1);
+	ZOOM_options_set(options, "elementSetName", "b");
+	cs[i].conn = zconn[i] = ZOOM_connection_create(options);
+	ZOOM_connection_connect(cs[i].conn, target, 0);
+	cs[i].rs = ZOOM_connection_search_pqf(cs[i].conn, "the");
+	cs[i].next_to_show = 0;
+	cs[i].next_to_fetch = 0;
+    }
+
+    while ((i = ZOOM_event(n, zconn)) != 0) {
+	struct conn_and_state *csp = &cs[i-1];
+	int ev = ZOOM_connection_last_event(csp->conn);
+	int errcode;
+	const char *errmsg;
+	const char *addinfo;
+
+	yaz_log(yaz_log_module_level("pod"),
+		"connection %d: event %d", i-1, ev);
+
+	errcode = ZOOM_connection_error(csp->conn, &errmsg, &addinfo);
+	if (errcode != 0) {
+	    fprintf(stderr, "error %d (%s) [%s]\n", errcode, errmsg, addinfo);
+	    return 2;
+	}
+
+	if (ev == ZOOM_EVENT_RECV_SEARCH) {
+	    completed_search(csp);
+	} else if (ev == ZOOM_EVENT_RECV_RECORD) {
+	    got_record(csp);
+	}
+    }
+
+    return 0;
+}
+
+
+static void completed_search(struct conn_and_state *csp) {
+    const char *host = ZOOM_connection_option_get(csp->conn, "host");
+
+    printf("%s: found %d records\n", host, ZOOM_resultset_size(csp->rs));
+    request_records(csp, 2);
+}
+
+
+static void got_record(struct conn_and_state *csp) {
+    const char *host = ZOOM_connection_option_get(csp->conn, "host");
+    int i;
+    ZOOM_record rec;
+
+    assert(csp->next_to_show < csp->next_to_fetch);
+    i = csp->next_to_show++;
+    rec = ZOOM_resultset_record(csp->rs, i);
+    printf("%s: record %d is %s\n", host, i, render_record(rec));
+    if (i == csp->next_to_fetch-1) {
+	request_records(csp, 3);
+    }
+}
+
+
+static void request_records(struct conn_and_state *csp, int count) {
+    const char *host = ZOOM_connection_option_get(csp->conn, "host");
+    int i = csp->next_to_fetch;
+
+    yaz_log(yaz_log_module_level("appl"),
+	    "requesting %d records from %d for %s", count, i, host);
+
+    ZOOM_resultset_records(csp->rs, (ZOOM_record*) 0, i, count);
+    csp->next_to_fetch += count;
+}
+
+
+static const char *render_record(ZOOM_record rec) {
+    int len;
+
+    if (rec == 0)
+	return "undefined";
+    else 
+	return ZOOM_record_get(rec, "render", &len);
+}