X-Git-Url: http://git.indexdata.com/?p=yaz-moved-to-github.git;a=blobdiff_plain;f=src%2Fzoom-c.c;h=41d6e1cab9e7b9bfa33fd235b3354a3591c42df7;hp=241444f97ab1a232578334430cb0209e7059fa6f;hb=44de7e21fac2c7c731b635ba1d31b99ae6bb1259;hpb=c844fbf71bf74b1d677c6e6e12e1530cc9b314ce diff --git a/src/zoom-c.c b/src/zoom-c.c index 241444f..41d6e1c 100644 --- a/src/zoom-c.c +++ b/src/zoom-c.c @@ -752,6 +752,7 @@ ZOOM_API(ZOOM_resultset) yaz_log(c->log_api, "%p ZOOM_connection_search set %p query %p", c, r, q); r->r_sort_spec = ZOOM_query_get_sortspec(q); r->query = q; + ZOOM_query_addref(q); r->options = ZOOM_options_create_with_parent(c->options); @@ -777,9 +778,21 @@ ZOOM_API(ZOOM_resultset) #if HAVE_LIBMEMCACHED_MEMCACHED_H r->mc_key = wrbuf_alloc(); + wrbuf_puts(r->mc_key, "0;"); wrbuf_puts(r->mc_key, c->host_port); wrbuf_puts(r->mc_key, ";"); - wrbuf_puts(r->mc_key, ZOOM_query_get_query_string(q)); + if (c->user) + wrbuf_puts(r->mc_key, c->user); + wrbuf_puts(r->mc_key, ";"); + if (c->group) + wrbuf_puts(r->mc_key, c->group); + wrbuf_puts(r->mc_key, ";"); + if (c->password) + wrbuf_sha1_puts(r->mc_key, c->password, 1); + wrbuf_puts(r->mc_key, ";"); + wrbuf_sha1_puts(r->mc_key, ZOOM_query_get_query_string(q), 1); + wrbuf_puts(r->mc_key, ";"); + /* TODO: add sorting */ if (c->mc_st) { size_t v_len; @@ -789,8 +802,20 @@ ZOOM_API(ZOOM_resultset) wrbuf_len(r->mc_key), &v_len, &flags, &rc); if (v) { - yaz_log(YLOG_LOG, "For key %s got value %.*s", - wrbuf_cstr(r->mc_key), (int) v_len, v); + ZOOM_Event event; + WRBUF w = wrbuf_alloc(); + + wrbuf_write(w, v, v_len); + free(v); + r->size = odr_atoi(wrbuf_cstr(w)); + + yaz_log(YLOG_LOG, "For key %s got value %s", + wrbuf_cstr(r->mc_key), wrbuf_cstr(w)); + + wrbuf_destroy(w); + event = ZOOM_Event_create(ZOOM_EVENT_RECV_SEARCH); + ZOOM_connection_put_event(c, event); + return r; } else { @@ -829,8 +854,6 @@ ZOOM_API(ZOOM_resultset) ZOOM_resultset_addref(r); - ZOOM_query_addref(q); - if (!c->async) { while (ZOOM_event(1, &c))