X-Git-Url: http://jsfdemo.indexdata.com/?a=blobdiff_plain;f=src%2Fconnection.c;h=a87d14c9027f71c171febbe9bc216c896e2cffce;hb=20bc8b17d60373c2c93ab6bb777d19dd92ed2960;hp=c1ff7d512c94f71140415a8117a2f60b51cb5933;hpb=71b10adee4c11891aa2283bf844c564bc06f3177;p=pazpar2-moved-to-github.git diff --git a/src/connection.c b/src/connection.c index c1ff7d5..a87d14c 100644 --- a/src/connection.c +++ b/src/connection.c @@ -1,5 +1,5 @@ /* This file is part of Pazpar2. - Copyright (C) 2006-2012 Index Data + Copyright (C) 2006-2013 Index Data Pazpar2 is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free @@ -257,8 +257,7 @@ static void non_block_events(struct connection *co) client_search_response(cl); break; case ZOOM_EVENT_RECV_RECORD: - client_record_response(cl); - got_records = 1; + client_record_response(cl, &got_records); break; default: yaz_log(YLOG_LOG, "Unhandled event (%d) from %s", @@ -281,20 +280,7 @@ void connection_continue(struct connection *co) { int r = ZOOM_connection_exec_task(co->link); if (!r) - { - const char *error, *addinfo; - int err; - if ((err = ZOOM_connection_error(co->link, &error, &addinfo))) - { - if (co->client) - { - yaz_log(YLOG_LOG, "Error %s from %s", - error, client_get_id(co->client)); - client_set_diagnostic(co->client, err, error, addinfo); - client_set_state_nb(co->client, Client_Error); - } - } - } + non_block_events(co); else { iochan_setflags(co->iochan, ZOOM_connection_get_mask(co->link)); @@ -465,10 +451,11 @@ static int connection_connect(struct connection *con, iochan_man_t iochan_man) if (sru && *sru && !strstr(host->url, "://")) { - char http_hostport[512]; - strcpy(http_hostport, "http://"); - strcat(http_hostport, host->url); - ZOOM_connection_connect(con->link, http_hostport, 0); + WRBUF w = wrbuf_alloc(); + wrbuf_puts(w, "http://"); + wrbuf_puts(w, host->url); + ZOOM_connection_connect(con->link, wrbuf_cstr(w), 0); + wrbuf_destroy(w); } else {