| /rocksdb-6.9/util/ |
| D | compression.h | 617 (void)output; in Snappy_Compress() 640 (void)output; in Snappy_Uncompress() 734 output->resize(output->size() - _stream.avail_out); in Zlib_Compress() 747 (void)output; in Zlib_Compress() 844 return output; 901 output->resize(output->size() - _stream.avail_out); in BZip2_Compress() 913 (void)output; in BZip2_Compress() 990 return output; 1065 (void)output; in LZ4_Compress() 1214 (void)output; in LZ4HC_Compress() [all …]
|
| D | string_util.cc | 47 return snprintf(output, len, "%.3lf ms", in AppendHumanMicros() 50 return snprintf(output, len, "%.3lf sec", in AppendHumanMicros() 218 std::string output; in EscapeOptionString() local 221 output += '\\'; in EscapeOptionString() 222 output += EscapeChar(c); in EscapeOptionString() 224 output += c; in EscapeOptionString() 228 return output; in EscapeOptionString() 233 std::string output; in UnescapeOptionString() local 237 output += UnescapeChar(c); in UnescapeOptionString() 244 output += c; in UnescapeOptionString() [all …]
|
| D | string_util.h | 60 int AppendHumanMicros(uint64_t micros, char* output, int len, 64 int AppendHumanBytes(uint64_t bytes, char* output, int len);
|
| /rocksdb-6.9/db/blob/ |
| D | blob_file_addition.cc | 33 void BlobFileAddition::EncodeTo(std::string* output) const { in EncodeTo() 34 PutVarint64(output, blob_file_number_); in EncodeTo() 35 PutVarint64(output, total_blob_count_); in EncodeTo() 36 PutVarint64(output, total_blob_bytes_); in EncodeTo() 37 PutLengthPrefixedSlice(output, checksum_method_); in EncodeTo() 38 PutLengthPrefixedSlice(output, checksum_value_); in EncodeTo() 45 TEST_SYNC_POINT_CALLBACK("BlobFileAddition::EncodeTo::CustomFields", output); in EncodeTo() 47 PutVarint32(output, kEndMarker); in EncodeTo()
|
| D | blob_file_garbage.cc | 33 void BlobFileGarbage::EncodeTo(std::string* output) const { in EncodeTo() 34 PutVarint64(output, blob_file_number_); in EncodeTo() 35 PutVarint64(output, garbage_blob_count_); in EncodeTo() 36 PutVarint64(output, garbage_blob_bytes_); in EncodeTo() 43 TEST_SYNC_POINT_CALLBACK("BlobFileGarbage::EncodeTo::CustomFields", output); in EncodeTo() 45 PutVarint32(output, kEndMarker); in EncodeTo()
|
| D | blob_file_garbage_test.cc | 113 std::string* output = static_cast<std::string*>(arg); in TEST_F() local 116 PutVarint32(output, forward_compatible_tag); in TEST_F() 118 PutLengthPrefixedSlice(output, "deadbeef"); in TEST_F() 138 std::string* output = static_cast<std::string*>(arg); in TEST_F() local 141 PutVarint32(output, forward_incompatible_tag); in TEST_F() 143 PutLengthPrefixedSlice(output, "foobar"); in TEST_F()
|
| D | blob_file_addition_test.cc | 140 std::string* output = static_cast<std::string*>(arg); in TEST_F() local 143 PutVarint32(output, forward_compatible_tag); in TEST_F() 145 PutLengthPrefixedSlice(output, "deadbeef"); in TEST_F() 168 std::string* output = static_cast<std::string*>(arg); in TEST_F() local 171 PutVarint32(output, forward_incompatible_tag); in TEST_F() 173 PutLengthPrefixedSlice(output, "foobar"); in TEST_F()
|
| /rocksdb-6.9/logging/ |
| D | event_logger_test.cc | 32 std::string output(logger.buffer()); in TEST_F() local 33 ASSERT_TRUE(output.find("\"event\": \"just_testing\"") != std::string::npos); in TEST_F() 34 ASSERT_TRUE(output.find("\"id\": 5") != std::string::npos); in TEST_F() 35 ASSERT_TRUE(output.find("\"time_micros\"") != std::string::npos); in TEST_F()
|
| /rocksdb-6.9/port/win/ |
| D | xpress_win.cc | 44 bool Compress(const char* input, size_t length, std::string* output) { in Compress() argument 47 assert(output != nullptr); in Compress() 50 output->clear(); in Compress() 124 output->swap(result); in Compress()
|
| D | env_win.cc | 555 std::vector<std::string> output; in GetChildren() local 597 output.emplace_back(FN_TO_RX(x)); in GetChildren() 607 output.swap(*result); in GetChildren() 892 std::string output; in GetTestDirectory() local 896 output = env; in GetTestDirectory() 901 output = env; in GetTestDirectory() 903 output = "c:\\tmp"; in GetTestDirectory() 906 CreateDir(output); in GetTestDirectory() 908 output.append("\\testrocksdb-"); in GetTestDirectory() 911 CreateDir(output); in GetTestDirectory() [all …]
|
| /rocksdb-6.9/tools/advisor/advisor/ |
| D | db_bench_runner.py | 65 output = { 80 output[self.THROUGHPUT] = ( 109 output[self.PERF_CON] = perf_context_ts 114 output[self.DB_PATH] = ( 117 return output
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction.cc | 449 int InputSummary(const std::vector<FileMetaData*>& files, char* output, in InputSummary() argument 451 *output = '\0'; in InputSummary() 458 ret = snprintf(output + write, sz, "%" PRIu64 "(%s) ", in InputSummary() 468 void Compaction::Summary(char* output, int len) { in Summary() argument 470 snprintf(output, len, "Base version %" PRIu64 " Base level %d, inputs: [", in Summary() 478 write += snprintf(output + write, len - write, "], ["); in Summary() 484 InputSummary(inputs_[level_iter].files, output + write, len - write); in Summary() 490 snprintf(output + write, len - write, "]"); in Summary()
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | MemoryUtil.java | 51 Map<MemoryUsageType, Long> output = new HashMap<>(); in getApproximateMemoryUsageByType() local 53 output.put(MemoryUsageType.getMemoryUsageType(longEntry.getKey()), longEntry.getValue()); in getApproximateMemoryUsageByType() 55 return output; in getApproximateMemoryUsageByType()
|
| /rocksdb-6.9/coverage/ |
| D | coverage_test.sh | 30 $GCOV --preserve-paths --relative-only --no-output $GCNO_FILES 2>/dev/null | 46 $GCOV --preserve-paths --relative-only --no-output $GCNO_FILES 2>/dev/null | 78 --output-file $COVERAGE_DIR/coverage.info)
|
| /rocksdb-6.9/tools/ |
| D | ldb_test.py | 24 output, unused_err = process.communicate() 32 return output.decode('utf-8') 58 output = my_check_output("./ldb %s |grep -v \"Created bg thread\"" % 62 self.assertNotEqual(expectedOutput.search(output.strip()), 65 self.assertEqual(output.strip(), expectedOutput.strip()) 68 self.assertEqual(expectedOutput.search(output.strip()), None) 70 self.assertNotEqual(output.strip(), expectedOutput.strip())
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2015-10-27-getthreadlist.markdown | 10 …output size, elapsed time, the number of bytes it has written. Below is an example output of `GetT… 118 In the above output, we can see `GetThreadList()` reports the activity of two threads: one thread r… 148 Since an Env can be shared across multiple rocksdb instances, the output of
|
| D | 2018-08-01-rocksdb-tuning-advisor.markdown | 30 The Advisor's output gives information about which rules were triggered, 45 Sample output where a Rocksdb log-based rule has been triggered :
|
| /rocksdb-6.9/table/plain/ |
| D | plain_table_key_coding.h | 101 bool ReadNonMmap(uint32_t file_offset, uint32_t len, Slice* output); 106 inline bool ReadVarint32(uint32_t offset, uint32_t* output, 109 bool ReadVarint32NonMmap(uint32_t offset, uint32_t* output,
|
| /rocksdb-6.9/port/ |
| D | port_example.h | 82 std::string* output); 98 char* output);
|
| /rocksdb-6.9/ |
| D | appveyor.yml | 32 …- curl --fail --silent --show-error --output snappy-1.1.7.zip --location https://github.com/google… 42 …- curl --fail --silent --show-error --output lz4-1.8.3.zip --location https://github.com/lz4/lz4/a… 50 …- curl --fail --silent --show-error --output zstd-1.4.0.zip --location https://github.com/facebook…
|
| /rocksdb-6.9/file/ |
| D | read_write_util.cc | 26 std::string* output, bool* has_data, Status* result) { in ReadOneLine() argument 58 *output = line; in ReadOneLine()
|
| /rocksdb-6.9/java/ |
| D | Makefile | 291 …unit/4.12/junit-4.12.jar $(JAVA_TEST_LIBDIR) || curl --fail --insecure --output $(JAVA_JUNIT_JAR) … 292 ….3/hamcrest-core-1.3.jar $(JAVA_TEST_LIBDIR) || curl --fail --insecure --output $(JAVA_HAMCR_JAR) … 293 …/mockito-all-1.10.19.jar $(JAVA_TEST_LIBDIR) || curl --fail --insecure --output "$(JAVA_MOCKITO_JA… 294 …ib/2.2.2/cglib-2.2.2.jar $(JAVA_TEST_LIBDIR) || curl --fail --insecure --output "$(JAVA_CGLIB_JAR)… 295 …1/assertj-core-1.7.1.jar $(JAVA_TEST_LIBDIR) || curl --fail --insecure --output "$(JAVA_ASSERTJ_JA…
|
| /rocksdb-6.9/.circleci/ |
| D | config.yml | 34 …curl --fail --silent --show-error --output cmake-3.16.4-win64-x64.zip --location https://github.co… 37 …curl --fail --silent --show-error --output snappy-1.1.7.zip --location https://github.com/google/s…
|
| /rocksdb-6.9/tools/block_cache_analyzer/ |
| D | block_cache_pysim.sh | 54 output="log-ml-$cache_type-$cache_size-$cf_name" 56 …"$trace_file" "$ml_tmp_result_dir" "$max_num_accesses" "$cf_name" >& "$ml_tmp_result_dir/$output" &
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_db_impl.cc | 502 const auto& output = *oit; in ProcessCompactionJobInfo() local 504 if (input.file_number == output.file_number) { in ProcessCompactionJobInfo() 507 } else if (input.file_number < output.file_number) { in ProcessCompactionJobInfo() 514 assert(output.file_number < input.file_number); in ProcessCompactionJobInfo() 516 if (output.oldest_blob_file_number != kInvalidBlobFileNumber) { in ProcessCompactionJobInfo() 517 LinkSstToBlobFile(output.file_number, output.oldest_blob_file_number); in ProcessCompactionJobInfo() 535 const auto& output = *oit; in ProcessCompactionJobInfo() local 537 if (output.oldest_blob_file_number != kInvalidBlobFileNumber) { in ProcessCompactionJobInfo() 538 LinkSstToBlobFile(output.file_number, output.oldest_blob_file_number); in ProcessCompactionJobInfo()
|