X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Fhttp_command.c;h=eecf63d5e3dea05ab8d0802dafa9264038e5468e;hb=419a9b497318d051f7b1dd6b1d123a7ee31a7ee0;hp=4800d2281a1011319af48f5f1ff1492a2eaff9ad;hpb=f047ea779e7380066483f9ab8edea5e857734ec9;p=pazpar2-moved-to-github.git diff --git a/src/http_command.c b/src/http_command.c index 4800d22..eecf63d 100644 --- a/src/http_command.c +++ b/src/http_command.c @@ -33,6 +33,7 @@ Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA #include #include +#include "ppmutex.h" #include "eventl.h" #include "parameters.h" #include "session.h" @@ -67,7 +68,7 @@ http_sessions_t http_sessions_create(void) http_sessions_t hs = xmalloc(sizeof(*hs)); hs->session_list = 0; hs->mutex = 0; - yaz_mutex_create(&hs->mutex); + pazpar2_mutex_create(&hs->mutex, "http_sessions"); return hs; } @@ -98,13 +99,16 @@ static void session_timeout(IOCHAN i, int event) } struct http_session *http_session_create(struct conf_service *service, - http_sessions_t http_sessions) + http_sessions_t http_sessions, + unsigned int sesid) { NMEM nmem = nmem_create(); struct http_session *r = nmem_malloc(nmem, sizeof(*r)); + char tmp_str[50]; - r->psession = new_session(nmem, service); - r->session_id = 0; + sprintf(tmp_str, "session#%u", sesid); + r->psession = new_session(nmem, service, tmp_str); + r->session_id = sesid; r->timestamp = 0; r->nmem = nmem; r->destroy_counter = r->activity_counter = 0; @@ -115,7 +119,7 @@ struct http_session *http_session_create(struct conf_service *service, http_sessions->session_list = r; yaz_mutex_leave(http_sessions->mutex); - r->timeout_iochan = iochan_create(-1, session_timeout, 0); + r->timeout_iochan = iochan_create(-1, session_timeout, 0, "http_session_timeout"); iochan_setdata(r->timeout_iochan, r); yaz_log(YLOG_LOG, "timeout=%d", service->session_timeout); iochan_settimeout(r->timeout_iochan, service->session_timeout); @@ -360,7 +364,8 @@ static void cmd_init(struct http_channel *c) return; } } - s = http_session_create(service, c->http_sessions); + sesid = make_sessionid(); + s = http_session_create(service, c->http_sessions, sesid); yaz_log(YLOG_DEBUG, "HTTP Session init"); if (!clear || *clear == '0') @@ -368,13 +373,11 @@ static void cmd_init(struct http_channel *c) else yaz_log(YLOG_LOG, "No databases preloaded"); - sesid = make_sessionid(); - s->session_id = sesid; if (process_settings(s->psession, c->request, c->response) < 0) return; sprintf(buf, HTTP_COMMAND_RESPONSE_PREFIX - "OK%u", sesid); + "OK%d", sesid); if (c->server->server_id) { strcat(buf, ".");