Searched refs:op_data (Results 1 – 5 of 5) sorted by relevance
318 my_aggregator.execute(&op_data);325 my_aggregator.execute(&op_data);332 my_aggregator.execute(&op_data);339 my_aggregator.execute(&op_data);345 my_aggregator.execute(&op_data);452 my_aggregator.execute(&op_data);453 …__TBB_ASSERT(op_data.status == SUCCEEDED || !op_data.bypass_t, "inconsistent return from aggregato…455 return op_data.bypass_t;480 my_aggregator.execute(&op_data);982 return op_data.bypass_t;[all …]
98 operation_type op_data(reg_pred); in register_predecessor()99 op_data.r = &src; in register_predecessor()100 my_aggregator.execute(&op_data); in register_predecessor()106 operation_type op_data(rem_pred); in remove_predecessor()107 op_data.r = &src; in remove_predecessor()108 my_aggregator.execute(&op_data); in remove_predecessor()144 my_aggregator.execute(&op_data); in try_get_postponed_task()145 return op_data.bypass_t; in try_get_postponed_task()263 my_aggregator.execute(&op_data); in internal_try_put_bypass()265 return op_data.bypass_t; in internal_try_put_bypass()[all …]
178 indexer_node_base_operation op_data(r, reg_succ);179 my_aggregator.execute(&op_data);180 return op_data.status == SUCCEEDED;184 indexer_node_base_operation op_data(r, rem_succ);185 my_aggregator.execute(&op_data);186 return op_data.status == SUCCEEDED;190 indexer_node_base_operation op_data(v, try__put_task);191 my_aggregator.execute(&op_data);192 return op_data.bypass_t;
174 cpq_operation op_data(value, PUSH_OP); in push()175 my_aggregator.execute(&op_data); in push()176 if (op_data.status == FAILED) in push()182 cpq_operation op_data(value, PUSH_RVALUE_OP); in push()183 my_aggregator.execute(&op_data); in push()184 if (op_data.status == FAILED) in push()200 cpq_operation op_data(value, POP_OP); in try_pop()201 my_aggregator.execute(&op_data); in try_pop()202 return op_data.status == SUCCEEDED; in try_pop()
1238 return op_data.ltask; in grab_forwarding_task()1255 op_data.status = WAIT; in forward_task()1256 op_data.ltask = nullptr; in forward_task()1395 op_data.r = &r; in register_successor()1396 my_aggregator.execute(&op_data); in register_successor()1408 op_data.r = &r; in remove_successor()1409 my_aggregator.execute(&op_data); in remove_successor()1422 op_data.elem = &v; in try_get()1423 my_aggregator.execute(&op_data); in try_get()1433 op_data.elem = &v; in try_reserve()[all …]