Searched refs:read_buffer_ (Results 1 – 6 of 6) sorted by relevance
470 : delegate_(delegate), read_buffer_(new ReadBuffer) { in Channel()482 DCHECK(read_buffer_); in GetReadBuffer()488 return read_buffer_->Reserve(required_capacity); in GetReadBuffer()493 read_buffer_->Claim(bytes_read); in OnReadComplete()494 while (read_buffer_->num_occupied_bytes() >= sizeof(Message::Header)) { in OnReadComplete()498 if (reinterpret_cast<uintptr_t>(read_buffer_->occupied_bytes()) % in OnReadComplete()500 read_buffer_->Realign(); in OnReadComplete()504 read_buffer_->occupied_bytes()); in OnReadComplete()511 if (read_buffer_->num_occupied_bytes() < header->num_bytes) { in OnReadComplete()515 header->num_bytes - read_buffer_->num_occupied_bytes(); in OnReadComplete()[all …]
40 read_buffer_.resize(message_size * 2); in SetUpMeasurement()53 uint32_t read_buffer_size = static_cast<uint32_t>(read_buffer_.size()); in WriteWaitThenRead()54 CHECK_EQ(MojoReadMessage(mp, &read_buffer_[0], &read_buffer_size, nullptr, in WriteWaitThenRead()132 std::string read_buffer_; member in mojo::edk::__anon580960590111::MessagePipePerfTest
284 const std::unique_ptr<ReadBuffer> read_buffer_; variable
258 read_buffer_(), in PcapReader()450 if (marker.payload_length > sizeof(read_buffer_)) { in ReadPacket()454 TRY_PCAP(Read(read_buffer_, marker.payload_length)); in ReadPacket()456 RtpUtility::RtpHeaderParser rtp_parser(read_buffer_, marker.payload_length); in ReadPacket()637 uint8_t read_buffer_[kMaxReadBufferSize]; member in webrtc::test::PcapReader
14 dEQP-GLES3.functional.state_query.integers.read_buffer_*