Bugfixes
This commit is contained in:
parent
2a5e90d667
commit
1a64d98697
@ -644,6 +644,9 @@ public class LLUtils {
|
|||||||
@Nullable
|
@Nullable
|
||||||
public static ByteBuffer asReadOnlyDirect(Buffer inputBuffer) {
|
public static ByteBuffer asReadOnlyDirect(Buffer inputBuffer) {
|
||||||
var bytes = inputBuffer.readableBytes();
|
var bytes = inputBuffer.readableBytes();
|
||||||
|
if (bytes == 0) {
|
||||||
|
return EMPTY_BYTE_BUFFER;
|
||||||
|
}
|
||||||
if (inputBuffer instanceof ReadableComponent rc) {
|
if (inputBuffer instanceof ReadableComponent rc) {
|
||||||
var componentBuffer = rc.readableBuffer();
|
var componentBuffer = rc.readableBuffer();
|
||||||
if (componentBuffer != null && componentBuffer.isDirect()) {
|
if (componentBuffer != null && componentBuffer.isDirect()) {
|
||||||
|
@ -322,8 +322,8 @@ public class DatabaseMapDictionaryDeep<T, U, US extends DatabaseStage<U>> extend
|
|||||||
.subStage(dictionary, snapshot, Mono.fromCallable(() -> groupKeyWithoutExtSend.copy().send()))
|
.subStage(dictionary, snapshot, Mono.fromCallable(() -> groupKeyWithoutExtSend.copy().send()))
|
||||||
.<Entry<T, US>>handle((us, sink) -> {
|
.<Entry<T, US>>handle((us, sink) -> {
|
||||||
T deserializedSuffix;
|
T deserializedSuffix;
|
||||||
try {
|
try (var splittedGroupSuffix = splitGroupSuffix(groupKeyWithoutExtSend)) {
|
||||||
deserializedSuffix = this.deserializeSuffix(splitGroupSuffix(groupKeyWithoutExtSend));
|
deserializedSuffix = this.deserializeSuffix(splittedGroupSuffix);
|
||||||
sink.next(Map.entry(deserializedSuffix, us));
|
sink.next(Map.entry(deserializedSuffix, us));
|
||||||
} catch (SerializationException ex) {
|
} catch (SerializationException ex) {
|
||||||
sink.error(ex);
|
sink.error(ex);
|
||||||
|
Loading…
Reference in New Issue
Block a user