| /external/grpc-grpc/test/core/iomgr/ios/CFStreamTests/ |
| D | CFStreamEndpointTests.mm | 164 size_t recv_size = 0;
175 while (recv_size < kBufferSize) {
178 recv_size += size;
181 XCTAssertEqual(recv_size, kBufferSize);
217 size_t recv_size = 0;
232 while (recv_size < kBufferSize) {
235 recv_size += size;
238 XCTAssertEqual(recv_size, kBufferSize);
266 size_t recv_size = 0;
281 while (recv_size < kBufferSize) {
[all …]
|
| /external/curl/lib/ |
| D | sendf.c | 140 psnd->recv_size > psnd->recv_processed; in Curl_recv_has_postponed_data()
147 size_t bytestorecv = psnd->allocated_size - psnd->recv_size; in pre_receive_plain()
166 psnd->recv_size = 0; in pre_receive_plain()
176 recvedbytes = sread(sockfd, psnd->buffer + psnd->recv_size, in pre_receive_plain()
179 psnd->recv_size += recvedbytes; in pre_receive_plain()
197 DEBUGASSERT(psnd->recv_size <= psnd->allocated_size); in get_pre_recved()
198 DEBUGASSERT(psnd->recv_processed <= psnd->recv_size); in get_pre_recved()
201 if(psnd->recv_size > psnd->recv_processed) { in get_pre_recved()
203 copysize = CURLMIN(len, psnd->recv_size - psnd->recv_processed); in get_pre_recved()
211 if(psnd->recv_processed == psnd->recv_size) { in get_pre_recved()
[all …]
|
| D | url.c | 672 DEBUGASSERT(psnd->recv_size <= psnd->allocated_size); in conn_reset_postponed_data()
673 DEBUGASSERT(psnd->recv_size ? in conn_reset_postponed_data()
674 (psnd->recv_processed < psnd->recv_size) : in conn_reset_postponed_data()
680 psnd->recv_size = 0; in conn_reset_postponed_data()
688 DEBUGASSERT(psnd->recv_size == 0); in conn_reset_postponed_data()
|
| D | urldata.h | 785 size_t recv_size; /* Size of received data during sending */ member
|
| /external/webrtc/modules/congestion_controller/goog_cc/ |
| D | robust_throughput_estimator.cc | 93 DataSize recv_size = data_size; in bitrate() local
107 recv_size -= first_last_average_size; in bitrate()
114 recv_size -= (window_.front().sent_packet.size + in bitrate()
132 return std::min(send_size / send_duration, recv_size / recv_duration); in bitrate()
|
| /external/perfetto/src/ipc/ |
| D | buffered_frame_deserializer.cc | 67 bool BufferedFrameDeserializer::EndReceive(size_t recv_size) { in EndReceive() argument
69 PERFETTO_CHECK(recv_size + size_ <= capacity_); in EndReceive()
70 size_ += recv_size; in EndReceive()
|
| D | buffered_frame_deserializer.h | 109 bool EndReceive(size_t recv_size) PERFETTO_WARN_UNUSED_RESULT;
|
| /external/crosvm/devices/src/virtio/snd/vios_backend/ |
| D | shm_vios.rs | 125 let (recv_size, fd_count) = client_socket in try_new()
140 if recv_size != std::mem::size_of::<VioSConfig>() { in try_new()
142 ProtocolErrorKind::UnexpectedConfigSize(recv_size), in try_new()
335 let recv_size = await_status(status_promise)?; in request_audio_data() localVariable
339 .pop_buffer(buffer, dst_offset, recv_size, src_offset) in request_audio_data()
340 .map(|()| recv_size) in request_audio_data()
|
| /external/llvm-project/lldb/source/Plugins/Process/gdb-remote/ |
| D | GDBRemoteCommunicationClient.cpp | 2335 uint32_t recv_size) { in MakeSpeedTestPacket() argument
2337 packet.Printf("qSpeedTest:response_size:%i;data:", recv_size); in MakeSpeedTestPacket()
2388 for (uint32_t recv_size = 0; recv_size <= max_recv; in TestPacketSpeed() local
2389 recv_size ? recv_size *= 2 : recv_size = 4) { in TestPacketSpeed()
2390 MakeSpeedTestPacket(packet, send_size, recv_size); in TestPacketSpeed()
2414 result_idx > 0 ? "," : "", send_size, recv_size, in TestPacketSpeed()
2421 send_size, recv_size, duration<float>(total_time), in TestPacketSpeed()
2441 for (uint32_t recv_size = 32; recv_size <= max_recv; recv_size *= 2) { in TestPacketSpeed() local
2442 MakeSpeedTestPacket(packet, send_size, recv_size); in TestPacketSpeed()
2446 if (recv_size > 0) { in TestPacketSpeed()
[all …]
|
| D | GDBRemoteCommunicationClient.h | 335 bool SendSpeedTestPacket(uint32_t send_size, uint32_t recv_size);
|
| /external/webrtc/rtc_base/ |
| D | socket_unittest.cc | 1011 int recv_size = 0; in GetSetOptionsInternal() local
1014 ASSERT_NE(-1, socket->GetOption(Socket::OPT_RCVBUF, &recv_size)); in GetSetOptionsInternal()
1020 ASSERT_NE(-1, socket->GetOption(Socket::OPT_RCVBUF, &recv_size)); in GetSetOptionsInternal()
1023 ASSERT_EQ(expected_size, recv_size); in GetSetOptionsInternal()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | message_wrappers.cc | 674 return response_.recv_size(); in num_recvs()
745 return response_->recv_size(); in num_recvs()
|
| /external/igt-gpu-tools/tests/ |
| D | kms_chamelium.c | 1387 size_t recv_size; in audio_state_receive() local
1400 recv_size = *recv_len * sizeof(int32_t); in audio_state_receive()
1401 igt_assert_f(write(state->dump_fd, *recv, recv_size) == recv_size, in audio_state_receive()
|