Searched refs:read_buffer_ (Results 1 – 3 of 3) sorted by relevance
164 TEMP_FAILURE_RETRY(read(fd_, &read_buffer_[read_buffer_size_], in ReadData()165 read_buffer_.size() - read_buffer_size_)); in ReadData()181 char* p = read_buffer_.data(); in ConsumeDataInReadBuffer()198 memmove(read_buffer_.data(), p, left_size); in ConsumeDataInReadBuffer()200 if (aligned_len > read_buffer_.size()) { in ConsumeDataInReadBuffer()201 read_buffer_.resize(aligned_len); in ConsumeDataInReadBuffer()
140 read_buffer_(READ_BUFFER_SIZE), in UnixSocketConnection()226 std::vector<char> read_buffer_; variable
106 read_buffer_.append(std::move(block)); in Run()108 if (!read_header_ && read_buffer_.size() >= sizeof(amessage)) { in Run()109 auto header_buf = read_buffer_.take_front(sizeof(amessage)).coalesce(); in Run()115 if (read_header_ && read_buffer_.size() >= read_header_->data_length) { in Run()116 auto data_chain = read_buffer_.take_front(read_header_->data_length); in Run()222 IOVector read_buffer_; member