Lines Matching refs:this

21 #error Do not #include this internal file directly; use public TBB headers instead.
304         reserving_port() : my_join(nullptr), my_predecessors(this), reserved(false) {
305             my_aggregator.initialize_handler(handler_type(this));
414                         was_empty = this->buffer_empty();
415                         this->push_back(current->my_val);
424                     if(!this->buffer_empty()) {
426                         *(current->my_arg) = this->front();
434                     __TBB_ASSERT(this->my_item_valid(this->my_head), "No item to reset");
435                     this->destroy_front();
436                     if(this->my_item_valid(this->my_head)) {
467             my_aggregator.initialize_handler(handler_type(this));
570                         bool was_inserted = this->insert_with_key(current->my_val);
578                     if(!this->find_with_key(my_join->current_key, *(current->my_arg))) {
585                     this->delete_with_key(my_join->current_key);
601                 rtask = my_join->increment_key_count((*(this->get_key_func()))(v));  // may spawn
616             my_aggregator.initialize_handler(handler_type(this));
632         void set_my_key_func(type_to_key_func_type *f) { this->set_key_func(f); }
634         type_to_key_func_type* get_my_key_func() { return this->get_key_func(); }
680             join_helper<N>::set_join_node_pointer(my_inputs, this);
685             join_helper<N>::set_join_node_pointer(my_inputs, this);
697                 if(is_graph_active(this->graph_ref)) {
702                     spawn_in_graph_arena(this->graph_ref, *t);
751             join_helper<N>::set_join_node_pointer(my_inputs, this);
756             join_helper<N>::set_join_node_pointer(my_inputs, this);
770                 if(is_graph_active(this->graph_ref)) {
777                     spawn_in_graph_arena(this->graph_ref, *t);
881             bool do_fwd = this->buffer_empty() && is_graph_active(this->graph_ref);
882             this->current_key = t;
883             this->delete_with_key(this->current_key);   // remove the key
885                 this->push_back(l_out);
889                     rtask = allocator.new_object<task_type>(this->graph_ref, allocator, *my_node);
890                     this->graph_ref.reserve_wait();
910                         this->destroy_front();
917                         if(!(this->find_ref_with_key(t,p))) {
921                             this->insert_with_key(ev);
922                             bool found = this->find_ref_with_key(t, p);
932 …      current->status.store( this->buffer_empty() ? FAILED : SUCCEEDED, std::memory_order_release);
935                     if(this->buffer_empty()) {
939                         *(current->my_output) = this->front();
951             join_helper<N>::set_join_node_pointer(my_inputs, this);
953             my_aggregator.initialize_handler(handler_type(this));
955             this->set_key_func(cfb);
961             join_helper<N>::set_join_node_pointer(my_inputs, this);
963             my_aggregator.initialize_handler(handler_type(this));
965             this->set_key_func(cfb);
1078 …                       graph_task* t = allocator.new_object<task_type>(my_graph, allocator, *this);
1138             : graph_node(g), input_ports_type(g), forwarder_busy(false), my_successors(this)
1140             input_ports_type::set_my_node(this);
1141             my_aggregator.initialize_handler(handler_type(this));
1146             sender<OutputTuple>(), forwarder_busy(false), my_successors(this)
1148             input_ports_type::set_my_node(this);
1149             my_aggregator.initialize_handler(handler_type(this));
1154             : graph_node(g), input_ports_type(g, f), forwarder_busy(false), my_successors(this)
1156             input_ports_type::set_my_node(this);
1157             my_aggregator.initialize_handler(handler_type(this));