X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Fhttp.h;h=1067e85080adc80490c7b3d3cb1ef37b9d85fd0a;hb=c61904671e969a32a7f9d38a523f7abaa2b371fd;hp=2a5d1fe9f10df6d7c5df206766870a68d5966cbf;hpb=ba5951a80fdd0da1d28c318852b69a1178cd6bfa;p=pazpar2-moved-to-github.git diff --git a/src/http.h b/src/http.h index 2a5d1fe..1067e85 100644 --- a/src/http.h +++ b/src/http.h @@ -1,5 +1,5 @@ /* This file is part of Pazpar2. - Copyright (C) 2006-2010 Index Data + Copyright (C) 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 @@ -20,19 +20,17 @@ Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA #ifndef HTTP_H #define HTTP_H +#include +#include + #include "eventl.h" // Generic I/O buffer -struct http_buf -{ -#define HTTP_BUF_SIZE 4096 - char buf[4096]; - int offset; - int len; - struct http_buf *next; -}; - +struct http_buf; typedef struct http_channel_observer_s *http_channel_observer_t; +typedef struct http_server *http_server_t; +typedef struct http_sessions *http_sessions_t; + struct http_channel { IOCHAN iochan; @@ -48,12 +46,15 @@ struct http_channel int keep_alive; NMEM nmem; WRBUF wrbuf; + yaz_timing_t yt; struct http_request *request; struct http_response *response; struct http_channel *next; // for freelist - char addr[20]; // forwarded address + char addr[256]; // forwarded address http_channel_observer_t observers; struct conf_server *server; + http_server_t http_server; + http_sessions_t http_sessions; }; struct http_proxy // attached to iochan for proxy connection @@ -101,16 +102,19 @@ struct http_response char *content_type; }; +void http_mutex_init(struct conf_server *server); +void http_server_destroy(http_server_t hs); + void http_set_proxyaddr(const char *url, struct conf_server *ser); -int http_init(const char *addr, struct conf_server *ser); +int http_init(struct conf_server *ser, const char *record_fname); void http_close_server(struct conf_server *ser); -void http_addheader(struct http_response *r, +void http_addheader(struct http_response *r, const char *name, const char *value); const char *http_lookup_header(struct http_header *header, const char *name); -struct http_header * http_header_append(struct http_channel *ch, - struct http_header * hp, - const char *name, +struct http_header * http_header_append(struct http_channel *ch, + struct http_header * hp, + const char *name, const char *value); const char *http_argbyname(struct http_request *r, const char *name); const char *http_headerbyname(struct http_header *r, const char *name); @@ -130,6 +134,9 @@ struct http_channel *http_channel_observer_chan(http_channel_observer_t obs); void http_command(struct http_channel *c); +http_sessions_t http_sessions_create(void); +void http_sessions_destroy(http_sessions_t hs); + #endif /*