src/package.cpp

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