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

Server: use formatter for logs in grpc server

Browse Source
This commit is contained in:
Stepan Usatiuk
2025-04-01 12:53:21 +02:00
parent b872c32a05
commit 68111a0c4f
2 changed files with 6 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
dhfs-parent/server/src/main/java/com/usatiuk/dhfs/repository/RemoteObjectServiceServerImpl.java
View File

@@ -72,9 +72,7 @@ public class RemoteObjectServiceServerImpl {
}
public Uni<CanDeleteReply> canDelete(PeerId from, CanDeleteRequest request) {
var peerId = from;
Log.info("<-- canDelete: " + request.getName() + " from " + peerId);
Log.infov("<-- canDelete: {0} from {1}", request, from);
var builder = CanDeleteReply.newBuilder();
@@ -96,7 +94,7 @@ public class RemoteObjectServiceServerImpl {
}
if (!builder.getDeletionCandidate()) {
Log.infov("Not deletion candidate: {0}, {1} (asked from {2})", obj, builder, peerId);
Log.infov("Not deletion candidate: {0}, {1} (asked from {2})", obj, builder, from);
}
});
return Uni.createFrom().item(builder.build());
@@ -106,7 +104,7 @@ public class RemoteObjectServiceServerImpl {
try {
var ops = request.getMsgList().stream().map(opProtoSerializer::deserialize).toList();
for (var op : ops) {
Log.info("<-- op: " + op + " from " + from);
Log.infov("<-- opPush: {0} from {1}", op, from);
txm.run(() -> {
opHandler.handleOp(from, op);
});

6
dhfs-parent/server/src/main/java/com/usatiuk/dhfs/repository/invalidation/InvalidationQueueService.java
View File

@@ -143,8 +143,8 @@ public class InvalidationQueueService {
locks.add(lock);
try {
var prepared = opPusher.preparePush(e);
ops.putAll(e.peer(), prepared.getLeft());
commits.putAll(e.peer(), prepared.getRight());
ops.get(e.peer()).addAll(prepared.getLeft());
commits.get(e.peer()).addAll(prepared.getRight());
success++;
} catch (Exception ex) {
Log.warnv("Failed to prepare invalidation to {0}, will retry: {1}", e, ex);
@@ -158,7 +158,7 @@ public class InvalidationQueueService {
for (var p : ops.keySet()) {
var list = ops.get(p);
Log.debugv("Pushing invalidations to {0}: {1}", p, list);
Log.infov("Pushing invalidations to {0}: {1}", p, list);
remoteObjectServiceClient.pushOps(p, list);
commits.get(p).forEach(Runnable::run);
}