src/package.cpp

   1 /* $Id: package.cpp,v 1.13 2006-08-30 08:49:13 marc Exp $
   2    Copyright (c) 2005-2006, Index Data.
   3
   4    See the LICENSE file for details
   5  */
   6
   7
   8 #include "config.hpp"
   9 #include "package.hpp"
  10
  11 #include <iostream>
  12
  13 namespace mp = metaproxy_1;
  14
  15 mp::Package::Package()
  16     : m_route_pos(0), m_data(0)
  17 {
  18 }
  19
  20 mp::Package::~Package()
  21 {
  22     delete m_route_pos;
  23 }
  24
  25 mp::Package::Package(mp::Session &session, const mp::Origin &origin)
  26     : m_session(session), m_origin(origin),
  27       m_route_pos(0), m_data(0)
  28 {
  29 }
  30
  31 mp::Package::Package(mp::Session &session,
  32                      const mp::Origin &origin, const mp::Origin &target)
  33     : m_session(session), m_origin(origin), m_target(target),
  34       m_route_pos(0), m_data(0)
  35 {
  36 }
  37
  38 mp::Package & mp::Package::copy_filter(const Package &p)
  39 {
  40     delete m_route_pos;
  41     m_route_pos = p.m_route_pos->clone();
  42     return *this;
  43 }
  44
  45
  46 void mp::Package::move()
  47 {
  48     if (m_route_pos)
  49     {
  50         const filter::Base *next_filter = m_route_pos->move(0);
  51         if (next_filter)
  52             next_filter->process(*this);
  53     }
  54 }
  55
  56 void mp::Package::move(std::string route)
  57 {
  58     if (m_route_pos)
  59     {
  60         const char *r_cstr = route.length() ? route.c_str() : 0;
  61         const filter::Base *next_filter = m_route_pos->move(r_cstr);
  62         if (next_filter)
  63             next_filter->process(*this);
  64     }
  65 }
  66
  67
  68 mp::Session & mp::Package::session()
  69 {
  70     return m_session;
  71 }
  72
  73
  74 int mp::Package::data() const
  75 {
  76     return m_data;
  77 }
  78
  79 int & mp::Package::data()
  80 {
  81     return m_data;
  82 }
  83
  84 mp::Package & mp::Package::data(const int & data)
  85 {
  86     m_data = data;
  87     return *this;
  88 }
  89
  90 mp::Origin mp::Package::origin() const
  91 {
  92     return m_origin;
  93 }
  94
  95 mp::Origin & mp::Package::origin()
  96 {
  97     return m_origin;
  98 }
  99
 100 mp::Package & mp::Package::origin(const Origin & origin)
 101 {
 102     m_origin = origin;
 103     return *this;
 104 }
 105
 106 mp::Origin mp::Package::target() const
 107 {
 108     return m_target;
 109 }
 110
 111 mp::Origin & mp::Package::target()
 112 {
 113     return m_target;
 114 }
 115
 116 mp::Package & mp::Package::target(const Origin & target)
 117 {
 118     m_target = target;
 119     return *this;
 120 }
 121
 122 mp::Package & mp::Package::router(const mp::Router &router)
 123 {
 124     m_route_pos = router.createpos();
 125     return *this;
 126 }
 127
 128 yazpp_1::GDU &mp::Package::request()
 129 {
 130     return m_request_gdu;
 131 }
 132
 133
 134 yazpp_1::GDU &mp::Package::response()
 135 {
 136     return m_response_gdu;
 137 }
 138
 139 mp::Session mp::Package::session() const
 140 {
 141     return m_session;
 142 }
 143
 144 std::ostream& std::operator<<(std::ostream& os,  mp::Package& p)
 145 {
 146     os << p.session().id() << " ";
 147     os << p.origin() << " ";
 148     os << p.target();
 149     return os;
 150 }
 151
 152 std::ostream& std::operator<<(std::ostream& os,  mp::Origin& o)
 153 {
 154     if (o.address != "")
 155         os << o.address;
 156     else
 157         os << "0";
 158     os << ":" << o.port;
 159     return os;
 160 }
 161
 162
 163 /*
 164  * Local variables:
 165  * c-basic-offset: 4
 166  * indent-tabs-mode: nil
 167  * c-file-style: "stroustrup"
 168  * End:
 169  * vim: shiftwidth=4 tabstop=8 expandtab
 170  */