Home
last modified time | relevance | path

Searched refs:r (Results 1 – 25 of 82) sorted by relevance

1234

/rocksdb-6.9/table/block_based/
Dblock_based_table_builder.cc506 Rep* r = rep_; in Add() local
523 r->data_begin_offset > r->target_file_size) { in Add()
536 r->index_builder->AddIndexEntry(&r->last_key, &key, r->pending_handle); in Add()
713 r->filter_builder->StartBlock(r->offset); in WriteBlock()
715 r->props.data_size = r->offset; in WriteBlock()
730 r->io_status = r->file->Append(block_contents); in WriteRawBlock()
778 if (r->status.ok() && r->io_status.ok()) { in WriteRawBlock()
785 r->io_status = r->file->Pad(pad_bytes); in WriteRawBlock()
792 r->status = r->io_status; in WriteRawBlock()
1059 r->io_status = r->file->Append(footer_encoding); in WriteFooter()
[all …]
/rocksdb-6.9/table/
Dsst_file_writer.cc181 Rep* r = rep_.get(); in Open() local
234 r->column_family_name = r->cfh->GetName(); in Open()
241 r->ioptions, r->mutable_cf_options, r->internal_comparator, in Open()
247 file_path, r->env_options, r->ioptions.env, in Open()
252 r->builder.reset(r->ioptions.table_factory->NewTableBuilder( in Open()
283 Rep* r = rep_.get(); in Finish() local
284 if (!r->builder) { in Finish()
293 r->file_info.file_size = r->builder->FileSize(); in Finish()
296 s = r->file_writer->Sync(r->ioptions.use_fsync); in Finish()
303 r->ioptions.env->DeleteFile(r->file_info.file_path); in Finish()
[all …]
Dsst_file_reader.cc41 auto r = rep_.get(); in Open() local
46 s = r->options.env->GetFileSize(file_path, &file_size); in Open()
48 s = r->options.env->NewRandomAccessFile(file_path, &file, r->soptions); in Open()
55 TableReaderOptions t_opt(r->ioptions, r->moptions.prefix_extractor.get(), in Open()
56 r->soptions, r->ioptions.internal_comparator); in Open()
66 auto r = rep_.get(); in NewIterator() local
70 auto internal_iter = r->table_reader->NewIterator( in NewIterator()
71 options, r->moptions.prefix_extractor.get(), /*arena=*/nullptr, in NewIterator()
73 return NewDBIterator(r->options.env, options, r->ioptions, r->moptions, in NewIterator()
74 r->ioptions.user_comparator, internal_iter, sequence, in NewIterator()
[all …]
/rocksdb-6.9/db/
Dversion_edit.cc679 std::string r; in DebugString() local
680 r.append("VersionEdit {"); in DebugString()
683 r.append(db_id_); in DebugString()
687 r.append(comparator_); in DebugString()
716 r.append(" "); in DebugString()
723 r.append(" "); in DebugString()
725 r.append(" "); in DebugString()
727 r.append(" "); in DebugString()
729 r.append(" .. "); in DebugString()
769 r.append("\n}\n"); in DebugString()
[all …]
Ddb_test_util.h411 Status s = target()->NewWritableFile(f, r, optimized); in NewWritableFile()
414 r->reset(new SSTableFile(this, std::move(*r))); in NewWritableFile()
416 r->reset(new ManifestFile(this, std::move(*r))); in NewWritableFile()
418 r->reset(new WalFile(this, std::move(*r))); in NewWritableFile()
455 Status s = target()->NewRandomAccessFile(f, r, soptions); in NewRandomAccessFile()
458 r->reset(new CountingFile(std::move(*r), &random_read_counter_, in NewRandomAccessFile()
486 Status s = target()->NewSequentialFile(f, r, soptions); in NewSequentialFile()
488 r->reset(new CountingFile(std::move(*r), &sequential_read_counter_)); in NewSequentialFile()
738 std::string r; in RandomString() local
739 test::RandomString(rnd, len, &r); in RandomString()
[all …]
Ddbformat.cc122 int r = user_comparator_.Compare(a.user_key, b.user_key); in Compare() local
123 if (r == 0) { in Compare()
125 r = -1; in Compare()
127 r = +1; in Compare()
129 r = -1; in Compare()
131 r = +1; in Compare()
134 return r; in Compare()
Ddbformat.h646 int r = user_comparator_.Compare(ExtractUserKey(akey), ExtractUserKey(bkey)); in Compare() local
647 if (r == 0) { in Compare()
651 r = -1; in Compare()
653 r = +1; in Compare()
656 return r; in Compare()
664 int r = user_comparator_.Compare(ExtractUserKey(akey), ExtractUserKey(bkey)); in CompareKeySeq() local
665 if (r == 0) { in CompareKeySeq()
670 r = -1; in CompareKeySeq()
672 r = +1; in CompareKeySeq()
675 return r; in CompareKeySeq()
/rocksdb-6.9/utilities/
Denv_librados.cc43 switch (r) { in err_to_status()
129 if (r >= 0) { in Read()
207 if (r >= 0) { in Read()
284 if (0 == r) { in _SyncLocked()
290 return r; in _SyncLocked()
330 int r = 0; in Append() local
364 int r = 0; in Truncate() local
407 int r = 0; in Flush() local
412 if (0 == r) { in Flush()
429 int r = 0; in Sync() local
[all …]
Denv_mirror.cc196 std::unique_ptr<SequentialFile>* r, in NewSequentialFile() argument
199 return a_->NewSequentialFile(f, r, options); in NewSequentialFile()
206 r->reset(mf); in NewSequentialFile()
216 return a_->NewRandomAccessFile(f, r, options); in NewRandomAccessFile()
223 r->reset(mf); in NewRandomAccessFile()
230 std::unique_ptr<WritableFile>* r, in NewWritableFile() argument
232 if (f.find("/proc/") == 0) return a_->NewWritableFile(f, r, options); in NewWritableFile()
238 r->reset(mf); in NewWritableFile()
246 std::unique_ptr<WritableFile>* r, in ReuseWritableFile() argument
249 return a_->ReuseWritableFile(fname, old_fname, r, options); in ReuseWritableFile()
[all …]
/rocksdb-6.9/file/
Drandom_access_file_reader.cc157 size_t End(const FSReadRequest& r) { in End() argument
158 return static_cast<size_t>(r.offset) + r.len; in End()
217 aligned_reqs.push_back(r); in MultiRead()
224 total_len += r.len; in MultiRead()
230 for (auto& r : aligned_reqs) { in MultiRead() local
231 r.scratch = scratch; in MultiRead()
232 scratch += r.len; in MultiRead()
257 auto& r = read_reqs[i]; in MultiRead() local
262 r.status = fs_r.status; in MultiRead()
263 if (r.status.ok()) { in MultiRead()
[all …]
Drandom_access_file_reader_test.cc69 for (const auto& r : reqs) { in AssertResult() local
70 ASSERT_OK(r.status); in AssertResult()
71 ASSERT_EQ(r.len, r.result.size()); in AssertResult()
72 ASSERT_EQ(content.substr(r.offset, r.len), r.result.ToString()); in AssertResult()
91 std::unique_ptr<RandomAccessFileReader> r; in GetAlignment() local
92 Read(f, FileOptions(), &r); in GetAlignment()
93 size_t alignment = r->file()->GetRequiredBufferAlignment(); in GetAlignment()
114 std::unique_ptr<RandomAccessFileReader> r; in TEST_F() local
115 Read(fname, opts, &r); in TEST_F()
116 ASSERT_TRUE(r->use_direct_io()); in TEST_F()
[all …]
/rocksdb-6.9/util/
Drate_limiter.cc82 r->cv.Signal(); in ~GenericRateLimiter()
85 r->cv.Signal(); in ~GenericRateLimiter()
134 Req r(bytes, &request_mutex_); in Request() local
135 queue_[pri].push_back(&r); in Request()
150 leader_ = &r; in Request()
163 r.cv.Wait(); in Request()
174 assert(r.granted || in Request()
185 if (leader_ == &r) { in Request()
196 if (r.granted) { in Request()
213 assert(!r.granted); in Request()
[all …]
Drandom_test.cc21 Random r(seed); in TEST() local
26 ++counts.at(r.Uniform(range)); in TEST()
38 Random r(42); in TEST() local
43 if (r.OneIn(range)) { in TEST()
58 Random r(42); in TEST() local
63 if (r.OneInOpt(range)) { in TEST()
80 Random r(42); in TEST() local
86 if (r.PercentTrue(pct)) { in TEST()
Dmurmurhash.cc34 const int r = 47; in MurmurHash64A() local
46 k ^= k >> r; in MurmurHash64A()
67 h ^= h >> r; in MurmurHash64A()
69 h ^= h >> r; in MurmurHash64A()
95 const int r = 24; in MurmurHash2() local
110 k ^= k >> r; in MurmurHash2()
150 const int r = 24; in MurmurHashNeutral2() local
166 k ^= k >> r; in MurmurHashNeutral2()
Dfile_reader_writer_test.cc82 Random r(301); in TEST_F() local
86 uint32_t num = r.Skewed(skew_limit) * 100 + r.Uniform(100); in TEST_F()
90 if (r.Uniform(10) == 0) { in TEST_F()
147 Random r(301); in TEST_F() local
168 uint32_t num = r.Skewed(16) * 100 + r.Uniform(100); in TEST_F()
170 test::RandomString(&r, num, &random_string); in TEST_F()
175 if (!no_flush && r.Uniform(10) == 0) { in TEST_F()
Dstring_util.cc103 std::string r; in NumberToString() local
104 AppendNumberTo(&r, num); in NumberToString()
105 return r; in NumberToString()
153 std::string r; in EscapeString() local
154 AppendEscapedStringTo(&r, value); in EscapeString()
155 return r; in EscapeString()
/rocksdb-6.9/monitoring/
Dhistogram.cc157 if (r < cur_min) r = static_cast<double>(cur_min); in Percentile()
158 if (r > cur_max) r = static_cast<double>(cur_max); in Percentile()
159 return r; in Percentile()
184 std::string r; in ToString() local
189 r.append(buf); in ToString()
193 r.append(buf); in ToString()
199 r.append(buf); in ToString()
216 r.append(buf); in ToString()
220 r.append(marks, '#'); in ToString()
221 r.push_back('\n'); in ToString()
[all …]
/rocksdb-6.9/build_tools/
Derror_filter.py34 _GTEST_NAME_PATTERN = re.compile(r'\[ RUN \] (\S+)$')
36 _GTEST_FAIL_PATTERN = re.compile(r'(unknown file|\S+:\d+): Failure$')
72 super(CompilerErrorParser, self).__init__(r'\S+:\d+: error:')
78 r'scan-build: \d+ bugs found.$')
83 super(DbCrashErrorParser, self).__init__(r'\*\*\*.*\^$|TEST FAILED.')
89 r'ERROR: write_stress died with exitcode=\d+')
95 r'==\d+==ERROR: AddressSanitizer:')
101 super(UbsanErrorParser, self).__init__(r'\S+:\d+:\d+: runtime error:')
108 super(ValgrindErrorParser, self).__init__(r'==\d+== ERROR SUMMARY:')
113 super(CompatErrorParser, self).__init__(r'==== .*[Ee]rror.* ====$')
[all …]
/rocksdb-6.9/utilities/cassandra/
Dcassandra_format_test.cc192 EXPECT_EQ(r.Size(), 12); in TEST()
193 EXPECT_EQ(r.IsTombstone(), true); in TEST()
198 dest.reserve(r.Size() * 2); in TEST()
199 r.Serialize(&dest); in TEST()
201 EXPECT_EQ(dest.size(), r.Size()); in TEST()
216 std::memcmp(dest.c_str(), dest.c_str() + r.Size(), r.Size()) == 0); in TEST()
251 EXPECT_EQ(r.IsTombstone(), false); in TEST()
256 dest.reserve(r.Size() * 2); in TEST()
257 r.Serialize(&dest); in TEST()
259 EXPECT_EQ(dest.size(), r.Size()); in TEST()
[all …]
/rocksdb-6.9/env/
Dio_posix.cc235 size_t r = 0; in Read() local
241 if (r < n) { in Read()
265 ssize_t r = -1; in PositionedRead() local
276 ptr += r; in PositionedRead()
277 offset += r; in PositionedRead()
278 left -= r; in PositionedRead()
285 if (r < 0) { in PositionedRead()
587 ptr += r; in Read()
589 left -= r; in Read()
597 if (r < 0) { in Read()
[all …]
Dcomposite_env_wrapper.h294 std::unique_ptr<SequentialFile>* r, in NewSequentialFile() argument
302 r->reset(new CompositeSequentialFileWrapper(file)); in NewSequentialFile()
315 r->reset(new CompositeRandomAccessFileWrapper(file)); in NewRandomAccessFile()
327 r->reset(new CompositeWritableFileWrapper(file)); in NewWritableFile()
346 std::unique_ptr<WritableFile>* r, in ReuseWritableFile() argument
354 r->reset(new CompositeWritableFileWrapper(file)); in ReuseWritableFile()
394 std::vector<std::string>* r) override { in GetChildren() argument
397 return file_system_->GetChildren(dir, io_opts, r, &dbg); in GetChildren()
890 std::unique_ptr<FSWritableFile>* r, in NewWritableFile() argument
954 std::vector<std::string>* r, in GetChildren() argument
[all …]
/rocksdb-6.9/java/src/main/java/org/rocksdb/util/
DBytewiseComparator.java44 int r = memcmp(a, b, minLen); in _compare()
45 if (r == 0) { in _compare()
47 r = -1; in _compare()
49 r = +1; in _compare()
52 return r; in _compare()
/rocksdb-6.9/include/rocksdb/utilities/
Denv_mirror.h47 std::unique_ptr<SequentialFile>* r,
50 std::unique_ptr<RandomAccessFile>* r,
52 Status NewWritableFile(const std::string& f, std::unique_ptr<WritableFile>* r,
56 std::unique_ptr<WritableFile>* r,
78 std::vector<std::string>* r) override { in GetChildren() argument
88 *r = ar; in GetChildren()
/rocksdb-6.9/memory/
Darena_test.cc156 char* r; in SimpleTest() local
158 r = arena.AllocateAligned(s); in SimpleTest()
160 r = arena.Allocate(s); in SimpleTest()
165 r[b] = i % 256; in SimpleTest()
168 allocated.push_back(std::make_pair(s, r)); in SimpleTest()
/rocksdb-6.9/include/rocksdb/
Dslice.h250 int r = memcmp(data_, b.data_, min_len); in compare() local
251 if (r == 0) { in compare()
253 r = -1; in compare()
255 r = +1; in compare()
257 return r; in compare()

1234