Lines Matching refs:op
232 void internal_try_put_task(operation_type *op) { in internal_try_put_task() argument
236 graph_task * new_task = create_body_task(*(op->elem)); in internal_try_put_task()
237 op->bypass_t = new_task; in internal_try_put_task()
238 op->status.store(SUCCEEDED, std::memory_order_release); in internal_try_put_task()
239 } else if ( my_queue && my_queue->push(*(op->elem)) ) { in internal_try_put_task()
240 op->bypass_t = SUCCESSFULLY_ENQUEUED; in internal_try_put_task()
241 op->status.store(SUCCEEDED, std::memory_order_release); in internal_try_put_task()
243 op->bypass_t = nullptr; in internal_try_put_task()
244 op->status.store(FAILED, std::memory_order_release); in internal_try_put_task()
249 void internal_forward(operation_type *op) { in internal_forward() argument
250 op->bypass_t = nullptr; in internal_forward()
252 op->bypass_t = perform_queued_requests(); in internal_forward()
253 if(op->bypass_t) in internal_forward()
254 op->status.store(SUCCEEDED, std::memory_order_release); in internal_forward()
257 op->status.store(FAILED, std::memory_order_release); in internal_forward()
561 typename std::tuple_element<N, typename MOP::output_ports_type>::type &output_port(MOP &op) {
562 return std::get<N>(op.output_ports());