X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Fpackage.cpp;h=c62852351e2b20ed35548c2ca08184a36e971871;hb=74d5524719194de5dc96abd552562fa473088677;hp=0802e29994fff998cb186117aa34e0aaaa95ffb6;hpb=ec5548301e2549fc0f8d2f962aade24cb6f90d1b;p=metaproxy-moved-to-github.git diff --git a/src/package.cpp b/src/package.cpp index 0802e29..c628523 100644 --- a/src/package.cpp +++ b/src/package.cpp @@ -1,140 +1,132 @@ -/* $Id: package.cpp,v 1.4 2006-01-09 13:43:59 adam Exp $ - Copyright (c) 2005, Index Data. +/* This file is part of Metaproxy. + Copyright (C) 2005-2010 Index Data -%LICENSE% - */ +Metaproxy is free software; you can redistribute it and/or modify it under +the terms of the GNU General Public License as published by the Free +Software Foundation; either version 2, or (at your option) any later +version. + +Metaproxy is distributed in the hope that it will be useful, but WITHOUT ANY +WARRANTY; without even the implied warranty of MERCHANTABILITY or +FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License +for more details. + +You should have received a copy of the GNU General Public License +along with this program; if not, write to the Free Software +Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA +*/ #include "config.hpp" +#include + +#include -#include "package.hpp" +namespace mp = metaproxy_1; -yp2::Package::Package() - : -#if ROUTE_POS - m_route_pos(0), -#else - m_filter(0), m_router(0), -#endif - m_data(0) +mp::Package::Package() + : m_route_pos(0) { } -yp2::Package::~Package() +mp::Package::~Package() { -#if ROUTE_POS delete m_route_pos; -#endif } -yp2::Package::Package(yp2::Session &session, yp2::Origin &origin) +mp::Package::Package(mp::Session &session, const mp::Origin &origin) : m_session(session), m_origin(origin), -#if ROUTE_POS - m_route_pos(0), -#else - m_filter(0), m_router(0), -#endif - m_data(0) + m_route_pos(0) { } -yp2::Package & yp2::Package::copy_filter(const Package &p) + +mp::Package & mp::Package::copy_filter(const Package &p) { -#if ROUTE_POS + delete m_route_pos; m_route_pos = p.m_route_pos->clone(); -#else - m_router = p.m_router; - m_filter = p.m_filter; -#endif return *this; } -void yp2::Package::move() +void mp::Package::move() { -#if ROUTE_POS if (m_route_pos) { - const filter::Base *next_filter = m_route_pos->move(); + const filter::Base *next_filter = m_route_pos->move(0); if (next_filter) next_filter->process(*this); } -#else - m_filter = m_router->move(m_filter, this); - if (m_filter) - m_filter->process(*this); -#endif } -yp2::Session & yp2::Package::session() +void mp::Package::move(std::string route) { - return m_session; + if (m_route_pos) + { + const char *r_cstr = route.length() ? route.c_str() : 0; + const filter::Base *next_filter = m_route_pos->move(r_cstr); + if (next_filter) + next_filter->process(*this); + } } -int yp2::Package::data() const +mp::Session & mp::Package::session() { - return m_data; -} - -int & yp2::Package::data() -{ - return m_data; -} - -yp2::Package & yp2::Package::data(const int & data) -{ - m_data = data; - return *this; + return m_session; } -yp2::Origin yp2::Package::origin() const +mp::Origin mp::Package::origin() const { return m_origin; } -yp2::Origin & yp2::Package::origin() +mp::Origin & mp::Package::origin() { return m_origin; } -yp2::Package & yp2::Package::origin(const Origin & origin) +mp::Package & mp::Package::origin(const Origin & origin) { m_origin = origin; return *this; } -yp2::Package & yp2::Package::router(const yp2::Router &router) +mp::Package & mp::Package::router(const mp::Router &router) { -#if ROUTE_POS m_route_pos = router.createpos(); -#else - m_filter = 0; - m_router = &router; -#endif return *this; } -yazpp_1::GDU &yp2::Package::request() +yazpp_1::GDU &mp::Package::request() { return m_request_gdu; } -yazpp_1::GDU &yp2::Package::response() +yazpp_1::GDU &mp::Package::response() { return m_response_gdu; } -yp2::Session yp2::Package::session() const +mp::Session mp::Package::session() const { return m_session; } + +std::ostream& std::operator<<(std::ostream& os, mp::Package& p) +{ + os << p.origin() << " "; + os << p.session().id(); + return os; +} + /* * Local variables: * c-basic-offset: 4 + * c-file-style: "Stroustrup" * indent-tabs-mode: nil - * c-file-style: "stroustrup" * End: * vim: shiftwidth=4 tabstop=8 expandtab */ +