Home
last modified time | relevance | path

Searched refs:result (Results 1 – 25 of 220) sorted by relevance

123456789

/rocksdb-6.9/db/
Dcolumn_family.cc203 result.arena_block_size = result.write_buffer_size / 8; in SanitizeOptions()
241 result.max_write_buffer_number_to_maintain = result.max_write_buffer_number; in SanitizeOptions()
345 result.max_compaction_bytes = result.target_file_size_base * 25; in SanitizeOptions()
357 result.ttl = 0; in SanitizeOptions()
380 result.ttl = result.periodic_compaction_seconds; in SanitizeOptions()
383 result.ttl = std::min(result.ttl, result.periodic_compaction_seconds); in SanitizeOptions()
393 std::min(result.ttl, result.periodic_compaction_seconds); in SanitizeOptions()
395 result.periodic_compaction_seconds = result.ttl; in SanitizeOptions()
403 return result; in SanitizeOptions()
1059 return result; in PickCompaction()
[all …]
Dc.cc476 return result; in CopyString()
489 return result; in rocksdb_open()
504 return result; in rocksdb_open_with_ttl()
518 return result; in rocksdb_open_for_read_only()
533 return result; in rocksdb_open_as_secondary()
549 return result; in rocksdb_backup_engine_open()
602 return result; in rocksdb_backup_engine_get_backup_info()
647 return result; in rocksdb_checkpoint_object_create()
698 return result; in rocksdb_open_column_families()
728 return result; in rocksdb_open_for_read_only_column_families()
[all …]
Ddbformat.cc83 result->append(ts.data(), ts.size()); in AppendInternalKeyWithDifferentTimestamp()
89 PutFixed64(result, PackSequenceAndType(s, t)); in AppendInternalKeyFooter()
96 std::string result = "'"; in DebugString() local
97 result += user_key.ToString(hex); in DebugString()
98 result += buf; in DebugString()
99 return result; in DebugString()
103 std::string result; in DebugString() local
106 result = parsed.DebugString(hex); in DebugString()
108 result = "(bad)"; in DebugString()
109 result.append(EscapeString(rep_)); in DebugString()
[all …]
Ddb_test_util.cc761 return result; in Get()
776 return result; in Get()
820 return result; in MultiGet()
848 return result; in MultiGet()
903 return result; in Contents()
966 return result; in AllEntriesFor()
1062 int result = 0; in TotalTableFiles() local
1066 return result; in TotalTableFiles()
1085 return result; in FilesPerLevel()
1240 return result; in IterStatus()
[all …]
/rocksdb-6.9/port/win/
Denv_win.cc110 Status result; in DeleteFile() local
120 return result; in DeleteFile()
147 result->reset(); in NewSequentialFile()
182 result->reset(); in NewRandomAccessFile()
612 Status result; in CreateDir() local
620 return result; in CreateDir()
624 Status result; in CreateDirIfMissing() local
637 result = in CreateDirIfMissing()
641 return result; in CreateDirIfMissing()
645 Status result; in DeleteDir() local
[all …]
Denv_win.h116 std::unique_ptr<MemoryMappedFileBuffer>* result);
119 std::unique_ptr<Directory>* result);
124 std::vector<std::string>* result);
153 virtual Status GetTestDirectory(std::string* result);
156 std::shared_ptr<Logger>* result);
227 std::unique_ptr<WritableFile>* result,
243 std::unique_ptr<RandomRWFile>* result,
248 std::unique_ptr<MemoryMappedFileBuffer>* result) override;
256 std::vector<std::string>* result) override;
285 Status GetTestDirectory(std::string* result) override;
[all …]
/rocksdb-6.9/env/
Dfs_posix.cc147 result->reset(); in NewSequentialFile()
201 result->reset(); in NewRandomAccessFile()
630 return result; in DeleteFile()
639 return result; in CreateDir()
652 result = in CreateDirIfMissing()
656 return result; in CreateDirIfMissing()
665 return result; in DeleteDir()
700 return result; in RenameFile()
713 return result; in LinkFile()
807 return result; in LockFile()
[all …]
Denv_basic_test.cc29 result->erase(std::remove_if(result->begin(), result->end(), in GetChildren()
33 result->end()); in GetChildren()
43 result->erase(std::remove_if(result->begin(), result->end(), in GetChildrenFileAttributes()
47 result->end()); in GetChildrenFileAttributes()
212 Slice result; in TEST_P() local
229 ASSERT_EQ(0U, result.size()); in TEST_P()
232 ASSERT_EQ(0U, result.size()); in TEST_P()
241 ASSERT_EQ(0, result.compare("d")); in TEST_P()
275 Slice result; in TEST_P() local
284 read_data.append(result.data(), result.size()); in TEST_P()
[all …]
Denv_encryption.cc52 status = stream_->Decrypt(offset_, (char*)result->data(), result->size()); in Read()
101 status = stream_->Decrypt(offset, (char*)result->data(), result->size()); in PositionedRead()
135 status = stream_->Decrypt(offset, (char*)result->data(), result->size()); in Read()
361 status = stream_->Decrypt(offset, (char*)result->data(), result->size()); in Read()
386 result->reset(); in NewSequentialFile()
424 result->reset(); in NewRandomAccessFile()
462 result->reset(); in NewWritableFile()
509 result->reset(); in ReopenWritableFile()
551 result->reset(); in ReuseWritableFile()
596 result->reset(); in NewRandomRWFile()
[all …]
Dmock_env.cc111 *result = Slice(); in Read()
116 *result = Slice(scratch, n); in Read()
191 pos_ += result->size(); in Read()
432 *result = nullptr; in NewSequentialFile()
449 *result = nullptr; in NewRandomAccessFile()
466 *result = nullptr; in NewRandomRWFile()
485 result->reset(); in ReuseWritableFile()
507 result->reset(new MockEnvDirectory()); in NewDirectory()
535 result->clear(); in GetChildren()
546 result->push_back( in GetChildren()
[all …]
Dmock_env_test.cc39 Slice result; in TEST_F() local
42 ASSERT_OK(rand_file->Read(0, kGood.size(), &result, &(scratch[0]))); in TEST_F()
43 ASSERT_EQ(result.compare(kGood), 0); in TEST_F()
48 result.clear(); in TEST_F()
50 ASSERT_EQ(result.compare(kGood), 0); in TEST_F()
55 result.clear(); in TEST_F()
57 &result, &(scratch[0]))); in TEST_F()
58 ASSERT_EQ(result.compare(kCorrupted), 0); in TEST_F()
61 result.clear(); in TEST_F()
63 &result, &(scratch[0]))); in TEST_F()
[all …]
Denv_hdfs.cc115 *result = Slice(scratch, total_bytes_read); in Read()
394 result->reset(); in NewSequentialFile()
398 *result = nullptr; in NewSequentialFile()
409 result->reset(); in NewRandomAccessFile()
413 *result = nullptr; in NewRandomAccessFile()
424 result->reset(); in NewWritableFile()
429 *result = nullptr; in NewWritableFile()
432 result->reset(dynamic_cast<WritableFile*>(f)); in NewWritableFile()
454 result->reset(new HdfsDirectory(0)); in NewDirectory()
601 *result = nullptr; in NewLogger()
[all …]
/rocksdb-6.9/table/
Dtable_properties.cc75 std::string result; in ToString() local
76 result.reserve(1024); in ToString()
89 AppendProperty(result, "raw average key size", in ToString()
118 result, "filter policy name", in ToString()
127 AppendProperty(result, "column family ID", in ToString()
135 result, "column family name", in ToString()
139 AppendProperty(result, "comparator name", in ToString()
144 result, "merge operator name", in ToString()
154 result, "SST file compression algo", in ToString()
159 result, "SST file compression options", in ToString()
[all …]
/rocksdb-6.9/utilities/transactions/
Dtransaction_util.cc25 Status result; in CheckKeyForConflicts() local
36 if (result.ok()) { in CheckKeyForConflicts()
46 return result; in CheckKeyForConflicts()
61 Status result; in CheckKey() local
105 if (result.ok()) { in CheckKey()
124 result = s; in CheckKey()
135 return result; in CheckKey()
141 Status result; in CheckKeysForConflicts() local
165 if (!result.ok()) { in CheckKeysForConflicts()
172 if (!result.ok()) { in CheckKeysForConflicts()
[all …]
/rocksdb-6.9/utilities/
Denv_mirror_test.cc117 Slice result; in TEST_F() local
130 ASSERT_EQ(0, result.compare("hello")); in TEST_F()
133 ASSERT_EQ(0, result.compare("world")); in TEST_F()
135 ASSERT_EQ(0U, result.size()); in TEST_F()
138 ASSERT_EQ(0U, result.size()); in TEST_F()
143 ASSERT_EQ(0, result.compare("world")); in TEST_F()
147 ASSERT_EQ(0, result.compare("d")); in TEST_F()
192 Slice result; in TEST_F() local
195 ASSERT_EQ(0, result.compare("foo")); in TEST_F()
201 read_data.append(result.data(), result.size()); in TEST_F()
[all …]
Denv_timed.cc21 std::unique_ptr<SequentialFile>* result, in NewSequentialFile() argument
24 return EnvWrapper::NewSequentialFile(fname, result, options); in NewSequentialFile()
35 std::unique_ptr<WritableFile>* result, in NewWritableFile() argument
38 return EnvWrapper::NewWritableFile(fname, result, options); in NewWritableFile()
50 std::unique_ptr<RandomRWFile>* result, in NewRandomRWFile() argument
53 return EnvWrapper::NewRandomRWFile(fname, result, options); in NewRandomRWFile()
59 return EnvWrapper::NewDirectory(name, result); in NewDirectory()
70 return EnvWrapper::GetChildren(dir, result); in GetChildren()
76 return EnvWrapper::GetChildrenFileAttributes(dir, result); in GetChildrenFileAttributes()
131 std::shared_ptr<Logger>* result) override { in NewLogger() argument
[all …]
Dutil_merge_operators_test.cc19 std::string result; in FullMergeV2() local
31 result.assign(result_operand.data(), result_operand.size()); in FullMergeV2()
33 return result; in FullMergeV2()
38 std::string result; in FullMergeV2() local
49 result.assign(result_operand.data(), result_operand.size()); in FullMergeV2()
51 return result; in FullMergeV2()
56 std::string result; in PartialMerge() local
58 merge_operator_->PartialMerge(key, left, right, &result, nullptr); in PartialMerge()
59 return result; in PartialMerge()
64 std::string result; in PartialMergeMulti() local
[all …]
/rocksdb-6.9/util/
Dstatus.cc23 char* result = new char[cch]; in CopyState() local
31 result[cch - 1] = '\0'; in CopyState()
33 return result; in CopyState()
66 memcpy(result, msg.data(), len1); in Status()
68 result[len1] = ':'; in Status()
69 result[len1 + 1] = ' '; in Status()
73 state_ = result; in Status()
130 std::string result(type); in ToString() local
134 result.append(msgs[index]); in ToString()
138 result.append(state_); in ToString()
[all …]
Dslice.cc158 std::string result; // RVO/NRVO/move in ToString() local
160 result.reserve(2 * size_); in ToString()
163 result.push_back(toHex(c >> 4)); in ToString()
164 result.push_back(toHex(c & 0xf)); in ToString()
166 return result; in ToString()
168 result.assign(data_, size_); in ToString()
169 return result; in ToString()
174 bool Slice::DecodeHex(std::string* result) const { in DecodeHex()
180 if (!result) { in DecodeHex()
183 result->clear(); in DecodeHex()
[all …]
/rocksdb-6.9/file/
Dsequence_file_reader.cc46 *result = Slice(scratch, r); in Read()
51 IOSTATS_ADD(bytes_read, result->size()); in Read()
100 *result = Slice(scratch, cached_len); in Read()
110 read_offset_ += result->size(); in Read()
111 *result = Slice(scratch, cached_len + result->size()); in Read()
155 Slice* result, char* scratch, in PositionedRead() argument
196 Slice result; in ReadIntoBuffer() local
200 buffer_.Size(result.size()); in ReadIntoBuffer()
201 assert(result.size() == 0 || buffer_.BufferStart() == result.data()); in ReadIntoBuffer()
233 std::unique_ptr<FSSequentialFile> result( in NewReadaheadSequentialFile() local
[all …]
/rocksdb-6.9/db/db_impl/
Ddb_impl_open.cc36 DBOptions result(src); in SanitizeOptions() local
54 Status s = CreateLoggerFromOptions(dbname, result, &result.info_log); in SanitizeOptions()
66 result.max_background_flushes, result.max_background_compactions, in SanitizeOptions()
81 result.delayed_write_rate = result.rate_limiter->GetBytesPerSecond(); in SanitizeOptions()
88 if (result.WAL_ttl_seconds > 0 || result.WAL_size_limit_MB > 0) { in SanitizeOptions()
107 result.wal_dir = result.wal_dir.substr(0, result.wal_dir.size() - 1); in SanitizeOptions()
114 if (result.use_direct_reads && result.compaction_readahead_size == 0) { in SanitizeOptions()
119 if (result.compaction_readahead_size > 0 || result.use_direct_reads) { in SanitizeOptions()
140 result.env->GetChildren(result.wal_dir, &filenames); in SanitizeOptions()
163 NewSstFileManager(result.env, result.info_log)); in SanitizeOptions()
[all …]
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index_internal.cc161 WriteBatchWithIndexInternal::Result result = in GetFromBatch() local
201 result = WriteBatchWithIndexInternal::Result::kFound; in GetFromBatch()
212 result = WriteBatchWithIndexInternal::Result::kDeleted; in GetFromBatch()
221 result = WriteBatchWithIndexInternal::Result::kError; in GetFromBatch()
227 if (result == WriteBatchWithIndexInternal::Result::kFound || in GetFromBatch()
229 result == WriteBatchWithIndexInternal::Result::kError) { in GetFromBatch()
256 result = WriteBatchWithIndexInternal::Result::kError; in GetFromBatch()
257 return result; in GetFromBatch()
271 result = WriteBatchWithIndexInternal::Result::kFound; in GetFromBatch()
273 result = WriteBatchWithIndexInternal::Result::kError; in GetFromBatch()
[all …]
/rocksdb-6.9/monitoring/
Dpersistent_stats_history.cc46 std::string result; in DecodePersistentStatsVersionNumber() local
48 if (!s.ok() || result.empty()) { in DecodePersistentStatsVersionNumber()
54 *version_number = ParseUint64(result); in DecodePersistentStatsVersionNumber()
97 std::pair<uint64_t, std::string> result; in parseKey() local
102 result.first = port::kMaxUint64; in parseKey()
103 result.second.clear(); in parseKey()
108 result.first = port::kMaxUint64; in parseKey()
109 result.second = ""; in parseKey()
111 result.first = parsed_time; in parseKey()
113 result.second = key_resize; in parseKey()
[all …]
/rocksdb-6.9/include/rocksdb/
Dfile_system.h168 std::shared_ptr<FileSystem>* result);
226 std::unique_ptr<FSRandomAccessFile>* result,
339 assert(result != nullptr); in GetChildrenFileAttributes()
345 result->resize(child_fnames.size()); in GetChildrenFileAttributes()
361 result->resize(result_size); in GetChildrenFileAttributes()
600 Slice result; member
624 Slice* result, char* scratch,
919 Slice* result, char* scratch,
1156 std::shared_ptr<Logger>* result, in NewLogger() argument
1234 Slice* result, char* scratch, in Read() argument
[all …]
/rocksdb-6.9/test_util/
Dfault_injection_test_env.cc42 ROCKSDB_NAMESPACE::Slice result; in Truncate() local
43 s = orig_file->Read(length, &result, scratch.get()); in Truncate()
52 s = tmp_file->Append(result); in Truncate()
189 return target_->Read(offset, n, result, scratch); in Read()
237 s = target()->NewWritableFile(fname, result, soptions); in NewWritableFile()
239 result->reset(new TestWritableFile(fname, std::move(*result), this)); in NewWritableFile()
258 Status s = target()->ReopenWritableFile(fname, result, soptions); in ReopenWritableFile()
260 result->reset(new TestWritableFile(fname, std::move(*result), this)); in ReopenWritableFile()
279 Status s = target()->NewRandomRWFile(fname, result, soptions); in NewRandomRWFile()
281 result->reset(new TestRandomRWFile(fname, std::move(*result), this)); in NewRandomRWFile()
[all …]

123456789