/dports/devel/grpc/grpc-1.42.0/test/core/promise/ |
H A D | for_each_test.cc | 35 int num_received = 0; in TEST() local 39 [&pipe, &num_received] { in TEST() 54 [&num_received](int i) { in TEST() 55 num_received++; in TEST() 56 EXPECT_EQ(num_received, i); in TEST() 64 EXPECT_EQ(num_received, 3); in TEST()
|
/dports/www/h2o-devel/h2o-dcc7134/deps/quicly/t/ |
H A D | lossy.c | 120 *num_received = 0; in transmit_cond() 148 ++*num_received; in transmit_cond() 162 size_t num_sent, num_received; in test_even() local 196 ok(num_received == 1); in test_even() 206 ok(num_received == 0); in test_even() 217 ok(num_received == 1); in test_even() 227 ok(num_received == 1); in test_even() 235 ok(num_received == 1); in test_even() 244 ok(num_received == 0); in test_even() 252 ok(num_received == 0); in test_even() [all …]
|
/dports/net/jgroups/jgroups-2.12.0/tests/stress/org/jgroups/tests/ |
H A D | NetworkUtilization.java | 16 long num_received=0; field in NetworkUtilization 34 double num_kb_received=num_received * received_packet_size / 1000.0; in run() 37 System.out.println("** took " + secs + " secs to receive " + num_received + " msgs (" + in run() 38 (num_received / secs) + " msgs/sec)\n" + in run() 90 num_received++; in start() 92 if(num_received % 1000 == 0) in start() 93 System.out.println(num_received); in start()
|
/dports/www/kannel/gateway-1.4.4/test/ |
H A D | fakesmsc.c | 229 long num_received, num_sent; in main() local 277 num_received = 0; in main() 358 ++num_received; in main() 359 if (num_received == max_send) { in main() 360 info(0, "Got message %ld: <%s>", num_received, in main() 363 debug("receive", 0, "Got message %ld: <%s>", num_received, in main() 381 info(0, "fakesmsc: %ld messages sent and %ld received", num_sent, num_received); in main() 392 if (num_received > 1) in main() 394 "%.1f msgs/s", delta, (num_received - 1) / delta); in main()
|
/dports/sysutils/nut-devel/nut-9e6a5ab2/drivers/ |
H A D | nutdrv_siemens_sitop.c | 104 ssize_t num_received; in check_for_new_data() local 110 num_received = ser_get_buf(upsfd, rx_buffer + rx_count, RX_BUFFER_SIZE - rx_count, 0, 0); in check_for_new_data() 111 if (num_received < 0) { in check_for_new_data() 113 ser_comm_fail("error %zd while reading", num_received); in check_for_new_data() 124 } else if (num_received == 0) { in check_for_new_data() 128 rx_count += (unsigned int)num_received; in check_for_new_data()
|
/dports/net/sie-nmsg/sie-nmsg-1.2.1/tests/ |
H A D | test-io.c | 142 static int touched_exit, touched_atstart, touched_close, num_received, touched_filter; variable 182 __sync_add_and_fetch(&num_received, 1); in output_callback() 254 touched_atstart = touched_exit = touched_close = num_received = touched_filter = 0; in test_io_filters() 288 check(num_received == 5); in test_io_filters() 291 check(num_received == 10); in test_io_filters() 294 check(num_received == 0); in test_io_filters() 297 check(num_received == 10); in test_io_filters()
|
/dports/emulators/visualboyadvance-m/visualboyadvance-m-VBA-M_Beta_2/src/gba/ |
H A D | GBASockClient.cpp | 48 std::size_t num_received = 0; in ReceiveCmd() local 55 if (client.receive(data_in, 5, num_received) == sf::Socket::Disconnected) in ReceiveCmd() 67 std::size_t num_received = 0; in ReceiveClock() local 68 if (clock_client.receive(sync_ticks, 4, num_received) == sf::Socket::Disconnected) in ReceiveClock() 71 if (num_received == 4) in ReceiveClock()
|
/dports/net/jgroups/jgroups-2.12.0/src/org/jgroups/blocks/ |
H A D | MultiRequest.java | 35 int num_received, num_not_received, num_suspected; field in MultiRequest 146 num_received++; in receiveResponse() 349 if(num_received > 0) in responsesComplete() 356 return num_received + num_suspected >= num_total; in responsesComplete() 359 if(num_received + num_suspected >= majority) in responsesComplete() 364 if(num_received >= majority) in responsesComplete() 371 …return num_received >= expected_mbrs || num_received + num_not_received < expected_mbrs && num_rec… in responsesComplete()
|
H A D | GroupRequest.java | 58 int num_received, num_not_received, num_suspected; field in GroupRequest 132 num_received++; in receiveResponse() 335 if(num_received > 0) in responsesComplete() 342 return num_received + num_suspected >= num_total; in responsesComplete() 345 if(num_received + num_suspected >= majority) in responsesComplete() 350 if(num_received >= majority) in responsesComplete()
|
/dports/dns/getdns/getdns-1.5.2/src/test/ |
H A D | check_getdns_context_set_timeout.c | 166 int num_received = 0; in run_server() local 202 if (r > 0 && num_received < 10) { in run_server() 204 … int n = recvfrom(fd,mesg,65536,0,(struct sockaddr *)&(responses[num_received].client_addr),&len); in run_server() 231 r = getdns_general_sync(ctxt, qname_str, qtype, NULL, &responses[num_received].reply); in run_server() 239 … if ((r = getdns_dict_set_int(responses[num_received].reply, "/replies_tree/0/header/id", qid))) { in run_server() 244 ++num_received; in run_server() 245 } else if (r == 0 && num_received > 0) { in run_server() 248 for (i = 0; i < num_received; ++i) { in run_server() 257 num_received = 0; in run_server()
|
/dports/security/distcache/distcache-1.5.1/test/ |
H A D | pong.c | 114 unsigned int num_sent, num_received; member 141 ret->num_sent = ret->num_received = 0; in pongctx_new() 172 ctx->num_received += num; in pongctx_postio_client() 176 num, ctx->num_received); in pongctx_postio_client() 184 if((ctx->num_sent + num) > (ctx->num_received + ctx->window)) in pongctx_postio_client() 185 num = ctx->num_received + ctx->window - ctx->num_sent; in pongctx_postio_client() 219 ctx->num_received += num; in pongctx_postio_server() 223 num, ctx->num_received); in pongctx_postio_server() 229 if((ctx->num_sent + num) > ctx->num_received) in pongctx_postio_server() 230 num = ctx->num_received - ctx->num_sent; in pongctx_postio_server() [all …]
|
/dports/net/jgroups/jgroups-2.12.0/tests/junit-functional/org/jgroups/tests/ |
H A D | UNICAST_Test.java | 126 int num_received=0; in _testReceptionOfAllMessages() local 137 while((num_received=r.getNumberOfReceivedMessages()) != NUM_MSGS && num_tries > 0) { in _testReceptionOfAllMessages() 146 printStats(num_received); in _testReceptionOfAllMessages() 147 Assert.assertEquals(num_received, NUM_MSGS); in _testReceptionOfAllMessages() 163 private void printStats(int num_received) { in printStats() argument 164 … System.out.println("-- num received=" + num_received + ", stats:\n" + simulator.dumpStats()); in printStats()
|
H A D | FCTest.java | 60 int num_received=0; in testReceptionOfAllMessages() local 73 num_received=r.getNumberOfReceivedMessages(); in testReceptionOfAllMessages() 74 System.out.println("-- num received=" + num_received + ", stats:\n" + s.dumpStats()); in testReceptionOfAllMessages() 75 if(num_received >= NUM_MSGS) in testReceptionOfAllMessages() 79 assert num_received == NUM_MSGS; in testReceptionOfAllMessages()
|
H A D | ConnectionMapUnitTest.java | 150 long num_expected=0, num_received=0, start_time=0, stop_time=0; field in ConnectionMapUnitTest.MyReceiver 165 return num_received; in getNumReceived() 174 num_received++; in receive() 175 if(num_received % modulo == 0) in receive() 176 log("received msg# " + num_received); in receive() 188 if(num_received >= num_expected) { in receive()
|
/dports/math/curv/curv-0.5/extern/imgui/examples/libs/usynergy/ |
H A D | uSynergy.c | 480 int num_received = 0; in sUpdateContext() local 482 …kie, context->m_receiveBuffer + context->m_receiveOfs, receive_size, &num_received) == USYNERGY_FA… in sUpdateContext() 486 …(%d bytes asked, %d bytes received), trying to reconnect in a second", receive_size, num_received); in sUpdateContext() 492 context->m_receiveOfs += num_received; in sUpdateContext() 497 if (num_received == 0) in sUpdateContext() 504 if (num_received == 0) in sUpdateContext() 537 num_received = context->m_receiveOfs-4; // 4 bytes for the size field in sUpdateContext() 538 while (num_received != packlen) in sUpdateContext() 540 int buffer_left = packlen - num_received; in sUpdateContext() 553 num_received += ditch_received; in sUpdateContext()
|
/dports/graphics/milton/milton-1.9.1/third_party/imgui/examples/libs/usynergy/ |
H A D | uSynergy.c | 480 int num_received = 0; in sUpdateContext() local 482 …kie, context->m_receiveBuffer + context->m_receiveOfs, receive_size, &num_received) == USYNERGY_FA… in sUpdateContext() 486 …(%d bytes asked, %d bytes received), trying to reconnect in a second", receive_size, num_received); in sUpdateContext() 492 context->m_receiveOfs += num_received; in sUpdateContext() 497 if (num_received == 0) in sUpdateContext() 504 if (num_received == 0) in sUpdateContext() 537 num_received = context->m_receiveOfs-4; // 4 bytes for the size field in sUpdateContext() 538 while (num_received != packlen) in sUpdateContext() 540 int buffer_left = packlen - num_received; in sUpdateContext() 553 num_received += ditch_received; in sUpdateContext()
|
/dports/graphics/openvkl/openvkl-1.1.0/examples/interactive/imgui-1.83/examples/libs/usynergy/ |
H A D | uSynergy.c | 480 int num_received = 0; in sUpdateContext() local 482 …kie, context->m_receiveBuffer + context->m_receiveOfs, receive_size, &num_received) == USYNERGY_FA… in sUpdateContext() 486 …(%d bytes asked, %d bytes received), trying to reconnect in a second", receive_size, num_received); in sUpdateContext() 492 context->m_receiveOfs += num_received; in sUpdateContext() 497 if (num_received == 0) in sUpdateContext() 504 if (num_received == 0) in sUpdateContext() 537 num_received = context->m_receiveOfs-4; // 4 bytes for the size field in sUpdateContext() 538 while (num_received != packlen) in sUpdateContext() 540 int buffer_left = packlen - num_received; in sUpdateContext() 553 num_received += ditch_received; in sUpdateContext()
|
/dports/devel/nextpnr/nextpnr-48cd407/3rdparty/imgui/examples/libs/usynergy/ |
H A D | uSynergy.c | 480 int num_received = 0; in sUpdateContext() local 482 …kie, context->m_receiveBuffer + context->m_receiveOfs, receive_size, &num_received) == USYNERGY_FA… in sUpdateContext() 486 …(%d bytes asked, %d bytes received), trying to reconnect in a second", receive_size, num_received); in sUpdateContext() 492 context->m_receiveOfs += num_received; in sUpdateContext() 497 if (num_received == 0) in sUpdateContext() 504 if (num_received == 0) in sUpdateContext() 537 num_received = context->m_receiveOfs-4; // 4 bytes for the size field in sUpdateContext() 538 while (num_received != packlen) in sUpdateContext() 540 int buffer_left = packlen - num_received; in sUpdateContext() 553 num_received += ditch_received; in sUpdateContext()
|
/dports/net/jgroups/jgroups-2.12.0/tests/junit/org/jgroups/protocols/ |
H A D | FRAG2_Test.java | 110 int num_received=0; field in FRAG2_Test.Sender 119 return num_received; in getNumReceived() 185 num_received++; in verify() 187 if(num_corrupted + num_received >= NUM_MSGS) { in verify() 196 … return id + ": num_sent=" + num_sent + ", num_received=" + num_received + ", done=" + done; in toString()
|
/dports/misc/posixtestsuite/posixtestsuite/conformance/interfaces/lio_listio/ |
H A D | 15-1.c | 38 int num_received = 0; variable 44 num_received++; in sigrt1_handler() 149 if (num_received != NUM_AIOCBS) { in main() 151 num_received); in main()
|
/dports/net/jgroups/jgroups-2.12.0/tests/junit/org/jgroups/tests/ |
H A D | StateTransferTest.java | 150 int num_received=0; in receive() local 155 num_received=map.size(); in receive() 156 changed=tmp_size != num_received; in receive() 159 if(changed && num_received % 1000 == 0) in receive() 160 log.info(channel.getAddress() + ": received " + num_received); in receive() 163 if(num_received >= MSG_SEND_COUNT * APP_COUNT) in receive()
|
/dports/net/samba412/samba-4.12.15/source3/winbindd/ |
H A D | wb_seqnums.c | 28 int num_received; 50 state->num_received = 0; in wb_seqnum_done() 130 state->num_received += 1; 132 if (state->num_received >= state->num_domains) {
|
H A D | winbindd_list_users.c | 32 size_t num_received; member 108 state->num_received = 0; in winbindd_list_users_send() 144 state->num_received += 1; in winbindd_list_users_done() 146 if (state->num_received >= state->num_domains) { in winbindd_list_users_done()
|
H A D | winbindd_list_groups.c | 31 int num_received; member 113 state->num_received = 0; in winbindd_list_groups_send() 151 state->num_received += 1; in winbindd_list_groups_done() 153 if (state->num_received >= state->num_domains) { in winbindd_list_groups_done()
|
/dports/net/jgroups/jgroups-2.12.0/src/org/jgroups/stack/ |
H A D | AckMcastSenderWindow.java | 270 entry.num_received++; in ack() 303 if(received.booleanValue()) entry.num_received--; in remove() 384 return entry.num_received; in getNumberOfResponsesReceived() 567 public int num_received=0; field in AckMcastSenderWindow.Entry 578 return (num_received >= senders.size()); in allReceived() 590 … buf.append("num_received = ").append(num_received).append(", received msgs = ").append(senders); in toString()
|