Lines Matching refs:g_NumItems
60 int g_NumItems; variable
189 if(*my_current_val > g_NumItems) { in operator ()()
191 *my_current_val = g_NumItems; in operator ()()
212 if(*my_current_val > g_NumItems) { in operator ()()
213 *my_current_val = g_NumItems; in operator ()()
325 if(*my_current_val > g_NumItems) { in operator ()()
326 *my_current_val = g_NumItems; // jam the final value; we assert on it later. in operator ()()
391 CHECK_MESSAGE( (src_cnt <= g_NumItems), "Too many input_node items emitted"); in run_one_input_node_test()
397 CHECK_MESSAGE( (src_cnt == g_NumItems), "Incorrect # input_node items emitted"); in run_one_input_node_test()
539 CHECK_MESSAGE( (ib0_cnt + ib1_cnt <= 2*g_NumItems), "Too many items sent by inputs"); in run_one_functype_node_test()
546 … CHECK_MESSAGE( (ib0_cnt + ib1_cnt == 2*g_NumItems), "Missing invocations of input_nodes"); in run_one_functype_node_test()
547 CHECK_MESSAGE( (t_cnt == 2*g_NumItems), "Not all items reached test node"); in run_one_functype_node_test()
548 …CHECK_MESSAGE( (nb0_cnt == 2*g_NumItems && nb1_cnt == 2*g_NumItems), "Missing items in absorbers"); in run_one_functype_node_test()
837 CHECK_MESSAGE( (ib_cnt <= g_NumItems), "Too many items sent by inputs"); in run_one_continue_node_test()
844 CHECK_MESSAGE( (ib_cnt == g_NumItems), "Missing invocations of input_node"); in run_one_continue_node_test()
845 CHECK_MESSAGE( (t_cnt == g_NumItems), "Not all items reached test node"); in run_one_continue_node_test()
846 CHECK_MESSAGE( (nb_cnt == g_NumItems), "Missing items in absorbers"); in run_one_continue_node_test()
951 CHECK_MESSAGE( (ib_cnt <= g_NumItems), "Too many items sent by inputs"); in run_one_buffer_node_test()
957 CHECK_MESSAGE( (ib_cnt == g_NumItems), "Missing invocations of input_node"); in run_one_buffer_node_test()
958 CHECK_MESSAGE( (nb_cnt == g_NumItems), "Missing items in absorbers"); in run_one_buffer_node_test()
1085 CHECK_MESSAGE( (ib_cnt <= g_NumItems), "Too many items sent by inputs"); in run_one_sequencer_node_test()
1091 CHECK_MESSAGE( (ib_cnt == g_NumItems), "Missing invocations of input_node"); in run_one_sequencer_node_test()
1092 CHECK_MESSAGE( (nb_cnt == g_NumItems), "Missing items in absorbers"); in run_one_sequencer_node_test()
1096 node_to_test.try_put(BufferItemType(g_NumItems + 1)); in run_one_sequencer_node_test()
1208 CHECK_MESSAGE( (ib_cnt <= g_NumItems), "Too many items sent by inputs"); in run_one_priority_queue_node_test()
1214 CHECK_MESSAGE( (ib_cnt == g_NumItems), "Missing invocations of input_node"); in run_one_priority_queue_node_test()
1215 CHECK_MESSAGE( (nb_cnt == g_NumItems), "Missing items in absorbers"); in run_one_priority_queue_node_test()
1219 node_to_test.try_put(BufferItemType(g_NumItems + 1)); in run_one_priority_queue_node_test()
1220 node_to_test.try_put(BufferItemType(g_NumItems + 2)); in run_one_priority_queue_node_test()
1353 … CHECK_MESSAGE( (ib0_cnt <= g_NumItems && ib1_cnt <= g_NumItems), "Too many items sent by inputs"); in execute_test()
1359 if(ib0_cnt != g_NumItems) { in execute_test()
1365 … CHECK_MESSAGE( (ib0_cnt == g_NumItems), "Missing invocations of input_node0"); // this one in execute_test()
1366 CHECK_MESSAGE( (ib1_cnt == g_NumItems), "Missing invocations of input_node1"); in execute_test()
1367 CHECK_MESSAGE( (nb_cnt == g_NumItems), "Missing items in absorbers"); in execute_test()
1371 tbb::flow::input_port<0>(node_to_test).try_put(ItemType0(g_NumItems + 1)); in execute_test()
1372 tbb::flow::input_port<1>(node_to_test).try_put(ItemType1(g_NumItems + 2)); in execute_test()
1463 … CHECK_MESSAGE( (ib0_cnt <= g_NumItems && ib1_cnt <= g_NumItems), "Too many items sent by inputs"); in execute_test()
1469 CHECK_MESSAGE( (ib0_cnt == g_NumItems), "Missing invocations of input_node0"); in execute_test()
1470 CHECK_MESSAGE( (ib1_cnt == g_NumItems), "Missing invocations of input_node1"); in execute_test()
1471 CHECK_MESSAGE( (nb_cnt == g_NumItems), "Missing items in absorbers"); in execute_test()
1475 tbb::flow::input_port<0>(node_to_test).try_put(ItemType0(g_NumItems + 4)); in execute_test()
1476 tbb::flow::input_port<1>(node_to_test).try_put(ItemType1(g_NumItems + 2)); in execute_test()
1592 CHECK_MESSAGE( (ib_cnt <= g_NumItems), "Too many items sent by inputs"); in run_one_limiter_node_test()
1719 CHECK_MESSAGE( (ib_cnt <= 2*g_NumItems), "Too many items sent by input"); in run_one_split_node_test()
1725 CHECK_MESSAGE( (ib_cnt == g_NumItems), "Missing invocations of input_nodes"); in run_one_split_node_test()
1726 … CHECK_MESSAGE( (nb0_cnt == g_NumItems && nb1_cnt == g_NumItems), "Missing items in absorbers"); in run_one_split_node_test()
1837 … CHECK_MESSAGE( (ib0_cnt <= g_NumItems && ib1_cnt <= g_NumItems), "Too many items sent by inputs"); in run_one_indexer_node_test()
1843 CHECK_MESSAGE( (ib0_cnt == g_NumItems), "Missing invocations of input_node0"); in run_one_indexer_node_test()
1844 CHECK_MESSAGE( (ib1_cnt == g_NumItems), "Missing invocations of input_node1"); in run_one_indexer_node_test()
1845 CHECK_MESSAGE( (nb_cnt == 2*g_NumItems), "Missing items in absorbers"); in run_one_indexer_node_test()
1849 tbb::flow::input_port<0>(node_to_test).try_put(ItemType0(g_NumItems + 4)); in run_one_indexer_node_test()
1850 tbb::flow::input_port<1>(node_to_test).try_put(ItemType1(g_NumItems + 2)); in run_one_indexer_node_test()
1982 g_NumItems = ((nThread > NUM_ITEMS) ? nThread *2 : NUM_ITEMS); in TestOneThreadNum()