src/package.cpp

   1 /* This file is part of Metaproxy.
   2    Copyright (C) 2005-2011 Index Data
   3
   4 Metaproxy is free software; you can redistribute it and/or modify it under
   5 the terms of the GNU General Public License as published by the Free
   6 Software Foundation; either version 2, or (at your option) any later
   7 version.
   8
   9 Metaproxy is distributed in the hope that it will be useful, but WITHOUT ANY
  10 WARRANTY; without even the implied warranty of MERCHANTABILITY or
  11 FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
  12 for more details.
  13
  14 You should have received a copy of the GNU General Public License
  15 along with this program; if not, write to the Free Software
  16 Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
  17 */
  18
  19 #include "config.hpp"
  20 #include <metaproxy/package.hpp>
  21
  22 #include <iostream>
  23
  24 namespace mp = metaproxy_1;
  25
  26 mp::Package::Package()
  27     : m_route_pos(0)
  28 {
  29 }
  30
  31 mp::Package::~Package()
  32 {
  33     delete m_route_pos;
  34 }
  35
  36 mp::Package::Package(mp::Session &session, const mp::Origin &origin)
  37     : m_session(session), m_origin(origin),
  38       m_route_pos(0)
  39 {
  40 }
  41
  42
  43 mp::Package & mp::Package::copy_filter(const Package &p)
  44 {
  45     delete m_route_pos;
  46     m_route_pos = p.m_route_pos->clone();
  47     return *this;
  48 }
  49
  50
  51 void mp::Package::move()
  52 {
  53     if (m_route_pos)
  54     {
  55         const filter::Base *next_filter = m_route_pos->move(0);
  56         if (next_filter)
  57             next_filter->process(*this);
  58     }
  59 }
  60
  61 void mp::Package::move(std::string route)
  62 {
  63     if (m_route_pos)
  64     {
  65         const char *r_cstr = route.length() ? route.c_str() : 0;
  66         const filter::Base *next_filter = m_route_pos->move(r_cstr);
  67         if (next_filter)
  68             next_filter->process(*this);
  69     }
  70 }
  71
  72
  73 mp::Session & mp::Package::session()
  74 {
  75     return m_session;
  76 }
  77
  78 mp::Origin mp::Package::origin() const
  79 {
  80     return m_origin;
  81 }
  82
  83 mp::Origin & mp::Package::origin()
  84 {
  85     return m_origin;
  86 }
  87
  88 mp::Package & mp::Package::origin(const Origin & origin)
  89 {
  90     m_origin = origin;
  91     return *this;
  92 }
  93
  94 mp::Package & mp::Package::router(const mp::Router &router)
  95 {
  96     m_route_pos = router.createpos();
  97     return *this;
  98 }
  99
 100 yazpp_1::GDU &mp::Package::request()
 101 {
 102     return m_request_gdu;
 103 }
 104
 105
 106 yazpp_1::GDU &mp::Package::response()
 107 {
 108     return m_response_gdu;
 109 }
 110
 111 mp::Session mp::Package::session() const
 112 {
 113     return m_session;
 114 }
 115
 116 std::ostream& std::operator<<(std::ostream& os,  mp::Package& p)
 117 {
 118     os << p.origin() << " ";
 119     os << p.session().id();
 120     return os;
 121 }
 122
 123
 124 /*
 125  * Local variables:
 126  * c-basic-offset: 4
 127  * c-file-style: "Stroustrup"
 128  * indent-tabs-mode: nil
 129  * End:
 130  * vim: shiftwidth=4 tabstop=8 expandtab
 131  */
 132