stepus53/dhfs
1
0
Fork 0
mirror of https://github.com/usatiuk/dhfs.git synced 2025-10-29 04:57:48 +01:00
Code Issues Packages Projects Releases Wiki Activity

Dhfs-app: handle empty op push correctly

Browse Source
This commit is contained in:
Stepan Usatiuk
2025-04-24 22:38:01 +02:00
parent f6685f45f9
commit 1965d93f25
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
dhfs-parent/sync-base/src/main/java/com/usatiuk/dhfs/repository/RemoteObjectServiceServerImpl.java
View File

@@ -1,6 +1,5 @@
package com.usatiuk.dhfs.repository;
import com.usatiuk.dhfs.ProtoSerializer;
import com.usatiuk.dhfs.*;
import com.usatiuk.dhfs.persistence.JObjectKeyP;
import com.usatiuk.dhfs.repository.invalidation.Op;
@@ -105,6 +104,11 @@ public class RemoteObjectServiceServerImpl {
}
public Uni<OpPushReply> opPush(PeerId from, OpPushRequest request) {
if (request.getMsgCount() == 0) {
Log.infov("<-- opPush: empty from {0}", from);
return Uni.createFrom().item(OpPushReply.getDefaultInstance());
}
var handles = new ArrayList<TransactionHandle>();
try {
var ops = request.getMsgList().stream().map(opProtoSerializer::deserialize).toList();