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

Revert "handle deleted objects in getObject pushedMoves"

Browse Source 
This reverts commit 81de8084a7.
This commit is contained in:
Stepan Usatiuk
2024-08-02 10:27:07 +02:00
parent 256f21a6e7
commit 3333151677
1 changed files with 6 additions and 15 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,22 +80,13 @@ public class RemoteObjectServiceServer implements DhfsObjectSyncGrpc {
continue;
}
ObjectHeader header;
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)
.setParent((ObjectHeader) obj.get().runReadLocked(JObject.ResolutionStrategy.NO_RESOLUTION, (m, d) -> {
if (m.getKnownClass().isAnnotationPresent(PushResolution.class))
throw new NotImplementedException();
return m.toRpcHeader();
}))
.setKid(next.child())
.build());
}