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

trace log getIndex/initial resync

Browse Source
This commit is contained in:
Stepan Usatiuk
2024-07-26 20:53:33 +02:00
parent d6c0120cf5
commit 50a1269b09
2 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -122,8 +122,10 @@ public class RemoteObjectServiceServer implements DhfsObjectSyncGrpc {
var reqUuid = UUID.fromString(request.getSelfUuid());
for (var obj : objs)
for (var obj : objs) {
Log.trace("GI: " + obj.getName() + " to " + reqUuid);
invalidationQueueService.pushInvalidationToOne(reqUuid, obj.getName());
}
return Uni.createFrom().item(GetIndexReply.getDefaultInstance());
}

4
dhfs-parent/server/src/main/java/com/usatiuk/dhfs/objects/repository/SyncHandler.java
View File

@@ -43,8 +43,10 @@ public class SyncHandler {
// they didn't thing we were disconnected
var objs = jObjectManager.findAll();
for (var obj : objs)
for (var obj : objs) {
Log.trace("IS: " + obj.getName() + " to " + host);
invalidationQueueService.pushInvalidationToOne(host, obj.getName());
}
}
public void handleOneUpdate(UUID from, ObjectHeader header) {