src/package.cpp

   1 /* $Id: package.cpp,v 1.11 2006-08-30 08:35:03 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 & mp::Package::copy_filter(const Package &p)
  32 {
  33     delete m_route_pos;
  34     m_route_pos = p.m_route_pos->clone();
  35     return *this;
  36 }
  37
  38
  39 void mp::Package::move()
  40 {
  41     if (m_route_pos)
  42     {
  43         const filter::Base *next_filter = m_route_pos->move(0);
  44         if (next_filter)
  45             next_filter->process(*this);
  46     }
  47 }
  48
  49 void mp::Package::move(std::string route)
  50 {
  51     if (m_route_pos)
  52     {
  53         const char *r_cstr = route.length() ? route.c_str() : 0;
  54         const filter::Base *next_filter = m_route_pos->move(r_cstr);
  55         if (next_filter)
  56             next_filter->process(*this);
  57     }
  58 }
  59
  60
  61 mp::Session & mp::Package::session()
  62 {
  63     return m_session;
  64 }
  65
  66
  67 int mp::Package::data() const
  68 {
  69     return m_data;
  70 }
  71
  72 int & mp::Package::data()
  73 {
  74     return m_data;
  75 }
  76
  77 mp::Package & mp::Package::data(const int & data)
  78 {
  79     m_data = data;
  80     return *this;
  81 }
  82
  83 mp::Origin mp::Package::origin() const
  84 {
  85     return m_origin;
  86 }
  87
  88 mp::Origin & mp::Package::origin()
  89 {
  90     return m_origin;
  91 }
  92
  93 mp::Package & mp::Package::origin(const Origin & origin)
  94 {
  95     m_origin = origin;
  96     return *this;
  97 }
  98
  99 mp::Package & mp::Package::router(const mp::Router &router)
 100 {
 101     m_route_pos = router.createpos();
 102     return *this;
 103 }
 104
 105 yazpp_1::GDU &mp::Package::request()
 106 {
 107     return m_request_gdu;
 108 }
 109
 110
 111 yazpp_1::GDU &mp::Package::response()
 112 {
 113     return m_response_gdu;
 114 }
 115
 116 mp::Session mp::Package::session() const
 117 {
 118     return m_session;
 119 }
 120
 121 std::ostream& std::operator<<(std::ostream& os,  mp::Package& p)
 122 {
 123     os << p.session().id() << " ";
 124     os << p.origin();
 125     return os;
 126 }
 127
 128 std::ostream& std::operator<<(std::ostream& os,  mp::Origin& o)
 129 {
 130     if (o.address != "")
 131         os << o.address;
 132     else
 133         os << "0";
 134     os << ":" << o.port;
 135     return os;
 136 }
 137
 138
 139 /*
 140  * Local variables:
 141  * c-basic-offset: 4
 142  * indent-tabs-mode: nil
 143  * c-file-style: "stroustrup"
 144  * End:
 145  * vim: shiftwidth=4 tabstop=8 expandtab
 146  */