Lines Matching refs:receiver
136 template< typename T > class receiver; variable
213 typedef receiver<T> successor_type;
222 friend bool register_successor(sender<C>& s, receiver<C>& r);
225 friend bool remove_successor (sender<C>& s, receiver<C>& r);
229 bool register_successor(sender<C>& s, receiver<C>& r) { in register_successor()
234 bool remove_successor(sender<C>& s, receiver<C>& r) { in remove_successor()
240 class receiver {
243 virtual ~receiver() {} in ~receiver()
280 friend bool register_predecessor(receiver<C>& r, sender<C>& s);
282 friend bool remove_predecessor (receiver<C>& r, sender<C>& s);
286 bool register_predecessor(receiver<C>& r, sender<C>& s) { in register_predecessor()
291 bool remove_predecessor(receiver<C>& r, sender<C>& s) { in remove_predecessor()
297 class continue_receiver : public receiver< continue_msg > {
308 continue_receiver( const continue_receiver& src ) : receiver<continue_msg>() { in continue_receiver()
335 typedef receiver<input_type>::predecessor_type predecessor_type;
789 …static_cast<receiver<input_type> *>(this), static_cast<sender<output_type> *>(this), this->my_body… in __TBB_requires()
818 …static_cast<receiver<input_type> *>(this), static_cast<sender<output_type> *>(this), this->my_body… in __TBB_requires()
883 &this->my_graph, static_cast<receiver<input_type> *>(this), in __TBB_requires()
911 &this->my_graph, static_cast<receiver<input_type> *>(this), in __TBB_requires()
923 class split_node : public graph_node, public receiver<TupleType> {
925 typedef receiver<TupleType> base_type;
939 static_cast<receiver<input_type> *>(this), this->output_ports()); in split_node()
954 static_cast<receiver<input_type> *>(this), this->output_ports()); in split_node()
1002 static_cast<receiver<input_type> *>(this), in __TBB_requires()
1035 static_cast<receiver<input_type> *>(this), in __TBB_requires()
1065 static_cast<receiver<input_type> *>(this), in __TBB_requires()
1085 class broadcast_node : public graph_node, public receiver<T>, public sender<T> {
1089 typedef typename receiver<input_type>::predecessor_type predecessor_type;
1097 … static_cast<receiver<input_type> *>(this), static_cast<sender<output_type> *>(this) ); in broadcast_node()
1150 , public receiver<T>, public sender<T>
1157 typedef typename receiver<input_type>::predecessor_type predecessor_type;
1369 : graph_node(g), reservable_item_buffer<T, internals_allocator>(), receiver<T>(), in buffer_node()
1374 … static_cast<receiver<input_type> *>(this), static_cast<sender<output_type> *>(this) ); in buffer_node()
1554 typedef typename receiver<input_type>::predecessor_type predecessor_type;
1560 static_cast<receiver<input_type> *>(this), in queue_node()
1574 static_cast<receiver<input_type> *>(this), in queue_node()
1595 typedef typename receiver<input_type>::predecessor_type predecessor_type; in __TBB_requires()
1604 static_cast<receiver<input_type> *>(this), in __TBB_requires()
1621 static_cast<receiver<input_type> *>(this), in __TBB_requires()
1664 typedef typename receiver<input_type>::predecessor_type predecessor_type;
1671 static_cast<receiver<input_type> *>(this),
1688 static_cast<receiver<input_type> *>(this), in priority_queue_node()
1877 class limiter_node : public graph_node, public receiver< T >, public sender< T > {
1881 typedef typename receiver<input_type>::predecessor_type predecessor_type;
2002 … static_cast<receiver<input_type> *>(this), static_cast<receiver<DecrementType> *>(&decrement), in initialize()
2028 receiver<DecrementType>& decrementer() { return decrement; } in decrementer()
2627 inline void internal_make_edge( sender<T> &p, receiver<T> &s ) { in internal_make_edge()
2634 inline void make_edge( sender<T> &p, receiver<T> &s ) { in make_edge()
2648 inline void make_edge( T& output, receiver<R>& input) { in make_edge()
2660 inline void internal_remove_edge( sender<T> &p, receiver<T> &s ) { in internal_remove_edge()
2667 inline void remove_edge( sender<T> &p, receiver<T> &s ) { in remove_edge()
2681 inline void remove_edge( T& output, receiver<R>& input) { in remove_edge()
2704 typedef std::tuple< receiver<InputTypes>&... > input_ports_type;
2756 typedef std::tuple< receiver<InputTypes>&... > input_ports_type;
2881 typedef receiver<input_type> receiver_type; in __TBB_requires()
2882 typedef receiver<output_type> successor_type; in __TBB_requires()
2946 &this->my_graph, static_cast<receiver<input_type> *>(this), in __TBB_requires()
2977 &this->my_graph, static_cast<receiver<input_type> *>(this), in __TBB_requires()
3018 class overwrite_node : public graph_node, public receiver<T>, public sender<T> {
3022 typedef typename receiver<input_type>::predecessor_type predecessor_type;
3029 … static_cast<receiver<input_type> *>(this), static_cast<sender<output_type> *>(this) ); in overwrite_node()
3173 typedef typename receiver<input_type>::predecessor_type predecessor_type;
3179 static_cast<receiver<input_type> *>(this), in write_once_node()
3193 static_cast<receiver<input_type> *>(this), in write_once_node()
3307 using detail::d1::receiver;