Lines Matching refs:msg_t

32     using msg_t = tbb::flow::continue_msg;  in jn_follows_and_precedes()  typedef
33 using JoinOutputType = std::tuple<msg_t, msg_t, msg_t>; in jn_follows_and_precedes()
35 std::array<msg_t, 3> messages_for_follows = { {msg_t(), msg_t(), msg_t()} }; in jn_follows_and_precedes()
36 std::vector<msg_t> messages_for_precedes = {msg_t(), msg_t(), msg_t()}; in jn_follows_and_precedes()
39 …<msg_t, tbb::flow::join_node<JoinOutputType>, tbb::flow::buffer_node<msg_t>>(messages_for_follows); in jn_follows_and_precedes()
41 <msg_t, tbb::flow::join_node<JoinOutputType, tbb::flow::queueing>>(messages_for_follows); in jn_follows_and_precedes()
43 …<msg_t, tbb::flow::join_node<JoinOutputType, tbb::flow::reserving>, tbb::flow::buffer_node<msg_t>>… in jn_follows_and_precedes()
44 auto b = [](msg_t) { return msg_t(); }; in jn_follows_and_precedes() argument
47 std::size_t hash(msg_t) const { return 0; } in jn_follows_and_precedes()
48 bool equal(msg_t, msg_t) const { return true; } in jn_follows_and_precedes() argument
51 …<msg_t, tbb::flow::join_node<JoinOutputType, tbb::flow::key_matching<msg_t, hash_compare>>, tbb::f… in jn_follows_and_precedes()
55 <msg_t, tbb::flow::join_node<JoinOutputType>>(messages_for_precedes); in jn_follows_and_precedes()
57 <msg_t, tbb::flow::join_node<JoinOutputType, tbb::flow::queueing>>(messages_for_precedes); in jn_follows_and_precedes()
59 <msg_t, tbb::flow::join_node<JoinOutputType, tbb::flow::reserving>>(messages_for_precedes); in jn_follows_and_precedes()
61 <msg_t, tbb::flow::join_node<JoinOutputType, tbb::flow::key_matching<msg_t, hash_compare>>> in jn_follows_and_precedes()
66 using msg_t = MyMessageKeyWithoutKey<int, int>; in jn_msg_key_matching_follows_and_precedes() typedef
67 using JoinOutputType = std::tuple<msg_t, msg_t, msg_t>; in jn_msg_key_matching_follows_and_precedes()
69 std::array<msg_t, 3> messages_for_follows = { {msg_t(), msg_t(), msg_t()} }; in jn_msg_key_matching_follows_and_precedes()
70 std::vector<msg_t> messages_for_precedes = { msg_t(), msg_t(), msg_t() }; in jn_msg_key_matching_follows_and_precedes()
73 …<msg_t, tbb::flow::join_node<JoinOutputType, tbb::flow::key_matching<std::size_t>>, tbb::flow::buf… in jn_msg_key_matching_follows_and_precedes()
76 <msg_t, tbb::flow::join_node<JoinOutputType, tbb::flow::key_matching<std::size_t>>> in jn_msg_key_matching_follows_and_precedes()