Lines Matching refs:op

1268     virtual void internal_reg_succ(buffer_operation *op) {  in internal_reg_succ()  argument
1269 __TBB_ASSERT(op->r, nullptr); in internal_reg_succ()
1270 my_successors.register_successor(*(op->r)); in internal_reg_succ()
1271 op->status.store(SUCCEEDED, std::memory_order_release); in internal_reg_succ()
1275 virtual void internal_rem_succ(buffer_operation *op) { in internal_rem_succ() argument
1276 __TBB_ASSERT(op->r, nullptr); in internal_rem_succ()
1277 my_successors.remove_successor(*(op->r)); in internal_rem_succ()
1278 op->status.store(SUCCEEDED, std::memory_order_release); in internal_rem_succ()
1300 virtual void internal_forward_task(buffer_operation *op) { in internal_forward_task() argument
1301 internal_forward_task_impl(op, this); in internal_forward_task()
1305 void internal_forward_task_impl(buffer_operation *op, derived_type* derived) { in internal_forward_task_impl() argument
1309 op->status.store(FAILED, std::memory_order_release); in internal_forward_task_impl()
1319 op->ltask = last_task; // return task in internal_forward_task_impl()
1321 op->status.store(SUCCEEDED, std::memory_order_release); in internal_forward_task_impl()
1324 op->status.store(FAILED, std::memory_order_release); in internal_forward_task_impl()
1329 virtual bool internal_push(buffer_operation *op) { in internal_push() argument
1330 __TBB_ASSERT(op->elem, nullptr); in internal_push()
1331 this->push_back(*(op->elem)); in internal_push()
1332 op->status.store(SUCCEEDED, std::memory_order_release); in internal_push()
1336 virtual void internal_pop(buffer_operation *op) { in internal_pop() argument
1337 __TBB_ASSERT(op->elem, nullptr); in internal_pop()
1338 if(this->pop_back(*(op->elem))) { in internal_pop()
1339 op->status.store(SUCCEEDED, std::memory_order_release); in internal_pop()
1342 op->status.store(FAILED, std::memory_order_release); in internal_pop()
1346 virtual void internal_reserve(buffer_operation *op) { in internal_reserve() argument
1347 __TBB_ASSERT(op->elem, nullptr); in internal_reserve()
1348 if(this->reserve_front(*(op->elem))) { in internal_reserve()
1349 op->status.store(SUCCEEDED, std::memory_order_release); in internal_reserve()
1352 op->status.store(FAILED, std::memory_order_release); in internal_reserve()
1356 virtual void internal_consume(buffer_operation *op) { in internal_consume() argument
1358 op->status.store(SUCCEEDED, std::memory_order_release); in internal_consume()
1361 virtual void internal_release(buffer_operation *op) { in internal_release() argument
1363 op->status.store(SUCCEEDED, std::memory_order_release); in internal_release()
1524 void internal_forward_task(queue_operation *op) override { in internal_forward_task() argument
1525 this->internal_forward_task_impl(op, this); in internal_forward_task()
1528 void internal_pop(queue_operation *op) override { in internal_pop() argument
1530 op->status.store(FAILED, std::memory_order_release); in internal_pop()
1533 this->pop_front(*(op->elem)); in internal_pop()
1534 op->status.store(SUCCEEDED, std::memory_order_release); in internal_pop()
1537 void internal_reserve(queue_operation *op) override { in internal_reserve() argument
1539 op->status.store(FAILED, std::memory_order_release); in internal_reserve()
1542 this->reserve_front(*(op->elem)); in internal_reserve()
1543 op->status.store(SUCCEEDED, std::memory_order_release); in internal_reserve()
1546 void internal_consume(queue_operation *op) override { in internal_consume() argument
1548 op->status.store(SUCCEEDED, std::memory_order_release); in internal_consume()
1633 bool internal_push(sequencer_operation *op) override { in __TBB_requires()
1634 size_type tag = (*my_sequencer)(*(op->elem)); in __TBB_requires()
1638 op->status.store(FAILED, std::memory_order_release); in __TBB_requires()
1650 const op_stat res = this->place_item(tag, *(op->elem)) ? SUCCEEDED : FAILED; in __TBB_requires()
1651 op->status.store(res, std::memory_order_release); in __TBB_requires()
1704 void internal_forward_task(prio_operation *op) override { in internal_forward_task() argument
1705 this->internal_forward_task_impl(op, this); in internal_forward_task()
1712 bool internal_push(prio_operation *op) override { in internal_push() argument
1713 prio_push(*(op->elem)); in internal_push()
1714 op->status.store(SUCCEEDED, std::memory_order_release); in internal_push()
1718 void internal_pop(prio_operation *op) override { in internal_pop() argument
1721 op->status.store(FAILED, std::memory_order_release); in internal_pop()
1725 *(op->elem) = prio(); in internal_pop()
1726 op->status.store(SUCCEEDED, std::memory_order_release); in internal_pop()
1732 void internal_reserve(prio_operation *op) override { in internal_reserve() argument
1734 op->status.store(FAILED, std::memory_order_release); in internal_reserve()
1738 *(op->elem) = prio(); in internal_reserve()
1739 reserved_item = *(op->elem); in internal_reserve()
1740 op->status.store(SUCCEEDED, std::memory_order_release); in internal_reserve()
1744 void internal_consume(prio_operation *op) override { in internal_consume() argument
1745 op->status.store(SUCCEEDED, std::memory_order_release); in internal_consume()
1750 void internal_release(prio_operation *op) override { in internal_release() argument
1751 op->status.store(SUCCEEDED, std::memory_order_release); in internal_release()