X-Git-Url: http://sru.miketaylor.org.uk/?a=blobdiff_plain;f=src%2Fpackage.hpp;h=1be3ed585a16c0a247d658e2a8295ba448f56875;hb=1e61b0aa05e2351e33d909f7503eaf936a2d9bb0;hp=a4924ddf39bb46c25b188d7791f62b8edc8b3bb3;hpb=7969e482bd427717e116917116e52958432a9c16;p=metaproxy-moved-to-github.git diff --git a/src/package.hpp b/src/package.hpp index a4924dd..1be3ed5 100644 --- a/src/package.hpp +++ b/src/package.hpp @@ -1,83 +1,91 @@ +/* $Id: package.hpp,v 1.17 2006-06-10 14:29:12 adam Exp $ + Copyright (c) 2005-2006, Index Data. -#ifndef PACKAGE_HPP -#define PACKAGE_HPP + See the LICENSE file for details + */ + +#ifndef YP2_PACKAGE_HPP +#define YP2_PACKAGE_HPP +#include #include +#include + +#include "router.hpp" +#include "filter.hpp" +#include "session.hpp" + +namespace metaproxy_1 { + + class Origin { + enum origin_t { + API, + UNIX, + TCPIP + } type; + std::string address; // UNIX+TCPIP + int port; // TCPIP only + public: + Origin() : type(API) {}; + }; + + class Package { + public: + Package(); + + ~Package(); + + Package(metaproxy_1::Session &session, metaproxy_1::Origin &origin); + + Package & copy_filter(const Package &p); + + /// send Package to it's next Filter defined in Router + void move(); + + /// send Package to other route + void move(std::string route); + + /// access session - left val in assignment + metaproxy_1::Session & session(); + + /// get function - right val in assignment + int data() const; + + /// set function - left val in assignment + int & data(); + + /// set function - can be chained + Package & data(const int & data); + + /// get function - right val in assignment + Origin origin() const; + + /// set function - left val in assignment + Origin & origin(); + + /// set function - can be chained + Package & origin(const Origin & origin); + + Package & router(const Router &router); + + yazpp_1::GDU &request(); + + yazpp_1::GDU &response(); + + /// get function - right val in assignment + Session session() const; + + private: + Session m_session; + Origin m_origin; + RoutePos *m_route_pos; -namespace yp2 { - - class Package { - public: - - Package(unsigned long int id = 0, bool close = 0) - : m_session_id(id), m_session_close(close), - m_filter(0), m_router(0), m_data(0) {} - - /// send Package to it's next Filter defined in Router - Package & move() { - m_filter = m_router->move(m_filter, this); - if (m_filter) - return m_filter->process(*this); - else - return *this; - } - - - /// get function - right val in assignment - unsigned int session_id() const { - return m_session_id; - } - - /// get function - right val in assignment - unsigned int session_close() const { - return m_session_close; - } - - - /// get function - right val in assignment - unsigned int data() const { - return m_data; - } - - /// set function - left val in assignment - unsigned int & data() { - return m_data; - } - - /// set function - can be chained - Package & data(const unsigned int & data){ - m_data = data; - return *this; - } - - - //Router router() const { - // return m_router; - //} - - //Router & router() { - // return m_router; - //} - - /// set function - can be chained - Package & router(const Router &router){ - m_filter = 0; - m_router = &router; - return *this; - } - - - private: - unsigned long int m_session_id; - bool m_session_close; - const Filter *m_filter; - const Router *m_router; - unsigned int m_data; - }; - - - + int m_data; + + yazpp_1::GDU m_request_gdu; + yazpp_1::GDU m_response_gdu; + }; } #endif @@ -85,6 +93,7 @@ namespace yp2 { * Local variables: * c-basic-offset: 4 * indent-tabs-mode: nil + * c-file-style: "stroustrup" * End: * vim: shiftwidth=4 tabstop=8 expandtab */