@@ -254,7 +254,7 @@ internal constructor(
254
254
memScoped {
255
255
rocksdb_put(
256
256
native,
257
- defaultWriteOptions .native,
257
+ writeOpts .native,
258
258
byteArrayToCPointer(key, offset, len),
259
259
len.toULong(),
260
260
byteArrayToCPointer(value, vOffset, vLen),
@@ -557,7 +557,7 @@ internal constructor(
557
557
wrapWithErrorThrower { error ->
558
558
rocksdb_merge_cf(
559
559
native,
560
- defaultWriteOptions .native,
560
+ writeOpts .native,
561
561
columnFamilyHandle.native,
562
562
byteArrayToCPointer(key, offset, len),
563
563
len.toULong(),
@@ -611,8 +611,14 @@ internal constructor(
611
611
valueLength.ptr,
612
612
error
613
613
)?.let {
614
+ val length = valueLength.value.toInt()
615
+
616
+ for (index in 0 until min(length, vLen)) {
617
+ value[index + vOffset] = it[index]
618
+ }
619
+
614
620
rocksdb.rocksdb_free(it)
615
- valueLength.value.toInt()
621
+ length
616
622
}
617
623
} ? : rocksDBNotFound
618
624
}
@@ -667,7 +673,7 @@ internal constructor(
667
673
native,
668
674
opt.native,
669
675
byteArrayToCPointer(key, offset, len),
670
- key.size .toULong(),
676
+ len .toULong(),
671
677
valueLength.ptr,
672
678
error
673
679
)?.let {
@@ -695,7 +701,7 @@ internal constructor(
695
701
return wrapWithNullErrorThrower { error ->
696
702
rocksdb_get_cf(
697
703
native,
698
- defaultReadOptions .native,
704
+ opt .native,
699
705
columnFamilyHandle.native,
700
706
key.toCValues(),
701
707
key.size.toULong(),
@@ -709,7 +715,6 @@ internal constructor(
709
715
}
710
716
711
717
rocksdb.rocksdb_free(it)
712
-
713
718
length
714
719
}
715
720
} ? : rocksDBNotFound
@@ -733,13 +738,19 @@ internal constructor(
733
738
native,
734
739
opt.native,
735
740
columnFamilyHandle.native,
736
- key.toCValues( ),
737
- key.size .toULong(),
741
+ byteArrayToCPointer(key, offset, len ),
742
+ len .toULong(),
738
743
valueLength.ptr,
739
744
error
740
745
)?.let {
746
+ val length = valueLength.value.toInt()
747
+
748
+ for (index in 0 until min(length, vLen)) {
749
+ value[index + vOffset] = it[index]
750
+ }
751
+
741
752
rocksdb.rocksdb_free(it)
742
- valueLength.value.toInt()
753
+ length
743
754
}
744
755
} ? : rocksDBNotFound
745
756
}
@@ -1409,7 +1420,7 @@ internal constructor(
1409
1420
val fileName = rocksdb_sst_file_metadata_get_relative_filename(sstMetaData)
1410
1421
val directory = rocksdb_sst_file_metadata_get_directory(sstMetaData)
1411
1422
val smallestKey = rocksdb_sst_file_metadata_get_smallestkey(sstMetaData, smallestKeyLength.ptr)
1412
- val largestKey = rocksdb_sst_file_metadata_get_smallestkey (sstMetaData, largestKeyLength.ptr)
1423
+ val largestKey = rocksdb.rocksdb_sst_file_metadata_get_largestkey (sstMetaData, largestKeyLength.ptr)
1413
1424
add(
1414
1425
SstFileMetaData (
1415
1426
fileName = fileName!! .toKString(),
0 commit comments