Home
last modified time | relevance | path

Searched refs:input (Results 1 – 25 of 46) sorted by relevance

12

/oneTBB/examples/parallel_for_each/parallel_preorder/
H A DGraph.cpp26 input[0] = other.input[0]; in Cell()
27 input[1] = other.input[1]; in Cell()
48 Cell& input = my_vertex_set[rand() % k]; in create_random_dag() local
49 c.input[j] = &input; in create_random_dag()
72 c.input[j]->successor.push_back(&c); in get_root_set()
82 case OP_NEGATE: value = -(input[0]->value); break; in update()
83 case OP_ADD: value = input[0]->value + input[1]->value; break; in update()
84 case OP_SUB: value = input[0]->value - input[1]->value; break; in update()
85 case OP_MUL: value = input[0]->value * input[1]->value; break; in update()
/oneTBB/doc/main/tbb_userguide/
H A DPredefined_Node_Types.rst29 …input single-output node that broadcasts its output to all successors. Has generic input and outpu…
31 …input, single-output node that broadcasts its output to all successors. It has a single input t…
33 …- A single-input multi-output node. It has a generic input type and several generic output type…
35 …- A single-input, single-output node that broadcasts each message received to all successors. I…
37 …- Single-input, single-output nodes that buffer messages and send their output to one successor…
39 …input, single-output node. There are several generic input types and the output type is a tuple…
41 …- A single-input, multi-output node. The input type is a tuple of generic types and there is on…
43 …- Single-input, single-output nodes that buffer a single message and broadcast their outputs to…
45 …input, single output node that broadcasts its output to all successors. The main input type and…
47 …input, single-output node that broadcasts its output message to all of its successors. The inpu…
[all …]
H A DWorking_on_the_Assembly_Line_pipeline.rst42 * - Read chunk from input file
55 raw I/O is sequential, the formatting of input and output can be moved
60 of text. Each input chunk is approximately 4000 characters. Each chunk
138 reached, the pipeline never creates a new token at the input filter
147 the input filter, the type is ``void``.
249 TextSlice* operator()( TextSlice* input ) const;
255 *input->end() = '\0';
256 char* p = input->begin();
260 while( p<input->end() && !isdigit(*p) )
262 if( p==input->end() )
[all …]
H A DFlow_Graph_Reservation.rst10 every input before they can create an output message. The reserving
12 messages from its inputs until it has a message at each input. To create
13 an output message it temporarily reserves a message at each input port,
14 and only if all input ports succeed reserving messages will an output
15 message be created. If any input port fails to reserve a message, no
26 - The reserving input port calls ``try_reserve`` on each edge in pull
27 state. This may fail; if so, the reserving input port switches that
29 an edge in pull state. While the input port's predecessor is in
31 - If each input port successfully reserves an edge in pull state, the
47 to create and push a message if all input ports succeed reserving
[all …]
H A Dcreate_token_based_system.rst39 first reserve an input on each port from an upstream source. If it
40 can reserve an input at each port, it gets those inputs and joins
51 The ``input_node`` will only generate an input when one is pulled from it
53 the input from the ``input_node`` when it knows there is also an item to
111 to be recycled and paired with another input from the ``input_node``. So
129 example, an ``input_node`` could be attached to the input of the
141 concurrency in the system. Since you can pair the token with an input at
H A Dstd_invoke.rst8 ``operator()`` that accepts input parameters.
12 * **Function Objects that provide operator(arg1, arg2, ...)**, which accepts the input parameters
127 …ample below, a ``function_node`` takes an object as an input to read a member object of that input…
138 // Lambda function to read the member object of the input Object
148 // Function node that takes an Object as input and produces an integer
151 // Function node that takes an integer as input and processes it
157 // Provide produced input to the graph
/oneTBB/test/tbb/
H A Dtest_async_node.cpp119 if ( input == -1 ) { in operator ()()
125 gateway.try_put(input); in operator ()()
320 input_type input; member
355 work_type work = {input, &gateway}; in submit()
420 g, tbb::flow::unlimited, [](int input) { return input_type(input); } in run() argument
433 [&](const output_type& input) { in run() argument
540 g, tbb::flow::unlimited, [](int input) { return input_type(input); } in run() argument
623 g, tbb::flow::unlimited, [](int input) { return input_type(input); } in operator ()() argument
678 int input; member
686 int res = do_work(w.input); in __anon62ab872d0a02()
[all …]
H A Dtest_flow_graph_priorities.cpp258 struct work_type { data_type input; gateway_type* gateway; }; member
271 work.gateway->try_put(work.input); in operator ()()
280 void submit(data_type input, gateway_type* gateway) { in submit()
281 work_type work = { input, gateway }; in submit()
305 ParallelForBody(SpinBarrier& barrier, const data_type& input) in ParallelForBody()
306 : my_barrier(barrier), my_input(input) {} in ParallelForBody()
316 data_type operator()(const data_type& input) { in operator ()()
318 return input; in operator ()()
328 if (input < my_limit) in operator ()()
329 std::get<0>(ports).try_put(input + 1); in operator ()()
[all …]
H A Dtest_eh_flow_graph.cpp810 make_edge(input, b1); in run_one_continue_node_test()
820 input.activate(); in run_one_continue_node_test()
826 input.activate(); in run_one_continue_node_test()
935 input.activate(); in run_one_buffer_node_test()
941 input.activate(); in run_one_buffer_node_test()
1069 input.activate(); in run_one_sequencer_node_test()
1075 input.activate(); in run_one_sequencer_node_test()
1192 input.activate(); in run_one_priority_queue_node_test()
1198 input.activate(); in run_one_priority_queue_node_test()
1576 input.activate(); in run_one_limiter_node_test()
[all …]
H A Dtest_limiter_node.cpp451 [&](int input) { in test_try_put_without_successors() argument
452 counter += input; in test_try_put_without_successors()
514 tbb::flow::input_node<int> input{ graph, [&](tbb::flow_control & fc) -> int { in test_decrement_while_try_put_task() local
527 tbb::flow::make_edge(input, blockingNode); in test_decrement_while_try_put_task()
531 input.activate(); in test_decrement_while_try_put_task()
617 [](const TestLargeStruct& input) { return input; } ); in __anon70523bc50502() argument
/oneTBB/test/conformance/
H A Dconformance_parallel_scan.cpp89 std::vector<int> input(size);
94 input[i] = int(i / 2);
96 control[i] = control[i-1] + input[i];
98 control[i] = input[i];
100 Body<int, std::plus<int>> body(input, output, 0);
109 std::vector<std::size_t> input(size);
114 input[i] = i;
116 control[i] = control[i-1]+input[i];
118 control[i] = input[i];
125 temp = temp + input[i]; in __anonb56fb5590102()
H A Dconformance_parallel_pipeline.cpp179 std::vector<double> input(max_counter);
182 input[i] = (double)i;
184 RootSequence(input.cbegin(), input.cend(), output.begin());
186 CHECK_MESSAGE(output[i] == input[i]*input[i], "pipeline result is incorrect");
/oneTBB/examples/task_group/sudoku/
H A DREADME.md25 * `filename` - the input filename.
30 The example's directory contains following files that may be used as an input file:
31 `input1` - Sample input file with modest number of solutions.
32 `input2` - Sample input file with small number of solutions.
33 `input3` - Sample input file with larger number of solutions.
34 `input4` - Sample input file with very large number of solutions.
/oneTBB/doc/main/reference/
H A Dhelpers_for_expressing_graphs.rst56 broadcast_node<int> input(g);
71 make_edge(input, doubler);
72 make_edge(input, squarer);
73 make_edge(input, cuber);
80 input.try_put(i);
103 broadcast_node input(precedes(handlers));
115 input.try_put(i);
H A Dfollows_and_precedes_functions.rst70 :caption: A set of nodes as an input
73 broadcast_node<int> input(precedes(handlers));
76 :caption: A sequence of nodes as an input
78 broadcast_node<int> input(precedes(n1, n2, n3));
H A Dmake_edges_function.rst65 broadcast_node<int> input(g);
74 make_edges(input, handlers);
78 input.try_put(i);
H A Dtype_specified_message_keys.rst17 its input types. The extension simplifies the existing approach by removing the need to
18 provide a function object for each input port of ``join_node``.
/oneTBB/examples/parallel_pipeline/square/
H A Dsquare.cpp141 TextSlice* operator()(TextSlice* input) const;
144 TextSlice* MyTransformFunc::operator()(TextSlice* input) const { in operator ()()
146 *input->end() = '\0'; in operator ()()
147 char* p = input->begin(); in operator ()()
151 while (p < input->end() && !isdigit(*p)) in operator ()()
153 if (p == input->end()) in operator ()()
164 input->free(); in operator ()()
H A DREADME.md19 square [n-of-threads=value] [input-file=value] [output-file=value] [max-slice-size=value] [silent] …
23 * `input`- file is an input file name.
H A DCMakeLists.txt33 set(ARGS 0 input.txt output.txt)
34 set(PERF_ARGS auto input.txt output.txt silent)
/oneTBB/include/oneapi/tbb/detail/
H A D_pipeline_filters.h234 void* operator()(void* input) override {
235 input_pointer temp_input = input_helper::cast_from_void_ptr(input);
241 void finalize(void * input) override {
242 input_pointer temp_input = input_helper::cast_from_void_ptr(input);
282 void* operator()(void* input) override {
283 input_pointer temp_input = input_helper::cast_from_void_ptr(input);
288 void finalize(void* input) override {
289 input_pointer temp_input = input_helper::cast_from_void_ptr(input);
H A D_flow_graph_body_impl.h103 virtual Output operator()(const Input &input) = 0;
186 void operator()(const Input &input, OutputSet &oset) override {
187 tbb::detail::invoke(body, input, oset); // body may explicitly put() to one or more of oset.
204 virtual Output operator()(const Input &input) = 0; // returns an Output
213 virtual const Output & operator()(const Input &input) = 0; // returns a const Output&
/oneTBB/include/oneapi/tbb/
H A Dprofiling.h206 static void emit_trace(const std::string &input) { in emit_trace() argument
207 …ta_str_add( ITT_DOMAIN_FLOW, nullptr, FLOW_NULL, USER_EVENT, ( "FGA::DATAID::" + input ).c_str() ); in emit_trace()
211 event(const std::string &input) in event() argument
212 : my_name( input ) in event()
/oneTBB/test/common/
H A Dgraph_utils.h705 …void operator()(const std::thread::id& input, gateway_type&) noexcept { increase_and_check(input);…
707 output_tuple_type operator()(const std::thread::id& input) noexcept {
708 increase_and_check(input);
713 void increase_and_check(const std::thread::id& input) {
716 CHECK_MESSAGE(input == body_thread_id, "Body executed as not lightweight");
789 void operator()(const std::thread::id& input, gateway_type&) noexcept(NoExcept) {
790 increase_and_check(input);
792 output_tuple_type operator()(const std::thread::id& input) noexcept(NoExcept) {
793 increase_and_check(input);
/oneTBB/examples/graph/logic_sim/
H A Dtest_all.cpp70 toggle input(g); in main() local
74 make_edge(input.get_out(), input_port<0>(b)); in main()
79 input.activate(); // 0 in main()
84 input.flip(); // 1 in main()
93 toggle input(g); in main() local
96 make_edge(input.get_out(), input_port<0>(n)); in main()
101 input.activate(); // 0 in main()
106 input.flip(); // 1 in main()

12