1237     inline graph_task *grab_forwarding_task( buffer_operation &op_data) {  in grab_forwarding_task()  argument
1238         return op_data.ltask;  in grab_forwarding_task()
1241     inline bool enqueue_forwarding_task(buffer_operation &op_data) {  in enqueue_forwarding_task()  argument
1242         graph_task *ft = grab_forwarding_task(op_data);  in enqueue_forwarding_task()
1252         buffer_operation op_data(try_fwd_task);  in forward_task()
1255             op_data.status = WAIT;  in forward_task()
1256             op_data.ltask = nullptr;  in forward_task()
1257             my_aggregator.execute(&op_data);  in forward_task()
1260             graph_task *xtask = op_data.ltask;  in forward_task()
1263         } while (op_data.status ==SUCCEEDED);  in forward_task()
1394         buffer_operation op_data(reg_succ);  in register_successor()
1395         op_data.r = &r;  in register_successor()
1396         my_aggregator.execute(&op_data);  in register_successor()
1397         (void)enqueue_forwarding_task(op_data);  in register_successor()
1407         buffer_operation op_data(rem_succ);  in remove_successor()
1408         op_data.r = &r;  in remove_successor()
1409         my_aggregator.execute(&op_data);  in remove_successor()
1413         (void)enqueue_forwarding_task(op_data);  in remove_successor()
1421         buffer_operation op_data(req_item);  in try_get()
1422         op_data.elem = &v;  in try_get()
1423         my_aggregator.execute(&op_data);  in try_get()
1424         (void)enqueue_forwarding_task(op_data);  in try_get()
1425         return (op_data.status==SUCCEEDED);  in try_get()
1432         buffer_operation op_data(res_item);  in try_reserve()
1433         op_data.elem = &v;  in try_reserve()
1434         my_aggregator.execute(&op_data);  in try_reserve()
1435         (void)enqueue_forwarding_task(op_data);  in try_reserve()
1436         return (op_data.status==SUCCEEDED);  in try_reserve()
1442         buffer_operation op_data(rel_res);  in try_release()
1443         my_aggregator.execute(&op_data);  in try_release()
1444         (void)enqueue_forwarding_task(op_data);  in try_release()
1451         buffer_operation op_data(con_res);  in try_consume()
1452         my_aggregator.execute(&op_data);  in try_consume()
1453         (void)enqueue_forwarding_task(op_data);  in try_consume()
1464         buffer_operation op_data(t, put_item);  in try_put_task()
1465         my_aggregator.execute(&op_data);  in try_put_task()
1466         graph_task *ft = grab_forwarding_task(op_data);  in try_put_task()
1470         if(ft && op_data.status ==FAILED) {  in try_put_task()
1476         else if(!ft && op_data.status ==SUCCEEDED) {  in try_put_task()