X-Git-Url: http://sru.miketaylor.org.uk/?a=blobdiff_plain;f=src%2Fpackage.hpp;h=c5e63ff69b739bad293e55808c78f97111bcd8d0;hb=77dee8966dd1304a0fb8540c3fc68d02dc6ce84a;hp=a4924ddf39bb46c25b188d7791f62b8edc8b3bb3;hpb=7969e482bd427717e116917116e52958432a9c16;p=metaproxy-moved-to-github.git diff --git a/src/package.hpp b/src/package.hpp index a4924dd..c5e63ff 100644 --- a/src/package.hpp +++ b/src/package.hpp @@ -1,83 +1,87 @@ +/* $Id: package.hpp,v 1.10 2005-11-11 15:00:25 adam Exp $ + Copyright (c) 2005, Index Data. -#ifndef PACKAGE_HPP -#define PACKAGE_HPP +%LICENSE% + */ + +#ifndef YP2_PACKAGE_HPP +#define YP2_PACKAGE_HPP +#include #include +#include +#include "router.hpp" +#include "filter.hpp" +#include "session.hpp" 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; - } + + 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(yp2::Session &session, yp2::Origin &origin); - /// set function - can be chained - Package & data(const unsigned int & data){ - m_data = data; - return *this; - } - + Package & copy_filter(const Package &p); - //Router router() const { - // return m_router; - //} + /// send Package to it's next Filter defined in Router + void move(); + + /// access session - left val in assignment + yp2::Session & session(); + + /// get function - right val in assignment + unsigned int data() const; - //Router & router() { - // return m_router; - //} + + /// set function - left val in assignment + unsigned int & data(); + + /// set function - can be chained + Package & data(const unsigned 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); - /// set function - can be chained - Package & router(const Router &router){ - m_filter = 0; - m_router = &router; - return *this; - } + Package & router(const Router &router); - - private: - unsigned long int m_session_id; - bool m_session_close; - const Filter *m_filter; - const Router *m_router; - unsigned int m_data; - }; - + yazpp_1::GDU &request(); - + yazpp_1::GDU &response(); + + /// get function - right val in assignment + Session session() const; + + private: + Session m_session; + Origin m_origin; + + const filter::Base *m_filter; + const Router *m_router; + unsigned int m_data; + + yazpp_1::GDU m_request_gdu; + yazpp_1::GDU m_response_gdu; + }; } #endif @@ -85,6 +89,7 @@ namespace yp2 { * Local variables: * c-basic-offset: 4 * indent-tabs-mode: nil + * c-file-style: "stroustrup" * End: * vim: shiftwidth=4 tabstop=8 expandtab */