metaproxy_1::filter::SessionShared::BackendSet Class Reference

Collaboration diagram for metaproxy_1::filter::SessionShared::BackendSet:

Public Member Functions
void	timestamp ()
	BackendSet (const std::string &result_set_id, const Databases &databases, const yazpp_1::Yaz_Z_Query &query, Z_OtherInformation *additionalSearchInfoRequest)
	~BackendSet ()
bool	search (Package &frontend_package, Package &search_package, const Z_APDU *apdu_req, const BackendInstancePtr bp, Z_Records **z_records)

Public Attributes
std::string	m_result_set_id
Databases	m_databases
Odr_int	m_result_set_size
yazpp_1::Yaz_Z_Query	m_query
time_t	m_time_last_use
yazpp_1::RecordCache	m_record_cache
Z_OtherInformation *	additionalSearchInfoRequest
Z_OtherInformation *	additionalSearchInfoResponse
NMEM	mem_additionalSearchInfo

Detailed Description

Definition at line 75 of file filter_session_shared.cpp.

Constructor & Destructor Documentation

BackendSet()

mp::filter::SessionShared::BackendSet::BackendSet	(	const std::string &	result_set_id,
		const Databases &	databases,
		const yazpp_1::Yaz_Z_Query &	query,
		Z_OtherInformation *	additionalSearchInfoRequest
	)

Definition at line 669 of file filter_session_shared.cpp.

                                              :
    m_result_set_id(result_set_id),
    m_databases(databases), m_result_set_size(0), m_query(query)
{
    timestamp();
    mem_additionalSearchInfo = nmem_create();
    additionalSearchInfoResponse = 0;
    additionalSearchInfoRequest =
        yaz_clone_z_OtherInformation(additionalSearchInfo,
                                     mem_additionalSearchInfo);
}

References additionalSearchInfoRequest, additionalSearchInfoResponse, mem_additionalSearchInfo, and timestamp().

Here is the call graph for this function:

~BackendSet()

mp::filter::SessionShared::BackendSet::~BackendSet

(

)

Definition at line 685 of file filter_session_shared.cpp.

{
    nmem_destroy(mem_additionalSearchInfo);
}

Member Function Documentation

search()

bool mp::filter::SessionShared::BackendSet::search	(	Package &	frontend_package,
		Package &	search_package,
		const Z_APDU *	apdu_req,
		const BackendInstancePtr	bp,
		Z_Records **	z_records
	)

Definition at line 695 of file filter_session_shared.cpp.

{
    mp::odr odr;
    Z_APDU *apdu_req = zget_APDU(odr, Z_APDU_searchRequest);
    Z_SearchRequest *req = apdu_req->u.searchRequest;
 
    req->additionalSearchInfo = additionalSearchInfoRequest;
    req->resultSetName = odr_strdup(odr, m_result_set_id.c_str());
    req->query = m_query.get_Z_Query();
 
    req->num_databaseNames = m_databases.size();
    req->databaseNames = (char**)
        odr_malloc(odr, req->num_databaseNames * sizeof(char *));
    Databases::const_iterator it = m_databases.begin();
    size_t i = 0;
    for (; it != m_databases.end(); it++)
        req->databaseNames[i++] = odr_strdup(odr, it->c_str());
 
    if (frontend_apdu->which == Z_APDU_searchRequest)
        req->preferredRecordSyntax =
            frontend_apdu->u.searchRequest->preferredRecordSyntax;
 
    search_package.request() = apdu_req;
 
    search_package.move();
 
    Z_GDU *gdu = search_package.response().get();
    if (!search_package.session().is_closed()
        && gdu && gdu->which == Z_GDU_Z3950
        && gdu->u.z3950->which == Z_APDU_searchResponse)
    {
        Z_SearchResponse *b_resp = gdu->u.z3950->u.searchResponse;
        *z_records = b_resp->records;
        m_result_set_size = *b_resp->resultCount;
 
        additionalSearchInfoResponse = yaz_clone_z_OtherInformation(
            b_resp->additionalSearchInfo, mem_additionalSearchInfo);
        return true;
    }
    Z_APDU *f_apdu = 0;
    const char *addinfo = "session_shared: "
        "target closed connection during search";
    if (frontend_apdu->which == Z_APDU_searchRequest)
        f_apdu = odr.create_searchResponse(
            frontend_apdu, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, addinfo);
    else if (frontend_apdu->which == Z_APDU_presentRequest)
        f_apdu = odr.create_presentResponse(
            frontend_apdu, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, addinfo);
    else
        f_apdu = odr.create_close(
            frontend_apdu, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, addinfo);
    frontend_package.response() = f_apdu;
    return false;
}

timestamp()

void mp::filter::SessionShared::BackendSet::timestamp

(

)

Definition at line 664 of file filter_session_shared.cpp.

{
    time(&m_time_last_use);
}

Referenced by BackendSet().

Member Data Documentation

additionalSearchInfoRequest

Z_OtherInformation* metaproxy_1::filter::SessionShared::BackendSet::additionalSearchInfoRequest

Definition at line 85 of file filter_session_shared.cpp.

Referenced by BackendSet().

additionalSearchInfoResponse

Z_OtherInformation* metaproxy_1::filter::SessionShared::BackendSet::additionalSearchInfoResponse

Definition at line 86 of file filter_session_shared.cpp.

Referenced by BackendSet().

m_databases

Databases metaproxy_1::filter::SessionShared::BackendSet::m_databases

Definition at line 78 of file filter_session_shared.cpp.

m_query

yazpp_1::Yaz_Z_Query metaproxy_1::filter::SessionShared::BackendSet::m_query

Definition at line 80 of file filter_session_shared.cpp.

m_record_cache

yazpp_1::RecordCache metaproxy_1::filter::SessionShared::BackendSet::m_record_cache

Definition at line 83 of file filter_session_shared.cpp.

m_result_set_id

std::string metaproxy_1::filter::SessionShared::BackendSet::m_result_set_id

Definition at line 77 of file filter_session_shared.cpp.

m_result_set_size

Odr_int metaproxy_1::filter::SessionShared::BackendSet::m_result_set_size

Definition at line 79 of file filter_session_shared.cpp.

m_time_last_use

time_t metaproxy_1::filter::SessionShared::BackendSet::m_time_last_use

Definition at line 81 of file filter_session_shared.cpp.

mem_additionalSearchInfo

NMEM metaproxy_1::filter::SessionShared::BackendSet::mem_additionalSearchInfo

Definition at line 87 of file filter_session_shared.cpp.

Referenced by BackendSet().

---

The documentation for this class was generated from the following file:

• filter_session_shared.cpp