Home
last modified time | relevance | path

Searched refs:num_msgs (Results 1 – 25 of 586) sorted by relevance

12345678910>>...24

/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/mpm/lib/i2c/
H A Di2cdev.c50 int num_msgs = 0; in i2cdev_transfer() local
56 msgs[num_msgs].addr = addr; in i2cdev_transfer()
57 msgs[num_msgs].buf = tx; in i2cdev_transfer()
58 msgs[num_msgs].len = tx_len; in i2cdev_transfer()
60 num_msgs++; in i2cdev_transfer()
64 msgs[num_msgs].addr = addr; in i2cdev_transfer()
65 msgs[num_msgs].buf = rx; in i2cdev_transfer()
66 msgs[num_msgs].len = rx_len; in i2cdev_transfer()
69 num_msgs++; in i2cdev_transfer()
72 i2c_data.nmsgs = num_msgs; in i2cdev_transfer()
[all …]
/dports/net/jgroups/jgroups-2.12.0/tests/other/org/jgroups/tests/
H A DNakReceiverWindowStressTest.java25 int num_msgs=1000, prev_value=0; field in NakReceiverWindowStressTest
33 this.num_msgs=num_msgs; in NakReceiverWindowStressTest()
56 sendMessages(num_msgs); in start()
64 void sendMessages(int num_msgs) { in sendMessages() argument
67 for(long i=1; i <= num_msgs; i++) { in sendMessages()
99 if(i == num_msgs) { in processMessage()
102 double msgs_per_sec=num_msgs / (total/1000.0); in processMessage()
103 double msgs_per_ms=num_msgs / (double)total; in processMessage()
104 System.out.println("Inserting and removing " + num_msgs + in processMessage()
126 int num_msgs=1000; in main() local
[all …]
H A DPerfTpTest.java26 int num_msgs=1000; in main() local
37 num_msgs=Integer.parseInt(args[++i]); in main()
61 new PerfTpTest().start(props, num_msgs, size, file_name, write); in main()
73 …void start(String props, int num_msgs, int size, String file_name, boolean write) throws Exception… in start() argument
99 tp.setExpectedMessages(num_msgs); in start()
100 for(int i=0; i < num_msgs; i++) { in start()
125 num_msgs=msgs.size(); in start()
126 System.out.println("read " + num_msgs + " msgs from file"); in start()
146 double msgs_per_ms=num_msgs / (double)total; in start()
148 double time_per_msg=total / (double)num_msgs; in start()
[all …]
/dports/security/pam_radius/pam_radius-4.0/
H A Dpam_radius.c228 int num_msgs; in do_challenge() local
234 num_msgs = 0; in do_challenge()
256 msg_ptrs[num_msgs] = &msgs[num_msgs]; in do_challenge()
257 num_msgs++; in do_challenge()
265 if (num_msgs == 0) { in do_challenge()
272 msg_ptrs[num_msgs] = &msgs[num_msgs]; in do_challenge()
273 num_msgs++; in do_challenge()
287 memset(resp[num_msgs-1].resp, 0, strlen(resp[num_msgs-1].resp)); in do_challenge()
288 free(resp[num_msgs-1].resp); in do_challenge()
290 while (num_msgs > 0) in do_challenge()
[all …]
/dports/net/kea/kea-2.0.1/src/lib/dhcp_ddns/tests/
H A Dncr_udp_unittests.cc250 for (int i = 0; i < num_msgs; i++) { in TEST_F()
426 for (int i = 0; i < num_msgs; i++) { in TEST_F()
449 for (int i = num_msgs; i > 0; i--) { in TEST_F()
482 for (int i = 0; i < num_msgs; i++) { in TEST_F()
554 for (int i = 0; i < num_msgs; i++) { in TEST_F()
577 for (int i = num_msgs; i > 0; i--) { in TEST_F()
610 for (int i = 0; i < num_msgs; i++) { in TEST_F()
652 for (int i = 0; i < num_msgs; i++) { in TEST_F()
670 for (int i = num_msgs; i > 0; i--) { in TEST_F()
851 --num_msgs; in TEST_F()
[all …]
/dports/net/jgroups/jgroups-2.12.0/tests/junit-functional/org/jgroups/tests/
H A DAckReceiverWindowStressTest.java33 private static void start(int num_threads, int num_msgs, int segment_size) { in start() argument
35 final AtomicInteger counter=new AtomicInteger(num_msgs); in start()
59 if(removed_msgs.get() >= num_msgs) in start()
71 double requests_sec=num_msgs / (time / 1000.0); in start()
74 assert removed_msgs.get() == num_msgs : in start()
82 final AtomicInteger num_msgs; field in AckReceiverWindowStressTest.Adder
91 this.num_msgs=num_msgs; in Adder()
108 while(num_msgs.getAndDecrement() > 0) { in run()
137 int num_msgs=1000000; in main() local
146 num_msgs=Integer.parseInt(args[++i]); in main()
[all …]
/dports/mail/squirrelmail/squirrelmail.stable/squirrelmail/functions/
H A Dmailbox_display.php349 if ($num_msgs < $show_num) {
350 $end_loop = $num_msgs;
351 } else if ($end > $num_msgs) {
376 if ($num_msgs >= 1) {
379 $end = $num_msgs;
389 $end_msg = $num_msgs;
454 if($start_msg > $num_msgs) {
532 if ($num_msgs > 0) {
671 if (!$num_msgs) {
866 if ($num_msgs) {
[all …]
/dports/net/jgroups/jgroups-2.12.0/src/org/jgroups/protocols/
H A DPERF_TP.java21 long num_msgs=0; field in PERF_TP
45 return num_msgs; in getNumMessages()
50 num_msgs=0; in setExpectedMessages()
56 num_msgs=expected_msgs=stop=start=0; in reset()
97 num_msgs++; in down()
98 if(num_msgs >= expected_msgs) { in down()
104 …if(log.isInfoEnabled()) log.info("all done (num_msgs=" + num_msgs + ", expected_msgs=" + expected_… in down()
131 num_msgs++; in up()
132 if(num_msgs >= expected_msgs) { in up()
138 …if(log.isInfoEnabled()) log.info("all done (num_msgs=" + num_msgs + ", expected_msgs=" + expected_… in up()
/dports/net/jgroups/jgroups-2.12.0/tests/junit/org/jgroups/tests/
H A DDiscardTest.java95 Long num_msgs; in _testLosslessReception() local
96 num_msgs=ch1_all_received.getResult(); in _testLosslessReception()
97 System.out.println("-- received " + num_msgs + " messages on ch1"); in _testLosslessReception()
99 num_msgs=ch2_all_received.getResult(); in _testLosslessReception()
101 System.out.println("-- received " + num_msgs + " messages on ch2"); in _testLosslessReception()
116 long num_msgs=0; field in DiscardTest.MyReceiver
129 num_msgs++; in receive()
131 if(num_msgs > 0 && num_msgs % 1000 == 0) in receive()
132 System.out.println("-- received " + num_msgs + " on " + channel_name); in receive()
134 if(num_msgs >= num_msgs_expected) { in receive()
[all …]
/dports/www/kannel/gateway-1.4.4/test/
H A Dfakesmsc.c151 return msgs[gw_rand() % num_msgs]; in choose_message()
228 int mptr, num_msgs; in main() local
247 num_msgs = argc - mptr; in main()
252 if (num_msgs <= 0) { in main()
254 num_msgs = 0; in main()
262 for (i = 0; i < num_msgs; i ++) { in main()
289 if ( num_msgs > 0 ) { in main()
290 for (i = 0; i < num_msgs; i ++) in main()
293 num_msgs = 0; in main()
317 num_msgs = 1; in main()
[all …]
/dports/net/jgroups/jgroups-2.12.0/tests/stress/org/jgroups/tests/
H A DRingBufferStressTest.java19 static void start(int capacity, int num_msgs, int num_adders, int num_removers) { in start() argument
40 adders[i]=new Adder(buffer, latch, num_msgs, added, seqno); in start()
45 removers[i]=new Remover(buffer, latch, num_msgs, removed); in start()
83 double requests_sec=num_msgs / (time / 1000.0); in start()
89 System.out.println("values (expected=" + num_msgs + ", removed=" + all_values.size() + in start()
132 final int num_msgs; field in RingBufferStressTest.Adder
141 this.num_msgs=num_msgs; in Adder()
156 if(added_msgs.incrementAndGet() > num_msgs) { in run()
212 int num_msgs=1000000; in main() local
224 num_msgs=Integer.parseInt(args[++i]); in main()
[all …]
H A DUnicastStressTest.java22 int num_msgs=1000; // number of messages sent by 1 thread field in UnicastStressTest
38 …public UnicastStressTest(String props, int num_channels, int num_threads, int num_msgs, int msg_si… in UnicastStressTest() argument
42 this.num_msgs=num_msgs; in UnicastStressTest()
58 int num_expected_msgs=num_threads * num_msgs * buddies; in start()
59 int num_total_msgs=num_channels * num_threads * num_msgs; // over all channels in start()
171 private final int num_msgs; field in UnicastStressTest.Sender
180 this.num_msgs=num_msgs; in Sender()
197 for(int i=0; i < num_msgs; i++) { in run()
208 int num_msgs=10000; // number of messages sent by 1 thread in main() local
227 num_msgs=Integer.parseInt(args[++i]); in main()
[all …]
H A DUnicastContentionTest.java22 int num_msgs=10000; field in UnicastContentionTest
39 …private void start(String props, int num_msgs, int size, int num_mbrs, int num_threads, boolean du… in start() argument
40 this.num_msgs=num_msgs; in start()
44 this.MOD=num_threads * num_msgs / 10; in start()
59 …ntln("View is " + view + "\n" + num_threads + " threads are sending " + num_msgs + " messages (of … in start()
114 for(int i=0; i < num_msgs; i++) { in run()
130 private int expected_msgs=num_msgs * num_threads;
161 int num_msgs=10000; in main() local
170 num_msgs=Integer.parseInt(args[++i]); in main()
197 new UnicastContentionTest().start(props, num_msgs, size, num_mbrs, num_threads, dump_stats); in main()
/dports/net/jgroups/jgroups-2.12.0/tests/junit-functional/org/jgroups/protocols/
H A DUNICAST_StressTest.java49 final AtomicInteger counter=new AtomicInteger(num_msgs); in start()
72 if(delivered_msgs.get() >= num_msgs) { in start()
107 while(delivered_msgs.get() < num_msgs) { in start()
126 double requests_sec=num_msgs / (time / 1000.0); in start()
137 assert results.size() == num_msgs : "expected " + num_msgs + ", but got " + results.size(); in start()
164 final AtomicInteger num_msgs; field in UNICAST_StressTest.Adder
174 this.num_msgs=num_msgs; in Adder()
191 while(num_msgs.getAndDecrement() > 0) { in run()
203 int num_msgs=1000000; in main() local
213 num_msgs=Integer.parseInt(args[++i]); in main()
[all …]
H A DNAKACK_StressTest.java54 final AtomicInteger counter=new AtomicInteger(num_msgs); in start()
79 if(delivered_msgs.get() >= num_msgs) { in start()
116 while(delivered_msgs.get() < num_msgs) { in start()
131 double requests_sec=num_msgs / (time / 1000.0); in start()
145 assert results.size() == num_msgs : "expected " + num_msgs + ", but got " + results.size(); in start()
172 final AtomicInteger num_msgs; field in NAKACK_StressTest.Sender
181 this.num_msgs=num_msgs; in Sender()
198 while(num_msgs.getAndDecrement() > 0) { in run()
210 int num_msgs=1000000; in main() local
219 num_msgs=Integer.parseInt(args[++i]); in main()
[all …]
H A DUNICAST2_StressTest.java57 final AtomicInteger counter=new AtomicInteger(num_msgs); in start()
84 if(delivered_msgs.get() >= num_msgs) { in start()
121 while(delivered_msgs.get() < num_msgs) { in start()
136 double requests_sec=num_msgs / (time / 1000.0); in start()
150 assert results.size() == num_msgs : "expected " + num_msgs + ", but got " + results.size(); in start()
177 final AtomicInteger num_msgs; field in UNICAST2_StressTest.Sender
187 this.num_msgs=num_msgs; in Sender()
205 while(num_msgs.getAndDecrement() > 0) { in run()
217 int num_msgs=1000000; in main() local
227 num_msgs=Integer.parseInt(args[++i]); in main()
[all …]
/dports/databases/freetds-devel/freetds-dev.1.3.7/src/ctlib/unittests/
H A Dct_diagall.c37 CS_INT num_msgs, totmsgs; in main() local
205 if (ct_diag(conn, CS_STATUS, CS_ALLMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
210 printf("Total number of client/server messages = %d \n", num_msgs); in main()
212 if (ct_diag(conn, CS_STATUS, CS_CLIENTMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
217 printf("Number of client messages returned: %d\n", num_msgs); in main()
219 for (i = 0; i < num_msgs; i++) { in main()
230 if (ct_diag(conn, CS_STATUS, CS_SERVERMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
235 printf("Number of server messages returned: %d\n", num_msgs); in main()
237 for (i = 0; i < num_msgs; i++) { in main()
253 if (ct_diag(conn, CS_STATUS, CS_ALLMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
[all …]
H A Dct_diagserver.c21 CS_INT num_msgs, totMsgs; in main() local
47 if (ct_diag(conn, CS_STATUS, CS_SERVERMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
52 printf("Number of messages returned: %d\n", num_msgs); in main()
54 for (i = 0; i < num_msgs; i++) { in main()
70 if (ct_diag(conn, CS_STATUS, CS_SERVERMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
74 if (num_msgs != 0) { in main()
75 fprintf(stderr, "cs_diag(CS_CLEAR) failed there are still %d messages on queue\n", num_msgs); in main()
/dports/databases/freetds/freetds-1.3.4/src/ctlib/unittests/
H A Dct_diagall.c37 CS_INT num_msgs, totmsgs; in main() local
205 if (ct_diag(conn, CS_STATUS, CS_ALLMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
210 printf("Total number of client/server messages = %d \n", num_msgs); in main()
212 if (ct_diag(conn, CS_STATUS, CS_CLIENTMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
217 printf("Number of client messages returned: %d\n", num_msgs); in main()
219 for (i = 0; i < num_msgs; i++) { in main()
230 if (ct_diag(conn, CS_STATUS, CS_SERVERMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
235 printf("Number of server messages returned: %d\n", num_msgs); in main()
237 for (i = 0; i < num_msgs; i++) { in main()
253 if (ct_diag(conn, CS_STATUS, CS_ALLMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
[all …]
H A Dct_diagserver.c21 CS_INT num_msgs, totMsgs; in main() local
47 if (ct_diag(conn, CS_STATUS, CS_SERVERMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
52 printf("Number of messages returned: %d\n", num_msgs); in main()
54 for (i = 0; i < num_msgs; i++) { in main()
70 if (ct_diag(conn, CS_STATUS, CS_SERVERMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
74 if (num_msgs != 0) { in main()
75 fprintf(stderr, "cs_diag(CS_CLEAR) failed there are still %d messages on queue\n", num_msgs); in main()
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/dbapi/driver/ftds100/freetds/ctlib/unittests/
H A Dct_diagall.c39 CS_INT num_msgs, totmsgs; in main() local
207 if (ct_diag(conn, CS_STATUS, CS_ALLMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
212 fprintf(stdout, "Total number of client/server messages = %d \n", num_msgs); in main()
214 if (ct_diag(conn, CS_STATUS, CS_CLIENTMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
219 fprintf(stdout, "Number of client messages returned: %d\n", num_msgs); in main()
221 for (i = 0; i < num_msgs; i++) { in main()
232 if (ct_diag(conn, CS_STATUS, CS_SERVERMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
237 fprintf(stdout, "Number of server messages returned: %d\n", num_msgs); in main()
239 for (i = 0; i < num_msgs; i++) { in main()
255 if (ct_diag(conn, CS_STATUS, CS_ALLMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
[all …]
H A Dct_diagserver.c26 CS_INT num_msgs, totMsgs; in main() local
52 if (ct_diag(conn, CS_STATUS, CS_SERVERMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
57 fprintf(stdout, "Number of messages returned: %d\n", num_msgs); in main()
59 for (i = 0; i < num_msgs; i++) { in main()
75 if (ct_diag(conn, CS_STATUS, CS_SERVERMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
79 if (num_msgs != 0) { in main()
80 fprintf(stderr, "cs_diag(CS_CLEAR) failed there are still %d messages on queue\n", num_msgs); in main()
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/dbapi/driver/ftds95/freetds/ctlib/unittests/
H A Dct_diagserver.c26 CS_INT num_msgs, totMsgs; in main() local
52 if (ct_diag(conn, CS_STATUS, CS_SERVERMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
57 fprintf(stdout, "Number of messages returned: %d\n", num_msgs); in main()
59 for (i = 0; i < num_msgs; i++) { in main()
75 if (ct_diag(conn, CS_STATUS, CS_SERVERMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
79 if (num_msgs != 0) { in main()
80 fprintf(stderr, "cs_diag(CS_CLEAR) failed there are still %d messages on queue\n", num_msgs); in main()
H A Dct_diagall.c42 CS_INT num_msgs, totmsgs; in main() local
210 if (ct_diag(conn, CS_STATUS, CS_ALLMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
215 fprintf(stdout, "Total number of client/server messages = %d \n", num_msgs); in main()
217 if (ct_diag(conn, CS_STATUS, CS_CLIENTMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
222 fprintf(stdout, "Number of client messages returned: %d\n", num_msgs); in main()
224 for (i = 0; i < num_msgs; i++) { in main()
235 if (ct_diag(conn, CS_STATUS, CS_SERVERMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
240 fprintf(stdout, "Number of server messages returned: %d\n", num_msgs); in main()
242 for (i = 0; i < num_msgs; i++) { in main()
258 if (ct_diag(conn, CS_STATUS, CS_ALLMSG_TYPE, CS_UNUSED, &num_msgs) != CS_SUCCEED) { in main()
[all …]
/dports/devel/libqb/libqb-2.0.3/tests/
H A Dcheck_log.c211 num_msgs++; in _test_logger()
223 num_msgs++; in _test_length_logger()
284 num_msgs = 0; in START_TEST()
404 num_msgs = 0; in START_TEST()
422 num_msgs = 0; in START_TEST()
455 num_msgs = 0; in START_TEST()
478 num_msgs = 0; in START_TEST()
493 num_msgs = 0; in START_TEST()
509 num_msgs = 0; in START_TEST()
525 num_msgs = 0; in START_TEST()
[all …]

12345678910>>...24