X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Fhttp_command.c;h=bb69bee438de2f4368384de25f587c369418924d;hb=18701a2fcad5171b03a76ceda18702831eb90850;hp=0ad6492e095554d345bb882d08d0dcffeec11275;hpb=aeca8671e89c5ade0a14aa95429632bd83772409;p=pazpar2-moved-to-github.git diff --git a/src/http_command.c b/src/http_command.c index 0ad6492..bb69bee 100644 --- a/src/http_command.c +++ b/src/http_command.c @@ -1,7 +1,5 @@ -/* $Id: http_command.c,v 1.58 2007-08-17 12:39:11 adam Exp $ - Copyright (c) 2006-2007, Index Data. - -This file is part of Pazpar2. +/* This file is part of Pazpar2. + Copyright (C) 2006-2008 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 @@ -14,31 +12,28 @@ FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License -along with Pazpar2; see the file LICENSE. If not, write to the -Free Software Foundation, 59 Temple Place - Suite 330, Boston, MA -02111-1307, USA. - */ +along with this program; if not, write to the Free Software +Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA -/* - * $Id: http_command.c,v 1.58 2007-08-17 12:39:11 adam Exp $ - */ +*/ +#if HAVE_CONFIG_H +#include +#endif #include #include -#include +#if HAVE_UNISTD_H #include +#endif #include -#include +#include #include +#if HAVE_SYS_TIME_H #include -#include -#if HAVE_CONFIG_H -#include #endif - +#include #include -#include "config.h" #include "util.h" #include "eventl.h" #include "pazpar2.h" @@ -139,20 +134,23 @@ static void error(struct http_response *rs, const char *addinfo) { struct http_channel *c = rs->channel; - char text[1024]; + WRBUF text = wrbuf_alloc(); const char *http_status = "417"; const char *msg = get_msg(code); - + rs->msg = nmem_strdup(c->nmem, msg); strcpy(rs->code, http_status); - yaz_snprintf(text, sizeof(text), - "%s", (int) code, - msg, addinfo ? addinfo : ""); + wrbuf_printf(text, "", (int) code, + msg); + if (addinfo) + wrbuf_xmlputs(text, addinfo); + wrbuf_puts(text, ""); yaz_log(YLOG_WARN, "HTTP %s %s%s%s", http_status, msg, addinfo ? ": " : "" , addinfo ? addinfo : ""); - rs->payload = nmem_strdup(c->nmem, text); + rs->payload = nmem_strdup(c->nmem, wrbuf_cstr(text)); + wrbuf_destroy(text); http_send_response(c); } @@ -166,6 +164,9 @@ unsigned int make_sessionid() res = seq; else { +#ifdef WIN32 + res = seq; +#else struct timeval t; if (gettimeofday(&t, 0) < 0) @@ -177,6 +178,7 @@ unsigned int make_sessionid() (long long would be more appropriate)*/ res = t.tv_sec; res = ((res << 8) | (seq & 0xff)) & ((1U << 31) - 1); +#endif } return res; } @@ -286,13 +288,13 @@ static int cmp_ht(const void *p1, const void *p2) } // This implements functionality somewhat similar to 'bytarget', but in a termlist form -static void targets_termlist(WRBUF wrbuf, struct session *se, int num) +static void targets_termlist(WRBUF wrbuf, struct session *se, int num, + NMEM nmem) { struct hitsbytarget *ht; int count, i; - if (!(ht = hitsbytarget(se, &count))) - return; + ht = hitsbytarget(se, &count, nmem); qsort(ht, count, sizeof(struct hitsbytarget), cmp_ht); for (i = 0; i < count && i < num && ht[i].hits > 0; i++) { @@ -367,7 +369,7 @@ static void cmd_termlist(struct http_channel *c) wrbuf_xmlputs(c->wrbuf, tname); wrbuf_puts(c->wrbuf, "\">\n"); if (!strcmp(tname, "xtargets")) - targets_termlist(c->wrbuf, s->psession, num); + targets_termlist(c->wrbuf, s->psession, num, c->nmem); else { p = termlist(s->psession, tname, &len); @@ -409,11 +411,7 @@ static void cmd_bytarget(struct http_channel *c) if (!s) return; - if (!(ht = hitsbytarget(s->psession, &count))) - { - error(rs, PAZPAR2_HITCOUNTS_FAILED, 0); - return; - } + ht = hitsbytarget(s->psession, &count, c->nmem); wrbuf_rewind(c->wrbuf); wrbuf_puts(c->wrbuf, "OK"); @@ -459,7 +457,7 @@ static void write_metadata(WRBUF w, struct conf_service *service, switch (cmd->type) { case Metadata_type_generic: - wrbuf_xmlputs(w, md->data.text); + wrbuf_xmlputs(w, md->data.text.disp); break; case Metadata_type_year: wrbuf_printf(w, "%d", md->data.number.min); @@ -517,12 +515,31 @@ static void show_raw_record_ok(void *data, const char *buf, size_t sz) http_send_response(c); } -void show_raw_reset(void *data, struct http_channel *c) + +static void show_raw_record_ok_binary(void *data, const char *buf, size_t sz) +{ + http_channel_observer_t obs = data; + struct http_channel *c = http_channel_observer_chan(obs); + struct http_response *rs = c->response; + + http_remove_observer(obs); + + wrbuf_write(c->wrbuf, buf, sz); + rs->payload = nmem_strdup(c->nmem, wrbuf_cstr(c->wrbuf)); + + rs->content_type = "application/octet-stream"; + http_send_response(c); +} + + +void show_raw_reset(void *data, struct http_channel *c, void *data2) { struct client *client = data; - client_show_raw_reset(client); + client_show_raw_remove(client, data2); } +static void cmd_record_ready(void *data); + static void cmd_record(struct http_channel *c) { struct http_response *rs = c->response; @@ -533,6 +550,7 @@ static void cmd_record(struct http_channel *c) struct conf_service *service = global_parameters.server->service; const char *idstr = http_argbyname(rq, "id"); const char *offsetstr = http_argbyname(rq, "offset"); + const char *binarystr = http_argbyname(rq, "binary"); if (!s) return; @@ -544,7 +562,11 @@ static void cmd_record(struct http_channel *c) wrbuf_rewind(c->wrbuf); if (!(rec = show_single(s->psession, idstr))) { - error(rs, PAZPAR2_RECORD_MISSING, idstr); + if (session_set_watch(s->psession, SESSION_WATCH_RECORD, + cmd_record_ready, c, c) != 0) + { + error(rs, PAZPAR2_RECORD_MISSING, idstr); + } return; } if (offsetstr) @@ -554,6 +576,10 @@ static void cmd_record(struct http_channel *c) const char *esn = http_argbyname(rq, "esn"); int i; struct record*r = rec->records; + int binary = 0; + + if (binarystr && *binarystr != '0') + binary = 1; for (i = 0; i < offset && r; r = r->next, i++) ; @@ -564,15 +590,22 @@ static void cmd_record(struct http_channel *c) } else { + void *data2; http_channel_observer_t obs = http_add_observer(c, r->client, show_raw_reset); - if (client_show_raw_begin(r->client, r->position, syntax, esn, + int ret = + client_show_raw_begin(r->client, r->position, syntax, esn, obs /* data */, show_raw_record_error, - show_raw_record_ok)) + (binary ? + show_raw_record_ok_binary : + show_raw_record_ok), + &data2, + (binary ? 1 : 0)); + if (ret == -1) { http_remove_observer(obs); - error(rs, PAZPAR2_RECORD_FAIL, "invalid parameters"); + error(rs, PAZPAR2_NO_SESSION, 0); return; } } @@ -590,6 +623,13 @@ static void cmd_record(struct http_channel *c) } } +static void cmd_record_ready(void *data) +{ + struct http_channel *c = (struct http_channel *) data; + + cmd_record(c); +} + static void show_records(struct http_channel *c, int active) { struct http_request *rq = c->request; @@ -682,13 +722,12 @@ static void cmd_show(struct http_channel *c) if (status && (!s->psession->reclist || !s->psession->reclist->num_records)) { // if there is already a watch/block. we do not block this one - if (session_set_watch(s->psession, - SESSION_WATCH_RECORDS, - show_records_ready, c, c) == 0) + if (session_set_watch(s->psession, SESSION_WATCH_SHOW, + show_records_ready, c, c) != 0) { yaz_log(YLOG_DEBUG, "Blocking on cmd_show"); - return; } + return; } }