Home
last modified time | relevance | path

Searched refs:res (Results 1 – 25 of 51) sorted by relevance

123

/rocksdb-6.9/table/
Dcleanable_test.cc34 res = 1; in TEST_F()
42 res = 1; in TEST_F()
52 res = 1; in TEST_F()
64 res = 1; in TEST_F()
94 res = 1; in TEST_F()
107 res = 1; in TEST_F()
122 res = 1; in TEST_F()
138 res = 1; in TEST_F()
155 res = 1; in TEST_F()
171 res = 1; in TEST_F()
[all …]
Dscoped_arena_iterator.h49 auto* res = iter_; in release() local
51 return res; in release()
/rocksdb-6.9/util/
Dslice_test.cc18 *res *= *num; in Multiplier()
50 int res = 1; in TEST_F() local
58 res = 1; in TEST_F()
66 ASSERT_EQ(1, res); in TEST_F()
71 ASSERT_EQ(2, res); in TEST_F()
85 res = 1; in TEST_F()
103 ASSERT_EQ(4, res); in TEST_F()
108 res = 1; in TEST_F()
123 ASSERT_EQ(2, res); in TEST_F()
140 res = 1; in TEST_F()
[all …]
Dthread_local.cc80 void Fold(uint32_t id, FoldFunc func, void* res);
453 void ThreadLocalPtr::StaticMeta::Fold(uint32_t id, FoldFunc func, void* res) { in Fold() argument
459 func(ptr, res); in Fold()
550 void ThreadLocalPtr::Fold(FoldFunc func, void* res) { in Fold() argument
551 Instance()->Fold(id_, func, res); in Fold()
Dcompression.h189 size_t res = 0; in CompressionDict() local
191 res = ZSTD_freeCDict(zstd_cdict_); in CompressionDict()
193 assert(res == 0); // Last I checked they can't fail in CompressionDict()
194 (void)res; // prevent unused var warning in CompressionDict()
285 size_t res = 0; in ~UncompressionDict() local
287 res = ZSTD_freeDDict(zstd_ddict_); in ~UncompressionDict()
289 assert(res == 0); // Last I checked they can't fail in ~UncompressionDict()
290 (void)res; // prevent unused var warning in ~UncompressionDict()
Dthread_local.h77 void Fold(FoldFunc func, void* res);
/rocksdb-6.9/utilities/merge_operators/string_append/
Dstringappend_test.cc144 std::string res; in TEST_F() local
210 ASSERT_EQ(res, "g1"); in TEST_F()
220 ASSERT_EQ(res, "g1"); in TEST_F()
234 std::string res; in TEST_F() local
249 std::string res; in TEST_F() local
250 slists.Get("k1", &res); in TEST_F()
260 std::string res; in TEST_F() local
333 std::string res; in TEST_F() local
384 std::string res; in TEST_F() local
564 std::string res; in TEST_F() local
[all …]
/rocksdb-6.9/db/
Ddb_memtable_test.cc149 bool res; in TEST_F() local
151 ASSERT_TRUE(res); in TEST_F()
153 ASSERT_FALSE(res); in TEST_F()
156 ASSERT_FALSE(res); in TEST_F()
159 ASSERT_TRUE(res); in TEST_F()
162 ASSERT_FALSE(res); in TEST_F()
164 ASSERT_FALSE(res); in TEST_F()
189 ASSERT_TRUE(res); in TEST_F()
201 ASSERT_TRUE(res); in TEST_F()
231 ASSERT_TRUE(res); in TEST_F()
[all …]
Ddb_log_iter_test.cc40 BatchResult res; in ReadRecords() local
42 res = iter->GetBatch(); in ReadRecords()
43 EXPECT_TRUE(res.sequence > lastSequence); in ReadRecords()
45 lastSequence = res.sequence; in ReadRecords()
49 return res.sequence; in ReadRecords()
249 auto res = OpenTransactionLogIter(0)->GetBatch(); in TEST_F() local
270 res.writeBatchPtr->Iterate(&handler); in TEST_F()
Ddb_write_test.cc164 auto res = Put("key" + ToString(index), "value"); in TEST_P() local
166 ASSERT_TRUE(res.ok()); in TEST_P()
175 ASSERT_FALSE(res.ok()); in TEST_P()
214 auto res = Put("key" + ToString(i), "value"); in TEST_P() local
228 ASSERT_FALSE(res.ok()); in TEST_P()
Dwal_manager_test.cc201 BatchResult res; in CountRecords() local
203 res = iter->GetBatch(); in CountRecords()
204 EXPECT_TRUE(res.sequence > lastSequence); in CountRecords()
206 lastSequence = res.sequence; in CountRecords()
Dmemtable.cc508 bool res = table->InsertKeyWithHint(handle, &insert_hints_[prefix]); in Add() local
509 if (UNLIKELY(!res)) { in Add()
510 return res; in Add()
513 bool res = table->InsertKey(handle); in Add() local
514 if (UNLIKELY(!res)) { in Add()
515 return res; in Add()
552 bool res = (hint == nullptr) in Add() local
555 if (UNLIKELY(!res)) { in Add()
556 return res; in Add()
/rocksdb-6.9/monitoring/
Dstatistics.cc248 uint64_t res = 0; in getTickerCountLocked() local
250 res += per_core_stats_.AccessAtCore(core_idx)->tickers_[tickerType]; in getTickerCountLocked()
252 return res; in getTickerCountLocked()
357 std::string res; in ToString() local
358 res.reserve(20000); in ToString()
364 res.append(buffer); in ToString()
383 res.append(buffer); in ToString()
385 res.shrink_to_fit(); in ToString()
386 return res; in ToString()
/rocksdb-6.9/env/
Denv_chroot.cc289 std::pair<Status, std::string> res; in EncodePath() local
290 res.second = chroot_dir_ + path; in EncodePath()
293 char* normalized_path = realpath(res.second.c_str(), resolvedName); in EncodePath()
295 char* normalized_path = realpath(res.second.c_str(), nullptr); in EncodePath()
298 res.first = Status::NotFound(res.second, strerror(errno)); in EncodePath()
302 res.first = Status::IOError(res.second, in EncodePath()
305 res.first = Status::OK(); in EncodePath()
310 return res; in EncodePath()
Denv_basic_test.cc115 std::vector<Env*> res; in GetCustomEnvs() local
117 res.emplace_back(custom_env); in GetCustomEnvs()
119 return res; in GetCustomEnvs()
/rocksdb-6.9/utilities/
Dobject_registry_test.cc42 auto res = registry->NewObject<Env>("a://test", &env_guard, &msg); in TEST_F() local
43 ASSERT_NE(res, nullptr); in TEST_F()
48 res = registry->NewObject<Env>("b://test", &env_guard, &msg); in TEST_F()
49 ASSERT_NE(res, nullptr); in TEST_F()
54 res = registry->NewObject<Env>("c://test", &env_guard, &msg); in TEST_F()
55 ASSERT_EQ(res, nullptr); in TEST_F()
/rocksdb-6.9/buckifier/
Dtargets_builder.py22 res = separator.join(sorted(lst))
23 res = "\n" + (" " * indent) + "\"" + res + "\",\n" + (" " * (indent - 4))
24 return res
/rocksdb-6.9/third-party/folly/folly/detail/
DFutex.cpp183 ParkResult res; in emulatedFutexWaitImpl() local
185 res = parkingLot.park_until( in emulatedFutexWaitImpl()
192 res = parkingLot.park_until( in emulatedFutexWaitImpl()
199 res = parkingLot.park( in emulatedFutexWaitImpl()
202 switch (res) { in emulatedFutexWaitImpl()
/rocksdb-6.9/utilities/simulator_cache/
Dsim_cache.cc282 std::string res; in ToString() local
283 res.append("SimCache MISSes: " + std::to_string(get_miss_counter()) + "\n"); in ToString()
284 res.append("SimCache HITs: " + std::to_string(get_hit_counter()) + "\n"); in ToString()
289 res.append(buff); in ToString()
290 return res; in ToString()
/rocksdb-6.9/tools/
Ddb_repl_stress.cc82 BatchResult res = iter->GetBatch(); in ReplicationThreadBody() local
83 if (res.sequence != currentSeqNum) { in ReplicationThreadBody()
85 (long)currentSeqNum, (long)res.sequence); in ReplicationThreadBody()
/rocksdb-6.9/port/win/
Denv_win.cc774 const std::string& second, bool* res) { in AreFilesSame() argument
779 assert(res != nullptr); in AreFilesSame()
781 if (res == nullptr) { in AreFilesSame()
837 *res = (0 == memcmp(FileInfo_1.FileId.Identifier, in AreFilesSame()
841 *res = false; in AreFilesSame()
1046 std::string res = FN_TO_RX(result); in GetAbsolutePath() local
1048 res.swap(*output_path); in GetAbsolutePath()
1414 const std::string& second, bool* res) { in AreFilesSame() argument
1415 return winenv_io_.AreFilesSame(first, second, res); in AreFilesSame()
/rocksdb-6.9/file/
Dsst_file_manager_impl.cc506 SstFileManagerImpl* res = in NewSstFileManager() local
523 res->OnAddFile(path_in_trash); in NewSstFileManager()
525 res->ScheduleFileDeletion(path_in_trash, trash_dir); in NewSstFileManager()
537 return res; in NewSstFileManager()
/rocksdb-6.9/options/
Doptions_test.cc1062 std::string res; in TEST_F() local
1064 ASSERT_OK(GetStringFromCompressionType(&res, kNoCompression)); in TEST_F()
1065 ASSERT_EQ(res, "kNoCompression"); in TEST_F()
1067 ASSERT_OK(GetStringFromCompressionType(&res, kSnappyCompression)); in TEST_F()
1068 ASSERT_EQ(res, "kSnappyCompression"); in TEST_F()
1070 ASSERT_OK(GetStringFromCompressionType(&res, kDisableCompressionOption)); in TEST_F()
1071 ASSERT_EQ(res, "kDisableCompressionOption"); in TEST_F()
1073 ASSERT_OK(GetStringFromCompressionType(&res, kLZ4Compression)); in TEST_F()
1074 ASSERT_EQ(res, "kLZ4Compression"); in TEST_F()
1076 ASSERT_OK(GetStringFromCompressionType(&res, kZlibCompression)); in TEST_F()
[all …]
/rocksdb-6.9/db/db_impl/
Ddb_impl_debug.cc37 auto res = cur_log_writer->TEST_BufferIsEmpty(); in TEST_WALBufferIsEmpty() local
41 return res; in TEST_WALBufferIsEmpty()
/rocksdb-6.9/db/compaction/
Dcompaction_iterator.cc721 auto res = snapshot_checker_->CheckInSnapshot(in, cur); in findEarliestVisibleSnapshot() local
722 if (res == SnapshotCheckerResult::kInSnapshot) { in findEarliestVisibleSnapshot()
724 } else if (res == SnapshotCheckerResult::kSnapshotReleased) { in findEarliestVisibleSnapshot()

123