| /rocksdb-6.9/utilities/cassandra/ |
| D | cassandra_format_test.cc | 56 std::memcmp(dest.c_str(), dest.c_str() + c.Size(), c.Size()) == 0); in TEST() 65 std::memcmp(dest.c_str() + c.Size(), dest.c_str() + c.Size() * 2, c.Size()) in TEST() 112 std::memcmp(dest.c_str(), dest.c_str() + c.Size(), c.Size()) == 0); in TEST() 121 std::memcmp(dest.c_str() + c.Size(), dest.c_str() + c.Size() * 2, c.Size()) in TEST() 175 std::memcmp(dest.c_str(), dest.c_str() + c.Size(), c.Size()) == 0); in TEST() 179 ColumnBase::Deserialize(dest.c_str(), c.Size()); in TEST() 183 std::memcmp(dest.c_str() + c.Size(), dest.c_str() + c.Size() * 2, c.Size()) in TEST() 216 std::memcmp(dest.c_str(), dest.c_str() + r.Size(), r.Size()) == 0); in TEST() 269 EXPECT_EQ(Deserialize<int8_t>(dest.c_str(), offset), in TEST() 296 EXPECT_EQ(Deserialize<int8_t>(dest.c_str(), offset), in TEST() [all …]
|
| D | cassandra_serialize_test.cc | 56 EXPECT_EQ(0, Deserialize<int64_t>(dest.c_str(), offset)); in TEST() 60 EXPECT_EQ(1, Deserialize<int64_t>(dest.c_str(), offset)); in TEST() 64 EXPECT_EQ(-1, Deserialize<int64_t>(dest.c_str(), offset)); in TEST() 117 EXPECT_EQ(0, Deserialize<int32_t>(dest.c_str(), offset)); in TEST() 121 EXPECT_EQ(1, Deserialize<int32_t>(dest.c_str(), offset)); in TEST() 125 EXPECT_EQ(-1, Deserialize<int32_t>(dest.c_str(), offset)); in TEST() 163 EXPECT_EQ(0, Deserialize<int8_t>(dest.c_str(), offset)); in TEST() 167 EXPECT_EQ(1, Deserialize<int8_t>(dest.c_str(), offset)); in TEST() 171 EXPECT_EQ(-1, Deserialize<int8_t>(dest.c_str(), offset)); in TEST() 175 EXPECT_EQ(127, Deserialize<int8_t>(dest.c_str(), offset)); in TEST() [all …]
|
| /rocksdb-6.9/env/ |
| D | env_hdfs.cc | 64 filename_.c_str()); in HdfsReadableFile() 73 filename_.c_str()); in ~HdfsReadableFile() 76 filename_.c_str()); in ~HdfsReadableFile() 110 filename_.c_str()); in Read() 126 filename_.c_str()); in Read() 130 filename_.c_str()); in Read() 141 filename_.c_str()); in Skip() 161 filename_.c_str()); in feof() 171 filename_.c_str()); in fileSize() 199 filename_.c_str()); in HdfsWritableFile() [all …]
|
| D | fs_posix.cc | 411 if (rename(old_fname.c_str(), fname.c_str()) != 0) { in ReuseWritableFile() 538 fd = open(name.c_str(), flags); in NewDirectory() 554 f = fopen(fname.c_str(), in NewLogger() 605 DIR* d = opendir(dir.c_str()); in GetChildren() 627 if (unlink(fname.c_str()) != 0) { in DeleteFile() 662 if (rmdir(name.c_str()) != 0) { in DeleteDir() 686 if (stat(fname.c_str(), &s) != 0) { in GetFileModificationTime() 697 if (rename(src.c_str(), target.c_str()) != 0) { in RenameFile() 707 if (link(src.c_str(), target.c_str()) != 0) { in LinkFile() 719 if (stat(fname.c_str(), &s) != 0) { in NumFileLinks() [all …]
|
| /rocksdb-6.9/db_stress_tool/ |
| D | cf_consistency_stress.cc | 153 column_family_names_[0].c_str()); in TestGet() 155 column_family_names_[i].c_str(), in TestGet() 156 Slice(value1).ToString(true).c_str()); in TestGet() 162 column_family_names_[0].c_str(), in TestGet() 165 column_family_names_[i].c_str()); in TestGet() 171 column_family_names_[0].c_str(), in TestGet() 174 column_family_names_[i].c_str(), in TestGet() 343 s.ToString().c_str()); in TestCheckpoint() 399 s.ToString().c_str()); in VerifyDb() 414 statuses[i].ToString().c_str()); in VerifyDb() [all …]
|
| D | batched_ops_stress.cc | 51 fprintf(stderr, "multiput error: %s\n", s.ToString().c_str()); in TestPut() 80 fprintf(stderr, "multidelete error: %s\n", s.ToString().c_str()); in TestDelete() 135 fprintf(stderr, "get error: %s\n", s.ToString().c_str()); in TestGet() 162 key.ToString(true).c_str(), StringToHex(values[0]).c_str(), in TestGet() 163 StringToHex(values[i]).c_str()); in TestGet() 202 fprintf(stderr, "get error: %s\n", s.ToString().c_str()); in TestMultiGet() 231 key_str[i].c_str(), StringToHex(values[0].ToString()).c_str(), in TestMultiGet() 232 StringToHex(values[i].ToString()).c_str()); in TestMultiGet() 306 prefixes[i].c_str(), StringToHex(values[0]).c_str(), in TestPrefixScan() 307 StringToHex(values[i]).c_str()); in TestPrefixScan() [all …]
|
| D | db_stress_test_base.cc | 315 s.ToString().c_str()); in VerificationAbort() 323 key, msg.c_str()); in VerificationAbort() 1086 iter->key().ToString(true).c_str(), op_logs.c_str()); in VerifyIterator() 1116 cmp_iter->key().ToString(true).c_str(), op_logs.c_str()); in VerifyIterator() 1130 total_order_key.ToString(true).c_str(), op_logs.c_str()); in VerifyIterator() 1260 s.ToString().c_str()); in TestBackupRestore() 1384 s.ToString().c_str()); in TestCheckpoint() 1426 s.ToString().c_str()); in TestCompactFiles() 1588 start_key.ToString(true).c_str(), end_key.ToString(true).c_str()); in TestCompactRange() 1837 FLAGS_options_file.c_str(), s.ToString().c_str()); in Open() [all …]
|
| /rocksdb-6.9/utilities/ |
| D | env_librados.cc | 75 LOG_DEBUG("[IN]%s\n", fn.c_str()); in split() 92 LOG_DEBUG("[OUT]%s | %s\n", dir->c_str(), file->c_str()); in split() 141 LOG_DEBUG("[OUT]%s, %i, %s\n", s.ToString().c_str(), (int)r, buffer.c_str()); in Read() 218 LOG_DEBUG("[OUT]%s, %i, %s\n", s.ToString().c_str(), (int)r, buffer.c_str()); in Read() 897 LOG_DEBUG("[IN]%s\n", fname.c_str()); in NewSequentialFile() 940 LOG_DEBUG("[IN]%s\n", fname.c_str()); in NewRandomAccessFile() 983 LOG_DEBUG("[IN]%s\n", fname.c_str()); in NewWritableFile() 1037 LOG_DEBUG("[IN]%s => %s\n", old_fname.c_str(), new_fname.c_str()); in ReuseWritableFile() 1073 LOG_DEBUG("[IN]%s\n", name.c_str()); in NewDirectory() 1372 LOG_DEBUG("[IN]%s => %s\n", src.c_str(), target_in.c_str()); in RenameFile() [all …]
|
| D | env_librados_test.cc | 100 int delete_ret = rados.pool_delete(db_pool.c_str()); in ~EnvLibradosTest() 792 delete_ret = rados.pool_delete(wal_pool.c_str()); in ~EnvLibradosMutipoolTest() 814 ASSERT_OK(env_->CreateDir(dir.c_str())); in TEST_F() 818 ASSERT_OK(env_->GetChildren(dir.c_str(), &children)); in TEST_F() 826 ASSERT_OK(env_->FileExists(dir_f.c_str())); in TEST_F() 829 ASSERT_OK(env_->GetChildren(dir.c_str(), &children)); in TEST_F() 845 ASSERT_TRUE(!env_->RenameFile(dir_non_existent.c_str(), dir_g.c_str()).ok()); in TEST_F() 846 ASSERT_OK(env_->RenameFile(dir_f.c_str(), dir_g.c_str())); in TEST_F() 848 ASSERT_OK(env_->FileExists(dir_g.c_str())); in TEST_F() 864 ASSERT_OK(env_->DeleteFile(dir_g.c_str())); in TEST_F() [all …]
|
| /rocksdb-6.9/logging/ |
| D | auto_roll_logger_test.cc | 73 ASSERT_TRUE(system(deleteCmd.c_str()) == 0); in InitTestDb() 140 LogMessage(logger, log_message.c_str()); in RollLogFileBySizeTest() 146 LogMessage(logger, log_message.c_str()); in RollLogFileBySizeTest() 152 LogMessage(logger, log_message.c_str()); in RollLogFileBySizeTest() 155 LogMessage(logger, log_message.c_str()); in RollLogFileBySizeTest() 175 LogMessage(logger, log_message.c_str()); in RollLogFileByTimeTest() 190 LogMessage(logger, log_message.c_str()); in RollLogFileByTimeTest() 261 LogMessage(logger, kSampleMessage.c_str()); in TEST_F() 546 ROCKS_LOG_INFO(&logger, "%s", kSampleMessage.c_str()); in TEST_F() 547 ROCKS_LOG_WARN(&logger, "%s", kSampleMessage.c_str()); in TEST_F() [all …]
|
| /rocksdb-6.9/utilities/checkpoint/ |
| D | checkpoint_impl.cc | 51 full_private_path.c_str(), s.ToString().c_str()); in CleanStagingDirectory() 57 subchild_path.c_str(), s.ToString().c_str()); in CleanStagingDirectory() 62 full_private_path.c_str(), s.ToString().c_str()); in CleanStagingDirectory() 88 checkpoint_dir.c_str()); in CreateCheckpoint() 104 full_private_path.c_str()); in CreateCheckpoint() 363 cf_name.c_str(), export_dir.c_str()); in ExportColumnFamily() 385 cf_name.c_str(), fname.c_str()); in ExportColumnFamily() 391 cf_name.c_str(), fname.c_str()); in ExportColumnFamily() 447 cf_name.c_str(), s.ToString().c_str()); in ExportColumnFamily() 457 subchild_path.c_str(), status.ToString().c_str()); in ExportColumnFamily() [all …]
|
| /rocksdb-6.9/tools/ |
| D | sst_dump_tool.cc | 57 fprintf(stdout, "Process %s\n", file_path.c_str()); in SstFileDumper() 195 fputs(s.ToString().c_str(), stderr); in CalculateCompressedTableSize() 302 DecodeFixed32(pos->second.c_str())); in SetTableOptionsByMagicNumber() 390 value.ToString(output_hex_).c_str()); in ReadSequential() 570 compression_type.c_str()); in Run() 668 fprintf(stderr, "%s: %s\n", filename.c_str(), in Run() 686 fprintf(stderr, "%s: %s\n", filename.c_str(), st.ToString().c_str()); in Run() 702 st.ToString().c_str()); in Run() 714 st.ToString().c_str()); in Run() 728 fprintf(stderr, "%s: %s\n", filename.c_str(), st.ToString().c_str()); in Run() [all …]
|
| D | db_bench_tool.cc | 1934 ts.cf_name.c_str(), in PrintThreadStatus() 2109 extra.c_str()); in Report() 3040 name.c_str()); in Run() 3053 name.c_str()); in Run() 3124 name.c_str()); in Run() 3270 .c_str()); in Run() 3587 FLAGS_options_file.c_str(), s.ToString().c_str()); in InitializeOptionsFromFile() 5985 key.ToString().c_str(), values[0].c_str(), values[1].c_str(), in GetMany() 5986 values[2].c_str()); in GetMany() 6930 s.ToString().c_str()); in Replay() [all …]
|
| /rocksdb-6.9/test_util/ |
| D | transaction_test_util.cc | 120 fprintf(stderr, "Get returned unexpected value: %s\n", value.c_str()); in DBGet() 158 s.ToString().c_str()); in DoInsert() 176 s.ToString().c_str()); in DoInsert() 188 txn->GetName().c_str(), s.ToString().c_str(), in DoInsert() 203 s.ToString().c_str(), txn->GetName().c_str()); in DoInsert() 218 s.ToString().c_str(), txn->GetName().c_str()); in DoInsert() 224 txn->GetName().c_str(), s.ToString().c_str()); in DoInsert() 247 s.ToString().c_str()); in DoInsert() 255 s.ToString().c_str()); in DoInsert() 262 s.ToString().c_str(), txn->GetName().c_str()); in DoInsert() [all …]
|
| /rocksdb-6.9/db/ |
| D | db_info_dumper.cc | 38 "Error when reading %s dir\n", dbname.c_str()); in DumpDBFileSummary() 47 Header(options.info_log, "CURRENT file: %s\n", file.c_str()); in DumpDBFileSummary() 50 Header(options.info_log, "IDENTITY file: %s\n", file.c_str()); in DumpDBFileSummary() 55 file.c_str(), file_size); in DumpDBFileSummary() 80 db_path.path.c_str()); in DumpDBFileSummary() 94 db_path.path.c_str(), file_num, file_info.c_str()); in DumpDBFileSummary() 104 options.wal_dir.c_str()); in DumpDBFileSummary() 121 options.wal_dir.c_str(), wal_info.c_str()); in DumpDBFileSummary()
|
| D | wal_manager.cc | 97 log->PathName().c_str()); in GetSortedWalFiles() 147 s.ToString().c_str()); in PurgeObsoleteWALFiles() 167 s.ToString().c_str()); in PurgeObsoleteWALFiles() 186 s.ToString().c_str()); in PurgeObsoleteWALFiles() 194 file_path.c_str(), s.ToString().c_str()); in PurgeObsoleteWALFiles() 210 s.ToString().c_str()); in PurgeObsoleteWALFiles() 262 file_path.c_str(), s.ToString().c_str()); in PurgeObsoleteWALFiles() 279 fname.c_str(), archived_log_name.c_str(), in ArchiveWALFile() 280 s.ToString().c_str()); in ArchiveWALFile() 376 ToString(type).c_str()); in ReadFirstRecord() [all …]
|
| D | filename_test.cc | 131 ASSERT_TRUE(ParseFileName(fname.c_str() + 4, &number, &type)); in TEST_F() 137 ASSERT_TRUE(ParseFileName(fname.c_str() + 4, &number, &type)); in TEST_F() 143 ASSERT_TRUE(ParseFileName(fname.c_str() + 4, &number, &type)); in TEST_F() 152 ASSERT_TRUE(ParseFileName(fname.c_str() + 4, &number, &type)); in TEST_F() 158 ASSERT_TRUE(ParseFileName(fname.c_str() + 4, &number, &type)); in TEST_F() 164 ASSERT_TRUE(ParseFileName(fname.c_str() + 4, &number, &type)); in TEST_F() 170 ASSERT_TRUE(ParseFileName(fname.c_str() + 4, &number, &type)); in TEST_F()
|
| D | external_sst_file_ingestion_job.cc | 121 path_inside_db.c_str(), status.ToString().c_str()); in Prepare() 156 path_id, status.ToString().c_str()); in Prepare() 174 f.internal_file_path.c_str(), s.ToString().c_str()); in Prepare() 304 f.external_file_path.c_str(), f.picked_level, in UpdateStats() 305 f.internal_file_path.c_str(), f.assigned_seqno); in UpdateStats() 338 f.internal_file_path.c_str(), s.ToString().c_str()); in Cleanup() 352 f.external_file_path.c_str(), s.ToString().c_str()); in Cleanup() 414 file_to_ingest->version = DecodeFixed32(version_iter->second.c_str()); in GetIngestedFileInfo() 425 file_to_ingest->original_seqno = DecodeFixed64(seqno_iter->second.c_str()); in GetIngestedFileInfo() 674 file_to_ingest->internal_file_path.c_str(), in AssignGlobalSeqnoForIngestedFile() [all …]
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | block_cache_tier.cc | 42 Error(opt_.log, "Error creating directory %s. %s", opt_.path.c_str(), in Open() 43 status.ToString().c_str()); in Open() 55 status.ToString().c_str()); in Open() 65 status.ToString().c_str()); in Open() 96 Error(opt_.log, "Error getting files for %s. %s", folder.c_str(), in CleanupCacheFolder() 97 status.ToString().c_str()); in CleanupCacheFolder() 105 Info(opt_.log, "Removing file %s.", file.c_str()); in CleanupCacheFolder() 108 Error(opt_.log, "Error deleting file %s. %s", file.c_str(), in CleanupCacheFolder() 109 status.ToString().c_str()); in CleanupCacheFolder() 113 ROCKS_LOG_DEBUG(opt_.log, "Skipping file %s", file.c_str()); in CleanupCacheFolder() [all …]
|
| D | block_cache_tier_file.cc | 187 fprintf(stderr, "** key %s ** \n", key_.ToString().c_str()); in Deserialize() 188 fprintf(stderr, "** val %s ** \n", val_.ToString().c_str()); in Deserialize() 211 ROCKS_LOG_DEBUG(log_, "Opening cache file %s", Path().c_str()); in OpenImpl() 218 status.ToString().c_str()); in OpenImpl() 240 Error(log_, "Error reading from file %s. %s", Path().c_str(), in Read() 241 s.ToString().c_str()); in Read() 258 Path().c_str(), lba.off_); in ParseRec() 294 Path().c_str(), max_size_); in Create() 300 ROCKS_LOG_WARN(log_, "File %s already exists. %s", Path().c_str(), in Create() 301 s.ToString().c_str()); in Create() [all …]
|
| /rocksdb-6.9/examples/ |
| D | multi_processes_example.cc | 113 memcpy(&ret, key.c_str(), sizeof(uint64_t)); in Key() 115 const char* buf = key.c_str(); in Key() 148 s.ToString().c_str()); in CreateDB() 156 s.ToString().c_str()); in CreateDB() 167 cf_name.c_str(), s.ToString().c_str()); in CreateDB() 203 s.ToString().c_str()); in RunPrimary() 259 if (nullptr == opendir(kSecondaryPath.c_str())) { in RunSecondary() 261 mkdir(kSecondaryPath.c_str(), S_IRWXU | S_IRWXG | S_IROTH | S_IXOTH); in RunSecondary() 274 my_pid, s.ToString().c_str()); in RunSecondary() 314 my_pid, s.ToString().c_str()); in RunSecondary() [all …]
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_db_impl.cc | 177 blob_dir_.c_str(), s.ToString().c_str()); in Open() 671 blob_file->PathName().c_str(), reason.c_str()); in NewBlobFile() 697 fpath.c_str(), s.ToString().c_str(), in CreateWriterLocked() 798 (*blob_file)->PathName().c_str(), s.ToString().c_str()); in CreateBlobFileAndWriter() 809 (*blob_file)->PathName().c_str(), s.ToString().c_str()); in CreateBlobFileAndWriter() 1083 blob_file->PathName().c_str(), key.ToString().c_str(), value.size(), in PutBlobValue() 1084 s.ToString().c_str(), blob_file->DumpState().c_str()); in PutBlobValue() 1301 bfile->PathName().c_str(), s.ToString().c_str()); in AppendBlob() 1415 key.ToString(/* output_hex */ true).c_str(), s.ToString().c_str()); in GetBlobValue() 1548 key.ToString(/* output_hex */ true).c_str(), s.ToString().c_str()); in GetRawBlobFromFile() [all …]
|
| /rocksdb-6.9/port/win/ |
| D | env_win.cc | 163 RX_FN(fname).c_str(), GENERIC_READ, in NewSequentialFile() 201 RX_FN(fname).c_str(), GENERIC_READ, in NewRandomAccessFile() 316 RX_FN(fname).c_str(), in OpenWritableFile() 384 RX_CreateFile(RX_FN(fname).c_str(), in NewRandomRWFile() 506 RX_FN(name).c_str(), 0, in NewDirectory() 715 if (!RX_MoveFileEx(RX_FN(src).c_str(), RX_FN(target).c_str(), in RenameFile() 732 if (!RX_CreateHardLink(RX_FN(target).c_str(), RX_FN(src).c_str(), NULL)) { in LinkFile() 750 RX_FN(fname).c_str(), 0, in NumFileLinks() 788 RX_FN(first).c_str(), 0, in AreFilesSame() 803 RX_FN(second).c_str(), 0, in AreFilesSame() [all …]
|
| /rocksdb-6.9/tools/block_cache_analyzer/ |
| D | block_cache_trace_analyzer.cc | 720 label_name.c_str(), label_str.c_str()); in ParseLabelStr() 1631 cf_name.c_str(), block_type_to_string(bt_stats.first).c_str(), in PrintBlockSizeStats() 1780 cf_name.c_str(), block_type_to_string(bt_stats.first).c_str(), in PrintAccessCountStats() 1854 cf_stats.first.c_str(), cf_stats.second.ToString().c_str()); in PrintDataBlockAccessStats() 1865 cf_stats.first.c_str(), cf_stats.second.ToString().c_str()); in PrintDataBlockAccessStats() 1875 cf_stats.first.c_str(), cf_stats.second.ToString().c_str()); in PrintDataBlockAccessStats() 1884 cf_stats.first.c_str(), cf_stats.second.ToString().c_str()); in PrintDataBlockAccessStats() 1893 cf_stats.first.c_str(), cf_stats.second.ToString().c_str()); in PrintDataBlockAccessStats() 2069 line.c_str()); in parse_cache_config_file() 2075 line.c_str(), kSupportedCacheNames.c_str()); in parse_cache_config_file() [all …]
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_picker_universal.cc | 384 cf_name_.c_str()); in PickCompaction() 410 cf_name_.c_str()); in PickCompaction() 420 cf_name_.c_str()); in PickCompaction() 449 cf_name_.c_str(), num_files); in PickCompaction() 460 cf_name_.c_str()); in PickCompaction() 667 cf_name_.c_str(), file_num_buf); in PickCompactionToReduceSortedRuns() 737 cf_name_.c_str(), file_num_buf); in PickCompactionToReduceSortedRuns() 817 cf_name_.c_str(), file_num_buf, start_index, in PickCompactionToReduceSizeAmp() 1009 cf_name_.c_str(), comp_reason_print_string.c_str(), in PickCompactionToOldest() 1040 cf_name_.c_str()); in PickPeriodicCompaction() [all …]
|