metaproxy_1::filter::Sort::Impl Class Reference

Collaboration diagram for metaproxy_1::filter::Sort::Impl:

Public Member Functions
	Impl ()
	~Impl ()
void	process (metaproxy_1::Package &package)
void	configure (const xmlNode *ptr, bool test_only, const char *path)

Private Member Functions
FrontendPtr	get_frontend (mp::Package &package)
void	release_frontend (mp::Package &package)

Private Attributes
int	m_prefetch
std::string	m_xpath_expr
std::string	m_namespaces
bool	m_ascending
bool	m_debug
boost::mutex	m_mutex
boost::condition	m_cond_session_ready
std::map< mp::Session, FrontendPtr >	m_clients

Friends
class	Frontend

Detailed Description

Definition at line 41 of file filter_sort.cpp.

Constructor & Destructor Documentation

Impl()

mp::filter::Sort::Impl::Impl

(

)

Definition at line 385 of file filter_sort.cpp.

                 : m_prefetch(20), m_ascending(true), m_debug(false)
{
}

~Impl()

mp::filter::Sort::Impl::~Impl

(

)

Definition at line 389 of file filter_sort.cpp.

{
}

Member Function Documentation

configure()

void mp::filter::Sort::Impl::configure	(	const xmlNode *	ptr,
		bool	test_only,
		const char *	path
	)

Definition at line 438 of file filter_sort.cpp.

{
    for (ptr = ptr->children; ptr; ptr = ptr->next)
    {
        if (ptr->type != XML_ELEMENT_NODE)
            continue;
        if (!strcmp((const char *) ptr->name, "sort"))
        {
            const struct _xmlAttr *attr;
            for (attr = ptr->properties; attr; attr = attr->next)
            {
                if (!strcmp((const char *) attr->name, "prefetch"))
                {
                    m_prefetch = mp::xml::get_int(attr->children, -1);
                    if (m_prefetch < 0)
                    {
                        throw mp::filter::FilterException(
                            "Bad or missing value for attribute " +
                            std::string((const char *) attr->name));
                    }
                }
                else if (!strcmp((const char *) attr->name, "xpath"))
                {
                    m_xpath_expr = mp::xml::get_text(attr->children);
                }
                else if (!strcmp((const char *) attr->name, "namespaces"))
                {
                    m_namespaces = mp::xml::get_text(attr->children);
                }
                else if (!strcmp((const char *) attr->name, "ascending"))
                {
                    m_ascending = mp::xml::get_bool(attr->children, true);
                }
                else if (!strcmp((const char *) attr->name, "debug"))
                {
                    m_debug = mp::xml::get_bool(attr->children, false);
                }
                else
                    throw mp::filter::FilterException(
                        "Bad attribute " +
                        std::string((const char *) attr->name));
            }
        }
        else
        {
            throw mp::filter::FilterException
                ("Bad element "
                 + std::string((const char *) ptr->name)
                 + " in sort filter");
        }
    }
    if (m_xpath_expr.length() == 0)
    {
        throw mp::filter::FilterException
            ("Missing xpath attribute for config element in sort filter");
    }
 
}

get_frontend()

yf::Sort::FrontendPtr mp::filter::Sort::Impl::get_frontend ( mp::Package &  package )

private

Definition at line 393 of file filter_sort.cpp.

{
    boost::mutex::scoped_lock lock(m_mutex);
 
    std::map<mp::Session,yf::Sort::FrontendPtr>::iterator it;
 
    while(true)
    {
        it = m_clients.find(package.session());
        if (it == m_clients.end())
            break;
 
        if (!it->second->m_in_use)
        {
            it->second->m_in_use = true;
            return it->second;
        }
        m_cond_session_ready.wait(lock);
    }
    FrontendPtr f(new Frontend(this));
    m_clients[package.session()] = f;
    f->m_in_use = true;
    return f;
}

process()

void mp::filter::Sort::Impl::process

(

metaproxy_1::Package &

package

)

Definition at line 725 of file filter_sort.cpp.

{
    FrontendPtr f = get_frontend(package);
    Z_GDU *gdu = package.request().get();
 
    if (f->m_is_virtual)
    {
        f->handle_package(package);
    }
    else if (gdu && gdu->which == Z_GDU_Z3950 && gdu->u.z3950->which ==
             Z_APDU_initRequest)
    {
        package.move();
        f->m_is_virtual = true;
    }
    else
        package.move();
 
    release_frontend(package);
}

release_frontend()

void mp::filter::Sort::Impl::release_frontend ( mp::Package &  package )

private

Definition at line 418 of file filter_sort.cpp.

{
    boost::mutex::scoped_lock lock(m_mutex);
    std::map<mp::Session,yf::Sort::FrontendPtr>::iterator it;
 
    it = m_clients.find(package.session());
    if (it != m_clients.end())
    {
        if (package.session().is_closed())
        {
            m_clients.erase(it);
        }
        else
        {
            it->second->m_in_use = false;
        }
        m_cond_session_ready.notify_all();
    }
}

Friends And Related Function Documentation

Frontend

friend class Frontend

friend

Definition at line 42 of file filter_sort.cpp.

Member Data Documentation

m_ascending

bool metaproxy_1::filter::Sort::Impl::m_ascending

private

Definition at line 53 of file filter_sort.cpp.

m_clients

std::map<mp::Session, FrontendPtr> metaproxy_1::filter::Sort::Impl::m_clients

private

Definition at line 57 of file filter_sort.cpp.

m_cond_session_ready

boost::condition metaproxy_1::filter::Sort::Impl::m_cond_session_ready

private

Definition at line 56 of file filter_sort.cpp.

m_debug

bool metaproxy_1::filter::Sort::Impl::m_debug

private

Definition at line 54 of file filter_sort.cpp.

m_mutex

boost::mutex metaproxy_1::filter::Sort::Impl::m_mutex

private

Definition at line 55 of file filter_sort.cpp.

m_namespaces

std::string metaproxy_1::filter::Sort::Impl::m_namespaces

private

Definition at line 52 of file filter_sort.cpp.

m_prefetch

int metaproxy_1::filter::Sort::Impl::m_prefetch

private

Definition at line 50 of file filter_sort.cpp.

m_xpath_expr

std::string metaproxy_1::filter::Sort::Impl::m_xpath_expr

private

Definition at line 51 of file filter_sort.cpp.

---

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

• filter_sort.cpp