/* This file is part of Pazpar2.
- Copyright (C) 2006-2008 Index Data
+ Copyright (C) 2006-2009 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
#if HAVE_UNISTD_H
#include <unistd.h>
#endif
-#if HAVE_SYS_SOCKET_H
-#include <sys/socket.h>
-#endif
-#ifdef WIN32
-#include <winsock.h>
-typedef int socklen_t;
-#endif
-#if HAVE_NETDB_H
-#include <netdb.h>
-#endif
#include <signal.h>
-#include <ctype.h>
#include <assert.h>
#include <yaz/log.h>
char *ibuf;
int ibufsize;
char *zproxy;
- int set_id_request;
- int set_id_response;
enum {
Conn_Resolving,
Conn_Connecting,
if (co->state != Conn_Open || !link)
return 0;
+ if (!ZOOM_connection_is_idle(link))
+ return 0;
event = ZOOM_connection_peek_event(link);
- if (event == ZOOM_EVENT_NONE ||
- event == ZOOM_EVENT_END)
+ if (event == ZOOM_EVENT_NONE || event == ZOOM_EVENT_END)
return 1;
else
return 0;
{
if (co->resultset)
ZOOM_resultset_destroy(co->resultset);
- co->set_id_request++;
co->resultset = rs;
}
new->link = 0;
new->resultset = 0;
new->state = Conn_Resolving;
- new->set_id_request = 0;
- new->set_id_response = 0;
if (host->ipport)
connection_connect(new);
return new;
if (!r)
break;
ev = ZOOM_connection_last_event(link);
+#if 0
+ yaz_log(YLOG_LOG, "ZOOM_EVENT_%s", ZOOM_get_event_str(ev));
+#endif
switch (ev)
{
case ZOOM_EVENT_END:
- if (co->set_id_request == co->set_id_response)
- client_set_state(co->client, Client_Idle);
+ {
+ const char *error, *addinfo;
+ if (ZOOM_connection_error(link, &error, &addinfo))
+ {
+ yaz_log(YLOG_LOG, "Error %s from %s",
+ error, client_get_url(cl));
+ }
+ client_set_state(cl, Client_Idle);
+ }
break;
case ZOOM_EVENT_SEND_DATA:
break;
case ZOOM_EVENT_CONNECT:
yaz_log(YLOG_LOG, "Connected to %s", client_get_url(cl));
co->state = Conn_Open;
- client_set_state(co->client, Client_Connected);
iochan_settimeout(iochan, global_parameters.z3950_session_timeout);
break;
case ZOOM_EVENT_RECV_SEARCH:
- co->set_id_response++;
- if (co->set_id_request == co->set_id_response)
- client_search_response(cl);
+ client_search_response(cl);
break;
case ZOOM_EVENT_RECV_RECORD:
- if (co->set_id_request == co->set_id_response)
- client_record_response(cl);
+ client_record_response(cl);
break;
default:
yaz_log(YLOG_LOG, "Unhandled event (%d) from %s",
if (sru && *sru)
strcpy(ipport, "http://");
strcat(ipport, host->ipport);
- /* deal with SRU path here because databaseName option is not read in
- ZOOM in SRU mode */
- if (sru && *sru)
- {
- if (*sdb->database->databases[0])
- {
- strcat(ipport, "/");
- strcat(ipport, sdb->database->databases[0]);
- }
- }
+
ZOOM_connection_connect(link, ipport, 0);
con->link = link;
connection_release(co);
client_set_connection(cl, co);
co->client = cl;
-#if 0
/* tells ZOOM to reconnect if necessary. Disabled becuase
the ZOOM_connection_connect flushes the task queue */
ZOOM_connection_connect(co->link, 0, 0);
-#endif
}
else
+ {
co = connection_create(cl);
+ }
}
if (co && co->link)
/*
* Local variables:
* c-basic-offset: 4
+ * c-file-style: "Stroustrup"
* indent-tabs-mode: nil
* End:
* vim: shiftwidth=4 tabstop=8 expandtab
*/
+