Home
last modified time | relevance | path

Searched refs:length (Results 1 – 25 of 106) sorted by relevance

12345

/rocksdb-6.9/java/src/main/java/org/rocksdb/
DTransaction.java349 if(keys.length == 0) { in multiGet()
673 put(nativeHandle_, key, key.length, value, value.length, in put()
705 put(nativeHandle_, key, key.length, value, value.length, in put()
734 put(nativeHandle_, key, key.length, value, value.length); in put()
836 merge(nativeHandle_, key, key.length, value, value.length, in merge()
868 merge(nativeHandle_, key, key.length, value, value.length, in merge()
897 merge(nativeHandle_, key, key.length, value, value.length); in merge()
1233 putUntracked(nativeHandle_, key, key.length, value, value.length, in putUntracked()
1259 putUntracked(nativeHandle_, key, key.length, value, value.length); in putUntracked()
1324 mergeUntracked(nativeHandle_, key, key.length, value, value.length, in mergeUntracked()
[all …]
DRocksDB.java613 put(nativeHandle_, key, 0, key.length, value, 0, value.length); in put()
658 put(nativeHandle_, key, 0, key.length, value, 0, value.length, in put()
706 key, 0, key.length, value, 0, value.length); in put()
1318 beginKey.length, endKey, 0, endKey.length); in deleteRange()
1342 beginKey.length, endKey, 0, endKey.length, in deleteRange()
1359 merge(nativeHandle_, key, 0, key.length, value, 0, value.length); in merge()
1402 merge(nativeHandle_, key, 0, key.length, value, 0, value.length, in merge()
1449 key, 0, key.length, value, 0, value.length); in merge()
1538 key, 0, key.length, value, 0, value.length, in merge()
1677 return get(nativeHandle_, key, 0, key.length, value, 0, value.length, in get()
[all …]
DAbstractWriteBatch.java24 put(nativeHandle_, key, key.length, value, value.length); in put()
30 put(nativeHandle_, key, key.length, value, value.length, in put()
36 merge(nativeHandle_, key, key.length, value, value.length); in merge()
42 merge(nativeHandle_, key, key.length, value, value.length, in merge()
49 delete(nativeHandle_, key, key.length); in remove()
56 delete(nativeHandle_, key, key.length, columnFamilyHandle.nativeHandle_); in remove()
79 delete(nativeHandle_, key, key.length); in delete()
91 singleDelete(nativeHandle_, key, key.length); in singleDelete()
103 deleteRange(nativeHandle_, beginKey, beginKey.length, endKey, endKey.length); in deleteRange()
109 deleteRange(nativeHandle_, beginKey, beginKey.length, endKey, endKey.length, in deleteRange()
[all …]
DDirectSlice.java65 public DirectSlice(final ByteBuffer data, final int length) { in DirectSlice() argument
66 super(createNewDirectSlice0(ensureDirect(data), length)); in DirectSlice() local
123 final int length); in createNewDirectSlice0() argument
129 private native void removePrefix0(long handle, int length); in removePrefix0() argument
DWriteBatchWithIndex.java174 key, key.length, columnFamilyHandle.nativeHandle_); in getFromBatch()
192 return getFromBatch(nativeHandle_, options.nativeHandle_, key, key.length); in getFromBatch()
221 options.nativeHandle_, key, key.length, in getFromBatchAndDB()
250 options.nativeHandle_, key, key.length); in getFromBatchAndDB()
/rocksdb-6.9/util/
Dcompression.h616 (void)length; in Snappy_Compress()
628 (void)length; in Snappy_GetUncompressedLength()
639 (void)length; in Snappy_Uncompress()
648 PutVarint32(output, length); in PutDecompressedSizeInfo()
746 (void)length; in Zlib_Compress()
912 (void)length; in BZip2_Compress()
1027 memcpy(p, &length, sizeof(length)); in LZ4_Compress()
1064 (void)length; in LZ4_Compress()
1161 memcpy(p, &length, sizeof(length)); in LZ4HC_Compress()
1213 (void)length; in LZ4HC_Compress()
[all …]
Dcrc32c_arm64.cc51 int length = (int)len; in crc32c_arm64() local
64 while (length >= 1024) { in crc32c_arm64()
104 length -= 1024; in crc32c_arm64()
107 if (length == 0) return crc ^ (0xffffffffU); in crc32c_arm64()
110 while (length >= 8) { in crc32c_arm64()
113 length -= 8; in crc32c_arm64()
117 if (length >= 4) { in crc32c_arm64()
120 length -= 4; in crc32c_arm64()
123 if (length >= 2) { in crc32c_arm64()
126 length -= 2; in crc32c_arm64()
[all …]
Dbloom_test.cc47 if (length < 10) { in NextLength()
48 length += 1; in NextLength()
49 } else if (length < 100) { in NextLength()
50 length += 10; in NextLength()
51 } else if (length < 1000) { in NextLength()
52 length += 100; in NextLength()
54 length += 1000; in NextLength()
56 return length; in NextLength()
154 for (int length = 1; length <= 10000; length = NextLength(length)) { in TEST_F() local
161 ASSERT_LE(FilterSize(), (size_t)((length * 10 / 8) + 40)) << length; in TEST_F()
[all …]
Dcrc32c_test.cc26 size_t length; member
107 uint32_t result = Value(buffer + expected.offset, expected.length); in TEST()
113 size_t partialLength = expected.length / 2; in TEST()
117 expected.length - partialLength); in TEST()
Dxxhash.h209 XXH_PUBLIC_API XXH32_hash_t XXH32 (const void* input, size_t length, XXH32_hash_t seed);
240 …_PUBLIC_API XXH_errorcode XXH32_update (XXH32_state_t* statePtr, const void* input, size_t length);
284 XXH_PUBLIC_API XXH64_hash_t XXH64 (const void* input, size_t length, XXH64_hash_t seed);
293 …_PUBLIC_API XXH_errorcode XXH64_update (XXH64_state_t* statePtr, const void* input, size_t length);
518 …_API XXH_errorcode XXH3p_64bits_update (XXH3p_state_t* statePtr, const void* input, size_t length);
556 …API XXH_errorcode XXH3p_128bits_update (XXH3p_state_t* statePtr, const void* input, size_t length);
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DRocksMemEnvTest.java43 for (int i = 0; i < keys.length; i++) { in memEnvFillAndReopen()
48 for (int i = 0; i < keys.length; i++) { in memEnvFillAndReopen()
55 for (int i = 0; i < keys.length; i++) { in memEnvFillAndReopen()
69 for (int i = 0; i < keys.length; i++) { in memEnvFillAndReopen()
80 for (int i = 0; i < keys.length; i++) { in memEnvFillAndReopen()
117 for (int i = 0; i < keys.length; i++) { in multipleDatabaseInstances()
123 for (int i = 0; i < keys.length; i++) { in multipleDatabaseInstances()
DLoggerTest.java35 assertThat(logMsg.length()).isGreaterThan(0); in customLogger()
64 assertThat(logMsg.length()).isGreaterThan(0); in warnLogger()
95 assertThat(logMsg.length()).isGreaterThan(0); in fatalLogger()
124 assertThat(logMsg.length()).isGreaterThan(0); in dbOptionsLogger()
164 assertThat(logMsg.length()).isGreaterThan(0); in setWarnLogLevel()
188 assertThat(logMsg.length()).isGreaterThan(0); in setInfoLogLevel()
213 assertThat(logMsg.length()).isGreaterThan(0); in changeLogLevelAtRuntime()
DSstFileWriterTest.java85 ByteBuffer keyDirect = ByteBuffer.allocateDirect(keyBytes.length); in newSstFile()
88 ByteBuffer valueDirect = ByteBuffer.allocateDirect(valueBytes.length); in newSstFile()
100 assertThat(keyDirect.position()).isEqualTo(keyBytes.length); in newSstFile()
101 assertThat(keyDirect.limit()).isEqualTo(keyBytes.length); in newSstFile()
102 assertThat(valueDirect.position()).isEqualTo(valueBytes.length); in newSstFile()
103 assertThat(valueDirect.limit()).isEqualTo(valueBytes.length); in newSstFile()
DSstFileReaderTest.java143 assertThat(iterator.key(direct)).isEqualTo("key1".getBytes().length); in readSstFile()
144 byte[] dst = new byte["key1".getBytes().length]; in readSstFile()
149 assertThat(iterator.value(direct)).isEqualTo("value1".getBytes().length); in readSstFile()
150 dst = new byte["value1".getBytes().length]; in readSstFile()
DDirectSliceTest.java38 final ByteBuffer buffer = ByteBuffer.allocateDirect(data.length + 1); in directSliceWithByteBuffer()
40 buffer.put(data.length, (byte)0); in directSliceWithByteBuffer()
50 final ByteBuffer buffer = ByteBuffer.allocateDirect(data.length); in directSliceWithByteBufferAndLength()
/rocksdb-6.9/db/
Dlog_reader.cc332 const uint32_t length = a | (b << 8); in ReadPhysicalRecord() local
352 if (header_size + length > buffer_.size()) { in ReadPhysicalRecord()
367 if (type == kZeroType && length == 0) { in ReadPhysicalRecord()
392 buffer_.remove_prefix(header_size + length); in ReadPhysicalRecord()
394 *result = Slice(header + header_size, length); in ReadPhysicalRecord()
564 const uint32_t length = a | (b << 8); in TryReadFragment() local
588 while (header_size + length > buffer_.size()) { in TryReadFragment()
599 if (type == kZeroType && length == 0) { in TryReadFragment()
607 uint32_t actual_crc = crc32c::Value(header + 6, length + header_size - 6); in TryReadFragment()
616 buffer_.remove_prefix(header_size + length); in TryReadFragment()
[all …]
/rocksdb-6.9/utilities/
Denv_mirror.cc54 Status InvalidateCache(size_t offset, size_t length) override { in InvalidateCache() argument
55 Status as = a_->InvalidateCache(offset, length); in InvalidateCache()
56 Status bs = b_->InvalidateCache(offset, length); in InvalidateCache()
173 Status InvalidateCache(size_t offset, size_t length) override { in InvalidateCache() argument
174 Status as = a_->InvalidateCache(offset, length); in InvalidateCache()
175 Status bs = b_->InvalidateCache(offset, length); in InvalidateCache()
181 Status Allocate(uint64_t offset, uint64_t length) override { in Allocate() argument
182 Status as = a_->Allocate(offset, length); in Allocate()
183 Status bs = b_->Allocate(offset, length); in Allocate()
/rocksdb-6.9/env/
Dio_posix.cc306 (void)length; in InvalidateCache()
311 int ret = Fadvise(fd_, offset, length, POSIX_FADV_DONTNEED); in InvalidateCache()
314 " len " + ToString(length), in InvalidateCache()
795 (void)length; in InvalidateCache()
799 int ret = Fadvise(fd_, offset, length, POSIX_FADV_DONTNEED); in InvalidateCache()
804 " len " + ToString(length), in InvalidateCache()
857 (void)length; in InvalidateCache()
861 int ret = Fadvise(fd_, offset, length, POSIX_FADV_DONTNEED); in InvalidateCache()
866 " len" + ToString(length), in InvalidateCache()
1077 (void)length; in InvalidateCache()
[all …]
/rocksdb-6.9/java/benchmark/src/main/java/org/rocksdb/benchmark/
DDbBenchmark.java94 if (message_.length() == 0) { in merge()
105 if (message_.length() > 0) { in addMessage()
424 stats_.finishedSingleOp(iter.key().length + iter.value().length); in runTask()
880 if (parts.length >= 1) { in main()
884 if (parts.length >= 2) { in main()
1569 pos += value.length; in RandomGenerator()
1574 int baseLength = value.length; in compressibleBytes()
1585 while (pos < value.length) { in compressibleBytes()
1593 if (position_ + value.length > data_.length) { in generate()
1595 assert(value.length <= data_.length); in generate()
[all …]
/rocksdb-6.9/file/
Dwritable_file_writer.h37 void NotifyOnFileWriteFinish(uint64_t offset, size_t length, in NotifyOnFileWriteFinish() argument
43 info.length = length; in NotifyOnFileWriteFinish()
150 IOStatus InvalidateCache(size_t offset, size_t length) { in InvalidateCache() argument
151 return writable_file_->InvalidateCache(offset, length); in InvalidateCache()
/rocksdb-6.9/java/rocksjni/
Dslice.cc226 jlong handle, jint length) { in Java_org_rocksdb_Slice_removePrefix0() argument
228 slice->remove_prefix(length); in Java_org_rocksdb_Slice_removePrefix0()
256 jint length) { in Java_org_rocksdb_DirectSlice_createNewDirectSlice0() argument
269 const auto* slice = new ROCKSDB_NAMESPACE::Slice(ptrData, length); in Java_org_rocksdb_DirectSlice_createNewDirectSlice0()
342 jint length) { in Java_org_rocksdb_DirectSlice_removePrefix0() argument
344 slice->remove_prefix(length); in Java_org_rocksdb_DirectSlice_removePrefix0()
Dcomparatorjnicallback.cc298 static_cast<int64_t>(start->length()) <= m_options->max_reused_buffer_size; in FindShortestSeparator()
304 Slice sstart(start->data(), start->length()); in FindShortestSeparator()
329 j_start_buf, reuse_jbuf_start ? start->length() : -1, in FindShortestSeparator()
336 } else if (static_cast<size_t>(jstart_len) != start->length()) { in FindShortestSeparator()
434 static_cast<int64_t>(key->length()) <= m_options->max_reused_buffer_size; in FindShortSuccessor()
438 Slice skey(key->data(), key->length()); in FindShortSuccessor()
451 j_key_buf, reuse_jbuf_key ? key->length() : -1); in FindShortSuccessor()
465 if (static_cast<size_t>(jkey_len) != key->length()) { in FindShortSuccessor()
/rocksdb-6.9/java/src/test/java/org/rocksdb/util/
DBytewiseComparatorTest.java375 bufS1 = ByteBuffer.allocateDirect(s1.length()); in toJavaComparator()
376 bufS2 = ByteBuffer.allocateDirect(s2.length()); in toJavaComparator()
378 bufS1 = ByteBuffer.allocate(s1.length()); in toJavaComparator()
379 bufS2 = ByteBuffer.allocate(s2.length()); in toJavaComparator()
449 if(b.length >= a.length) {
450 for(int i = 0; i < a.length; i++) {
455 return a.length;
/rocksdb-6.9/port/win/
Dxpress_win.cc44 bool Compress(const char* input, size_t length, std::string* output) { in Compress() argument
49 if (length == 0) { in Compress()
80 length, // Uncompressed data size in Compress()
110 length, // Uncompressed data size in Compress()
/rocksdb-6.9/java/samples/src/main/java/
DRocksDBSample.java21 if (args.length < 1) { in main()
193 assert (len > insufficientArray.length); in main()
197 assert (len == testValue.length); in main()
200 assert (len > insufficientArray.length); in main()
204 assert (len == testValue.length); in main()
216 assert (len == testValue.length); in main()

12345