| /rocksdb-6.9/java/src/main/java/org/rocksdb/util/ |
| D | BytewiseComparator.java | 42 final int minLen = a.remaining() < b.remaining() ? in _compare()
43 a.remaining() : b.remaining(); in _compare()
46 if (a.remaining() < b.remaining()) { in _compare()
48 } else if (a.remaining() > b.remaining()) { in _compare()
59 final int minLength = Math.min(start.remaining(), limit.remaining());
78 if (diffIndex < limit.remaining() - 1 || startByte + 1 < limitByte) {
91 while (diffIndex < start.remaining()) {
110 final int n = key.remaining();
|
| D | ReverseBytewiseComparator.java | 45 final int minLength = Math.min(start.remaining(), limit.remaining()); in findShortestSeparator()
66 if (startByte > limitByte && diffIndex < start.remaining() - 1) { in findShortestSeparator()
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | AbstractWriteBatch.java | 61 putDirect(nativeHandle_, key, key.position(), key.remaining(), value, value.position(), in put()
62 value.remaining(), 0); in put()
71 putDirect(nativeHandle_, key, key.position(), key.remaining(), value, value.position(), in put()
72 value.remaining(), columnFamilyHandle.nativeHandle_); in put()
114 removeDirect(nativeHandle_, key, key.position(), key.remaining(), 0); in remove()
122 nativeHandle_, key, key.position(), key.remaining(), columnFamilyHandle.nativeHandle_); in remove()
|
| D | AbstractComparatorJniBridge.java | 97 return start.remaining(); in findShortestSeparatorInternal()
123 return key.remaining(); in findShortSuccessorInternal()
|
| D | RocksIterator.java | 59 int result = keyDirect0(nativeHandle_, key, key.position(), key.remaining()); in key()
94 int result = valueDirect0(nativeHandle_, value, value.position(), value.remaining()); in value()
|
| D | SstFileReaderIterator.java | 59 int result = keyDirect0(nativeHandle_, key, key.position(), key.remaining()); in key()
94 int result = valueDirect0(nativeHandle_, value, value.position(), value.remaining()); in value()
|
| D | AbstractRocksIterator.java | 72 seekDirect0(nativeHandle_, target, target.position(), target.remaining()); in seek()
79 seekForPrevDirect0(nativeHandle_, target, target.position(), target.remaining()); in seekForPrev()
|
| D | SstFileWriter.java | 134 putDirect(nativeHandle_, key, key.position(), key.remaining(), value, value.position(), in put()
135 value.remaining()); in put()
|
| D | RocksDB.java | 782 putDirect(nativeHandle_, writeOpts.nativeHandle_, key, key.position(), key.remaining(), value, in put()
783 value.position(), value.remaining(), columnFamilyHandle.nativeHandle_); in put()
806 putDirect(nativeHandle_, writeOpts.nativeHandle_, key, key.position(), key.remaining(), value, in put()
807 value.position(), value.remaining(), 0); in put()
1096 int result = getDirect(nativeHandle_, opt.nativeHandle_, key, key.position(), key.remaining(), in get()
1097 value, value.position(), value.remaining(), 0); in get()
1129 int result = getDirect(nativeHandle_, opt.nativeHandle_, key, key.position(), key.remaining(), in get()
1130 value, value.position(), value.remaining(), columnFamilyHandle.nativeHandle_); in get()
1496 deleteDirect(nativeHandle_, writeOpt.nativeHandle_, key, key.position(), key.remaining(), 0); in delete()
1517 deleteDirect(nativeHandle_, writeOpt.nativeHandle_, key, key.position(), key.remaining(), in delete()
|
| /rocksdb-6.9/hdfs/ |
| D | env_hdfs.h | 204 std::string remaining(parts[1]); in connectToPath()
206 int rem = static_cast<int>(remaining.find(pathsep)); in connectToPath()
207 std::string portStr = (rem == 0 ? remaining : in connectToPath()
208 remaining.substr(0, rem)); in connectToPath()
|
| /rocksdb-6.9/db/ |
| D | version_set_test.cc | 843 int remaining = atomic_group_size; in SetupValidAtomicGroup() local
847 edits_[i].MarkAtomicGroup(--remaining); in SetupValidAtomicGroup()
855 int remaining = atomic_group_size; in SetupIncompleteTrailingAtomicGroup() local
859 edits_[i].MarkAtomicGroup(--remaining); in SetupIncompleteTrailingAtomicGroup()
867 int remaining = atomic_group_size; in SetupCorruptedAtomicGroup() local
872 edits_[i].MarkAtomicGroup(--remaining); in SetupCorruptedAtomicGroup()
881 int remaining = atomic_group_size; in SetupIncorrectAtomicGroup() local
886 edits_[i].MarkAtomicGroup(--remaining); in SetupIncorrectAtomicGroup()
888 edits_[i].MarkAtomicGroup(remaining--); in SetupIncorrectAtomicGroup()
1274 uint32_t remaining = kAtomicGroupSize; in TEST_P() local
[all …]
|
| D | log_reader.cc | 225 size_t remaining = kBlockSize - eof_offset_; in UnmarkEOFInternal() local
237 Status status = file_->Read(remaining, &read_buffer, in UnmarkEOFInternal()
261 if (added < remaining) { in UnmarkEOFInternal()
|
| /rocksdb-6.9/tools/advisor/test/input_files/ |
| D | LOG-0 | 28 remaining part of the log
|
| /rocksdb-6.9/tools/advisor/ |
| D | README.md | 67 For more information about the remaining command-line arguments, run:
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | WriteBatchWithIndexTest.java | 538 final byte[] ary = new byte[buf.remaining()]; in toArray()
|
| /rocksdb-6.9/docs/ |
| D | LICENSE-DOCUMENTATION | 355 without affecting the enforceability of the remaining terms and
|