X-Git-Url: http://sru.miketaylor.org.uk/?a=blobdiff_plain;f=src%2Fdesign.h;h=a2b08b96e1a67fb529450f819b867ba433c1bfc8;hb=c90fa1d9d80ba80198953b34c2e5a3134d1b5402;hp=bb6f5b1a1030ece1821e8e46c6e5df64846876a5;hpb=1500d350bb472bc50d36642060e559bb67c1d185;p=metaproxy-moved-to-github.git

diff --git a/src/design.h b/src/design.h
index bb6f5b1..a2b08b9 100644
--- a/src/design.h
+++ b/src/design.h
@@ -1,147 +1,238 @@
 
-#ifndef P3_FILTER_H
-#define P3_FILTER_H
+#ifndef DESIGN_H
+#define DESIGN_H
 
 #include <stdexcept>
+#include <list>
 
+#include <boost/thread/mutex.hpp>
 
-namespace p3 {
+namespace yp2 {
 
-  class Package;
+    class Package;
+    
+    class Filter {
+    public:
+        virtual ~Filter(){};
+
+        ///sends Package off to next Filter, returns altered Package
+        virtual  Package & process(Package & package) const {
+            return package;
+        };
+        virtual  void configure(){};
+
+        /// get function - right val in assignment
+        std::string name() const {
+            return m_name;
+        }
+
+        /// set function - left val in assignment
+        std::string & name() {
+            return m_name;
+        }
+
+        /// set function - can be chained
+        Filter & name(const std::string & name){
+            m_name = name;
+            return *this;
+        }
+        
+    private:
+        std::string m_name;
+    };
+    
+    
+    class FilterException : public std::runtime_error {
+    public:
+        FilterException(const std::string message)
+            : std::runtime_error("FilterException: " + message){
+        };
+    };
+    
   
-
+    class RouterException : public std::runtime_error {
+    public:
+        RouterException(const std::string message)
+            : std::runtime_error("RouterException: " + message){};
+    };
   
-  class Filter {
-  public:
-    virtual ~Filter(){};
-    virtual  Package & process(Package & package) const {
-      return package;
+    
+    class Router {
+    public:
+        Router(){};
+        virtual ~Router(){};
+
+        /// determines next Filter to use from current Filter and Package
+        virtual const Filter *move(const Filter *filter,
+                                   const Package *package) const {
+            return 0;
+        };
+
+        /// re-read configuration of routing tables
+        virtual void configure(){};
+
+        /// add routing rule expressed as Filter to Router
+        virtual Router & rule(const Filter &filter){
+            return *this;
+        }
+    private:
+        /// disabled because class is singleton
+        Router(const Router &);
+
+        /// disabled because class is singleton
+        Router& operator=(const Router &);
     };
-    virtual  void configure(){};
-
-    // set/get the C++ way .. just as showoff
-
-    // get function - returns copy and keeps object const, 
-    // thus is right val in assignment
-    unsigned int max_front_workers() const {
-      return m_max_front;
-    }
-    // set function - returns reference and changes object,
-    // thus is left val in assignment
-    unsigned int & max_front_workers() {
-      return m_max_front;
-    }
-    // more traditional set function, taking const reference 
-    // or copy (here const ref for demo), returning ref to object
-    // can be chained with other similar functions!
-    Filter & max_front_workers(const unsigned int & max_front){
-      m_max_front = max_front;
-      return *this;
-    }
+  
     
-  private:
-    unsigned int m_max_front;
-  };
-
-
-  class Filter_Exception : public std::runtime_error {
-  public:
-    Filter_Exception(const std::string message)
-      : std::runtime_error("Filter_Exception: " + message){
+    class RouterChain : public Router {
+    public:
+        RouterChain(){};
+        virtual ~RouterChain(){};
+        virtual const Filter *move(const Filter *filter,
+                                   const Package *package) const {
+            std::list<const Filter *>::const_iterator it;
+            it = m_filter_list.begin();
+            if (filter)
+                {
+                    for (; it != m_filter_list.end(); it++)
+                        if (*it == filter)
+                            {
+                                it++;
+                                break;
+                            }
+                }
+            if (it == m_filter_list.end())
+                {
+                    //throw RouterException("no routing rules known");
+                    return 0;
+                }
+            return *it;
+        };
+        virtual void configure(){};
+        RouterChain & rule(const Filter &filter){
+            m_filter_list.push_back(&filter);
+            return *this;
+        }
+    protected:
+        std::list<const Filter *> m_filter_list;
+    private:
+        /// disabled because class is singleton
+        RouterChain(const RouterChain &);
+
+        /// disabled because class is singleton
+        RouterChain& operator=(const RouterChain &);
     };
-  };
-
+  
 
-  class Router {
+  class PackageException : public std::runtime_error {
   public:
-    virtual ~Router(){};
-    virtual const Filter & 
-      route(const Filter & filter, Package & package) const {
-      //if (!m_sillyrule)
-      //throw Router_Exception("no routing rules known");
-          return m_sillyrule;
-    };
-    virtual void configure(){};
-    Router & rule(Filter filter){
-      m_sillyrule = filter;
-      return *this;
-    }
-  private:
-    Filter m_sillyrule;
+      PackageException(const std::string message)
+          : std::runtime_error("PackageException: " + message){
+      };
   };
   
   
-  class Router_Exception : public std::runtime_error {
-  public:
-    Router_Exception(const std::string message)
-      : std::runtime_error("Router_Exception: " + message){};
-  };
-  
-
   class Package {
   public:
-
-    // send package to it's next filter defined in chain
-    void move() {
-      Filter oldfilter;
-      Filter nextfilter = m_router.route(oldfilter, *this);
-      nextfilter.process(*this);
-    }
-    
-
-    // get function - returns copy and keeps object const, 
-    // thus is right val in assignment
-    unsigned int data() const {
-      return m_data;
-    }
-    // set function - returns reference and changes object,
-    // thus is left val in assignment
-    unsigned int & data() {
-      return m_data;
-    }
-
-    // more traditional set function, taking const reference 
-    // or copy (here const ref for demo), returning ref to object
-    // can be chained with other similar functions!
-    Package & data(const unsigned int & data){
-      m_data = data;
-      return *this;
-    }
-
-    // get function - returns copy and keeps object const, 
-    // thus is right val in assignment
-    Router router() const {
-      return m_router;
-    }
-    // set function - returns reference and changes object,
-    // thus is left val in assignment
-    Router & router() {
-      return m_router;
-    }
-    // more traditional set function, taking const reference 
-    // or copy (here const ref for demo), returning ref to object
-    // can be chained with other similar functions!
-    Package & router(const Router & router){
-      m_router = router;
-      return *this;
-    }
-    
+      
+      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 int m_data;
-    Router m_router;
+      unsigned long int m_session_id;
+      bool m_session_close;
+      const Filter *m_filter;
+      const Router *m_router;
+      unsigned int m_data;
   };
+  
 
-
-  class Package_Exception : public std::runtime_error {
-  public:
-    Package_Exception(const std::string message)
-      : std::runtime_error("Package_Exception: " + message){
+  class Session 
+    {
+    public:
+      Session() : m_id(0){};
+      /// returns next id, global state of id protected by boost::mutex
+      long unsigned int id() {
+          boost::mutex::scoped_lock scoped_lock(m_mutex);
+          ++m_id;
+        return m_id;
+      };
+    private:
+      /// disabled because class is singleton
+      Session(const Session &);
+
+      /// disabled because class is singleton
+      Session& operator=(const Session &);
+
+      boost::mutex m_mutex;
+      unsigned long int m_id;
+      
     };
-  };
-
 
 
   
 }
 
 #endif
+/*
+ * Local variables:
+ * c-basic-offset: 4
+ * indent-tabs-mode: nil
+ * End:
+ * vim: shiftwidth=4 tabstop=8 expandtab
+ */