X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;ds=sidebyside;f=zoom%2Fzoomsh.c;h=2126f3065136d3b2feecd43144500b5b1fa712d4;hb=57cae124c6a1c7cdd8c70090db636b227887fc19;hp=8469ce41430bfc99bfb0281805351f9d36c0d676;hpb=ca359fadd2bc021173109ad2e84a03f5e0f6a677;p=yaz-moved-to-github.git diff --git a/zoom/zoomsh.c b/zoom/zoomsh.c index 8469ce4..2126f30 100644 --- a/zoom/zoomsh.c +++ b/zoom/zoomsh.c @@ -1,17 +1,19 @@ /* This file is part of the YAZ toolkit. - * Copyright (C) 1995-2010 Index Data + * Copyright (C) 1995-2011 Index Data * See the file LICENSE for details. */ - /** \file zoomsh.c \brief ZOOM C command line tool (shell) */ +#if HAVE_CONFIG_H +#include +#endif #include #include #include -#include #include +#include #if HAVE_READLINE_READLINE_H #include @@ -25,7 +27,24 @@ #define MAX_CON 100 -static int next_token(const char **cpp, const char **t_start) +static void process_events(ZOOM_connection *c) +{ + int i; + + yaz_log(YLOG_DEBUG, "process_events"); + 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]); + yaz_log(YLOG_DEBUG, "no = %d peek = %d event = %d %s", i-1, + peek, + event, + ZOOM_get_event_str(event)); + } +} + +static int next_token_chars(const char **cpp, const char **t_start, + const char *tok_chars) { int len = 0; const char *cp = *cpp; @@ -46,7 +65,7 @@ static int next_token(const char **cpp, const char **t_start) else { *t_start = cp; - while (*cp && *cp != ' ' && *cp != '\r' && *cp != '\n') + while (*cp && !strchr(tok_chars, *cp)) { cp++; len++; @@ -58,6 +77,12 @@ static int next_token(const char **cpp, const char **t_start) return len; /* return -1 if no token was read .. */ } +static int next_token(const char **cpp, const char **t_start) +{ + return next_token_chars(cpp, t_start, "\r\n "); +} + + static WRBUF next_token_new_wrbuf(const char **cpp) { WRBUF w = 0; @@ -85,18 +110,18 @@ static void cmd_set(ZOOM_connection *c, ZOOM_resultset *r, ZOOM_options options, const char **args) { - WRBUF key, val; + WRBUF key; + const char *val_buf; + int val_len; if (!(key = next_token_new_wrbuf(args))) { printf("missing argument for set\n"); return ; } - if ((val = next_token_new_wrbuf(args))) - { - ZOOM_options_set(options, wrbuf_cstr(key), wrbuf_cstr(val)); - wrbuf_destroy(val); - } + val_len = next_token_chars(args, &val_buf, ""); + if (val_len != -1) + ZOOM_options_setl(options, wrbuf_cstr(key), val_buf, val_len); else ZOOM_options_set(options, wrbuf_cstr(key), 0); wrbuf_destroy(key); @@ -249,8 +274,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); - while (ZOOM_event(MAX_CON, c)) - ; + process_events(c); for (i = 0; i < MAX_CON; i++) { @@ -294,38 +318,8 @@ static void cmd_facets(ZOOM_connection *c, ZOOM_resultset *r, const char **args) { int i; - size_t start = 0, count = 1; - const char *type = "render"; - WRBUF render_str = 0; - - if (0) - { - WRBUF tmp; - - if ((tmp = next_token_new_wrbuf(args))) - { - start = atoi(wrbuf_cstr(tmp)); - wrbuf_destroy(tmp); - } - if ((tmp = next_token_new_wrbuf(args))) - { - count = atoi(wrbuf_cstr(tmp)); - wrbuf_destroy(tmp); - } - render_str = next_token_new_wrbuf(args); - } - 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++) { @@ -347,9 +341,6 @@ static void cmd_facets(ZOOM_connection *c, ZOOM_resultset *r, } } } - if (render_str) - wrbuf_destroy(render_str); - } static void cmd_ext(ZOOM_connection *c, ZOOM_resultset *r, @@ -371,8 +362,7 @@ static void cmd_ext(ZOOM_connection *c, ZOOM_resultset *r, p[i] = 0; } - while (ZOOM_event(MAX_CON, c)) - ; + process_events(c); for (i = 0; i