diff --git a/enterprise-module/src/main/java/com/inteligr8/alfresco/asie/enterprise/service/ShardDiscoveryService.java b/enterprise-module/src/main/java/com/inteligr8/alfresco/asie/enterprise/service/ShardDiscoveryService.java index 92bf678..cc0bd7e 100644 --- a/enterprise-module/src/main/java/com/inteligr8/alfresco/asie/enterprise/service/ShardDiscoveryService.java +++ b/enterprise-module/src/main/java/com/inteligr8/alfresco/asie/enterprise/service/ShardDiscoveryService.java @@ -50,12 +50,15 @@ public class ShardDiscoveryService implements com.inteligr8.alfresco.asie.spi.Sh for (Entry> flocShard : floc.getValue().entrySet()) { for (ShardState shardState : flocShard.getValue()) { ShardSet shardSet = ShardSet.from(floc.getKey(), shardState); - if (shardSet.getCore().equals(core)) + if (shardSet.getCore().equals(core)) { + this.logger.debug("Found matching shard set: {}: {}", core, shardSet); return shardSet; + } } } } - + + this.logger.trace("Did not find matching shard set: {}", core); return null; } @@ -96,7 +99,8 @@ public class ShardDiscoveryService implements com.inteligr8.alfresco.asie.spi.Sh } } } - + + this.logger.trace("Did not find matching node: {}:{}", nodeHostname, nodePort); return null; } @@ -127,6 +131,7 @@ public class ShardDiscoveryService implements com.inteligr8.alfresco.asie.spi.Sh ShardInstance shardInstance = shardState.getShardInstance(); if (node.equals(SolrHost.from(shardInstance))) { + this.logger.trace("Found shard on node: {}: {}", node, shardInstance.getShard().getInstance()); Map shardStates = setShardStates.get(shardSet); if (shardStates == null) setShardStates.put(shardSet, shardStates = new HashMap<>()); @@ -152,7 +157,9 @@ public class ShardDiscoveryService implements com.inteligr8.alfresco.asie.spi.Sh for (Entry>> floc : flocs.entrySet()) { if (shardMethodSet.contains(floc.getKey().getShardMethod())) { + this.logger.trace("Found qualifying shard method: {}", floc.getKey().getShardMethod()); ShardState shardState = this.extractAnyShardState(floc.getValue()); + this.logger.trace("Found single shard state representing shard method: {}: {}", floc.getKey().getShardMethod(), shardState); shardSets.add(ShardSet.from(floc.getKey(), shardState)); } }