Home
last modified time | relevance | path

Searched refs:send_buffer (Results 1 – 25 of 47) sorted by relevance

12

/external/rust/android-crates-io/crates/h2/src/proto/streams/
Dstreams.rs35 send_buffer: Arc<SendBuffer<B>>, field
46 send_buffer: &'a SendBuffer<B>, field
55 send_buffer: Arc<SendBuffer<B>>, field
116 send_buffer: Arc::new(SendBuffer::new()), in new()
151 send_buffer: self.send_buffer.clone(), in next_incoming()
186 me.poll_complete(&self.send_buffer, cx, dst) in poll_complete()
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
204 send_buffer, in apply_remote_settings()
240 let mut send_buffer = self.send_buffer.inner.lock().unwrap(); in send_request() localVariable
[all …]
/external/cronet/stable/net/third_party/quiche/src/quiche/quic/test_tools/
Dquic_stream_send_buffer_peer.cc15 QuicStreamSendBuffer* send_buffer, QuicStreamOffset stream_offset) { in SetStreamOffset() argument
16 send_buffer->stream_offset_ = stream_offset; in SetStreamOffset()
21 QuicStreamSendBuffer* send_buffer) { in CurrentWriteSlice() argument
22 auto wi = write_index(send_buffer); in CurrentWriteSlice()
27 return QuicIntervalDequePeer::GetItem(&send_buffer->interval_deque_, wi); in CurrentWriteSlice()
31 QuicStreamSendBuffer* send_buffer) { in EndOffset() argument
32 return send_buffer->current_end_offset_; in EndOffset()
37 QuicStreamSendBuffer* send_buffer) { in TotalLength() argument
39 for (auto slice = send_buffer->interval_deque_.DataBegin(); in TotalLength()
40 slice != send_buffer->interval_deque_.DataEnd(); ++slice) { in TotalLength()
[all …]
Dquic_stream_send_buffer_peer.h16 static void SetStreamOffset(QuicStreamSendBuffer* send_buffer,
20 QuicStreamSendBuffer* send_buffer);
22 static QuicStreamOffset EndOffset(QuicStreamSendBuffer* send_buffer);
24 static QuicByteCount TotalLength(QuicStreamSendBuffer* send_buffer);
26 static int32_t write_index(QuicStreamSendBuffer* send_buffer);
/external/cronet/tot/net/third_party/quiche/src/quiche/quic/test_tools/
Dquic_stream_send_buffer_peer.cc15 QuicStreamSendBuffer* send_buffer, QuicStreamOffset stream_offset) { in SetStreamOffset() argument
16 send_buffer->stream_offset_ = stream_offset; in SetStreamOffset()
21 QuicStreamSendBuffer* send_buffer) { in CurrentWriteSlice() argument
22 auto wi = write_index(send_buffer); in CurrentWriteSlice()
27 return QuicIntervalDequePeer::GetItem(&send_buffer->interval_deque_, wi); in CurrentWriteSlice()
31 QuicStreamSendBuffer* send_buffer) { in EndOffset() argument
32 return send_buffer->current_end_offset_; in EndOffset()
37 QuicStreamSendBuffer* send_buffer) { in TotalLength() argument
39 for (auto slice = send_buffer->interval_deque_.DataBegin(); in TotalLength()
40 slice != send_buffer->interval_deque_.DataEnd(); ++slice) { in TotalLength()
[all …]
Dquic_stream_send_buffer_peer.h16 static void SetStreamOffset(QuicStreamSendBuffer* send_buffer,
20 QuicStreamSendBuffer* send_buffer);
22 static QuicStreamOffset EndOffset(QuicStreamSendBuffer* send_buffer);
24 static QuicByteCount TotalLength(QuicStreamSendBuffer* send_buffer);
26 static int32_t write_index(QuicStreamSendBuffer* send_buffer);
/external/cronet/tot/net/third_party/quiche/src/quiche/quic/core/
Dquic_crypto_stream.cc145 QuicStreamSendBuffer* send_buffer = in WriteCryptoData() local
146 &substreams_[QuicUtils::GetPacketNumberSpace(level)].send_buffer; in WriteCryptoData()
147 QuicStreamOffset offset = send_buffer->stream_offset(); in WriteCryptoData()
153 offset < send_buffer->stream_bytes_written()); in WriteCryptoData()
155 offset - std::min(offset, send_buffer->stream_bytes_written()); in WriteCryptoData()
174 send_buffer->SaveStreamData(data); in WriteCryptoData()
188 send_buffer->OnStreamDataConsumed(bytes_consumed); in WriteCryptoData()
199 .send_buffer.OnStreamDataAcked(frame.offset, frame.data_length, in OnCryptoFrameAcked()
222 send_buffer().OnStreamDataAcked( in NeuterStreamDataOfEncryptionLevel()
227 QuicStreamSendBuffer* send_buffer = in NeuterStreamDataOfEncryptionLevel() local
[all …]
Dquic_stream_send_buffer_test.cc318 QuicStreamSendBuffer send_buffer(&allocator); in TEST_F() local
326 EXPECT_EQ(10 * 1024u, send_buffer.SaveMemSliceSpan(absl::MakeSpan(buffers))); in TEST_F()
327 EXPECT_EQ(10u, send_buffer.size()); in TEST_F()
332 QuicStreamSendBuffer send_buffer(&allocator); in TEST_F() local
340 EXPECT_EQ(10 * 1024u, send_buffer.SaveMemSliceSpan(absl::MakeSpan(buffers))); in TEST_F()
342 EXPECT_EQ(10u, send_buffer.size()); in TEST_F()
/external/cronet/stable/net/third_party/quiche/src/quiche/quic/core/
Dquic_crypto_stream.cc145 QuicStreamSendBuffer* send_buffer = in WriteCryptoData() local
146 &substreams_[QuicUtils::GetPacketNumberSpace(level)].send_buffer; in WriteCryptoData()
147 QuicStreamOffset offset = send_buffer->stream_offset(); in WriteCryptoData()
153 offset < send_buffer->stream_bytes_written()); in WriteCryptoData()
155 offset - std::min(offset, send_buffer->stream_bytes_written()); in WriteCryptoData()
174 send_buffer->SaveStreamData(data); in WriteCryptoData()
188 send_buffer->OnStreamDataConsumed(bytes_consumed); in WriteCryptoData()
199 .send_buffer.OnStreamDataAcked(frame.offset, frame.data_length, in OnCryptoFrameAcked()
222 send_buffer().OnStreamDataAcked( in NeuterStreamDataOfEncryptionLevel()
227 QuicStreamSendBuffer* send_buffer = in NeuterStreamDataOfEncryptionLevel() local
[all …]
Dquic_stream_send_buffer_test.cc318 QuicStreamSendBuffer send_buffer(&allocator); in TEST_F() local
326 EXPECT_EQ(10 * 1024u, send_buffer.SaveMemSliceSpan(absl::MakeSpan(buffers))); in TEST_F()
327 EXPECT_EQ(10u, send_buffer.size()); in TEST_F()
332 QuicStreamSendBuffer send_buffer(&allocator); in TEST_F() local
340 EXPECT_EQ(10 * 1024u, send_buffer.SaveMemSliceSpan(absl::MakeSpan(buffers))); in TEST_F()
342 EXPECT_EQ(10u, send_buffer.size()); in TEST_F()
/external/grpc-grpc/test/cpp/end2end/
Dgeneric_end2end_test.cc144 std::unique_ptr<ByteBuffer> send_buffer = in SendRpc() local
146 call->Write(*send_buffer, tag(2)); in SendRpc()
148 send_buffer.reset(); in SendRpc()
172 send_buffer = SerializeToByteBuffer(&send_response); in SendRpc()
173 stream.Write(*send_buffer, tag(6)); in SendRpc()
174 send_buffer.reset(); in SendRpc()
351 std::unique_ptr<ByteBuffer> send_buffer = in TEST_F() local
353 cli_stream->Write(*send_buffer, tag(3)); in TEST_F()
354 send_buffer.reset(); in TEST_F()
364 send_buffer = SerializeToByteBuffer(&send_response); in TEST_F()
[all …]
/external/tensorflow/tensorflow/compiler/xla/service/gpu/
Dnccl_all_to_all_thunk.cc100 const uint8_t* send_buffer = in RunAllToAll() local
118 XLA_CUDA_RETURN_IF_ERROR(ncclSend(send_buffer + rank * chunk_bytes, in RunAllToAll()
132 const uint8_t* send_buffer = in RunAllToAll() local
143 XLA_CUDA_RETURN_IF_ERROR(ncclSend(send_buffer, element_count, dtype, in RunAllToAll()
Dnccl_all_gather_thunk.cc76 const void* send_buffer = buffer.source_buffer.opaque(); in RunAllGather() local
88 send_buffer, recv_buffer, element_count, static_cast<const void*>(comm), in RunAllGather()
92 send_buffer, recv_buffer, element_count, dtype, comm, gpu_stream)); in RunAllGather()
Dnccl_all_reduce_thunk.cc56 const void* send_buffer = buffer.source_buffer.opaque(); in RunAllReduce() local
67 send_buffer, recv_buffer, element_count, static_cast<const void*>(comm), in RunAllReduce()
70 XLA_CUDA_RETURN_IF_ERROR(ncclAllReduce(send_buffer, recv_buffer, in RunAllReduce()
387 const void* send_buffer = buffer.source_buffer.opaque(); in RunReduceScatter() local
406 send_buffer, recv_buffer, recv_count, static_cast<const void*>(comm), in RunReduceScatter()
408 XLA_CUDA_RETURN_IF_ERROR(ncclReduceScatter(send_buffer, recv_buffer, in RunReduceScatter()
/external/walt/arduino/walt/
Dwalt.ino86 String send_buffer;
121 void send(char c) { send_buffer += c; }
122 void send(String s) { send_buffer += s; }
143 usbMIDI.sendSysEx(send_buffer.length(), (const uint8_t *)send_buffer.c_str());
145 send_buffer = MIDI_SYSEX_BEGIN;
147 Serial.write(send_buffer.c_str(), send_buffer.length());
149 send_buffer = String();
472 send_buffer = (serial_over_midi ? MIDI_SYSEX_BEGIN : String());
/external/grpc-grpc/test/cpp/util/
Dcli_call.cc98 grpc::ByteBuffer send_buffer(&req_slice, 1); in Write() local
99 call_->Write(send_buffer, tag(2)); in Write()
140 grpc::ByteBuffer send_buffer(&req_slice, 1); in WriteAndWait() local
143 call_->Write(send_buffer, tag(2)); in WriteAndWait()
Dbyte_buffer_test.cc113 ByteBuffer send_buffer; in TEST_F() local
118 SerializationTraits<ByteBuffer>::Serialize(buffer, &send_buffer, &owned); in TEST_F()
121 EXPECT_TRUE(send_buffer.Valid()); in TEST_F()
/external/rust/android-crates-io/crates/criterion/src/
Dconnection.rs78 send_buffer: Vec<u8>, field
115 send_buffer: vec![], in new()
132 self.send_buffer.truncate(0); in send()
133 ciborium::ser::into_writer(message, &mut self.send_buffer)?; in send()
134 let size = u32::try_from(self.send_buffer.len()).unwrap(); in send()
137 self.socket.write_all(&self.send_buffer)?; in send()
/external/grpc-grpc/test/cpp/cocoapods/generic/
Dgeneric.mm186 std::unique_ptr<ByteBuffer> send_buffer =
188 call->Write(*send_buffer, tag(2));
190 send_buffer.reset();
211 send_buffer = std::unique_ptr<ByteBuffer>(new ByteBuffer(recv_buffer));
212 stream.Write(*send_buffer, tag(6));
213 send_buffer.reset();
/external/tensorflow/tensorflow/compiler/xla/stream_executor/tpu/
Dtpu_stream.h66 stream_executor::DeviceMemoryBase send_buffer, in EnqueueOnTpuDeviceSendRecvLocal() argument
71 stream_, ApiConverter::ToC(send_buffer), in EnqueueOnTpuDeviceSendRecvLocal()
Dtpu_stream_interface.h32 stream_executor::DeviceMemoryBase send_buffer,
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/tsi/alts/handshaker/
Dalts_handshaker_client.cc77 grpc_byte_buffer* send_buffer = nullptr; member
122 grpc_byte_buffer_destroy(client->send_buffer); in handshaker_client_send_buffer_destroy()
123 client->send_buffer = nullptr; in handshaker_client_send_buffer_destroy()
138 grpc_byte_buffer_destroy(client->send_buffer); in alts_grpc_handshaker_client_unref()
140 client->send_buffer = nullptr; in alts_grpc_handshaker_client_unref()
349 op->data.send_message.send_message = client->send_buffer; in continue_make_grpc_call()
558 client->send_buffer = buffer; in handshaker_client_start_client()
617 client->send_buffer = buffer; in handshaker_client_start_server()
656 client->send_buffer = buffer; in handshaker_client_next()
772 return client->send_buffer; in alts_handshaker_client_get_send_buffer_for_testing()
/external/grpc-grpc/src/core/tsi/alts/handshaker/
Dalts_handshaker_client.cc77 grpc_byte_buffer* send_buffer = nullptr; member
122 grpc_byte_buffer_destroy(client->send_buffer); in handshaker_client_send_buffer_destroy()
123 client->send_buffer = nullptr; in handshaker_client_send_buffer_destroy()
138 grpc_byte_buffer_destroy(client->send_buffer); in alts_grpc_handshaker_client_unref()
140 client->send_buffer = nullptr; in alts_grpc_handshaker_client_unref()
349 op->data.send_message.send_message = client->send_buffer; in continue_make_grpc_call()
558 client->send_buffer = buffer; in handshaker_client_start_client()
617 client->send_buffer = buffer; in handshaker_client_start_server()
656 client->send_buffer = buffer; in handshaker_client_next()
774 return client->send_buffer; in alts_handshaker_client_get_send_buffer_for_testing()
/external/trusty/arm-trusted-firmware/drivers/arm/mhu/
Dmhu_wrapper_v2_x.c163 enum mhu_error_t mhu_send_data(const uint8_t *send_buffer, size_t size) in mhu_send_data() argument
173 if ((uintptr_t)send_buffer & 0x3U) { in mhu_send_data()
189 p = (uint32_t *)send_buffer; in mhu_send_data()
Dmhu_wrapper_v3_x.c289 enum mhu_error_t mhu_send_data(const uint8_t *send_buffer, size_t size) in mhu_send_data() argument
309 mhu_err = validate_buffer_params((uintptr_t)send_buffer); in mhu_send_data()
327 buffer = (uint32_t *)send_buffer; in mhu_send_data()
/external/python/cpython3/Lib/test/support/interpreters/
Dchannels.py224 def send_buffer(self, obj, timeout=None, *, member in SendChannel
235 _channels.send_buffer(self._id, obj, unboundop,
250 return _channels.send_buffer(self._id, obj, unboundop, blocking=False)

12