| /aosp_15_r20/external/rust/android-crates-io/crates/h2/src/proto/streams/ |
| D | streams.rs | 35 send_buffer: Arc<SendBuffer<B>>, field
46 send_buffer: &'a SendBuffer<B>, field
55 send_buffer: Arc<SendBuffer<B>>, field
197 let mut send_buffer = self.send_buffer.inner.lock().unwrap(); in apply_remote_settings() localVariable
198 let send_buffer = &mut *send_buffer; in apply_remote_settings() localVariable
240 let mut send_buffer = self.send_buffer.inner.lock().unwrap(); in send_request() localVariable
241 let send_buffer = &mut *send_buffer; in send_request() localVariable
476 let mut send_buffer = send_buffer.inner.lock().unwrap(); in recv_headers() localVariable
477 let send_buffer = &mut *send_buffer; in recv_headers() localVariable
566 let mut send_buffer = send_buffer.inner.lock().unwrap(); in recv_data() localVariable
[all …]
|
| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/ |
| H A D | quic_stream_send_buffer_peer.cc | 15 QuicStreamSendBuffer* send_buffer, QuicStreamOffset stream_offset) { in SetStreamOffset()
21 QuicStreamSendBuffer* send_buffer) { in CurrentWriteSlice()
31 QuicStreamSendBuffer* send_buffer) { in EndOffset()
37 QuicStreamSendBuffer* send_buffer) { in TotalLength()
48 QuicStreamSendBuffer* send_buffer) { in write_index()
|
| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/ |
| H A D | quic_crypto_stream.cc | 144 QuicStreamSendBuffer* send_buffer = in WriteCryptoData() local
226 QuicStreamSendBuffer* send_buffer = in NeuterStreamDataOfEncryptionLevel() local
269 QuicStreamSendBuffer* send_buffer = in WritePendingCryptoRetransmission() local
415 QuicStreamSendBuffer* send_buffer = in RetransmitData() local
446 QuicStreamSendBuffer* send_buffer = in WriteBufferedCryptoFrames() local
470 const QuicStreamSendBuffer& send_buffer = substream.send_buffer; in HasBufferedCryptoFrames() local
|
| H A D | quic_stream_send_buffer_test.cc | 316 QuicStreamSendBuffer send_buffer(&allocator); in TEST_F() local
330 QuicStreamSendBuffer send_buffer(&allocator); in TEST_F() local
|
| H A D | quic_stream.h | 483 const QuicStreamSendBuffer& send_buffer() const { return send_buffer_; } in send_buffer() function
485 QuicStreamSendBuffer& send_buffer() { return send_buffer_; } in send_buffer() function
|
| H A D | quic_crypto_stream.h | 266 QuicStreamSendBuffer send_buffer; member
|
| /aosp_15_r20/external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
| H A D | nccl_all_to_all_thunk.cc | 100 const uint8_t* send_buffer = in RunAllToAll() local
132 const uint8_t* send_buffer = in RunAllToAll() local
|
| H A D | nccl_all_reduce_thunk.cc | 56 const void* send_buffer = buffer.source_buffer.opaque(); in RunAllReduce() local
387 const void* send_buffer = buffer.source_buffer.opaque(); in RunReduceScatter() local
|
| H A D | nccl_all_gather_thunk.cc | 76 const void* send_buffer = buffer.source_buffer.opaque(); in RunAllGather() local
|
| /aosp_15_r20/external/grpc-grpc/test/cpp/util/ |
| H A D | cli_call.cc | 98 grpc::ByteBuffer send_buffer(&req_slice, 1); in Write() local
140 grpc::ByteBuffer send_buffer(&req_slice, 1); in WriteAndWait() local
|
| H A D | byte_buffer_test.cc | 113 ByteBuffer send_buffer; in TEST_F() local
|
| /aosp_15_r20/external/grpc-grpc/test/cpp/end2end/ |
| H A D | hybrid_end2end_test.cc | 94 auto send_buffer = SerializeToByteBuffer(&send_response); in HandleRawEcho() local
136 auto send_buffer = SerializeToByteBuffer(&send_response); in HandleRawClientStreaming() local
172 auto send_buffer = SerializeToByteBuffer(&send_response); in HandleGenericEcho() local
194 auto send_buffer = SerializeToByteBuffer(&send_response); in HandleGenericRequestStream() local
|
| H A D | generic_end2end_test.cc | 144 std::unique_ptr<ByteBuffer> send_buffer = in SendRpc() local
351 std::unique_ptr<ByteBuffer> send_buffer = in TEST_F() local
|
| H A D | server_interceptors_end2end_test.cc | 537 std::unique_ptr<ByteBuffer> send_buffer = in TEST_F() local
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/ |
| D | grpc_wrap.cc | 487 grpc_call* call, grpcwrap_batch_context* ctx, grpc_slice* send_buffer, in grpcwrap_call_start_unary()
581 grpc_call* call, grpcwrap_batch_context* ctx, grpc_slice* send_buffer, in grpcwrap_call_start_server_streaming()
667 grpc_call* call, grpcwrap_batch_context* ctx, grpc_slice* send_buffer, in grpcwrap_call_send_message()
|
| /aosp_15_r20/external/tensorflow/tensorflow/compiler/xla/stream_executor/tpu/ |
| H A D | tpu_stream.h | 66 stream_executor::DeviceMemoryBase send_buffer, in EnqueueOnTpuDeviceSendRecvLocal()
|
| /aosp_15_r20/external/trusty/arm-trusted-firmware/drivers/arm/mhu/ |
| D | mhu_wrapper_v2_x.c | 163 enum mhu_error_t mhu_send_data(const uint8_t *send_buffer, size_t size) in mhu_send_data()
|
| D | mhu_wrapper_v3_x.c | 289 enum mhu_error_t mhu_send_data(const uint8_t *send_buffer, size_t size) in mhu_send_data()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/criterion/src/ |
| D | connection.rs | 78 send_buffer: Vec<u8>, field
|
| /aosp_15_r20/external/webrtc/rtc_base/ |
| H A D | socket_unittest.cc | 785 rtc::Buffer send_buffer(0, data_size); in TcpInternal() local
|
| H A D | virtual_socket_unittest.cc | 522 char send_buffer[kDataSize], recv_buffer[kDataSize]; in TcpSendTest() local
|
| /aosp_15_r20/external/grpc-grpc/src/core/tsi/alts/handshaker/ |
| H A D | alts_handshaker_client.cc | 77 grpc_byte_buffer* send_buffer = nullptr; member
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/tsi/alts/handshaker/ |
| D | alts_handshaker_client.cc | 77 grpc_byte_buffer* send_buffer = nullptr; member
|
| /aosp_15_r20/external/crosvm/devices/src/virtio/snd/vios_backend/ |
| H A D | shm_vios.rs | 795 fn send_buffer(&self, stream_id: u32, offset: usize, size: usize) -> Result<()> { in send_buffer() method
|
| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/http/ |
| H A D | quic_spdy_session_test.cc | 1974 QuicStreamSendBuffer& send_buffer = in TEST_P() local
4166 QuicStreamSendBuffer& send_buffer = in TEST_P() local
|