Home
last modified time | relevance | path

Searched refs:num_received (Results 1 – 25 of 139) sorted by relevance

123456

/dports/devel/grpc/grpc-1.42.0/test/core/promise/
H A Dfor_each_test.cc35 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 Dlossy.c120 *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 DNetworkUtilization.java16 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 Dfakesmsc.c229 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 Dnutdrv_siemens_sitop.c104 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 Dtest-io.c142 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 DGBASockClient.cpp48 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 DMultiRequest.java35 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 DGroupRequest.java58 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 Dcheck_getdns_context_set_timeout.c166 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 Dpong.c114 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 DUNICAST_Test.java126 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 DFCTest.java60 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 DConnectionMapUnitTest.java150 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 DuSynergy.c480 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 DuSynergy.c480 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 DuSynergy.c480 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 DuSynergy.c480 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 DFRAG2_Test.java110 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 D15-1.c38 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 DStateTransferTest.java150 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 Dwb_seqnums.c28 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 Dwinbindd_list_users.c32 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 Dwinbindd_list_groups.c31 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 DAckMcastSenderWindow.java270 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()

123456