metaproxy_1::filter::PresentChunk::Impl Class Reference

Collaboration diagram for metaproxy_1::filter::PresentChunk::Impl:

Public Member Functions
	Impl ()
	~Impl ()
void	process (metaproxy_1::Package &package)
void	configure (const xmlNode *ptr)
void	chunk_it (metaproxy_1::Package &package, Z_APDU *apdu)

Private Attributes
Odr_int	chunk_number

Detailed Description

Definition at line 33 of file filter_present_chunk.cpp.

Constructor & Destructor Documentation

Impl()

mp::filter::PresentChunk::Impl::Impl

(

)

Definition at line 65 of file filter_present_chunk.cpp.

                         : chunk_number(0)
{
}

~Impl()

mp::filter::PresentChunk::Impl::~Impl

(

)

Definition at line 69 of file filter_present_chunk.cpp.

{
}

Member Function Documentation

chunk_it()

void mp::filter::PresentChunk::Impl::chunk_it	(	metaproxy_1::Package &	package,
		Z_APDU *	apdu
	)

Definition at line 92 of file filter_present_chunk.cpp.

{
    mp::odr odr;
    Z_PresentRequest *pr = apdu->u.presentRequest;
 
    Odr_int total = *pr->numberOfRecordsRequested;
    Odr_int start = *pr->resultSetStartPoint;
    Odr_int offset = 0;
    Z_NamePlusRecordList *npl = (Z_NamePlusRecordList *)
        odr_malloc(odr, sizeof(*npl));
    npl->num_records = total;
    npl->records = (Z_NamePlusRecord **)
        odr_malloc(odr, sizeof(*npl->records) * total);
    while (offset < total)
    {
        Odr_int left = total - offset;
 
        Package pp(package.session(), package.origin());
 
        *pr->numberOfRecordsRequested =
            left > chunk_number ? chunk_number : left;
 
        *pr->resultSetStartPoint = start + offset;
 
        pp.copy_filter(package);
        pp.request() = apdu;
 
        pp.move();
 
        if (pp.session().is_closed())
        {
            package.session().close();
            return;
        }
        Z_GDU *gdu_res = pp.response().get();
        if (gdu_res && gdu_res->which == Z_GDU_Z3950 &&
            gdu_res->u.z3950->which == Z_APDU_presentResponse)
        {
            Z_PresentResponse *pres =
                gdu_res->u.z3950->u.presentResponse;
            if (pres->records &&
                pres->records->which == Z_Records_DBOSD)
            {
                Z_NamePlusRecordList *nprl =
                    pres->records->u.databaseOrSurDiagnostics;
                int i;
                for (i = 0; i < nprl->num_records; i++)
                {
                    ODR o = odr;
                    npl->records[offset+i] = yaz_clone_z_NamePlusRecord(
                        nprl->records[i], o->mem);
                }
                offset += nprl->num_records;
            }
            else
            {
                package.response() = pp.response();
                return;
            }
        }
        else
        {
            package.response() = pp.response();
            return;
        }
    }
 
    yaz_log(YLOG_LOG, "building response . %lld", offset);
 
    Z_APDU *a = zget_APDU(odr, Z_APDU_presentResponse);
    Z_PresentResponse *pres = a->u.presentResponse;
    pres->records = (Z_Records *)
        odr_malloc(odr, sizeof(Z_Records));
    pres->records->which = Z_Records_DBOSD;
    pres->records->u.databaseOrSurDiagnostics = npl;
    npl->num_records = offset;
    *pres->numberOfRecordsReturned = offset;
 
    package.response() = a;
}

configure()

void mp::filter::PresentChunk::Impl::configure

(

const xmlNode *

ptr

)

Definition at line 73 of file filter_present_chunk.cpp.

{
    for (ptr = ptr->children; ptr; ptr = ptr->next)
    {
        if (ptr->type != XML_ELEMENT_NODE)
            continue;
        if (!strcmp((const char *) ptr->name, "chunk"))
        {
            chunk_number = mp::xml::get_int(ptr, 0);
        }
        else
        {
            throw mp::filter::FilterException("Bad element "
                                               + std::string((const char *)
                                                             ptr->name));
        }
    }
}

process()

void mp::filter::PresentChunk::Impl::process

(

metaproxy_1::Package &

package

)

Definition at line 174 of file filter_present_chunk.cpp.

{
    Z_GDU *gdu = package.request().get();
    if (gdu && gdu->which == Z_GDU_Z3950)
    {
        Z_APDU *apdu = gdu->u.z3950;
        if (apdu->which == Z_APDU_presentRequest && chunk_number > 0)
            chunk_it(package, apdu);
        else
            package.move();
    }
    else
        package.move();
}

Member Data Documentation

chunk_number

Odr_int metaproxy_1::filter::PresentChunk::Impl::chunk_number

private

Definition at line 41 of file filter_present_chunk.cpp.

---

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

• filter_present_chunk.cpp