| /rocksdb-6.9/tools/ |
| D | ldb_tool.cc | 17 std::string ret; in PrintHelp() local 20 ret.append("\n\n"); in PrintHelp() 23 ret.append("\n"); in PrintHelp() 26 ret.append( in PrintHelp() 35 ret.append("\n"); in PrintHelp() 37 ret.append( in PrintHelp() 40 ret.append( in PrintHelp() 65 ret.append("\n\n"); in PrintHelp() 67 PutCommand::Help(ret); in PrintHelp() 68 GetCommand::Help(ret); in PrintHelp() [all …]
|
| D | ldb_cmd.cc | 531 ret.insert(ret.end(), options.begin(), options.end()); in BuildCmdLineOptions() 532 return ret; in BuildCmdLineOptions() 897 ret.append(" "); in Help() 900 ret.append("\n"); in Help() 952 ret.append(" "); in Help() 958 ret.append("\n"); in Help() 1042 ret.append(" "); in Help() 1047 ret.append("\n"); in Help() 1193 ret.append(" "); in Help() 1196 ret.append("\n"); in Help() [all …]
|
| D | ldb_cmd_impl.h | 25 static void Help(std::string& ret); 44 static void Help(std::string& ret); 57 static void Help(std::string& ret); 103 static void Help(std::string& ret); 136 static void Help(std::string& ret); 159 static void Help(std::string& ret); 182 static void Help(std::string& ret); 201 static void Help(std::string& ret); 215 static void Help(std::string& ret); 232 static void Help(std::string& ret); [all …]
|
| D | trace_analyzer_tool.cc | 522 int ret; in MakeStatistics() local 662 int ret; in MakeStatisticKeyStatsOrPrefix() local 685 if (ret < 0) { in MakeStatisticKeyStatsOrPrefix() 711 ret = in MakeStatisticKeyStatsOrPrefix() 716 if (ret < 0) { in MakeStatisticKeyStatsOrPrefix() 792 int ret; in MakeStatisticQPS() local 944 if (ret < 0) { in MakeStatisticQPS() 1004 int ret; in ReProcessing() local 1028 ret = in ReProcessing() 1925 int ret; in WriteTraceSequence() local [all …]
|
| /rocksdb-6.9/table/block_based/ |
| D | block_based_table_factory.cc | 293 std::string ret; in GetPrintableTableOptions() local 294 ret.reserve(20000); in GetPrintableTableOptions() 301 ret.append(buffer); in GetPrintableTableOptions() 304 ret.append(buffer); in GetPrintableTableOptions() 308 ret.append(buffer); in GetPrintableTableOptions() 312 ret.append(buffer); in GetPrintableTableOptions() 315 ret.append(buffer); in GetPrintableTableOptions() 318 ret.append(buffer); in GetPrintableTableOptions() 321 ret.append(buffer); in GetPrintableTableOptions() 324 ret.append(buffer); in GetPrintableTableOptions() [all …]
|
| /rocksdb-6.9/memory/ |
| D | jemalloc_nodump_allocator.cc | 42 int ret = in GetThreadSpecificCache() local 44 if (ret != 0) { in GetThreadSpecificCache() 81 if (ret != 0) { in Alloc() 85 ret); in Alloc() 96 if (ret != 0) { in DestroyArena() 107 int ret __attribute__((__unused__)) = in DestroyThreadSpecificCache() local 110 assert(ret == 0); in DestroyThreadSpecificCache() 158 int ret = in NewJemallocNodumpAllocator() local 160 if (ret != 0) { in NewJemallocNodumpAllocator() 171 if (ret != 0) { in NewJemallocNodumpAllocator() [all …]
|
| /rocksdb-6.9/examples/ |
| D | multi_processes_example.cc | 75 std::string ret; in Key() local 88 ret.append(buf, sizeof(k)); in Key() 90 size_t i = 0, j = ret.size() - 1; in Key() 92 char tmp = ret[i]; in Key() 93 ret[i] = ret[j]; in Key() 94 ret[j] = tmp; in Key() 98 return ret; in Key() 111 uint64_t ret = 0; in Key() local 125 return ret; in Key() 260 int ret = in RunSecondary() local [all …]
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | persistent_cache_tier.cc | 17 std::string ret; in ToString() local 18 ret.reserve(20000); in ToString() 23 ret.append(buffer); in ToString() 26 ret.append(buffer); in ToString() 29 ret.append(buffer); in ToString() 31 ret.append(buffer); in ToString() 34 ret.append(buffer); in ToString() 37 ret.append(buffer); in ToString() 39 ret.append(buffer); in ToString() 43 ret.append(buffer); in ToString() [all …]
|
| D | hash_table.h | 114 bool Find(const T& t, T* ret, port::RWMutex** ret_lock) { in Find() argument 123 if (Find(&bucket, t, ret)) { in Find() 135 bool Erase(const T& t, T* ret) { in Erase() argument 143 return Erase(&bucket, t, ret); in Erase() 196 bool Find(Bucket* bucket, const T& t, T* ret) { in Find() argument 199 if (ret) { in Find() 200 *ret = *it; in Find() 207 bool Erase(Bucket* bucket, const T& t, T* ret) { in Erase() argument 210 if (ret) { in Erase() 211 *ret = *it; in Erase()
|
| /rocksdb-6.9/utilities/ |
| D | env_librados.cc | 308 if (ret < 0) { in LibradosWritableFile() 634 int ret = 0; in EnvLibrados() local 640 ret = EXIT_FAILURE; in EnvLibrados() 646 if (ret < 0) { in EnvLibrados() 656 if (ret < 0) { in EnvLibrados() 664 if (ret < 0 && ret != -EEXIST && ret != -EPERM) { in EnvLibrados() 671 if (ret < 0) { in EnvLibrados() 679 if (ret < 0 && ret != -EEXIST && ret != -EPERM) { in EnvLibrados() 686 if (ret < 0) { in EnvLibrados() 1299 if (ret < 0) { in GetFileSize() [all …]
|
| D | env_librados_test.cc | 67 int ret = 0; in ~EnvLibradosTest() local 72 ret = EXIT_FAILURE; in ~EnvLibradosTest() 77 if (ret < 0) { in ~EnvLibradosTest() 81 ret = EXIT_FAILURE; in ~EnvLibradosTest() 89 ret = rados.connect(); in ~EnvLibradosTest() 90 if (ret < 0) { in ~EnvLibradosTest() 92 ret = EXIT_FAILURE; in ~EnvLibradosTest() 104 ret = EXIT_FAILURE; in ~EnvLibradosTest() 753 int ret = 0; in ~EnvLibradosMutipoolTest() local 763 if (ret < 0) { in ~EnvLibradosMutipoolTest() [all …]
|
| /rocksdb-6.9/port/win/ |
| D | io_win.cc | 207 assert(ret); in ~WinMmapReadableFile() 210 assert(ret); in ~WinMmapReadableFile() 294 assert(ret); in MapNewRegion() 591 if (ret != FALSE) { in Read() 643 if (ret == FALSE) { in Skip() 757 if (ret != 0) { in WinWritableImpl() 1028 BOOL ret in ~WinMemoryMappedBuffer() local 1036 assert(ret); in ~WinMemoryMappedBuffer() 1041 assert(ret); in ~WinMemoryMappedBuffer() 1046 assert(ret); in ~WinMemoryMappedBuffer() [all …]
|
| D | win_logger.cc | 47 BOOL ret = WriteFile(file_, str, len, &bytesWritten, NULL); in DebugWriter() local 48 if (ret == FALSE) { in DebugWriter() 65 BOOL ret = FlushFileBuffers(file_); in CloseInternal() local 66 if (ret == 0) { in CloseInternal() 71 ret = CloseHandle(file_); in CloseInternal() 73 if (ret == 0 && s.ok()) { in CloseInternal() 162 BOOL ret = WriteFile(file_, base, static_cast<DWORD>(write_size), in Logv() local 164 if (ret == FALSE) { in Logv() 170 assert((bytesWritten == write_size) || (ret == FALSE)); in Logv()
|
| D | env_win.cc | 88 BOOL ret __attribute__((__unused__)); in WinEnvIO() local 90 assert(ret == TRUE); in WinEnvIO() 114 if(!ret) { in DeleteFile() 337 if (!ret) { in OpenWritableFile() 601 if (ret == FALSE) { in GetChildren() 614 if (!ret) { in CreateDir() 631 if (!ret) { in CreateDirIfMissing() 647 if (!ret) { in DeleteDir() 1061 if (ret) { in TimeToString() 1170 if (ret) { in GetSectorSize() [all …]
|
| /rocksdb-6.9/table/plain/ |
| D | plain_table_factory.cc | 53 std::string ret; in GetPrintableTableOptions() local 54 ret.reserve(20000); in GetPrintableTableOptions() 60 ret.append(buffer); in GetPrintableTableOptions() 63 ret.append(buffer); in GetPrintableTableOptions() 66 ret.append(buffer); in GetPrintableTableOptions() 69 ret.append(buffer); in GetPrintableTableOptions() 72 ret.append(buffer); in GetPrintableTableOptions() 75 ret.append(buffer); in GetPrintableTableOptions() 78 ret.append(buffer); in GetPrintableTableOptions() 81 ret.append(buffer); in GetPrintableTableOptions() [all …]
|
| /rocksdb-6.9/table/cuckoo/ |
| D | cuckoo_table_factory.cc | 47 std::string ret; in GetPrintableTableOptions() local 48 ret.reserve(2000); in GetPrintableTableOptions() 54 ret.append(buffer); in GetPrintableTableOptions() 57 ret.append(buffer); in GetPrintableTableOptions() 60 ret.append(buffer); in GetPrintableTableOptions() 63 ret.append(buffer); in GetPrintableTableOptions() 64 return ret; in GetPrintableTableOptions()
|
| /rocksdb-6.9/db/ |
| D | snapshot_impl.h | 93 std::vector<SequenceNumber> ret; variable 94 GetAll(&ret, oldest_write_conflict_snapshot, max_seq); 95 return ret; 101 std::vector<SequenceNumber>& ret = *snap_vector; variable 103 assert(ret.size() == 0); 118 if (ret.empty() || ret.back() != s->next_->number_) { 119 ret.push_back(s->next_->number_);
|
| D | db_filesnapshot.cc | 77 Status DBImpl::GetLiveFiles(std::vector<std::string>& ret, in GetLiveFiles() argument 130 ret.clear(); in GetLiveFiles() 131 ret.reserve(live.size() + 3); // *.sst + CURRENT + MANIFEST + OPTIONS in GetLiveFiles() 136 ret.push_back(MakeTableFileName("", live_file.GetNumber())); in GetLiveFiles() 139 ret.push_back(CurrentFileName("")); in GetLiveFiles() 140 ret.push_back(DescriptorFileName("", versions_->manifest_file_number())); in GetLiveFiles() 141 ret.push_back(OptionsFileName("", versions_->options_file_number())); in GetLiveFiles()
|
| /rocksdb-6.9/utilities/cassandra/ |
| D | cassandra_functional_test.cc | 163 auto ret = store.Get("k1"); in TEST_F() local 165 ASSERT_TRUE(std::get<0>(ret)); in TEST_F() 166 RowValue& merged = std::get<1>(ret); in TEST_F() 196 auto ret = store.Get("k1"); in TEST_F() local 197 ASSERT_TRUE(std::get<0>(ret)); in TEST_F() 198 RowValue& merged = std::get<1>(ret); in TEST_F() 229 auto ret = store.Get("k1"); in TEST_F() local 230 ASSERT_TRUE(std::get<0>(ret)); in TEST_F() 284 auto ret = store.Get("k1"); in TEST_F() local 285 ASSERT_TRUE(std::get<0>(ret)); in TEST_F() [all …]
|
| /rocksdb-6.9/cache/ |
| D | sharded_cache.cc | 128 std::string ret; in GetPrintableOptions() local 129 ret.reserve(20000); in GetPrintableOptions() 136 ret.append(buffer); in GetPrintableOptions() 138 ret.append(buffer); in GetPrintableOptions() 141 ret.append(buffer); in GetPrintableOptions() 145 ret.append(buffer); in GetPrintableOptions() 146 ret.append(GetShard(0)->GetPrintableOptions()); in GetPrintableOptions() 147 return ret; in GetPrintableOptions()
|
| /rocksdb-6.9/env/ |
| D | io_posix.cc | 160 assert(ret == 0); in IsSyncFileRangeSupported() 312 if (ret != 0) { in InvalidateCache() 673 ssize_t ret = in MultiRead() local 687 assert(!ret); in MultiRead() 800 if (ret == 0) { in InvalidateCache() 830 if (ret != 0) { in ~PosixMmapReadableFile() 862 if (ret == 0) { in InvalidateCache() 1082 if (ret == 0) { in InvalidateCache() 1304 if (ret == 0) { in InvalidateCache() 1342 int ret; in RangeSync() local [all …]
|
| /rocksdb-6.9/table/adaptive/ |
| D | adaptive_table_factory.cc | 79 std::string ret; in GetPrintableTableOptions() local 80 ret.reserve(20000); in GetPrintableTableOptions() 89 ret.append(buffer); in GetPrintableTableOptions() 95 ret.append(buffer); in GetPrintableTableOptions() 103 ret.append(buffer); in GetPrintableTableOptions() 109 ret.append(buffer); in GetPrintableTableOptions() 111 return ret; in GetPrintableTableOptions()
|
| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_common.h | 324 std::vector<std::string> ret; in SplitString() local 326 return ret; in SplitString() 331 ret.push_back(src.substr(pos, pos_comma - pos)); in SplitString() 334 ret.push_back(src.substr(pos, src.length())); in SplitString() 335 return ret; in SplitString() 344 std::string ret = src.ToString(); in GetNextPrefix() local 345 for (int i = static_cast<int>(ret.size()) - 1; i >= 0; i--) { in GetNextPrefix() 346 if (ret[i] != static_cast<char>(255)) { in GetNextPrefix() 347 ret[i] = ret[i] + 1; in GetNextPrefix() 350 ret[i] = 0; in GetNextPrefix() [all …]
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | ldb_cmd_execute_result.h | 28 std::string ret; in ToString() local 33 ret.append("Failed: "); in ToString() 36 ret.append("Not started: "); in ToString() 39 ret.append(message_); in ToString() 41 return ret; in ToString()
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_db_impl_filesnapshot.cc | 64 Status BlobDBImpl::GetLiveFiles(std::vector<std::string>& ret, in GetLiveFiles() argument 73 Status s = db_->GetLiveFiles(ret, manifest_file_size, flush_memtable); in GetLiveFiles() 77 ret.reserve(ret.size() + blob_files_.size()); in GetLiveFiles() 81 ret.emplace_back( in GetLiveFiles()
|