Lines Matching refs:buffer_operation
1171 class buffer_operation : public aggregated_operation< buffer_operation > {
1178 buffer_operation(const T& e, op_type t) : type(char(t)) in buffer_operation() function
1182 buffer_operation(op_type t) : type(char(t)), elem(nullptr), ltask(nullptr), r(nullptr) {} in buffer_operation() function
1186 typedef aggregating_functor<class_type, buffer_operation> handler_type;
1187 friend class aggregating_functor<class_type, buffer_operation>;
1188 aggregator< handler_type, buffer_operation> my_aggregator;
1190 virtual void handle_operations(buffer_operation *op_list) { in handle_operations()
1195 void handle_operations_impl(buffer_operation *op_list, derived_type* derived) { in handle_operations_impl()
1198 buffer_operation *tmp = nullptr; in handle_operations_impl()
1237 inline graph_task *grab_forwarding_task( buffer_operation &op_data) { in grab_forwarding_task()
1241 inline bool enqueue_forwarding_task(buffer_operation &op_data) { in enqueue_forwarding_task()
1252 buffer_operation op_data(try_fwd_task); in forward_task()
1268 virtual void internal_reg_succ(buffer_operation *op) { in internal_reg_succ()
1275 virtual void internal_rem_succ(buffer_operation *op) { in internal_rem_succ()
1300 virtual void internal_forward_task(buffer_operation *op) { in internal_forward_task()
1305 void internal_forward_task_impl(buffer_operation *op, derived_type* derived) { in internal_forward_task_impl()
1329 virtual bool internal_push(buffer_operation *op) { in internal_push()
1336 virtual void internal_pop(buffer_operation *op) { in internal_pop()
1346 virtual void internal_reserve(buffer_operation *op) { in internal_reserve()
1356 virtual void internal_consume(buffer_operation *op) { in internal_consume()
1361 virtual void internal_release(buffer_operation *op) { in internal_release()
1394 buffer_operation op_data(reg_succ); in register_successor()
1407 buffer_operation op_data(rem_succ); in remove_successor()
1421 buffer_operation op_data(req_item); in try_get()
1432 buffer_operation op_data(res_item); in try_reserve()
1442 buffer_operation op_data(rel_res); in try_release()
1451 buffer_operation op_data(con_res); in try_consume()
1464 buffer_operation op_data(t, put_item); in try_put_task()
1503 typedef typename base_type::buffer_operation queue_operation;
1630 typedef typename buffer_node<T>::buffer_operation sequencer_operation; in __TBB_requires()
1701 typedef typename buffer_node<T>::buffer_operation prio_operation;