Searched refs:my_aggregator (Results 1 – 6 of 6) sorted by relevance
57 my_aggregator.initialize_handler(functor{this}); in concurrent_priority_queue()63 my_aggregator.initialize_handler(functor{this});70 my_aggregator.initialize_handler(functor{this});77 my_aggregator.initialize_handler(functor{this});84 my_aggregator.initialize_handler(functor{this});103 my_aggregator.initialize_handler(functor{this}); in concurrent_priority_queue()110 my_aggregator.initialize_handler(functor{this}); in concurrent_priority_queue()175 my_aggregator.execute(&op_data); in push()183 my_aggregator.execute(&op_data); in push()201 my_aggregator.execute(&op_data); in try_pop()[all …]
84 aggregator_type my_aggregator; variable95 my_aggregator.initialize_handler(aggregator_function_type(this)); in concurrent_lru_cache()100 my_aggregator.execute(&op);126 my_aggregator.execute(&op); in signal_end_of_usage()
1188 aggregator< handler_type, buffer_operation> my_aggregator; variable1257 my_aggregator.execute(&op_data); in forward_task()1372 my_aggregator.initialize_handler(handler_type(this)); in buffer_node()1396 my_aggregator.execute(&op_data); in register_successor()1409 my_aggregator.execute(&op_data); in remove_successor()1423 my_aggregator.execute(&op_data); in try_get()1434 my_aggregator.execute(&op_data); in try_reserve()1443 my_aggregator.execute(&op_data); in try_release()1452 my_aggregator.execute(&op_data); in try_consume()1465 my_aggregator.execute(&op_data); in try_put_task()
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);480 my_aggregator.execute(&op_data);488 my_aggregator.execute(&op_data);599 my_aggregator.execute(&op_data);639 my_aggregator.execute(&op_data);[all …]
137 aggregator<handler_type, indexer_node_base_operation> my_aggregator;167 my_aggregator.initialize_handler(handler_type(this));174 my_aggregator.initialize_handler(handler_type(this));179 my_aggregator.execute(&op_data);185 my_aggregator.execute(&op_data);191 my_aggregator.execute(&op_data);
73 my_aggregator.initialize_handler(handler_type(this)); in function_input_base()100 my_aggregator.execute(&op_data); in register_predecessor()108 my_aggregator.execute(&op_data); in remove_predecessor()144 my_aggregator.execute(&op_data); in try_get_postponed_task()169 aggregator< handler_type, operation_type > my_aggregator; variable263 my_aggregator.execute(&op_data); in internal_try_put_bypass()275 my_aggregator.execute(&check_op); in try_put_task_impl()316 my_aggregator.execute(&op_data); in forward_task()