X-Git-Url: http://git.indexdata.com/?p=yaz-moved-to-github.git;a=blobdiff_plain;f=src%2Fseshigh.c;h=a9e248e41a47c2d0aff229f4f78c31c769578c1b;hp=1949eb91b73984aa7d63dba4fc8210d7a34706ca;hb=75fff8a1c0b9deb4b402475a408fc69bc2b06a13;hpb=9782c90f15aaf9e68b404ddc8fa9b9a078e7df55 diff --git a/src/seshigh.c b/src/seshigh.c index 1949eb9..a9e248e 100644 --- a/src/seshigh.c +++ b/src/seshigh.c @@ -74,7 +74,7 @@ #include #include #include - +#include #include #include #include @@ -469,7 +469,8 @@ void ir_session(IOCHAN h, int event) } if (event & EVENT_EXCEPT) { - yaz_log(YLOG_WARN, "ir_session (exception)"); + if (assoc->state != ASSOC_DEAD) + yaz_log(YLOG_WARN, "ir_session (exception)"); cs_close(conn); destroy_association(assoc); iochan_destroy(h); @@ -1862,8 +1863,8 @@ static void process_http_request(association *assoc, request *req) if (sr->which == Z_SRW_searchRetrieve_request) { Z_SRW_PDU *res = - yaz_srw_get_pdu(assoc->encode, Z_SRW_searchRetrieve_response, - sr->srw_version); + yaz_srw_get_pdu_e(assoc->encode, Z_SRW_searchRetrieve_response, + sr); stylesheet = sr->u.request->stylesheet; if (num_diagnostic) { @@ -1879,8 +1880,7 @@ static void process_http_request(association *assoc, request *req) } else if (sr->which == Z_SRW_explain_request) { - Z_SRW_PDU *res = yaz_srw_get_pdu(o, Z_SRW_explain_response, - sr->srw_version); + Z_SRW_PDU *res = yaz_srw_get_pdu_e(o, Z_SRW_explain_response, sr); stylesheet = sr->u.explain_request->stylesheet; if (num_diagnostic) { @@ -1894,8 +1894,7 @@ static void process_http_request(association *assoc, request *req) } else if (sr->which == Z_SRW_scan_request) { - Z_SRW_PDU *res = yaz_srw_get_pdu(o, Z_SRW_scan_response, - sr->srw_version); + Z_SRW_PDU *res = yaz_srw_get_pdu_e(o, Z_SRW_scan_response, sr); stylesheet = sr->u.scan_request->stylesheet; if (num_diagnostic) { @@ -2500,7 +2499,8 @@ static Z_Records *pack_records(association *a, char *setname, Odr_int start, Z_ReferenceId *referenceId, Odr_oid *oid, int *errcode) { - int recno, dumped_records = 0; + int recno; + Odr_int dumped_records = 0; int toget = odr_int_to_int(*num); Z_Records *records = (Z_Records *) odr_malloc(a->encode, sizeof(*records)); @@ -2593,7 +2593,7 @@ static Z_Records *pack_records(association *a, char *setname, Odr_int start, else this_length = odr_total(a->encode) - total_length - dumped_records; yaz_log(log_requestdetail, " fetched record, len=" ODR_INT_PRINTF - " total=" ODR_INT_PRINTF " dumped=%d", + " total=" ODR_INT_PRINTF " dumped=" ODR_INT_PRINTF, this_length, total_length, dumped_records); if (a->preferredMessageSize > 0 && this_length + total_length > a->preferredMessageSize) @@ -2709,6 +2709,19 @@ static Z_APDU *process_searchRequest(association *assoc, request *reqb) bsrr->search_input = req->otherInfo; bsrr->present_number = *req->mediumSetPresentNumber; + if (assoc->server && assoc->server->client_query_charset && + req->query->which == Z_Query_type_1) + { + yaz_iconv_t cd = + yaz_iconv_open("UTF-8", assoc->server->client_query_charset); + if (cd) + { + yaz_query_charset_convert_rpnquery(req->query->u.type_1, + assoc->decode, cd); + yaz_iconv_close(cd); + } + } + if (assoc->server && assoc->server->cql_transform && req->query->which == Z_Query_type_104 && req->query->u.type_104->which == Z_External_CQL)