| /external/cronet/stable/ipc/ |
| D | sync_socket_unittest.cc | 104 auto bytes_to_send = base::as_byte_span(kHelloString); in SetHandle() local
105 EXPECT_EQ(sync_socket.Send(bytes_to_send), bytes_to_send.size()); in SetHandle()
290 auto bytes_to_send = base::as_byte_span(kHelloString); in TEST_F() local
291 pair[1].Send(bytes_to_send); in TEST_F()
296 EXPECT_EQ(received, bytes_to_send.size()); in TEST_F()
307 auto bytes_to_send = base::as_byte_span(kHelloString); in TEST_F() local
308 while (pair[0].Send(bytes_to_send) != 0) { in TEST_F()
317 EXPECT_EQ(pair[0].Send(bytes_to_send), 0U); in TEST_F()
325 EXPECT_EQ(pair[0].Send(bytes_to_send), bytes_to_send.size()); in TEST_F()
|
| /external/cronet/tot/ipc/ |
| D | sync_socket_unittest.cc | 104 auto bytes_to_send = base::as_byte_span(kHelloString); in SetHandle() local
105 EXPECT_EQ(sync_socket.Send(bytes_to_send), bytes_to_send.size()); in SetHandle()
290 auto bytes_to_send = base::as_byte_span(kHelloString); in TEST_F() local
291 pair[1].Send(bytes_to_send); in TEST_F()
296 EXPECT_EQ(received, bytes_to_send.size()); in TEST_F()
307 auto bytes_to_send = base::as_byte_span(kHelloString); in TEST_F() local
308 while (pair[0].Send(bytes_to_send) != 0) { in TEST_F()
317 EXPECT_EQ(pair[0].Send(bytes_to_send), 0U); in TEST_F()
325 EXPECT_EQ(pair[0].Send(bytes_to_send), bytes_to_send.size()); in TEST_F()
|
| /external/curl/tests/libtest/ |
| D | lib1533.c | 62 size_t bytes_to_send = data->remaining_bytes; in read_callback() local
63 if(bytes_to_send > totalsize) { in read_callback()
64 bytes_to_send = totalsize; in read_callback()
67 memset(ptr, 'a', bytes_to_send); in read_callback()
68 data->remaining_bytes -= bytes_to_send; in read_callback()
70 return bytes_to_send; in read_callback()
|
| /external/grpc-grpc/test/http2_test/ |
| D | http2_base_server.py | 172 bytes_to_send = min(chunk_size, self._send_remaining[stream_id])
179 self._send_offset + bytes_to_send + padding_bytes,
187 if bytes_to_send + padding_bytes > _MIN_SETTINGS_MAX_FRAME_SIZE:
189 "overload: sending %d" % (bytes_to_send + padding_bytes)
192 self._send_offset : self._send_offset + bytes_to_send
201 self._send_remaining[stream_id] -= bytes_to_send
202 self._send_offset += bytes_to_send
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/test/http2_test/ |
| D | http2_base_server.py | 163 bytes_to_send = min(chunk_size, self._send_remaining[stream_id])
166 % (lfcw, self._send_offset, self._send_offset + bytes_to_send +
171 if bytes_to_send + padding_bytes > _MIN_SETTINGS_MAX_FRAME_SIZE:
173 (bytes_to_send + padding_bytes))
175 bytes_to_send]
184 self._send_remaining[stream_id] -= bytes_to_send
185 self._send_offset += bytes_to_send
|
| /external/grpc-grpc/test/core/tsi/alts/handshaker/ |
| D | alts_tsi_handshaker_test.cc | 250 const unsigned char* bytes_to_send, in on_client_start_success_cb() argument
256 ASSERT_EQ(memcmp(bytes_to_send, ALTS_TSI_HANDSHAKER_TEST_OUT_FRAME, in on_client_start_success_cb()
279 const unsigned char* bytes_to_send, in on_server_start_success_cb() argument
285 ASSERT_EQ(memcmp(bytes_to_send, ALTS_TSI_HANDSHAKER_TEST_OUT_FRAME, in on_server_start_success_cb()
308 const unsigned char* bytes_to_send, in on_client_next_success_cb() argument
314 ASSERT_EQ(memcmp(bytes_to_send, ALTS_TSI_HANDSHAKER_TEST_OUT_FRAME, in on_client_next_success_cb()
411 const unsigned char* bytes_to_send, in on_server_next_success_cb() argument
417 ASSERT_EQ(bytes_to_send, nullptr); in on_server_next_success_cb()
738 const unsigned char* bytes_to_send, in on_invalid_input_cb() argument
743 ASSERT_EQ(bytes_to_send, nullptr); in on_invalid_input_cb()
[all …]
|
| /external/cronet/tot/third_party/apache-portable-runtime/src/network_io/win32/ |
| D | sendrecv.c | 269 apr_size_t bytes_to_send; /* Bytes to send out of the file (not including headers) */ in apr_socket_sendfile() local
279 bytes_to_send = *len; in apr_socket_sendfile()
283 if (!bytes_to_send && hdtr) { in apr_socket_sendfile()
330 while (bytes_to_send) { in apr_socket_sendfile()
333 if (bytes_to_send > MAX_SEGMENT_SIZE) { in apr_socket_sendfile()
338 xmitbytes = (DWORD)bytes_to_send; in apr_socket_sendfile()
422 bytes_to_send -= xmitbytes; in apr_socket_sendfile()
|
| /external/cronet/stable/third_party/apache-portable-runtime/src/network_io/win32/ |
| D | sendrecv.c | 269 apr_size_t bytes_to_send; /* Bytes to send out of the file (not including headers) */ in apr_socket_sendfile() local
279 bytes_to_send = *len; in apr_socket_sendfile()
283 if (!bytes_to_send && hdtr) { in apr_socket_sendfile()
330 while (bytes_to_send) { in apr_socket_sendfile()
333 if (bytes_to_send > MAX_SEGMENT_SIZE) { in apr_socket_sendfile()
338 xmitbytes = (DWORD)bytes_to_send; in apr_socket_sendfile()
422 bytes_to_send -= xmitbytes; in apr_socket_sendfile()
|
| /external/grpc-grpc/src/core/lib/security/transport/ |
| D | security_handshaker.cc | 94 tsi_result result, const unsigned char* bytes_to_send,
107 tsi_result result, void* user_data, const unsigned char* bytes_to_send,
375 tsi_result result, const unsigned char* bytes_to_send, in OnHandshakeNextDoneLocked() argument
415 reinterpret_cast<const char*>(bytes_to_send), bytes_to_send_size); in OnHandshakeNextDoneLocked()
442 tsi_result result, void* user_data, const unsigned char* bytes_to_send, in OnHandshakeNextDoneGrpcWrapper() argument
448 result, bytes_to_send, bytes_to_send_size, handshaker_result); in OnHandshakeNextDoneGrpcWrapper()
459 const unsigned char* bytes_to_send = nullptr; in DoHandshakerNextLocked() local
463 handshaker_, bytes_received, bytes_received_size, &bytes_to_send, in DoHandshakerNextLocked()
473 return OnHandshakeNextDoneLocked(result, bytes_to_send, bytes_to_send_size, in DoHandshakerNextLocked()
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/security/transport/ |
| D | security_handshaker.cc | 93 tsi_result result, const unsigned char* bytes_to_send,
106 tsi_result result, void* user_data, const unsigned char* bytes_to_send,
376 tsi_result result, const unsigned char* bytes_to_send, in OnHandshakeNextDoneLocked() argument
415 reinterpret_cast<const char*>(bytes_to_send), bytes_to_send_size); in OnHandshakeNextDoneLocked()
442 tsi_result result, void* user_data, const unsigned char* bytes_to_send, in OnHandshakeNextDoneGrpcWrapper() argument
448 result, bytes_to_send, bytes_to_send_size, handshaker_result); in OnHandshakeNextDoneGrpcWrapper()
459 const unsigned char* bytes_to_send = nullptr; in DoHandshakerNextLocked() local
463 handshaker_, bytes_received, bytes_received_size, &bytes_to_send, in DoHandshakerNextLocked()
473 return OnHandshakeNextDoneLocked(result, bytes_to_send, bytes_to_send_size, in DoHandshakerNextLocked()
|
| /external/grpc-grpc/src/core/tsi/ |
| D | transport_security_interface.h | 465 tsi_result status, void* user_data, const unsigned char* bytes_to_send,
497 const unsigned char** bytes_to_send,
|
| D | transport_security.h | 78 const unsigned char** bytes_to_send,
|
| D | transport_security.cc | 217 size_t received_bytes_size, const unsigned char** bytes_to_send, in tsi_handshaker_next() argument
237 bytes_to_send, bytes_to_send_size, in tsi_handshaker_next()
|
| D | fake_transport_security.cc | 725 size_t received_bytes_size, const unsigned char** bytes_to_send, in fake_handshaker_next() argument
731 bytes_to_send == nullptr || bytes_to_send_size == nullptr || in fake_handshaker_next()
765 *bytes_to_send = handshaker->outgoing_bytes_buffer; in fake_handshaker_next()
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/tsi/ |
| D | transport_security_interface.h | 465 tsi_result status, void* user_data, const unsigned char* bytes_to_send,
497 const unsigned char** bytes_to_send,
|
| D | transport_security.h | 78 const unsigned char** bytes_to_send,
|
| D | transport_security.cc | 217 size_t received_bytes_size, const unsigned char** bytes_to_send, in tsi_handshaker_next() argument
237 bytes_to_send, bytes_to_send_size, in tsi_handshaker_next()
|
| D | fake_transport_security.cc | 725 size_t received_bytes_size, const unsigned char** bytes_to_send, in fake_handshaker_next() argument
731 bytes_to_send == nullptr || bytes_to_send_size == nullptr || in fake_handshaker_next()
765 *bytes_to_send = handshaker->outgoing_bytes_buffer; in fake_handshaker_next()
|
| /external/grpc-grpc/test/core/tsi/ |
| D | transport_security_test_lib.cc | 303 tsi_result result, void* user_data, const unsigned char* bytes_to_send, in on_handshake_next_done() argument
330 send_bytes_to_peer(fixture->channel, bytes_to_send, bytes_to_send_size, in on_handshake_next_done()
342 tsi_result result, void* user_data, const unsigned char* bytes_to_send, in on_handshake_next_done_wrapper() argument
345 args->error = on_handshake_next_done(result, user_data, bytes_to_send, in on_handshake_next_done_wrapper()
368 unsigned char* bytes_to_send = nullptr; in do_handshaker_next() local
382 const_cast<const unsigned char**>(&bytes_to_send), &bytes_to_send_size, in do_handshaker_next()
386 result, args, bytes_to_send, bytes_to_send_size, handshaker_result); in do_handshaker_next()
|
| /external/grpc-grpc/test/core/util/ |
| D | fake_udp_and_tcp_server.cc | 251 int bytes_to_send = kEmptyHttp2SettingsFrame.size() - total_bytes_sent_; in MaybeContinueSendingSettings() local
254 bytes_to_send, 0); in MaybeContinueSendingSettings()
259 ERRNO, bytes_to_send, fd_); in MaybeContinueSendingSettings()
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/tsi/alts/handshaker/ |
| D | alts_handshaker_client.cc | 54 const unsigned char* bytes_to_send; member
179 client->cb(r->status, client->user_data, r->bytes_to_send, in maybe_complete_tsi_next()
186 const unsigned char* bytes_to_send, in handle_response_done() argument
192 p->bytes_to_send = bytes_to_send; in handle_response_done()
267 unsigned char* bytes_to_send = nullptr; in alts_handshaker_client_handle_response() local
277 bytes_to_send = client->buffer; in alts_handshaker_client_handle_response()
310 std::move(error), bytes_to_send, bytes_to_send_size, in alts_handshaker_client_handle_response()
|
| /external/grpc-grpc/src/core/tsi/alts/handshaker/ |
| D | alts_handshaker_client.cc | 54 const unsigned char* bytes_to_send; member
179 client->cb(r->status, client->user_data, r->bytes_to_send, in maybe_complete_tsi_next()
186 const unsigned char* bytes_to_send, in handle_response_done() argument
192 p->bytes_to_send = bytes_to_send; in handle_response_done()
267 unsigned char* bytes_to_send = nullptr; in alts_handshaker_client_handle_response() local
277 bytes_to_send = client->buffer; in alts_handshaker_client_handle_response()
310 std::move(error), bytes_to_send, bytes_to_send_size, in alts_handshaker_client_handle_response()
|
| /external/webrtc/modules/rtp_rtcp/source/ |
| D | rtp_format_h264.cc | 240 size_t bytes_to_send = packet.source_fragment.size(); in NextPacket() local
241 uint8_t* buffer = rtp_packet->AllocatePayload(bytes_to_send); in NextPacket()
242 memcpy(buffer, packet.source_fragment.data(), bytes_to_send); in NextPacket()
|
| /external/cronet/tot/third_party/apache-portable-runtime/src/network_io/unix/ |
| D | sendrecv.c | 418 apr_off_t bytes_to_send = *len; in apr_socket_sendfile() local
458 if (!bytes_to_send) { in apr_socket_sendfile()
471 nbytes = bytes_to_send; in apr_socket_sendfile()
541 apr_size_t bytes_to_send = *len; in apr_socket_sendfile() local
561 bytes_to_send += hdtr->headers[i].iov_len; in apr_socket_sendfile()
582 if (bytes_to_send) { in apr_socket_sendfile()
590 bytes_to_send, /* number of bytes to send */ in apr_socket_sendfile()
|
| /external/cronet/stable/third_party/apache-portable-runtime/src/network_io/unix/ |
| D | sendrecv.c | 418 apr_off_t bytes_to_send = *len; in apr_socket_sendfile() local
458 if (!bytes_to_send) { in apr_socket_sendfile()
471 nbytes = bytes_to_send; in apr_socket_sendfile()
541 apr_size_t bytes_to_send = *len; in apr_socket_sendfile() local
561 bytes_to_send += hdtr->headers[i].iov_len; in apr_socket_sendfile()
582 if (bytes_to_send) { in apr_socket_sendfile()
590 bytes_to_send, /* number of bytes to send */ in apr_socket_sendfile()
|