metaproxy_1::filter::FrontendNet::ZAssocChild Class Reference

Inheritance diagram for metaproxy_1::filter::FrontendNet::ZAssocChild:

Collaboration diagram for metaproxy_1::filter::FrontendNet::ZAssocChild:

Public Member Functions
	~ZAssocChild ()
	ZAssocChild (yazpp_1::IPDU_Observable *the_PDU_Observable, mp::ThreadPoolSocketObserver *m_thread_pool_observer, const mp::Package *package, Port *port, Rep *rep, yazpp_1::LimitConnect &limit, const char *peername)

Public Attributes
int	m_no_requests
Port *	m_port

Private Member Functions
yazpp_1::IPDU_Observer *	sessionNotify (yazpp_1::IPDU_Observable *the_PDU_Observable, int fd)
void	recv_GDU (Z_GDU *apdu, int len)
void	report (Z_HTTP_Request *hreq)
void	failNotify ()
void	timeoutNotify ()
void	connectNotify ()

Private Attributes
mp::ThreadPoolSocketObserver *	m_thread_pool_observer
mp::Session	m_session
mp::Origin	m_origin
bool	m_delete_flag
const mp::Package *	m_package
Rep *	m_p
yazpp_1::LimitConnect &	m_limit_http_req
std::string	m_peer

Detailed Description

Definition at line 118 of file filter_frontend_net.cpp.

Constructor & Destructor Documentation

~ZAssocChild()

mp::filter::FrontendNet::ZAssocChild::~ZAssocChild

(

)

Definition at line 350 of file filter_frontend_net.cpp.

{
    int d = m_p->m_peerStat.remove(m_peer);
    if (m_p->m_msg_config.length())
    {
        std::ostringstream os;
        os  << m_p->m_msg_config << " "
            << m_peer << " closing cnt=" << d;
        yaz_log(YLOG_LOG, "%s", os.str().c_str());
    }
}

References metaproxy_1::filter::FrontendNet::m_p.

ZAssocChild()

mp::filter::FrontendNet::ZAssocChild::ZAssocChild	(	yazpp_1::IPDU_Observable *	the_PDU_Observable,
		mp::ThreadPoolSocketObserver *	m_thread_pool_observer,
		const mp::Package *	package,
		Port *	port,
		Rep *	rep,
		yazpp_1::LimitConnect &	limit,
		const char *	peername
	)

Definition at line 306 of file filter_frontend_net.cpp.

    :  Z_Assoc(PDU_Observable), m_p(rep), m_limit_http_req(limit_http_req)
    , m_peer(peername)
{
    m_thread_pool_observer = my_thread_pool;
    m_no_requests = 0;
    m_delete_flag = false;
    m_package = package;
    m_port = port;
    std::string addr;
    addr.append(peername);
    addr.append(" ");
    addr.append(port->port);
    m_p->m_peerStat.add(m_peer);
    m_origin.set_tcpip_address(addr, m_session.id());
    int session_timeout = 300; // 5 minutes
    if (peername) {
        std::list<IP_Pattern>::const_iterator it = m_p->session_timeout.begin();
        for (; it != m_p->session_timeout.end(); it++)
            if (mp::util::match_ip(it->pattern, peername))
            {
                if (it->verbose > 1)
                    yaz_log(YLOG_LOG, "timeout pattern=%s ip=%s value=%d",
                            it->pattern.c_str(),
                            peername, it->value);
                session_timeout = it->value;
                break;
            }
    }
    timeout(session_timeout);
}

References metaproxy_1::filter::FrontendNet::PeerStat::add(), m_delete_flag, m_no_requests, m_origin, m_p, m_package, m_peer, metaproxy_1::filter::FrontendNet::Rep::m_peerStat, m_port, m_session, m_thread_pool_observer, metaproxy_1::filter::FrontendNet::Port::port, and metaproxy_1::filter::FrontendNet::Rep::session_timeout.

Here is the call graph for this function:

Member Function Documentation

connectNotify()

void mp::filter::FrontendNet::ZAssocChild::connectNotify ( )

private

Definition at line 531 of file filter_frontend_net.cpp.

{
 
}

failNotify()

void mp::filter::FrontendNet::ZAssocChild::failNotify ( )

private

Definition at line 505 of file filter_frontend_net.cpp.

{
    // TODO: send Package to signal "close"
    if (m_session.is_closed())
    {
        if (m_no_requests == 0)
            delete this;
        return;
    }
    m_no_requests++;
 
    m_session.close();
 
    mp::Package *p = new mp::Package(m_session, m_origin);
 
    ThreadPoolPackage *tp = new ThreadPoolPackage(p, this, m_p);
    p->copy_route(*m_package);
    m_thread_pool_observer->cleanup(tp, &m_session);
    m_thread_pool_observer->put(tp);
}

References metaproxy_1::filter::FrontendNet::m_p.

recv_GDU()

void mp::filter::FrontendNet::ZAssocChild::recv_GDU ( Z_GDU *  apdu, int  len  )

private

Definition at line 434 of file filter_frontend_net.cpp.

{
    m_no_requests++;
 
    mp::Package *p = new mp::Package(m_session, m_origin);
 
    if (z_pdu && z_pdu->which == Z_GDU_HTTP_Request)
    {
        Z_HTTP_Request *hreq = z_pdu->u.HTTP_Request;
 
        const char *f = z_HTTP_header_lookup(hreq->headers, "X-Forwarded-For");
        if (f)
            p->origin().set_tcpip_address(std::string(f), m_session.id());
 
        if (m_p->m_stat_req.length()
            && !strcmp(hreq->path, m_p->m_stat_req.c_str()))
        {
            report(hreq);
            delete p;
            delete this;
            return;
        }
    }
 
    p->copy_route(*m_package);
    p->request() = yazpp_1::GDU(z_pdu);
 
    if (m_p->m_msg_config.length())
    {
        if (z_pdu)
        {
            std::ostringstream os;
            os  << m_p->m_msg_config << " "
                << *p << " "
                << "0.000000" << " "
                << *z_pdu;
            yaz_log(YLOG_LOG, "%s", os.str().c_str());
        }
    }
    if (z_pdu && z_pdu->which == Z_GDU_HTTP_Request)
    {
        Z_HTTP_Request *hreq = z_pdu->u.HTTP_Request;
        std::string peername = p->origin().get_address();
 
        m_limit_http_req.cleanup(false);
        int con_sz = m_limit_http_req.get_total(peername.c_str());
        std::list<IP_Pattern>::const_iterator it = m_p->http_req_max.begin();
        for (; it != m_p->http_req_max.end(); it++)
        {
            if (mp::util::match_ip(it->pattern, peername))
            {
                if (it->verbose > 1 ||
                    (it->value && con_sz >= it->value && it->verbose > 0))
                    yaz_log(YLOG_LOG, "http-req-max pattern=%s ip=%s con_sz=%d value=%d", it->pattern.c_str(), peername.c_str(), con_sz, it->value);
                if (con_sz < it->value)
                    break;
                mp::odr o;
                Z_GDU *gdu_res = o.create_HTTP_Response(m_session, hreq, 500);
                int len;
                send_GDU(gdu_res, &len);
                delete p;
                delete this;
                return;
            }
        }
        m_limit_http_req.add_connect(peername.c_str());
    }
    ThreadPoolPackage *tp = new ThreadPoolPackage(p, this, m_p);
    m_thread_pool_observer->put(tp);
}

References metaproxy_1::filter::FrontendNet::m_p.

report()

void mp::filter::FrontendNet::ZAssocChild::report ( Z_HTTP_Request *  hreq )

private

Definition at line 362 of file filter_frontend_net.cpp.

{
    mp::odr o;
 
    Z_GDU *gdu_res = o.create_HTTP_Response(m_session, hreq, 200);
 
    Z_HTTP_Response *hres = gdu_res->u.HTTP_Response;
 
    mp::wrbuf w;
    size_t i;
    int number_total = 0;
 
    for (i = 0; m_p->m_duration_lim[i] != 0.0; i++)
        number_total += m_p->m_duration_freq[i];
    number_total += m_p->m_duration_freq[i];
 
    wrbuf_puts(w, "<?xml version=\"1.0\"?>\n");
    wrbuf_puts(w, "<frontend_net>\n");
    wrbuf_printf(w, "  <responses frequency=\"%d\">\n", number_total);
    for (i = 0; m_p->m_duration_lim[i] != 0.0; i++)
    {
        if (m_p->m_duration_freq[i] > 0)
            wrbuf_printf(
                w, "    <response duration_start=\"%f\" "
                "duration_end=\"%f\" frequency=\"%d\"/>\n",
                i > 0 ? m_p->m_duration_lim[i - 1] : 0.0,
                m_p->m_duration_lim[i], m_p->m_duration_freq[i]);
    }
 
    if (m_p->m_duration_freq[i] > 0)
        wrbuf_printf(
            w, "    <response duration_start=\"%f\" frequency=\"%d\"/>\n",
            m_p->m_duration_lim[i - 1], m_p->m_duration_freq[i]);
 
    if (m_p->m_duration_max != 0.0)
        wrbuf_printf(
            w, "    <response duration_max=\"%f\"/>\n",
            m_p->m_duration_max);
    if (m_p->m_duration_min != 0.0)
        wrbuf_printf(
            w, "    <response duration_min=\"%f\"/>\n",
            m_p->m_duration_min);
    if (m_p->m_duration_total != 0.0)
        wrbuf_printf(
            w, "    <response duration_average=\"%f\"/>\n",
            m_p->m_duration_total / number_total);
 
    wrbuf_puts(w, "  </responses>\n");
 
    int thread_busy;
    int thread_total;
    m_thread_pool_observer->get_thread_info(thread_busy, thread_total);
 
    wrbuf_printf(w, " <thread_info busy=\"%d\" total=\"%d\"/>\n",
                 thread_busy, thread_total);
 
    wrbuf_malloc_info(w);
 
    {
        char buf[200];
        if (nmem_get_status(buf, sizeof(buf) - 1) == 0)
            wrbuf_puts(w, buf);
    }
    wrbuf_puts(w, "</frontend_net>\n");
 
    hres->content_len = w.len();
    hres->content_buf = (char *) w.buf();
 
    int len;
    send_GDU(gdu_res, &len);
}

References metaproxy_1::filter::FrontendNet::m_p.

sessionNotify()

yazpp_1::IPDU_Observer * mp::filter::FrontendNet::ZAssocChild::sessionNotify ( yazpp_1::IPDU_Observable *  the_PDU_Observable, int  fd  )

private

Definition at line 344 of file filter_frontend_net.cpp.

{
    return 0;
}

timeoutNotify()

void mp::filter::FrontendNet::ZAssocChild::timeoutNotify ( )

private

Definition at line 526 of file filter_frontend_net.cpp.

{
    failNotify();
}

Member Data Documentation

m_delete_flag

bool metaproxy_1::filter::FrontendNet::ZAssocChild::m_delete_flag

private

Definition at line 143 of file filter_frontend_net.cpp.

Referenced by ZAssocChild().

m_limit_http_req

yazpp_1::LimitConnect& metaproxy_1::filter::FrontendNet::ZAssocChild::m_limit_http_req

private

Definition at line 146 of file filter_frontend_net.cpp.

m_no_requests

int metaproxy_1::filter::FrontendNet::ZAssocChild::m_no_requests

Definition at line 128 of file filter_frontend_net.cpp.

Referenced by ZAssocChild().

m_origin

mp::Origin metaproxy_1::filter::FrontendNet::ZAssocChild::m_origin

private

Definition at line 142 of file filter_frontend_net.cpp.

Referenced by ZAssocChild().

m_p

Rep* metaproxy_1::filter::FrontendNet::ZAssocChild::m_p

private

Definition at line 145 of file filter_frontend_net.cpp.

Referenced by ZAssocChild().

m_package

const mp::Package* metaproxy_1::filter::FrontendNet::ZAssocChild::m_package

private

Definition at line 144 of file filter_frontend_net.cpp.

Referenced by ZAssocChild().

m_peer

std::string metaproxy_1::filter::FrontendNet::ZAssocChild::m_peer

private

Definition at line 147 of file filter_frontend_net.cpp.

Referenced by ZAssocChild().

m_port

Port* metaproxy_1::filter::FrontendNet::ZAssocChild::m_port

Definition at line 129 of file filter_frontend_net.cpp.

Referenced by ZAssocChild().

m_session

mp::Session metaproxy_1::filter::FrontendNet::ZAssocChild::m_session

private

Definition at line 141 of file filter_frontend_net.cpp.

Referenced by ZAssocChild().

m_thread_pool_observer

mp::ThreadPoolSocketObserver* metaproxy_1::filter::FrontendNet::ZAssocChild::m_thread_pool_observer

private

Definition at line 140 of file filter_frontend_net.cpp.

Referenced by ZAssocChild().

---

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

• filter_frontend_net.cpp