Skip to content

Commit

Permalink
Add client hash to debugging
Browse files Browse the repository at this point in the history
  • Loading branch information
HoustonPutman committed Feb 17, 2025
1 parent 278e7c7 commit 1dcfc08
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ public abstract class LBSolrClient extends SolrClient {

public static final String UPDATE_LIVE_SERVER_MESSAGE = "Updated alive server list";

private static final String UPDATE_LIVE_SERVER_LOG = UPDATE_LIVE_SERVER_MESSAGE + ": {}";
private static final String UPDATE_LIVE_SERVER_LOG = UPDATE_LIVE_SERVER_MESSAGE + " for {}: {}";

// defaults
protected static final Set<Integer> RETRY_CODES =
Expand Down Expand Up @@ -431,7 +431,7 @@ protected void updateAliveList() {
.filter(server -> !zombieServers.containsKey(server.baseUrl))
.toArray(ServerWrapper[]::new);
if (log.isDebugEnabled()) {
log.debug(UPDATE_LIVE_SERVER_LOG, Arrays.toString(aliveServerList));
log.debug(UPDATE_LIVE_SERVER_LOG, this, Arrays.toString(aliveServerList));
}
}
}
Expand Down Expand Up @@ -603,7 +603,7 @@ private void startAliveCheckExecutor() {
if (aliveCheckExecutor == null) {
synchronized (this) {
if (aliveCheckExecutor == null) {
log.debug("Starting aliveCheckExecutor");
log.debug("Starting aliveCheckExecutor for {}", this);
aliveCheckExecutor =
Executors.newSingleThreadScheduledExecutor(
new SolrNamedThreadFactory("aliveCheckExecutor"));
Expand Down Expand Up @@ -662,7 +662,7 @@ public RequestWriter getRequestWriter() {

private void checkAZombieServer(ServerWrapper zombieServer) {
try {
log.debug("Checking zombie server {}", zombieServer);
log.debug("Checking zombie server {} for {}", zombieServer, this);
QueryRequest queryRequest = new QueryRequest(solrQuery);
final var responseRaw = doRequest(zombieServer.getBaseUrl(), queryRequest, null);
final var resp = new QueryResponse();
Expand Down

0 comments on commit 1dcfc08

Please sign in to comment.