MCPcopy Create free account
hub / github.com/apache/arrow / MakeBuffered

Method MakeBuffered

cpp/src/arrow/io/buffered_test.cc:928–951  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

926class 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);

Callers

nothing calls this directly

Calls 11

FromStringFunction · 0.85
EXPECT_OK_AND_ASSIGNFunction · 0.85
default_memory_poolFunction · 0.85
substrMethod · 0.80
MakeFunction · 0.50
clearMethod · 0.45
reserveMethod · 0.45
sizeMethod · 0.45
appendMethod · 0.45
resetMethod · 0.45
getMethod · 0.45

Tested by

no test coverage detected