X-Git-Url: http://jsfdemo.indexdata.com/?a=blobdiff_plain;f=pazpar2.c;h=13b9b6c9904ab5c7f920a6ea599009f008faa8f6;hb=e4fd74330d18b5c167f2a83ac50233b7c68f7ece;hp=a1d939a5fb5f2257c75181626135c3a23a2855aa;hpb=2ee0feea4b202416cc08b8edbcc4ea6b9a691a3b;p=pazpar2-moved-to-github.git diff --git a/pazpar2.c b/pazpar2.c index a1d939a..13b9b6c 100644 --- a/pazpar2.c +++ b/pazpar2.c @@ -1,4 +1,4 @@ -/* $Id: pazpar2.c,v 1.9 2006-12-04 02:27:02 quinn Exp $ */; +/* $Id: pazpar2.c,v 1.15 2006-12-18 14:37:21 sondberg Exp $ */; #include #include @@ -17,8 +17,6 @@ #include #include #include -#include -#include #include "pazpar2.h" #include "eventl.h" @@ -35,8 +33,9 @@ static void client_fatal(struct client *cl); static void connection_destroy(struct connection *co); static int client_prep_connection(struct client *cl); static void ingest_records(struct client *cl, Z_Records *r); +void session_alert_watch(struct session *s, int what); -IOCHAN channel_list = 0; // Master list of connections we're listening to. +IOCHAN channel_list = 0; // Master list of connections we're handling events to static struct connection *connection_freelist = 0; static struct client *client_freelist = 0; @@ -57,25 +56,14 @@ static char *client_states[] = { "Client_Stopped" }; -static struct parameters { - int timeout; /* operations timeout, in seconds */ - char implementationId[128]; - char implementationName[128]; - char implementationVersion[128]; - int target_timeout; // seconds - int toget; - int chunk; - CCL_bibset ccl_filter; - yaz_marc_t yaz_marc; - ODR odr_out; - ODR odr_in; -} global_parameters = +struct parameters global_parameters = { 30, "81", "Index Data PazPar2 (MasterKey)", PAZPAR2_VERSION, 600, // 10 minutes + 60, 100, MAX_CHUNK, 0, @@ -359,11 +347,11 @@ char *extract_title(struct session *s, const char *rec) } } wrbuf_putc(s->wrbuf, '\0'); - obuf = nmem_strdup(s->nmem, wrbuf_buf(s->wrbuf)); + obuf = (unsigned char*) nmem_strdup(s->nmem, wrbuf_buf(s->wrbuf)); for (p = obuf; *p; p++) if (*p == '&' || *p == '<' || *p > 122 || *p < ' ') *p = ' '; - return obuf; + return (char*) obuf; } // Extract 245 $a $b 100 $a @@ -651,6 +639,7 @@ static struct record *ingest_record(struct client *cl, char *buf, int len) static void ingest_records(struct client *cl, Z_Records *r) { struct record *rec; + struct session *s = cl->session; Z_NamePlusRecordList *rlist; int i; @@ -682,6 +671,8 @@ static void ingest_records(struct client *cl, Z_Records *r) if (!rec) continue; } + if (s->watchlist[SESSION_WATCH_RECORDS].fun && rlist->num_records) + session_alert_watch(s, SESSION_WATCH_RECORDS); } static void do_presentResponse(IOCHAN i, Z_APDU *a) @@ -749,12 +740,14 @@ static void handler(IOCHAN i, int event) if (len < 0) { - client_fatal(cl); + yaz_log(YLOG_WARN|YLOG_ERRNO, "Error reading from Z server"); + connection_destroy(co); return; } else if (len == 0) { - client_fatal(cl); + yaz_log(YLOG_WARN, "EOF reading from Z server"); + connection_destroy(co); return; } else if (len > 1) // We discard input if we have no connection @@ -983,7 +976,7 @@ void load_simpletargets(const char *fn) continue; url = line + 7; url[strlen(url) - 1] = '\0'; - yaz_log(LOG_DEBUG, "Target: %s", url); + yaz_log(YLOG_DEBUG, "Target: %s", url); if ((db = strchr(url, '/'))) *(db++) = '\0'; else @@ -1121,11 +1114,26 @@ void client_destroy(struct client *c) cc->next = c->next; } if (c->connection) - connection_destroy(c->connection); + connection_release(c->connection); c->next = client_freelist; client_freelist = c; } +void session_set_watch(struct session *s, int what, session_watchfun fun, void *data) +{ + s->watchlist[what].fun = fun; + s->watchlist[what].data = data; +} + +void session_alert_watch(struct session *s, int what) +{ + if (!s->watchlist[what].fun) + return; + (*s->watchlist[what].fun)(s->watchlist[what].data); + s->watchlist[what].fun = 0; + s->watchlist[what].data = 0; +} + // This should be extended with parameters to control selection criteria // Associates a set of clients with a session; int select_targets(struct session *se) @@ -1182,8 +1190,18 @@ char *search(struct session *se, char *query) return 0; } +void destroy_session(struct session *s) +{ + yaz_log(YLOG_LOG, "Destroying session"); + while (s->clients) + client_destroy(s->clients); + nmem_destroy(s->nmem); + wrbuf_free(s->wrbuf, 1); +} + struct session *new_session() { + int i; struct session *session = xmalloc(sizeof(*session)); yaz_log(YLOG_DEBUG, "New pazpar2 session"); @@ -1197,17 +1215,17 @@ struct session *new_session() session->query[0] = '\0'; session->nmem = nmem_create(); session->wrbuf = wrbuf_alloc(); + for (i = 0; i <= SESSION_WATCH_MAX; i++) + { + session->watchlist[i].data = 0; + session->watchlist[i].fun = 0; + } select_targets(session); return session; } -void session_destroy(struct session *s) -{ - // FIXME do some shit here!!!! -} - struct hitsbytarget *hitsbytarget(struct session *se, int *count) { static struct hitsbytarget res[1000]; // FIXME MM @@ -1307,6 +1325,7 @@ int main(int argc, char **argv) { int ret; char *arg; + int setport = 0; if (signal(SIGPIPE, SIG_IGN) < 0) yaz_log(YLOG_WARN|YLOG_ERRNO, "signal"); @@ -1316,16 +1335,16 @@ int main(int argc, char **argv) while ((ret = options("c:h:p:C:s:", argv, argc, &arg)) != -2) { switch (ret) { - case 0: - break; case 'c': command_init(atoi(arg)); + setport++; break; - case 'C': - global_parameters.ccl_filter = load_cclfile(arg); - break; case 'h': http_init(atoi(arg)); + setport++; + break; + case 'C': + global_parameters.ccl_filter = load_cclfile(arg); break; case 'p': http_set_proxyaddr(arg); @@ -1334,11 +1353,22 @@ int main(int argc, char **argv) load_simpletargets(arg); break; default: - fprintf(stderr, "Usage: pazpar2 -d comport"); + fprintf(stderr, "Usage: pazpar2\n" + " -h httpport (REST)\n" + " -c cmdport (telnet-style)\n" + " -C cclconfig\n" + " -s simpletargetfile\n" + " -p hostname[:portno] (HTTP proxy)\n"); exit(1); } } + if (!setport) + { + fprintf(stderr, "Set command port with -h or -c\n"); + exit(1); + } + global_parameters.ccl_filter = load_cclfile("default.bib"); global_parameters.yaz_marc = yaz_marc_create(); yaz_marc_subfield_str(global_parameters.yaz_marc, "\t");