Lines Matching refs:try_put
69 snode.try_put(std::tuple<int>(1)); in TestSplitNode()
94 bnode.try_put(1); // will forward to the fnode in TestBufferingNode()
100 bnode.try_put(2); // should reverse the edge in TestBufferingNode()
123 bnode.try_put(1); // the edge should reverse in TestBufferingNode()
135 bnode.try_put(1); // the edge should reverse in TestBufferingNode()
168 fnode0.try_put(1); // start the first function node. in TestContinueNode()
171 fnode0.try_put(1); // second message in TestContinueNode()
246 qnode0.try_put(1); in TestFunctionNode()
257 qnode0.try_put(1); in TestFunctionNode()
273 qnode0.try_put(1); in TestFunctionNode()
274 qnode0.try_put(2); // rejecting node should reject, reverse. in TestFunctionNode()
319 qnode0.try_put(1); in TestFunctionNode()
322 qnode0.try_put(2); // start queue node. in TestFunctionNode()
409 q0.try_put(1); in TestJoinNode()
416 q1.try_put(2); in TestJoinNode()
424 q1.try_put(3); in TestJoinNode()
492 inq.try_put(1); in TestLimiterNode()
496 inq.try_put(2); in TestLimiterNode()
500 bn.try_put(DecrementerHelper<dtype>::makeDType()); in TestLimiterNode()
507 inq.try_put(3); in TestLimiterNode()
523 inq.try_put(4); in TestLimiterNode()
524 inq.try_put(5); in TestLimiterNode()
528 bn.try_put(DecrementerHelper<dtype>::makeDType()); in TestLimiterNode()
546 std::get<1>(outports).try_put(in); in operator ()()
548 std::get<0>(outports).try_put(in); in operator ()()
588 qin.try_put(0); in TestMultifunctionNode()
589 qin.try_put(1); in TestMultifunctionNode()
675 bnode.try_put(0); // will forward to the fnode in TestSequencerNode()
692 bnode.try_put(3); // the edge should reverse in TestSequencerNode()
867 c.try_put(tbb::flow::continue_msg());
884 on.try_put(1);
938 c.try_put(continue_msg());
965 f1.try_put(1);