X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Ffilter_z3950_client.cpp;h=b93ecb2b1315286e27403be8e580bf379b8a9be9;hb=e0274b6e40958df2e422b1e3db69a9bc710f5357;hp=2d9e6a64a2e70680dabc346228dde055326b4d22;hpb=e1c7fdb3e2ff41fb43ea3dd2c540b6d568dee851;p=metaproxy-moved-to-github.git diff --git a/src/filter_z3950_client.cpp b/src/filter_z3950_client.cpp index 2d9e6a6..b93ecb2 100644 --- a/src/filter_z3950_client.cpp +++ b/src/filter_z3950_client.cpp @@ -1,5 +1,5 @@ -/* $Id: filter_z3950_client.cpp,v 1.28 2006-08-30 12:27:34 adam Exp $ - Copyright (c) 2005-2006, Index Data. +/* $Id: filter_z3950_client.cpp,v 1.30 2007-01-26 14:49:22 adam Exp $ + Copyright (c) 2005-2007, Index Data. See the LICENSE file for details */ @@ -64,6 +64,8 @@ namespace metaproxy_1 { public: // number of seconds to wait before we give up request int m_timeout_sec; + std::string m_default_target; + std::string m_force_target; boost::mutex m_mutex; boost::condition m_cond_session_ready; std::map m_clients; @@ -226,34 +228,48 @@ yf::Z3950Client::Assoc *yf::Z3950Client::Rep::get_assoc(Package &package) package.session().close(); return 0; } - std::list vhosts; - mp::util::remove_vhost_otherinfo(&apdu->u.initRequest->otherInfo, vhosts); - size_t no_vhosts = vhosts.size(); - if (no_vhosts == 0) + std::string target = m_force_target; + if (!target.length()) { - mp::odr odr; - package.response() = odr.create_initResponse( - apdu, - YAZ_BIB1_INIT_NEGOTIATION_OPTION_REQUIRED, - "z3950_client: No virtal host given"); - - package.session().close(); - return 0; - } - if (no_vhosts > 1) - { - mp::odr odr; - package.response() = odr.create_initResponse( - apdu, - YAZ_BIB1_COMBI_OF_SPECIFIED_DATABASES_UNSUPP, - "z3950_client: Can not cope with multiple vhosts"); - package.session().close(); - return 0; + target = m_default_target; + std::list vhosts; + mp::util::remove_vhost_otherinfo(&apdu->u.initRequest->otherInfo, + vhosts); + size_t no_vhosts = vhosts.size(); + if (no_vhosts == 1) + { + std::list::const_iterator v_it = vhosts.begin(); + target = *v_it; + } + else if (no_vhosts == 0) + { + if (!target.length()) + { + // no default target. So we don't know where to connect + mp::odr odr; + package.response() = odr.create_initResponse( + apdu, + YAZ_BIB1_INIT_NEGOTIATION_OPTION_REQUIRED, + "z3950_client: No virtal host given"); + + package.session().close(); + return 0; + } + } + else if (no_vhosts > 1) + { + mp::odr odr; + package.response() = odr.create_initResponse( + apdu, + YAZ_BIB1_COMBI_OF_SPECIFIED_DATABASES_UNSUPP, + "z3950_client: Can not cope with multiple vhosts"); + package.session().close(); + return 0; + } } - std::list::const_iterator v_it = vhosts.begin(); std::list dblist; std::string host; - mp::util::split_zurl(*v_it, host, dblist); + mp::util::split_zurl(target, host, dblist); if (dblist.size()) { @@ -374,6 +390,14 @@ void yf::Z3950Client::configure(const xmlNode *ptr) { m_p->m_timeout_sec = mp::xml::get_int(ptr->children, 30); } + else if (!strcmp((const char *) ptr->name, "default_target")) + { + m_p->m_default_target = mp::xml::get_text(ptr); + } + else if (!strcmp((const char *) ptr->name, "force_target")) + { + m_p->m_force_target = mp::xml::get_text(ptr); + } else { throw mp::filter::FilterException("Bad element "