/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/mpm/lib/i2c/ |
H A D | i2cdev.c | 50 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 D | NakReceiverWindowStressTest.java | 25 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 D | PerfTpTest.java | 26 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 D | pam_radius.c | 228 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 D | ncr_udp_unittests.cc | 250 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 D | AckReceiverWindowStressTest.java | 33 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 D | mailbox_display.php | 349 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 D | PERF_TP.java | 21 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 D | DiscardTest.java | 95 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 D | fakesmsc.c | 151 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 D | RingBufferStressTest.java | 19 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 D | UnicastStressTest.java | 22 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 D | UnicastContentionTest.java | 22 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 D | UNICAST_StressTest.java | 49 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 D | NAKACK_StressTest.java | 54 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 D | UNICAST2_StressTest.java | 57 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 D | ct_diagall.c | 37 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 D | ct_diagserver.c | 21 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 D | ct_diagall.c | 37 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 D | ct_diagserver.c | 21 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 D | ct_diagall.c | 39 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 D | ct_diagserver.c | 26 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 D | ct_diagserver.c | 26 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 D | ct_diagall.c | 42 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 D | check_log.c | 211 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 …]
|