X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=include%2Fyaz%2B%2B%2Fproxy.h;h=aafef3cc8bb244a2c3534ab3ba0e59c7e3cd8bde;hb=598464a40f5eea658ae9afafab11e5eaf0c1124c;hp=a2d8819f6450f85ab0557507ef5af5e0aea2acb1;hpb=efb41657fc33883e6520fa571c5a944106271ec5;p=yazpp-moved-to-github.git diff --git a/include/yaz++/proxy.h b/include/yaz++/proxy.h index a2d8819..aafef3c 100644 --- a/include/yaz++/proxy.h +++ b/include/yaz++/proxy.h @@ -2,7 +2,7 @@ * Copyright (c) 1998-2004, Index Data. * See the file LICENSE for details. * - * $Id: proxy.h,v 1.32 2004-01-08 22:54:52 adam Exp $ + * $Id: proxy.h,v 1.41 2004-02-27 00:42:57 adam Exp $ */ #include @@ -13,6 +13,8 @@ #if HAVE_XSLT #include #include +#include +#include #endif class Yaz_Proxy; @@ -91,7 +93,6 @@ private: int m_copy; int match_list(int v, const char *m); int atoi_l(const char **cp); - }; class YAZ_EXPORT Yaz_RecordCache { @@ -167,6 +168,10 @@ class YAZ_EXPORT Yaz_ProxyClient : public Yaz_Z_Assoc { int m_pdu_recv; ODR m_init_odr; Z_APDU *m_initResponse; + Z_Options *m_initResponse_options; + Z_ProtocolVersion *m_initResponse_version; + int m_initResponse_preferredMessageSize; + int m_initResponse_maximumRecordSize; Yaz_RecordCache m_cache; void pre_init_client(); int m_target_idletime; @@ -238,19 +243,28 @@ class YAZ_EXPORT Yaz_Proxy : public Yaz_Z_Assoc { int m_request_no; int m_invalid_session; int m_marcxml_flag; - char *m_stylesheet_schema; + xsltStylesheetPtr m_stylesheet_xsp; + int m_stylesheet_offset; + Z_APDU *m_stylesheet_apdu; + Z_NamePlusRecordList *m_stylesheet_nprl; char *m_schema; void convert_to_marcxml(Z_NamePlusRecordList *p); - void convert_xsl(Z_NamePlusRecordList *p); + int convert_xsl(Z_NamePlusRecordList *p, Z_APDU *apdu); + void convert_xsl_delay(); Z_APDU *m_initRequest_apdu; + int m_initRequest_preferredMessageSize; + int m_initRequest_maximumRecordSize; + Z_Options *m_initRequest_options; + Z_ProtocolVersion *m_initRequest_version; NMEM m_initRequest_mem; Z_APDU *m_apdu_invalid_session; NMEM m_mem_invalid_session; - int send_PDU_convert(Z_APDU *apdu, int *len); + int send_PDU_convert(Z_APDU *apdu); ODR m_s2z_odr_init; ODR m_s2z_odr_search; int m_s2z_hit_count; int m_s2z_packing; + char *m_s2z_database; Z_APDU *m_s2z_init_apdu; Z_APDU *m_s2z_search_apdu; Z_APDU *m_s2z_present_apdu; @@ -260,8 +274,8 @@ class YAZ_EXPORT Yaz_Proxy : public Yaz_Z_Assoc { int send_to_srw_client_ok(int hits, Z_Records *records, int start); int send_http_response(int code); int send_srw_response(Z_SRW_PDU *srw_pdu); - int send_srw_explain(); - + int send_srw_explain_response(Z_SRW_diagnostic *diagnostics, + int num_diagnostics); int z_to_srw_diag(ODR o, Z_SRW_searchRetrieveResponse *srw_res, Z_DefaultDiagFormat *ddf); int m_http_keepalive; @@ -270,6 +284,12 @@ class YAZ_EXPORT Yaz_Proxy : public Yaz_Z_Assoc { struct timeval m_time_tv; void logtime(); Z_ElementSetNames *mk_esn_from_schema(ODR o, const char *schema); + Z_ReferenceId *m_referenceId; + NMEM m_referenceId_mem; +#define NO_SPARE_SOLARIS_FD 10 + int m_lo_fd[NO_SPARE_SOLARIS_FD]; + void low_socket_open(); + void low_socket_close(); public: Yaz_Proxy(IYaz_PDU_Observable *the_PDU_Observable, Yaz_Proxy *parent = 0); @@ -283,6 +303,7 @@ class YAZ_EXPORT Yaz_Proxy : public Yaz_Z_Assoc { void failNotify(); void timeoutNotify(); void connectNotify(); + void markInvalid(); const char *option(const char *name, const char *value); void set_default_target(const char *target); void set_proxy_authentication (const char *auth);