X-Git-Url: http://lists.indexdata.com/cgi-bin?a=blobdiff_plain;f=src%2Ffilter_frontend_net.cpp;h=38c6306a1583a306855b12d67d78975aac26ad4e;hb=b87d59a4add20f61400cfb77a9256dd26c243fb7;hp=8aa35a251666cab9f3e942b57ccdebfc3cf846ed;hpb=63ea8aedbfd7dc56ab28dbc82c38b4458dcecb68;p=metaproxy-moved-to-github.git diff --git a/src/filter_frontend_net.cpp b/src/filter_frontend_net.cpp index 8aa35a2..38c6306 100644 --- a/src/filter_frontend_net.cpp +++ b/src/filter_frontend_net.cpp @@ -1,4 +1,4 @@ -/* $Id: filter_frontend_net.cpp,v 1.10 2006-01-04 11:19:04 adam Exp $ +/* $Id: filter_frontend_net.cpp,v 1.12 2006-01-09 13:43:59 adam Exp $ Copyright (c) 2005, Index Data. %LICENSE% @@ -7,6 +7,7 @@ #include "config.hpp" +#include "xmlutil.hpp" #include "pipe.hpp" #include "filter.hpp" #include "router.hpp" @@ -242,6 +243,9 @@ void yp2::My_Timer_Thread::socketNotify(int event) } void yp2::filter::FrontendNet::process(Package &package) const { + if (m_ports.size() == 0) + return; + yazpp_1::SocketManager mySocketManager; My_Timer_Thread *tt = 0; @@ -275,6 +279,34 @@ void yp2::filter::FrontendNet::process(Package &package) const { delete tt; } +void yp2::filter::FrontendNet::configure(const xmlNode * ptr) +{ + if (!ptr || !ptr->children) + { + throw yp2::filter::FilterException("No ports for Frontend"); + } + std::vector ports; + for (ptr = ptr->children; ptr; ptr = ptr->next) + { + if (ptr->type == XML_ELEMENT_NODE) + { + if (!strcmp((const char *) ptr->name, "port")) + { + std::string port = yp2::xml::get_text(ptr); + ports.push_back(port); + + } + else + { + throw yp2::filter::FilterException("Bad element " + + std::string((const char *) + ptr->name)); + } + } + } + m_ports = ports; +} + std::vector &yp2::filter::FrontendNet::ports() { return m_ports; @@ -291,7 +323,7 @@ static yp2::filter::Base* filter_creator() } extern "C" { - const struct yp2_filter_struct yp2_filter_frontend_net = { + struct yp2_filter_struct yp2_filter_frontend_net = { 0, "frontend_net", filter_creator