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

handle deleted objects in getObject pushedMoves

Browse Source
This commit is contained in:
Stepan Usatiuk
2024-07-31 18:29:13 +02:00
parent 8e33dae303
commit 81de8084a7
1 changed files with 15 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
dhfs-parent/server/src/main/java/com/usatiuk/dhfs/objects/repository/RemoteObjectServiceServer.java
View File

@@ -80,13 +80,22 @@ public class RemoteObjectServiceServer implements DhfsObjectSyncGrpc {
continue;
}
builder.addPushedMoves(PushedMove.newBuilder()
.setParent((ObjectHeader) obj.get().runReadLocked(JObject.ResolutionStrategy.NO_RESOLUTION, (m, d) -> {
if (m.getKnownClass().isAnnotationPresent(PushResolution.class))
throw new NotImplementedException();
ObjectHeader header;
return m.toRpcHeader();
}))
try {
header = obj.get().runReadLocked(JObject.ResolutionStrategy.NO_RESOLUTION, (m, d) -> {
if (m.getKnownClass().isAnnotationPresent(PushResolution.class))
throw new NotImplementedException();
return m.toRpcHeader();
});
} catch (DeletedObjectAccessException e) {
it.remove();
continue;
}
builder.addPushedMoves(PushedMove.newBuilder()
.setParent(header)
.setKid(next.child())
.build());
}