[Boost-commit] svn:boost r43630 - in sandbox/SOC/2007/signals/libs/dataflow: build/xcodeide/dataflow.xcodeproj example/signals

From: stipe_at_[hidden]
Date: 2008-03-15 12:59:36

Author: srajko
Date: 2008-03-15 12:59:35 EDT (Sat, 15 Mar 2008)
New Revision: 43630
URL: http://svn.boost.org/trac/boost/changeset/43630

Log:
added specific_tracking_example
Added:
   sandbox/SOC/2007/signals/libs/dataflow/example/signals/specific_tracking_consumer_example.cpp   (contents, props changed)
Text files modified: 
   sandbox/SOC/2007/signals/libs/dataflow/build/xcodeide/dataflow.xcodeproj/project.pbxproj |     2 ++                                      
   sandbox/SOC/2007/signals/libs/dataflow/example/signals/Jamfile.v2                        |     3 ++-                                     
   2 files changed, 4 insertions(+), 1 deletions(-)

Modified: sandbox/SOC/2007/signals/libs/dataflow/build/xcodeide/dataflow.xcodeproj/project.pbxproj
==============================================================================
--- sandbox/SOC/2007/signals/libs/dataflow/build/xcodeide/dataflow.xcodeproj/project.pbxproj	(original)
+++ sandbox/SOC/2007/signals/libs/dataflow/build/xcodeide/dataflow.xcodeproj/project.pbxproj	2008-03-15 12:59:35 EDT (Sat, 15 Mar 2008)
@@ -122,6 +122,7 @@
                 089321B50D7BB26100F16965 /* examples.qbk */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = text; path = examples.qbk; sourceTree = "<group>"; };
                 089321B60D7BB28000F16965 /* examples.qbk */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = text; path = examples.qbk; sourceTree = "<group>"; };
                 089321BB0D7BB38D00F16965 /* examples.qbk */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = text; path = examples.qbk; sourceTree = "<group>"; };
+		08998BA10D8B2094006ED577 /* specific_tracking_consumer_example.cpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.cpp; path = specific_tracking_consumer_example.cpp; sourceTree = "<group>"; };
                 089AE57F0D79C5CF00AB9DA8 /* bind_mem_fn.hpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.h; path = bind_mem_fn.hpp; sourceTree = "<group>"; };
                 089AE5830D79C7CB00AB9DA8 /* bind_object.hpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.h; path = bind_object.hpp; sourceTree = "<group>"; };
                 089AE58B0D79C96200AB9DA8 /* slot_type.hpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.h; path = slot_type.hpp; sourceTree = "<group>"; };
@@ -778,6 +779,7 @@
                                 084D2E6E0CE7DFE900E861FA /* gil_example.cpp */,
                                 08A0E54C0D7A7674009B11DD /* quick_start_examples.cpp */,
                                 083F151E0D8A356500D0F8B7 /* tracking_consumer_example.cpp */,
+				08998BA10D8B2094006ED577 /* specific_tracking_consumer_example.cpp */,
                         );
                         path = signals;
                         sourceTree = "<group>";

Modified: sandbox/SOC/2007/signals/libs/dataflow/example/signals/Jamfile.v2
==============================================================================
--- sandbox/SOC/2007/signals/libs/dataflow/example/signals/Jamfile.v2	(original)
+++ sandbox/SOC/2007/signals/libs/dataflow/example/signals/Jamfile.v2	2008-03-15 12:59:35 EDT (Sat, 15 Mar 2008)
@@ -18,4 +18,5 @@
     /boost/system//boost_system/<link>static ;
 exe gil_example : gil_example.cpp /boost/thread//boost_thread/<link>static ;
 exe quick_start_examples : quick_start_examples.cpp ;
-exe tracking_consumer_example : tracking_consumer_example.cpp ;
\ No newline at end of file
+exe tracking_consumer_example : tracking_consumer_example.cpp ;
+exe specific_tracking_consumer_example : specific_tracking_consumer_example.cpp ;
\ No newline at end of file

Added: sandbox/SOC/2007/signals/libs/dataflow/example/signals/specific_tracking_consumer_example.cpp
==============================================================================
--- (empty file)
+++ sandbox/SOC/2007/signals/libs/dataflow/example/signals/specific_tracking_consumer_example.cpp	2008-03-15 12:59:35 EDT (Sat, 15 Mar 2008)
@@ -0,0 +1,143 @@
+// Copyright 2008 Stjepan Rajko.
+// Distributed under the Boost Software License, Version 1.0. (See
+// accompanying file LICENSE_1_0.txt or copy at
+// http://www.boost.org/LICENSE_1_0.txt)
+
+#include <boost/dataflow/signals/component/storage.hpp>
+
+#include <boost/foreach.hpp>
+
+#include <iostream>
+
+namespace boost { namespace dataflow {
+
+namespace signals {
+
+    // we're making a new PortTraits for a operator() consumer that can track
+    struct specific_tracking_call_consumer
+        : public port_traits<ports::consumer, tag>
+    {};
+
+} // namespace signals
+
+namespace extension {
+
+    // here we specialize the connect operation
+    template<typename T>
+    struct binary_operation_impl<signals::producer<T>, signals::specific_tracking_call_consumer, operations::connect>
+    {
+        typedef boost::signals::connection result_type;
+        
+        template<typename Producer, typename Consumer>
+        result_type operator()(Producer &producer, Consumer &consumer)
+        {
+            // object_type is so that a port_adapter can be used on the consumer
+            typedef typename get_object_type<Consumer>::type object_type;
+            typedef typename boost::dataflow::utility::slot_type<T, object_type>::type mem_fn_type;
+            
+            // grab the correct overload of operator()
+            boost::function<T> mem_fn = boost::dataflow::utility::bind_mem_fn<mem_fn_type, object_type>
+                (static_cast<mem_fn_type>(&object_type::operator()), get_object(consumer));
+
+            // make the connection, register it with the consumer
+            result_type connection = producer.connect(mem_fn);
+            get_object(consumer).register_connection(&producer, connection);
+            return connection;
+        }
+    };
+    
+} // namespace extension
+
+} } // namespace boost::dataflow
+
+using namespace boost;
+namespace df = boost::dataflow;
+
+// simple consumer that tracks its connections - when it receives a specified
+// number of signals, it will disconnect itself from any producers that sends
+// it a signal
+class specific_tracking_consumer
+    : public df::port<df::signals::specific_tracking_call_consumer>
+{
+public:
+    specific_tracking_consumer(unsigned max_count)
+        : m_count(0), m_max_count(max_count)
+    {}
+    
+    void operator()(void *producer)
+    {
+        m_count++;
+        if (m_count >= m_max_count)
+            disconnect_all(producer);
+    }
+    
+    void register_connection(void *producer, const signals::connection &connection)
+    {   m_connections.push_back(connections_type::value_type(producer, connection)); }
+    
+    unsigned count()
+    {   return m_count; }
+    
+private:
+    void disconnect_all(void *producer)
+    {
+        connections_type::reverse_iterator it, next;
+        for(it=m_connections.rbegin(); it!= m_connections.rend(); it=next)
+        {
+            next = it+1;
+            if (it->first == producer)
+            {
+                it->second.disconnect();
+                m_connections.erase(next.base());
+            }
+        }
+    }
+        
+    typedef std::vector<std::pair<void *, signals::connection> > connections_type;
+    connections_type m_connections;
+    unsigned m_count, m_max_count;
+};
+
+// this class sends signals compatible with what specific_tracking_consumer
+// expects (it sends the address of its signal to identify itself)
+class trackable_producer : public signals::filter<trackable_producer, void(void *)>
+{
+public:
+    void operator()()
+    {
+        // out is the signal.  we'll send it's address.
+        out(&out);
+    }
+};
+
+int main(int, char* [])
+{
+    trackable_producer producer1, producer2;
+    specific_tracking_consumer c1(1), c3(3), c5(5);
+    
+    connect(producer1, c1);
+    connect(producer1, c3);
+    connect(producer1, c5);
+
+    connect(producer2, c1);
+    connect(producer2, c3);
+    connect(producer2, c5);
+
+    // send out 5 signals.  c1 should disconnect after 1, c3 after 3, c5 after 5
+    // all disconnects are from producer1 only
+    for(int i=0; i<5; i++)
+        producer1();
+    
+    // producer2 is still connected.  each consumer will receive another signal
+    // and disconnect from producer2
+    producer2();
+        
+    std::cout << c1.count() << std::endl; // 2
+    std::cout << c3.count() << std::endl; // 4
+    std::cout << c5.count() << std::endl; // 6
+    
+    // get_port_c<0> will retreive the signal - there are no more consumers connected
+    std::cout << df::get_port_c<0, df::signals::tag>(producer1).num_slots() << std::endl; // 0
+    std::cout << df::get_port_c<0, df::signals::tag>(producer2).num_slots() << std::endl; // 0
+
+    return 0;
+}