projects
/
yaz-moved-to-github.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
544555b
)
zoomsh: print events if in async mode
author
Adam Dickmeiss
<adam@indexdata.dk>
Thu, 23 Sep 2010 12:27:54 +0000
(14:27 +0200)
committer
Adam Dickmeiss
<adam@indexdata.dk>
Thu, 23 Sep 2010 12:27:54 +0000
(14:27 +0200)
zoom/zoomsh.c
patch
|
blob
|
history
diff --git
a/zoom/zoomsh.c
b/zoom/zoomsh.c
index
8469ce4
..
a770e7d
100644
(file)
--- a/
zoom/zoomsh.c
+++ b/
zoom/zoomsh.c
@@
-25,6
+25,22
@@
#define MAX_CON 100
#define MAX_CON 100
+static void process_events(ZOOM_connection *c)
+{
+ int i;
+
+ printf("process_events\n");
+ while ((i = ZOOM_event(MAX_CON, c)) != 0)
+ {
+ int peek = ZOOM_connection_peek_event(c[i-1]);
+ int event = ZOOM_connection_last_event(c[i-1]);
+ printf ("no = %d peek = %d event = %d %s\n", i-1,
+ peek,
+ event,
+ ZOOM_get_event_str(event));
+ }
+}
+
static int next_token(const char **cpp, const char **t_start)
{
int len = 0;
static int next_token(const char **cpp, const char **t_start)
{
int len = 0;
@@
-249,8
+265,7
@@
static void cmd_show(ZOOM_connection *c, ZOOM_resultset *r,
for (i = 0; i < MAX_CON; i++)
ZOOM_resultset_records(r[i], 0, start, count);
for (i = 0; i < MAX_CON; i++)
ZOOM_resultset_records(r[i], 0, start, count);
- while (ZOOM_event(MAX_CON, c))
- ;
+ process_events(c);
for (i = 0; i < MAX_CON; i++)
{
for (i = 0; i < MAX_CON; i++)
{
@@
-318,14
+333,7
@@
static void cmd_facets(ZOOM_connection *c, ZOOM_resultset *r,
if (render_str)
type = wrbuf_cstr(render_str);
if (render_str)
type = wrbuf_cstr(render_str);
- /*
- for (i = 0; i < MAX_CON; i++) {
- int num_facets = ZOOM_resultset_facet_size(r[i]);
- ZOOM_resultset_records(r[i], 0, start, count);
- }
- */
- while (ZOOM_event(MAX_CON, c))
- ;
+ process_events(c);
for (i = 0; i < MAX_CON; i++)
{
for (i = 0; i < MAX_CON; i++)
{
@@
-371,8
+379,7
@@
static void cmd_ext(ZOOM_connection *c, ZOOM_resultset *r,
p[i] = 0;
}
p[i] = 0;
}
- while (ZOOM_event(MAX_CON, c))
- ;
+ process_events(c);
for (i = 0; i<MAX_CON; i++)
{
for (i = 0; i<MAX_CON; i++)
{
@@
-442,8
+449,7
@@
static void cmd_search(ZOOM_connection *c, ZOOM_resultset *r,
}
ZOOM_query_destroy(s);
}
ZOOM_query_destroy(s);
- while (ZOOM_event(MAX_CON, c))
- ;
+ process_events(c);
for (i = 0; i<MAX_CON; i++)
{
for (i = 0; i<MAX_CON; i++)
{
@@
-464,8
+470,10
@@
static void cmd_search(ZOOM_connection *c, ZOOM_resultset *r,
printf("%s: %lld hits\n", ZOOM_connection_option_get(c[i], "host"),
(long long int) ZOOM_resultset_size(r[i]));
printf("%s: %lld hits\n", ZOOM_connection_option_get(c[i], "host"),
(long long int) ZOOM_resultset_size(r[i]));
+#if 0
/* and display */
display_records(c[i], r[i], start, count, "render");
/* and display */
display_records(c[i], r[i], start, count, "render");
+#endif
}
}
}
}
}
}
@@
-501,8
+509,8
@@
static void cmd_scan(ZOOM_connection *c, ZOOM_resultset *r,
}
ZOOM_query_destroy(query);
}
ZOOM_query_destroy(query);
- while (ZOOM_event(MAX_CON, c))
- ;
+ process_events(c);
+
for (i = 0; i<MAX_CON; i++)
{
int error;
for (i = 0; i<MAX_CON; i++)
{
int error;
@@
-545,8
+553,7
@@
static void cmd_sort(ZOOM_connection *c, ZOOM_resultset *r,
if (r[i])
ZOOM_resultset_sort(r[i], "yaz", sort_spec);
}
if (r[i])
ZOOM_resultset_sort(r[i], "yaz", sort_spec);
}
- while (ZOOM_event(MAX_CON, c))
- ;
+ process_events(c);
}
static void cmd_help(ZOOM_connection *c, ZOOM_resultset *r,
}
static void cmd_help(ZOOM_connection *c, ZOOM_resultset *r,