| 926 | class TestBufferedInputStreamRandom : public ::testing::Test { |
| 927 | public: |
| 928 | void MakeBuffered(int64_t data_size, int64_t buffer_size, |
| 929 | std::optional<int64_t> read_bound = std::nullopt) { |
| 930 | buffer_size_ = buffer_size; |
| 931 | data_.clear(); |
| 932 | data_.reserve(data_size); |
| 933 | while (data_.size() < static_cast<size_t>(data_size)) { |
| 934 | data_.append(kExample1, /*pos*/ 0, |
| 935 | /*count*/ static_cast<size_t>(data_size) - data_.size()); |
| 936 | } |
| 937 | EXPECT_EQ(data_.size(), data_size); |
| 938 | |
| 939 | // Clear dependent streams in reverse order |
| 940 | buffered_.reset(); |
| 941 | tracked_.reset(); |
| 942 | // Read from a copy of data, so that data_.substr() below doesn't invalidate it |
| 943 | raw_ = BufferReader::FromString(data_); |
| 944 | tracked_ = TrackedRandomAccessFile::Make(raw_.get()); |
| 945 | EXPECT_OK_AND_ASSIGN(buffered_, |
| 946 | BufferedInputStream::Create(buffer_size, default_memory_pool(), |
| 947 | tracked_, read_bound.value_or(-1))); |
| 948 | if (read_bound) { |
| 949 | data_ = data_.substr(0, *read_bound); |
| 950 | } |
| 951 | } |
| 952 | |
| 953 | void TestReads() { |
| 954 | std::default_random_engine gen(/*seed*/ 42); |
nothing calls this directly
no test coverage detected