1 /* $Id: filter_session_shared.cpp,v 1.20 2008-02-20 15:07:52 adam Exp $
2 Copyright (c) 2005-2007, Index Data.
4 This file is part of Metaproxy.
6 Metaproxy is free software; you can redistribute it and/or modify it under
7 the terms of the GNU General Public License as published by the Free
8 Software Foundation; either version 2, or (at your option) any later
11 Metaproxy is distributed in the hope that it will be useful, but WITHOUT ANY
12 WARRANTY; without even the implied warranty of MERCHANTABILITY or
13 FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
16 You should have received a copy of the GNU General Public License
17 along with Metaproxy; see the file LICENSE. If not, write to the
18 Free Software Foundation, 59 Temple Place - Suite 330, Boston, MA
25 #include "package.hpp"
27 #include <boost/thread/mutex.hpp>
28 #include <boost/thread/condition.hpp>
29 #include <boost/thread/thread.hpp>
30 #include <boost/thread/xtime.hpp>
31 #include <boost/shared_ptr.hpp>
32 #include <boost/format.hpp>
35 #include "filter_session_shared.hpp"
39 #include <yaz/otherinfo.h>
40 #include <yaz/diagbib1.h>
41 #include <yazpp/z-query.h>
46 namespace mp = metaproxy_1;
47 namespace yf = metaproxy_1::filter;
49 namespace metaproxy_1 {
52 class SessionShared::InitKey {
54 bool operator < (const SessionShared::InitKey &k) const;
55 InitKey(Z_InitRequest *req);
56 InitKey(const InitKey &);
59 InitKey &operator = (const InitKey &k);
60 char *m_idAuthentication_buf;
61 int m_idAuthentication_size;
62 char *m_otherInfo_buf;
66 class SessionShared::Worker {
68 Worker(SessionShared::Rep *rep);
69 void operator() (void);
71 SessionShared::Rep *m_p;
73 class SessionShared::BackendSet {
75 std::string m_result_set_id;
76 Databases m_databases;
77 int m_result_set_size;
78 yazpp_1::Yaz_Z_Query m_query;
79 time_t m_time_last_use;
82 const std::string &result_set_id,
83 const Databases &databases,
84 const yazpp_1::Yaz_Z_Query &query);
86 Package &frontend_package,
87 const Z_APDU *apdu_req,
88 const BackendInstancePtr bp);
90 class SessionShared::BackendInstance {
92 friend class BackendClass;
93 friend class BackendSet;
95 mp::Session m_session;
96 BackendSetList m_sets;
99 int m_result_set_sequence;
100 time_t m_time_last_use;
101 mp::Package * m_close_package;
104 class SessionShared::BackendClass : boost::noncopyable {
106 friend struct Frontend;
107 bool m_named_result_sets;
108 BackendInstanceList m_backend_list;
109 BackendInstancePtr create_backend(const Package &package);
110 void remove_backend(BackendInstancePtr b);
111 BackendInstancePtr get_backend(const Package &package);
112 void use_backend(BackendInstancePtr b);
113 void release_backend(BackendInstancePtr b);
115 yazpp_1::GDU m_init_request;
116 yazpp_1::GDU m_init_response;
117 boost::mutex m_mutex_backend_class;
119 time_t m_backend_set_ttl;
120 time_t m_backend_expiry_ttl;
121 size_t m_backend_set_max;
123 BackendClass(const yazpp_1::GDU &init_request,
129 class SessionShared::FrontendSet {
130 Databases m_databases;
131 yazpp_1::Yaz_Z_Query m_query;
133 const Databases &get_databases();
134 const yazpp_1::Yaz_Z_Query &get_query();
136 const Databases &databases,
137 const yazpp_1::Yaz_Z_Query &query);
140 struct SessionShared::Frontend {
145 Z_Options m_init_options;
146 void search(Package &package, Z_APDU *apdu);
147 void present(Package &package, Z_APDU *apdu);
148 void scan(Package &package, Z_APDU *apdu);
150 void get_set(mp::Package &package,
151 const Z_APDU *apdu_req,
152 const Databases &databases,
153 yazpp_1::Yaz_Z_Query &query,
154 BackendInstancePtr &found_backend,
155 BackendSetPtr &found_set);
156 void override_set(BackendInstancePtr &found_backend,
157 std::string &result_set_id);
160 BackendClassPtr m_backend_class;
161 FrontendSets m_frontend_sets;
163 class SessionShared::Rep {
164 friend class SessionShared;
165 friend struct Frontend;
167 FrontendPtr get_frontend(Package &package);
168 void release_frontend(Package &package);
173 void init(Package &package, const Z_GDU *gdu,
174 FrontendPtr frontend);
175 boost::mutex m_mutex;
176 boost::condition m_cond_session_ready;
177 std::map<mp::Session, FrontendPtr> m_clients;
179 BackendClassMap m_backend_map;
180 boost::mutex m_mutex_backend_map;
181 boost::thread_group m_thrds;
189 yf::SessionShared::FrontendSet::FrontendSet(
190 const Databases &databases,
191 const yazpp_1::Yaz_Z_Query &query)
192 : m_databases(databases), m_query(query)
196 const yf::SessionShared::Databases &
197 yf::SessionShared::FrontendSet::get_databases()
202 const yazpp_1::Yaz_Z_Query& yf::SessionShared::FrontendSet::get_query()
207 yf::SessionShared::InitKey::InitKey(const InitKey &k)
209 m_odr = odr_createmem(ODR_ENCODE);
211 m_idAuthentication_size = k.m_idAuthentication_size;
212 m_idAuthentication_buf = (char*)odr_malloc(m_odr, m_idAuthentication_size);
213 memcpy(m_idAuthentication_buf, k.m_idAuthentication_buf,
214 m_idAuthentication_size);
216 m_otherInfo_size = k.m_otherInfo_size;
217 m_otherInfo_buf = (char*)odr_malloc(m_odr, m_otherInfo_size);
218 memcpy(m_otherInfo_buf, k.m_otherInfo_buf,
222 yf::SessionShared::InitKey::InitKey(Z_InitRequest *req)
224 m_odr = odr_createmem(ODR_ENCODE);
226 Z_IdAuthentication *t = req->idAuthentication;
227 z_IdAuthentication(m_odr, &t, 1, 0);
228 m_idAuthentication_buf =
229 odr_getbuf(m_odr, &m_idAuthentication_size, 0);
231 Z_OtherInformation *o = req->otherInfo;
232 z_OtherInformation(m_odr, &o, 1, 0);
233 m_otherInfo_buf = odr_getbuf(m_odr, &m_otherInfo_size, 0);
236 yf::SessionShared::InitKey::~InitKey()
241 bool yf::SessionShared::InitKey::operator < (const SessionShared::InitKey &k)
245 c = mp::util::memcmp2(
246 (void*) m_idAuthentication_buf, m_idAuthentication_size,
247 (void*) k.m_idAuthentication_buf, k.m_idAuthentication_size);
253 c = mp::util::memcmp2((void*) m_otherInfo_buf, m_otherInfo_size,
254 (void*) k.m_otherInfo_buf, k.m_otherInfo_size);
262 void yf::SessionShared::BackendClass::release_backend(BackendInstancePtr b)
264 boost::mutex::scoped_lock lock(m_mutex_backend_class);
269 void yf::SessionShared::BackendClass::remove_backend(BackendInstancePtr b)
271 BackendInstanceList::iterator it = m_backend_list.begin();
273 while (it != m_backend_list.end())
276 it = m_backend_list.erase(it);
284 yf::SessionShared::BackendInstancePtr
285 yf::SessionShared::BackendClass::get_backend(
286 const mp::Package &frontend_package)
289 boost::mutex::scoped_lock lock(m_mutex_backend_class);
291 BackendInstanceList::const_iterator it = m_backend_list.begin();
293 BackendInstancePtr backend1; // null
295 for (; it != m_backend_list.end(); it++)
297 if (!(*it)->m_in_use)
300 || (*it)->m_sequence_this < backend1->m_sequence_this)
306 use_backend(backend1);
310 return create_backend(frontend_package);
313 void yf::SessionShared::BackendClass::use_backend(BackendInstancePtr backend)
315 backend->m_in_use = true;
316 time(&backend->m_time_last_use);
317 backend->m_sequence_this = m_sequence_top++;
320 yf::SessionShared::BackendInstance::~BackendInstance()
322 delete m_close_package;
325 yf::SessionShared::BackendInstancePtr yf::SessionShared::BackendClass::create_backend(
326 const mp::Package &frontend_package)
328 BackendInstancePtr bp(new BackendInstance);
329 BackendInstancePtr null;
331 bp->m_close_package =
332 new mp::Package(bp->m_session, frontend_package.origin());
333 bp->m_close_package->copy_filter(frontend_package);
335 Package init_package(bp->m_session, frontend_package.origin());
337 init_package.copy_filter(frontend_package);
339 yazpp_1::GDU actual_init_request = m_init_request;
340 Z_GDU *init_pdu = actual_init_request.get();
342 assert(init_pdu->which == Z_GDU_Z3950);
343 assert(init_pdu->u.z3950->which == Z_APDU_initRequest);
345 Z_InitRequest *req = init_pdu->u.z3950->u.initRequest;
346 ODR_MASK_ZERO(req->options);
348 ODR_MASK_SET(req->options, Z_Options_search);
349 ODR_MASK_SET(req->options, Z_Options_present);
350 ODR_MASK_SET(req->options, Z_Options_namedResultSets);
351 ODR_MASK_SET(req->options, Z_Options_scan);
353 ODR_MASK_SET(req->protocolVersion, Z_ProtocolVersion_1);
354 ODR_MASK_SET(req->protocolVersion, Z_ProtocolVersion_2);
355 ODR_MASK_SET(req->protocolVersion, Z_ProtocolVersion_3);
357 init_package.request() = init_pdu;
361 boost::mutex::scoped_lock lock(m_mutex_backend_class);
363 m_named_result_sets = false;
364 Z_GDU *gdu = init_package.response().get();
365 if (!init_package.session().is_closed()
366 && gdu && gdu->which == Z_GDU_Z3950
367 && gdu->u.z3950->which == Z_APDU_initResponse)
369 Z_InitResponse *res = gdu->u.z3950->u.initResponse;
372 m_init_response = gdu->u.z3950;
373 if (ODR_MASK_GET(res->options, Z_Options_namedResultSets))
375 m_named_result_sets = true;
380 // did not receive an init response or closed
384 time(&bp->m_time_last_use);
385 bp->m_sequence_this = 0;
386 bp->m_result_set_sequence = 0;
387 m_backend_list.push_back(bp);
393 yf::SessionShared::BackendClass::BackendClass(const yazpp_1::GDU &init_request,
397 : m_named_result_sets(false), m_init_request(init_request),
398 m_sequence_top(0), m_backend_set_ttl(resultset_ttl),
399 m_backend_expiry_ttl(session_ttl), m_backend_set_max(resultset_max)
402 yf::SessionShared::BackendClass::~BackendClass()
405 void yf::SessionShared::Rep::init(mp::Package &package, const Z_GDU *gdu,
406 FrontendPtr frontend)
408 Z_InitRequest *req = gdu->u.z3950->u.initRequest;
410 frontend->m_is_virtual = true;
411 frontend->m_init_options = *req->options;
414 boost::mutex::scoped_lock lock(m_mutex_backend_map);
415 BackendClassMap::const_iterator it;
416 it = m_backend_map.find(k);
417 if (it == m_backend_map.end())
419 BackendClassPtr b(new BackendClass(gdu->u.z3950,
423 m_backend_map[k] = b;
424 frontend->m_backend_class = b;
428 frontend->m_backend_class = it->second;
431 BackendClassPtr bc = frontend->m_backend_class;
432 BackendInstancePtr backend = bc->get_backend(package);
437 Z_APDU *apdu = odr.create_initResponse(gdu->u.z3950, 0, 0);
438 *apdu->u.initResponse->result = 0;
439 package.response() = apdu;
440 package.session().close();
444 boost::mutex::scoped_lock lock(bc->m_mutex_backend_class);
445 yazpp_1::GDU init_response = bc->m_init_response;
446 Z_GDU *response_gdu = init_response.get();
447 mp::util::transfer_referenceId(odr, gdu->u.z3950,
448 response_gdu->u.z3950);
450 Z_Options *server_options =
451 response_gdu->u.z3950->u.initResponse->options;
452 Z_Options *client_options = &frontend->m_init_options;
455 for (i = 0; i<30; i++)
456 if (!ODR_MASK_GET(client_options, i))
457 ODR_MASK_CLEAR(server_options, i);
458 package.response() = init_response;
461 bc->release_backend(backend);
464 void yf::SessionShared::BackendSet::timestamp()
466 time(&m_time_last_use);
469 yf::SessionShared::BackendSet::BackendSet(
470 const std::string &result_set_id,
471 const Databases &databases,
472 const yazpp_1::Yaz_Z_Query &query) :
473 m_result_set_id(result_set_id),
474 m_databases(databases), m_result_set_size(0), m_query(query)
479 bool yf::SessionShared::BackendSet::search(
480 mp::Package &frontend_package,
481 const Z_APDU *frontend_apdu,
482 const BackendInstancePtr bp)
484 Package search_package(bp->m_session, frontend_package.origin());
486 search_package.copy_filter(frontend_package);
489 Z_APDU *apdu_req = zget_APDU(odr, Z_APDU_searchRequest);
490 Z_SearchRequest *req = apdu_req->u.searchRequest;
492 req->resultSetName = odr_strdup(odr, m_result_set_id.c_str());
493 req->query = m_query.get_Z_Query();
495 req->num_databaseNames = m_databases.size();
496 req->databaseNames = (char**)
497 odr_malloc(odr, req->num_databaseNames * sizeof(char *));
498 Databases::const_iterator it = m_databases.begin();
500 for (; it != m_databases.end(); it++)
501 req->databaseNames[i++] = odr_strdup(odr, it->c_str());
503 search_package.request() = apdu_req;
505 search_package.move();
507 Z_Records *z_records_diag = 0;
508 Z_GDU *gdu = search_package.response().get();
509 if (!search_package.session().is_closed()
510 && gdu && gdu->which == Z_GDU_Z3950
511 && gdu->u.z3950->which == Z_APDU_searchResponse)
513 Z_SearchResponse *b_resp = gdu->u.z3950->u.searchResponse;
516 if (b_resp->records->which == Z_Records_NSD
517 || b_resp->records->which == Z_Records_multipleNSD)
518 z_records_diag = b_resp->records;
522 if (frontend_apdu->which == Z_APDU_searchRequest)
524 Z_APDU *f_apdu = odr.create_searchResponse(frontend_apdu,
526 Z_SearchResponse *f_resp = f_apdu->u.searchResponse;
527 f_resp->records = z_records_diag;
528 frontend_package.response() = f_apdu;
531 if (frontend_apdu->which == Z_APDU_presentRequest)
533 Z_APDU *f_apdu = odr.create_presentResponse(frontend_apdu,
535 Z_PresentResponse *f_resp = f_apdu->u.presentResponse;
536 f_resp->records = z_records_diag;
537 frontend_package.response() = f_apdu;
541 m_result_set_size = *b_resp->resultCount;
545 if (frontend_apdu->which == Z_APDU_searchRequest)
546 f_apdu = odr.create_searchResponse(
547 frontend_apdu, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, 0);
548 else if (frontend_apdu->which == Z_APDU_presentRequest)
549 f_apdu = odr.create_presentResponse(
550 frontend_apdu, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, 0);
552 f_apdu = odr.create_close(
553 frontend_apdu, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, 0);
554 frontend_package.response() = f_apdu;
558 void yf::SessionShared::Frontend::override_set(
559 BackendInstancePtr &found_backend,
560 std::string &result_set_id)
562 BackendClassPtr bc = m_backend_class;
563 BackendInstanceList::const_iterator it = bc->m_backend_list.begin();
567 for (; it != bc->m_backend_list.end(); it++)
569 if (!(*it)->m_in_use)
571 BackendSetList::iterator set_it = (*it)->m_sets.begin();
572 for (; set_it != (*it)->m_sets.end(); set_it++)
574 if (now >= (*set_it)->m_time_last_use &&
575 now - (*set_it)->m_time_last_use > bc->m_backend_set_ttl)
578 result_set_id = (*set_it)->m_result_set_id;
579 found_backend->m_sets.erase(set_it);
585 size_t max_sets = bc->m_named_result_sets ? bc->m_backend_set_max : 1;
586 for (it = bc->m_backend_list.begin(); it != bc->m_backend_list.end(); it++)
588 if (!(*it)->m_in_use && (*it)->m_sets.size() < max_sets)
591 if (bc->m_named_result_sets)
593 result_set_id = boost::io::str(
594 boost::format("%1%") %
595 found_backend->m_result_set_sequence);
596 found_backend->m_result_set_sequence++;
599 result_set_id = "default";
605 void yf::SessionShared::Frontend::get_set(mp::Package &package,
606 const Z_APDU *apdu_req,
607 const Databases &databases,
608 yazpp_1::Yaz_Z_Query &query,
609 BackendInstancePtr &found_backend,
610 BackendSetPtr &found_set)
612 std::string result_set_id;
613 BackendClassPtr bc = m_backend_class;
615 boost::mutex::scoped_lock lock(bc->m_mutex_backend_class);
617 // look at each backend and see if we have a similar search
618 BackendInstanceList::const_iterator it = bc->m_backend_list.begin();
620 for (; it != bc->m_backend_list.end(); it++)
622 if (!(*it)->m_in_use)
624 BackendSetList::const_iterator set_it = (*it)->m_sets.begin();
625 for (; set_it != (*it)->m_sets.end(); set_it++)
627 if ((*set_it)->m_databases == databases
628 && query.match(&(*set_it)->m_query))
632 bc->use_backend(found_backend);
633 found_set->timestamp();
634 // found matching set. No need to search again
640 override_set(found_backend, result_set_id);
642 bc->use_backend(found_backend);
646 // create a new backend set (and new set)
647 found_backend = bc->create_backend(package);
653 if (apdu_req->which == Z_APDU_searchRequest)
655 f_apdu = odr.create_searchResponse(
656 apdu_req, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, 0);
658 else if (apdu_req->which == Z_APDU_presentRequest)
660 f_apdu = odr.create_presentResponse(
661 apdu_req, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, 0);
665 f_apdu = odr.create_close(
666 apdu_req, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, 0);
668 package.response() = f_apdu;
671 if (bc->m_named_result_sets)
673 result_set_id = boost::io::str(
674 boost::format("%1%") % found_backend->m_result_set_sequence);
675 found_backend->m_result_set_sequence++;
678 result_set_id = "default";
680 // we must search ...
681 BackendSetPtr new_set(new BackendSet(result_set_id,
683 if (!new_set->search(package, apdu_req, found_backend))
685 bc->remove_backend(found_backend);
686 return; // search error
689 found_set->timestamp();
690 found_backend->m_sets.push_back(found_set);
693 void yf::SessionShared::Frontend::search(mp::Package &package,
696 Z_SearchRequest *req = apdu_req->u.searchRequest;
697 FrontendSets::iterator fset_it =
698 m_frontend_sets.find(req->resultSetName);
699 if (fset_it != m_frontend_sets.end())
701 // result set already exist
702 // if replace indicator is off: we return diagnostic if
703 // result set already exist.
704 if (*req->replaceIndicator == 0)
708 odr.create_searchResponse(
710 YAZ_BIB1_RESULT_SET_EXISTS_AND_REPLACE_INDICATOR_OFF,
712 package.response() = apdu;
716 m_frontend_sets.erase(fset_it);
719 yazpp_1::Yaz_Z_Query query;
720 query.set_Z_Query(req->query);
723 for (i = 0; i<req->num_databaseNames; i++)
724 databases.push_back(req->databaseNames[i]);
726 BackendSetPtr found_set; // null
727 BackendInstancePtr found_backend; // null
729 get_set(package, apdu_req, databases, query, found_backend, found_set);
734 Z_APDU *f_apdu = odr.create_searchResponse(apdu_req, 0, 0);
735 Z_SearchResponse *f_resp = f_apdu->u.searchResponse;
736 *f_resp->resultCount = found_set->m_result_set_size;
737 package.response() = f_apdu;
739 FrontendSetPtr fset(new FrontendSet(databases, query));
740 m_frontend_sets[req->resultSetName] = fset;
742 m_backend_class->release_backend(found_backend);
745 void yf::SessionShared::Frontend::present(mp::Package &package,
749 Z_PresentRequest *req = apdu_req->u.presentRequest;
751 FrontendSets::iterator fset_it =
752 m_frontend_sets.find(req->resultSetId);
754 if (fset_it == m_frontend_sets.end())
757 odr.create_presentResponse(
759 YAZ_BIB1_SPECIFIED_RESULT_SET_DOES_NOT_EXIST,
761 package.response() = apdu;
764 FrontendSetPtr fset = fset_it->second;
766 Databases databases = fset->get_databases();
767 yazpp_1::Yaz_Z_Query query = fset->get_query();
769 BackendClassPtr bc = m_backend_class;
770 BackendSetPtr found_set; // null
771 BackendInstancePtr found_backend;
773 get_set(package, apdu_req, databases, query, found_backend, found_set);
777 Z_APDU *p_apdu = zget_APDU(odr, Z_APDU_presentRequest);
778 Z_PresentRequest *p_req = p_apdu->u.presentRequest;
779 p_req->preferredRecordSyntax = req->preferredRecordSyntax;
780 p_req->resultSetId = odr_strdup(odr, found_set->m_result_set_id.c_str());
781 *p_req->resultSetStartPoint = *req->resultSetStartPoint;
782 *p_req->numberOfRecordsRequested = *req->numberOfRecordsRequested;
783 p_req->preferredRecordSyntax = req->preferredRecordSyntax;
784 p_req->recordComposition = req->recordComposition;
786 Package present_package(found_backend->m_session, package.origin());
787 present_package.copy_filter(package);
789 present_package.request() = p_apdu;
791 present_package.move();
793 Z_GDU *gdu = present_package.response().get();
794 if (!present_package.session().is_closed()
795 && gdu && gdu->which == Z_GDU_Z3950
796 && gdu->u.z3950->which == Z_APDU_presentResponse)
798 Z_PresentResponse *b_resp = gdu->u.z3950->u.presentResponse;
799 Z_APDU *f_apdu_res = odr.create_presentResponse(apdu_req, 0, 0);
800 Z_PresentResponse *f_resp = f_apdu_res->u.presentResponse;
802 f_resp->numberOfRecordsReturned = b_resp->numberOfRecordsReturned;
803 f_resp->nextResultSetPosition = b_resp->nextResultSetPosition;
804 f_resp->presentStatus= b_resp->presentStatus;
805 f_resp->records = b_resp->records;
806 f_resp->otherInfo = b_resp->otherInfo;
807 package.response() = f_apdu_res;
808 bc->release_backend(found_backend);
812 bc->remove_backend(found_backend);
814 odr.create_presentResponse(
815 apdu_req, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, 0);
816 package.response() = f_apdu_res;
820 void yf::SessionShared::Frontend::scan(mp::Package &frontend_package,
823 BackendClassPtr bc = m_backend_class;
824 BackendInstancePtr backend = bc->get_backend(frontend_package);
828 Z_APDU *apdu = odr.create_scanResponse(
829 apdu_req, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, 0);
830 frontend_package.response() = apdu;
834 Package scan_package(backend->m_session, frontend_package.origin());
835 scan_package.copy_filter(frontend_package);
836 scan_package.request() = apdu_req;
838 frontend_package.response() = scan_package.response();
839 if (scan_package.session().is_closed())
841 frontend_package.session().close();
842 bc->remove_backend(backend);
845 bc->release_backend(backend);
849 yf::SessionShared::Worker::Worker(SessionShared::Rep *rep) : m_p(rep)
853 void yf::SessionShared::Worker::operator() (void)
858 void yf::SessionShared::BackendClass::expire()
862 boost::mutex::scoped_lock lock(m_mutex_backend_class);
863 BackendInstanceList::iterator bit = m_backend_list.begin();
864 while (bit != m_backend_list.end())
866 time_t last_use = (*bit)->m_time_last_use;
868 if ((*bit)->m_in_use)
872 else if ((now >= last_use && now - last_use > m_backend_expiry_ttl)
876 (*bit)->m_close_package->response() = odr.create_close(
877 0, Z_Close_lackOfActivity, 0);
878 (*bit)->m_close_package->session().close();
879 (*bit)->m_close_package->move();
881 bit = m_backend_list.erase(bit);
890 void yf::SessionShared::Rep::expire()
895 boost::xtime_get(&xt, boost::TIME_UTC);
897 boost::thread::sleep(xt);
899 BackendClassMap::const_iterator b_it = m_backend_map.begin();
900 for (; b_it != m_backend_map.end(); b_it++)
901 b_it->second->expire();
905 yf::SessionShared::Rep::Rep()
907 m_resultset_ttl = 30;
908 m_resultset_max = 10;
910 yf::SessionShared::Worker w(this);
911 m_thrds.add_thread(new boost::thread(w));
914 yf::SessionShared::SessionShared() : m_p(new SessionShared::Rep)
918 yf::SessionShared::~SessionShared() {
922 yf::SessionShared::Frontend::Frontend(Rep *rep) : m_is_virtual(false), m_p(rep)
926 yf::SessionShared::Frontend::~Frontend()
930 yf::SessionShared::FrontendPtr yf::SessionShared::Rep::get_frontend(mp::Package &package)
932 boost::mutex::scoped_lock lock(m_mutex);
934 std::map<mp::Session,yf::SessionShared::FrontendPtr>::iterator it;
938 it = m_clients.find(package.session());
939 if (it == m_clients.end())
942 if (!it->second->m_in_use)
944 it->second->m_in_use = true;
947 m_cond_session_ready.wait(lock);
949 FrontendPtr f(new Frontend(this));
950 m_clients[package.session()] = f;
955 void yf::SessionShared::Rep::release_frontend(mp::Package &package)
957 boost::mutex::scoped_lock lock(m_mutex);
958 std::map<mp::Session,yf::SessionShared::FrontendPtr>::iterator it;
960 it = m_clients.find(package.session());
961 if (it != m_clients.end())
963 if (package.session().is_closed())
969 it->second->m_in_use = false;
971 m_cond_session_ready.notify_all();
976 void yf::SessionShared::process(mp::Package &package) const
978 FrontendPtr f = m_p->get_frontend(package);
980 Z_GDU *gdu = package.request().get();
982 if (gdu && gdu->which == Z_GDU_Z3950 && gdu->u.z3950->which ==
983 Z_APDU_initRequest && !f->m_is_virtual)
985 m_p->init(package, gdu, f);
987 else if (!f->m_is_virtual)
989 else if (gdu && gdu->which == Z_GDU_Z3950)
991 Z_APDU *apdu = gdu->u.z3950;
992 if (apdu->which == Z_APDU_initRequest)
996 package.response() = odr.create_close(
998 Z_Close_protocolError,
1001 package.session().close();
1003 else if (apdu->which == Z_APDU_close)
1007 package.response() = odr.create_close(
1009 Z_Close_peerAbort, "received close from client");
1010 package.session().close();
1012 else if (apdu->which == Z_APDU_searchRequest)
1014 f->search(package, apdu);
1016 else if (apdu->which == Z_APDU_presentRequest)
1018 f->present(package, apdu);
1020 else if (apdu->which == Z_APDU_scanRequest)
1022 f->scan(package, apdu);
1028 package.response() = odr.create_close(
1029 apdu, Z_Close_protocolError,
1030 "unsupported APDU in filter_session_shared");
1032 package.session().close();
1035 m_p->release_frontend(package);
1038 void yf::SessionShared::configure(const xmlNode *ptr, bool test_only)
1040 for (ptr = ptr->children; ptr; ptr = ptr->next)
1042 if (ptr->type != XML_ELEMENT_NODE)
1044 if (!strcmp((const char *) ptr->name, "resultset"))
1046 const struct _xmlAttr *attr;
1047 for (attr = ptr->properties; attr; attr = attr->next)
1049 if (!strcmp((const char *) attr->name, "ttl"))
1050 m_p->m_resultset_ttl =
1051 mp::xml::get_int(attr->children, 30);
1052 else if (!strcmp((const char *) attr->name, "max"))
1054 m_p->m_resultset_max =
1055 mp::xml::get_int(attr->children, 10);
1058 throw mp::filter::FilterException(
1059 "Bad attribute " + std::string((const char *)
1063 else if (!strcmp((const char *) ptr->name, "session"))
1065 const struct _xmlAttr *attr;
1066 for (attr = ptr->properties; attr; attr = attr->next)
1068 if (!strcmp((const char *) attr->name, "ttl"))
1069 m_p->m_session_ttl =
1070 mp::xml::get_int(attr->children, 120);
1072 throw mp::filter::FilterException(
1073 "Bad attribute " + std::string((const char *)
1079 throw mp::filter::FilterException("Bad element "
1080 + std::string((const char *)
1086 static mp::filter::Base* filter_creator()
1088 return new mp::filter::SessionShared;
1092 struct metaproxy_1_filter_struct metaproxy_1_filter_session_shared = {
1102 * indent-tabs-mode: nil
1103 * c-file-style: "stroustrup"
1105 * vim: shiftwidth=4 tabstop=8 expandtab