Lines Matching refs:sender
135 template< typename T > class sender; variable
192 class sender {
194 virtual ~sender() {} in ~sender()
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()
259 typedef sender<T> predecessor_type;
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()
538 class input_node : public graph_node, public sender< Output > { in __TBB_requires()
544 typedef typename sender<output_type>::successor_type successor_type; in __TBB_requires()
559 static_cast<sender<output_type> *>(this), this->my_body); in __TBB_requires()
574 : graph_node(src.my_graph), sender<Output>() in __TBB_requires()
580 static_cast<sender<output_type> *>(this), this->my_body); in __TBB_requires()
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()
1003 … static_cast<sender<output_type> *>(this), this->my_body ); in __TBB_requires()
1036 … static_cast<sender<output_type> *>(this), this->my_body ); in __TBB_requires()
1066 … static_cast<sender<output_type> *>(this), this->my_body ); in __TBB_requires()
1085 class broadcast_node : public graph_node, public receiver<T>, public sender<T> {
1090 typedef typename sender<output_type>::successor_type successor_type;
1097 … static_cast<receiver<input_type> *>(this), static_cast<sender<output_type> *>(this) ); in broadcast_node()
1150 , public receiver<T>, public sender<T>
1158 typedef typename sender<output_type>::successor_type successor_type;
1370 sender<T>(), my_successors(this), forwarder_busy(false) in buffer_node()
1374 … static_cast<receiver<input_type> *>(this), static_cast<sender<output_type> *>(this) ); in buffer_node()
1555 typedef typename sender<output_type>::successor_type successor_type;
1561 static_cast<sender<output_type> *>(this) ); in queue_node()
1575 static_cast<sender<output_type> *>(this) ); in queue_node()
1596 typedef typename sender<output_type>::successor_type successor_type; in __TBB_requires()
1605 static_cast<sender<output_type> *>(this) ); in __TBB_requires()
1622 static_cast<sender<output_type> *>(this) ); in __TBB_requires()
1665 typedef typename sender<output_type>::successor_type successor_type;
1672 static_cast<sender<output_type> *>(this) );
1689 static_cast<sender<output_type> *>(this) ); in priority_queue_node()
1877 class limiter_node : public graph_node, public receiver< T >, public sender< T > {
1882 typedef typename sender<output_type>::successor_type successor_type;
2003 static_cast<sender<output_type> *>(this) in initialize()
2150 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in join_node()
2162 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in join_node()
2177 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in join_node()
2189 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in join_node()
2230 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in __TBB_requires()
2236 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in __TBB_requires()
2242 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in __TBB_requires()
2249 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in __TBB_requires()
2258 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in __TBB_requires()
2268 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in __TBB_requires()
2278 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in __TBB_requires()
2288 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in __TBB_requires()
2298 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in __TBB_requires()
2319 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in join_node()
2343 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2356 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2370 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2383 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2398 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2411 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2426 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2439 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2454 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2467 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2483 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2496 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2514 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2527 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2545 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2558 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2576 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2589 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2607 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
2620 … this->input_ports(), static_cast< sender< output_type > *>(this) ); in indexer_node()
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()
2655 inline void make_edge( sender<S>& output, V& 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()
2687 inline void remove_edge( sender<S>& output, V& input) { in remove_edge()
2705 typedef std::tuple< sender<OutputTypes>&... > output_ports_type;
2797 typedef std::tuple< sender<OutputTypes>&... > output_ports_type;
2872 : public multifunction_node< Input, std::tuple< Output >, Policy >, public sender< Output > in __TBB_requires()
2883 typedef sender<input_type> predecessor_type; in __TBB_requires()
2972 …__TBB_NOINLINE_SYM async_node( const async_node &other ) : base_type(other), sender<Output>(), my_… in __TBB_requires()
3018 class overwrite_node : public graph_node, public receiver<T>, public sender<T> {
3023 typedef typename sender<output_type>::successor_type successor_type;
3029 … static_cast<receiver<input_type> *>(this), static_cast<sender<output_type> *>(this) ); in overwrite_node()
3174 typedef typename sender<output_type>::successor_type successor_type;
3180 static_cast<sender<output_type> *>(this) ); in write_once_node()
3194 static_cast<sender<output_type> *>(this) ); in write_once_node()
3308 using detail::d1::sender;