Home
last modified time | relevance | path

Searched refs:send_buffer_ (Results 1 – 9 of 9) sorted by relevance

/external/cronet/net/third_party/quiche/src/quiche/quic/core/
Dquic_stream_send_buffer_test.cc25 QuicStreamSendBufferTest() : send_buffer_(&allocator_) { in QuicStreamSendBufferTest()
26 EXPECT_EQ(0u, send_buffer_.size()); in QuicStreamSendBufferTest()
27 EXPECT_EQ(0u, send_buffer_.stream_bytes_written()); in QuicStreamSendBufferTest()
28 EXPECT_EQ(0u, send_buffer_.stream_bytes_outstanding()); in QuicStreamSendBufferTest()
30 EXPECT_EQ(0u, QuicStreamSendBufferPeer::EndOffset(&send_buffer_)); in QuicStreamSendBufferTest()
45 send_buffer_.SaveStreamData(data1); in QuicStreamSendBufferTest()
47 send_buffer_.SaveMemSlice(std::move(slice1)); in QuicStreamSendBufferTest()
49 send_buffer_.SaveMemSlice(std::move(slice2)); in QuicStreamSendBufferTest()
52 EXPECT_EQ(4u, send_buffer_.size()); in QuicStreamSendBufferTest()
64 send_buffer_.WriteStreamData(0, 3840u, &writer); in WriteAllData()
[all …]
Dquic_stream.cc359 send_buffer_( in QuicStream()
390 << send_buffer_.stream_bytes_outstanding() in ~QuicStream()
685 QuicStreamOffset offset = send_buffer_.stream_offset(); in WriteOrBufferDataAtLevel()
693 send_buffer_.SaveStreamData(data); in WriteOrBufferDataAtLevel()
785 QuicStreamOffset offset = send_buffer_.stream_offset(); in WriteMemSlices()
786 consumed_data.bytes_consumed = send_buffer_.SaveMemSliceSpan(span); in WriteMemSlices()
787 if (offset > send_buffer_.stream_offset() || in WriteMemSlices()
788 kMaxStreamLength < send_buffer_.stream_offset()) { in WriteMemSlices()
809 return send_buffer_.HasPendingRetransmission() || fin_lost_; in HasPendingRetransmission()
815 return send_buffer_.IsStreamDataOutstanding(offset, data_length) || in IsStreamFrameOutstanding()
[all …]
Dquic_stream.h469 const QuicStreamSendBuffer& send_buffer() const { return send_buffer_; } in send_buffer()
471 QuicStreamSendBuffer& send_buffer() { return send_buffer_; } in send_buffer()
583 QuicStreamSendBuffer send_buffer_; variable
Dquic_dispatcher.cc82 : send_buffer_(allocator) {} in PacketCollector()
123 if (send_buffer_.WriteStreamData(offset, data_length, writer)) { in WriteStreamData()
131 return send_buffer_.WriteStreamData(offset, data_length, writer); in WriteCryptoData()
142 QuicStreamSendBuffer send_buffer_; member in quic::__anon9a71d2d70111::PacketCollector
/external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/
Dquic_stream_peer.cc25 stream->send_buffer_.stream_bytes_written_ = stream_bytes_written; in SetStreamBytesWritten()
26 stream->send_buffer_.stream_bytes_outstanding_ = stream_bytes_written; in SetStreamBytesWritten()
27 QuicStreamSendBufferPeer::SetStreamOffset(&stream->send_buffer_, in SetStreamBytesWritten()
105 return stream->send_buffer_; in SendBuffer()
/external/webrtc/pc/test/
Dfake_audio_capture_module.cc396 Sample* buffer_ptr = reinterpret_cast<Sample*>(send_buffer_); in SetSendBuffer()
398 sizeof(send_buffer_) / kNumberBytesPerSample; in SetSendBuffer()
515 send_buffer_, kNumberSamples, kNumberBytesPerSample, in SendFrameP()
Dfake_audio_capture_module.h218 char send_buffer_[kNumberSamples * kNumberBytesPerSample]; variable
/external/webrtc/rtc_base/
Dvirtual_socket_server.cc565 size_t capacity = server_->send_buffer_capacity() - send_buffer_.size(); in SendTcp()
573 send_buffer_.insert(send_buffer_.end(), cpv, cpv + consumed); in SendTcp()
604 size_t new_buffer_size = send_buffer_.size() - data_size; in UpdateSend()
607 if (data_size < send_buffer_.size()) { in UpdateSend()
609 memmove(&send_buffer_[0], &send_buffer_[data_size], new_buffer_size); in UpdateSend()
611 send_buffer_.resize(new_buffer_size); in UpdateSend()
615 if (!ready_to_send_ && (send_buffer_.size() < capacity)) { in MaybeSignalWriteEvent()
Dvirtual_socket_server.h65 size_t send_buffer_size() const { return send_buffer_.size(); } in send_buffer_size()
66 const char* send_buffer_data() const { return send_buffer_.data(); } in send_buffer_data()
185 SendBuffer send_buffer_; variable