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;
+}