diff --git a/envoy-control-core/src/main/java/pl/allegro/tech/servicemesh/envoycontrol/SimpleCache.java b/envoy-control-core/src/main/java/pl/allegro/tech/servicemesh/envoycontrol/SimpleCache.java index 31a84d39c..4cfbfdd26 100644 --- a/envoy-control-core/src/main/java/pl/allegro/tech/servicemesh/envoycontrol/SimpleCache.java +++ b/envoy-control-core/src/main/java/pl/allegro/tech/servicemesh/envoycontrol/SimpleCache.java @@ -188,7 +188,7 @@ public DeltaWatch createDeltaWatch( request.getTypeUrl()); T group; group = groups.hash(request.v3Request().getNode()); - + request.v3Request().getNode().getId() // even though we're modifying, we take a readLock to allow multiple watches to be created in parallel since it // doesn't conflict readLock.lock(); @@ -213,7 +213,7 @@ public DeltaWatch createDeltaWatch( openWatch(status, watch, request.getTypeUrl(), watch.trackedResources().keySet(), group, requesterVersion); return watch; } - LOGGER.info("KSKSKS: version {}, requeterVersion {}", version, requesterVersion); + LOGGER.info("KSKSKS: version {}, requeterVersion {}, id {}, cluster {}", version, requesterVersion, request.v3Request().getNode().getId(), request.v3Request().getNode().getCluster()); // If the requested version is up-to-date or missing a response, leave an open watch. if (version.equals(requesterVersion)) { // If the request is not wildcard, we have pending resources and we have them, we should respond immediately.