| /third_party/gstreamer/gstplugins_bad/ext/curl/ |
| D | gstcurlsmtpsink.c | 770 size_t bytes_to_send; in gst_curl_smtp_sink_flush_data_unlocked() local
823 bytes_to_send = MIN (block_size, array->len); in gst_curl_smtp_sink_flush_data_unlocked()
824 memcpy ((guint8 *) curl_ptr, array->data, bytes_to_send); in gst_curl_smtp_sink_flush_data_unlocked()
825 g_byte_array_remove_range (array, 0, bytes_to_send); in gst_curl_smtp_sink_flush_data_unlocked()
827 return bytes_to_send; in gst_curl_smtp_sink_flush_data_unlocked()
834 size_t bytes_to_send; in transfer_chunk() local
842 bytes_to_send = MIN (block_size, buffer->len); in transfer_chunk()
844 if (bytes_to_send == 0) { in transfer_chunk()
845 bytes_to_send = MIN (block_size, array->len); in transfer_chunk()
860 size_out = (bytes_to_send / 3 + 1) * 4 + 4 + bytes_to_send + in transfer_chunk()
[all …]
|
| D | gstcurlbasesink.c | 782 size_t bytes_to_send = MIN (max_bytes_to_send, buf->len); in transfer_data_buffer() local
784 memcpy ((guint8 *) curl_ptr, buf->ptr + buf->offset, bytes_to_send); in transfer_data_buffer()
785 buf->offset = buf->offset + bytes_to_send; in transfer_data_buffer()
786 buf->len = buf->len - bytes_to_send; in transfer_data_buffer()
789 if (bytes_to_send == buf_len) { in transfer_data_buffer()
795 GST_LOG ("sent : %" G_GSIZE_FORMAT, bytes_to_send); in transfer_data_buffer()
797 return bytes_to_send; in transfer_data_buffer()
827 size_t bytes_to_send; in gst_curl_base_sink_transfer_read_cb() local
850 bytes_to_send = klass->flush_data_unlocked (sink, curl_ptr, in gst_curl_base_sink_transfer_read_cb()
855 return bytes_to_send; in gst_curl_base_sink_transfer_read_cb()
[all …]
|
| /third_party/curl/tests/libtest/ |
| D | lib1533.c | 60 size_t bytes_to_send = data->remaining_bytes; in read_callback() local
61 if(bytes_to_send > totalsize) { in read_callback()
62 bytes_to_send = totalsize; in read_callback()
65 memset(ptr, 'a', bytes_to_send); in read_callback()
66 data->remaining_bytes -= bytes_to_send; in read_callback()
68 return bytes_to_send; in read_callback()
|
| /third_party/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
|
| /third_party/grpc/test/core/tsi/alts/handshaker/ |
| D | alts_tsi_handshaker_test.cc | 229 const unsigned char* bytes_to_send, in on_client_start_success_cb() argument
235 GPR_ASSERT(memcmp(bytes_to_send, ALTS_TSI_HANDSHAKER_TEST_OUT_FRAME, in on_client_start_success_cb()
256 const unsigned char* bytes_to_send, in on_server_start_success_cb() argument
262 GPR_ASSERT(memcmp(bytes_to_send, ALTS_TSI_HANDSHAKER_TEST_OUT_FRAME, in on_server_start_success_cb()
283 const unsigned char* bytes_to_send, in on_client_next_success_cb() argument
289 GPR_ASSERT(memcmp(bytes_to_send, ALTS_TSI_HANDSHAKER_TEST_OUT_FRAME, in on_client_next_success_cb()
355 const unsigned char* bytes_to_send, in on_server_next_success_cb() argument
361 GPR_ASSERT(bytes_to_send == nullptr); in on_server_next_success_cb()
647 const unsigned char* bytes_to_send, in on_invalid_input_cb() argument
652 GPR_ASSERT(bytes_to_send == nullptr); in on_invalid_input_cb()
[all …]
|
| D | alts_handshaker_client_test.cc | 444 const unsigned char* bytes_to_send, in tsi_cb_assert_tsi_internal_error() argument
|
| /third_party/grpc/src/core/lib/security/transport/ |
| D | security_handshaker.cc | 64 tsi_result result, const unsigned char* bytes_to_send,
76 tsi_result result, void* user_data, const unsigned char* bytes_to_send,
284 tsi_result result, const unsigned char* bytes_to_send, in OnHandshakeNextDoneLocked() argument
315 reinterpret_cast<const char*>(bytes_to_send), bytes_to_send_size); in OnHandshakeNextDoneLocked()
342 tsi_result result, void* user_data, const unsigned char* bytes_to_send, in OnHandshakeNextDoneGrpcWrapper() argument
348 result, bytes_to_send, bytes_to_send_size, handshaker_result); in OnHandshakeNextDoneGrpcWrapper()
359 const unsigned char* bytes_to_send = nullptr; in DoHandshakerNextLocked() local
363 handshaker_, bytes_received, bytes_received_size, &bytes_to_send, in DoHandshakerNextLocked()
372 return OnHandshakeNextDoneLocked(result, bytes_to_send, bytes_to_send_size, in DoHandshakerNextLocked()
|
| /third_party/grpc/test/core/tsi/ |
| D | transport_security_test_lib.cc | 292 const unsigned char* bytes_to_send, in on_handshake_next_done() argument
320 send_bytes_to_peer(fixture->channel, bytes_to_send, bytes_to_send_size, in on_handshake_next_done()
332 tsi_result result, void* user_data, const unsigned char* bytes_to_send, in on_handshake_next_done_wrapper() argument
335 args->error = on_handshake_next_done(result, user_data, bytes_to_send, in on_handshake_next_done_wrapper()
361 unsigned char* bytes_to_send = nullptr; in do_handshaker_next() local
374 (const unsigned char**)&bytes_to_send, in do_handshaker_next()
379 result, args, bytes_to_send, bytes_to_send_size, handshaker_result); in do_handshaker_next()
|
| /third_party/grpc/src/core/tsi/ |
| D | transport_security_interface.h | 435 tsi_result status, void* user_data, const unsigned char* bytes_to_send,
459 size_t received_bytes_size, const unsigned char** bytes_to_send,
|
| D | transport_security.h | 71 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
225 bytes_to_send, bytes_to_send_size, in tsi_handshaker_next()
|
| D | fake_transport_security.cc | 674 size_t received_bytes_size, const unsigned char** bytes_to_send, in fake_handshaker_next() argument
679 bytes_to_send == nullptr || bytes_to_send_size == nullptr || in fake_handshaker_next()
711 *bytes_to_send = handshaker->outgoing_bytes_buffer; in fake_handshaker_next()
|
| D | ssl_transport_security.cc | 1505 size_t received_bytes_size, const unsigned char** bytes_to_send, in ssl_handshaker_next() argument
1510 bytes_to_send == nullptr || bytes_to_send_size == nullptr || in ssl_handshaker_next()
1537 *bytes_to_send = impl->outgoing_bytes_buffer; in ssl_handshaker_next()
|
| /third_party/grpc/src/core/tsi/alts/handshaker/ |
| D | alts_handshaker_client.cc | 49 const unsigned char* bytes_to_send; member
174 client->cb(r->status, client->user_data, r->bytes_to_send, in maybe_complete_tsi_next()
181 const unsigned char* bytes_to_send, in handle_response_done() argument
187 p->bytes_to_send = bytes_to_send; in handle_response_done()
251 unsigned char* bytes_to_send = nullptr; in alts_handshaker_client_handle_response() local
261 bytes_to_send = client->buffer; in alts_handshaker_client_handle_response()
292 bytes_to_send, bytes_to_send_size, result); in alts_handshaker_client_handle_response()
|
| D | alts_tsi_handshaker.cc | 559 size_t received_bytes_size, const unsigned char** bytes_to_send, in handshaker_next_dedicated() argument
564 bytes_to_send, bytes_to_send_size, result, cb, in handshaker_next_dedicated()
|
| /third_party/boost/libs/interprocess/test/ |
| D | message_queue_test.cpp | 174 std::size_t bytes_to_send = MaxMsgSize < (db_origin.get_size() - sent) ? in test_serialize_db() local
177 , bytes_to_send in test_serialize_db()
179 sent += bytes_to_send; in test_serialize_db()
|
| /third_party/libuv/src/unix/ |
| D | fs.c | 1274 off_t bytes_to_send; in uv__fs_copyfile() local
1376 bytes_to_send = src_statsbuf.st_size; in uv__fs_copyfile()
1378 while (bytes_to_send != 0) { in uv__fs_copyfile()
1380 if (bytes_to_send < (off_t) bytes_chunk) in uv__fs_copyfile()
1381 bytes_chunk = bytes_to_send; in uv__fs_copyfile()
1391 bytes_to_send -= bytes_written; in uv__fs_copyfile()
|
| /third_party/pulseaudio/src/modules/bluetooth/ |
| D | module-bluez5-device.c | 1486 … size_t bytes_to_send = pa_usec_to_bytes(time_passed - audio_sent, &u->encoder_sample_spec); in thread_func() local
1492 if (bytes_to_send > 2 * u->write_block_size) { in thread_func()
1498 skip_bytes = bytes_to_send - 2 * u->write_block_size; in thread_func()
|