Searched refs:buf_ (Results 1 – 14 of 14) sorted by relevance
41 if (buf_.Capacity() - buf_.CurrentSize() < left) { in Append()57 if (!use_direct_io() && (buf_.Capacity() - buf_.CurrentSize()) < left) { in Append()58 if (buf_.CurrentSize() > 0) { in Append()64 assert(buf_.CurrentSize() == 0); in Append()100 size_t cap = buf_.Capacity() - buf_.CurrentSize(); in Pad()107 buf_.PadWith(append_bytes, 0); in Pad()115 cap = buf_.Capacity() - buf_.CurrentSize(); in Pad()173 if (buf_.CurrentSize() > 0) { in Flush()181 s = WriteBuffered(buf_.BufferStart(), buf_.CurrentSize()); in Flush()343 buf_.Size(0); in WriteBuffered()[all …]
58 AlignedBuffer buf_; variable88 buf_(), in writable_file_()104 buf_.Alignment(writable_file_->GetRequiredBufferAlignment()); in writable_file_()105 buf_.AllocateNewBuffer(std::min((size_t)65536, max_buffer_size_)); in writable_file_()158 bool TEST_BufferIsEmpty() { return buf_.CurrentSize() == 0; } in TEST_BufferIsEmpty()
337 : buf_(space_), in IterKey()338 key_(buf_), in IterKey()394 buf_ = p; in TrimAppend()399 key_ = buf_; in TrimAppend()434 key_ = buf_; in OwnKey()466 key_ = buf_;497 key_ = buf_; in EncodeLengthPrefixedKey()504 char* buf_;517 key_ = buf_; in SetKeyImpl()528 delete[] buf_; in ResetBuffer()[all …]
203 buf_ = new char[key_size]; in EnlargeBuffer()
147 PinnableSlice() { buf_ = &self_space_; } in PinnableSlice()148 explicit PinnableSlice(std::string* buf) { buf_ = buf; } in PinnableSlice()178 buf_->assign(slice.data(), slice.size()); in PinSelf()179 data_ = buf_->data(); in PinSelf()180 size_ = buf_->size(); in PinSelf()186 data_ = buf_->data(); in PinSelf()187 size_ = buf_->size(); in PinSelf()196 buf_->erase(size() - n, n); in remove_suffix()207 buf_->erase(0, n); in remove_prefix()218 inline std::string* GetSelf() { return buf_; } in GetSelf()[all …]
226 if (other.buf_ == &other.self_space_) { in operator =()228 buf_ = &self_space_; in operator =()229 data_ = buf_->data(); in operator =()231 buf_ = other.buf_; in operator =()236 other.buf_ = &other.self_space_; in operator =()
59 std::unique_ptr<char[]> buf_; variable78 buf_ = std::move(o.buf_);123 return buf_.release(); in Release()175 buf_.reset(new_buf);
177 autovector() : values_(reinterpret_cast<pointer>(buf_)) {}180 : values_(reinterpret_cast<pointer>(buf_)) {341 value_type)) char buf_[kSize *350 values_ = reinterpret_cast<pointer>(buf_);
260 std::unique_ptr<const char[]> buf_; member in ROCKSDB_NAMESPACE::FullBloomTest282 buf_.reset(nullptr); in Reset()302 Slice filter = bits_builder_->Finish(&buf_); in Build()311 Slice FilterData() { return Slice(buf_.get(), filter_size_); } in FilterData()315 int8_t raw_num_probes = static_cast<int8_t>(buf_.get()[filter_size_ - 5]); in GetNumProbesFromFilterData()317 return static_cast<uint8_t>(buf_.get()[filter_size_ - 3]); in GetNumProbesFromFilterData()
142 buf_(new char[buf_size_]) { in KeyMaker()143 memset(buf_.get(), 0, buf_size_); in KeyMaker()148 std::unique_ptr<char[]> buf_; member162 char * data = buf_.get() + start; in Get()
25 buf_.reset(new char[size_]); in CacheWriteBuffer()34 memcpy(buf_.get() + pos_, buf, size); in Append()41 memset(buf_.get() + pos_, '0', size_ - pos_); in FillTrailingZeros()49 char* Data() const { return buf_.get(); } in Data()52 std::unique_ptr<char[]> buf_;
263 : file_(file), buf_(buf), file_off_(file_off), callback_(callback) {} in IO()270 CacheWriteBuffer* buf_ = nullptr; // buffer to write member
577 while (!cache_->Reserve(io.buf_->Used())) { in ThreadMain()592 while (written < io.buf_->Used()) { in DispatchIO()593 Slice data(io.buf_->Data() + written, io_size_); in DispatchIO()
1820 Status s = file_->Read(offset, n, &file_res, buf_); in TEST_P()1848 char buf_[10000]; in TEST_P() member in ROCKSDB_NAMESPACE::RandomRWFileWithMirrorString