Use logger built-in formatter
Change-Id: I6b46309f07ca4c402ae7a51cfb462c1be6bec333
diff --git a/src/main/java/com/googlesource/gerrit/plugins/replication/AutoReloadConfigDecorator.java b/src/main/java/com/googlesource/gerrit/plugins/replication/AutoReloadConfigDecorator.java
index 55c7072..8b6b8fc 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/replication/AutoReloadConfigDecorator.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/replication/AutoReloadConfigDecorator.java
@@ -75,11 +75,9 @@
this.currentConfig = newConfig;
this.currentConfigTs = lastModified;
log.info(
- "Configuration reloaded: "
- + currentConfig.getDestinations(FilterType.ALL).size()
- + " destinations, "
- + discarded
- + " replication events discarded");
+ "Configuration reloaded: {} destinations, {} replication events discarded",
+ currentConfig.getDestinations(FilterType.ALL).size(),
+ discarded);
}
}
} catch (Exception e) {
diff --git a/src/main/java/com/googlesource/gerrit/plugins/replication/Destination.java b/src/main/java/com/googlesource/gerrit/plugins/replication/Destination.java
index f8e2d7b..b2dd382 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/replication/Destination.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/replication/Destination.java
@@ -121,7 +121,7 @@
builder.add(g.getUUID());
addRecursiveParents(g.getUUID(), builder, groupIncludeCache);
} else {
- repLog.warn(String.format("Group \"%s\" not recognized, removing from authGroup", name));
+ repLog.warn("Group \"{}\" not recognized, removing from authGroup", name);
}
}
remoteUser = replicationUserFactory.create(new ListGroupMembership(builder.build()));
@@ -201,7 +201,7 @@
int cnt = 0;
if (pool != null) {
for (Runnable r : pool.getQueue()) {
- repLog.warn(String.format("Cancelling replication event %s", r));
+ repLog.warn("Cancelling replication event {}", r);
}
cnt = pool.shutdownNow().size();
pool.unregisterWorkQueue();
@@ -505,8 +505,7 @@
} else if (remoteNameStyle.equals("basenameOnly")) {
name = FilenameUtils.getBaseName(name);
} else if (!remoteNameStyle.equals("slash")) {
- repLog.debug(
- String.format("Unknown remoteNameStyle: %s, falling back to slash", remoteNameStyle));
+ repLog.debug("Unknown remoteNameStyle: {}, falling back to slash", remoteNameStyle);
}
String replacedPath =
ReplicationQueue.replaceName(uri.getPath(), name, isSingleProjectMatch());
diff --git a/src/main/java/com/googlesource/gerrit/plugins/replication/PushOne.java b/src/main/java/com/googlesource/gerrit/plugins/replication/PushOne.java
index 525c990..8f61bfa 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/replication/PushOne.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/replication/PushOne.java
@@ -220,10 +220,10 @@
if (ALL_REFS.equals(ref)) {
delta.clear();
pushAllRefs = true;
- repLog.trace("Added all refs for replication to " + uri);
+ repLog.trace("Added all refs for replication to {}", uri);
} else if (!pushAllRefs) {
delta.add(ref);
- repLog.trace("Added ref " + ref + " for replication to " + uri);
+ repLog.trace("Added ref {} for replication to {}", ref, uri);
}
}
@@ -307,13 +307,13 @@
if (!pool.requestRunway(this)) {
if (!canceled) {
repLog.info(
- "Rescheduling replication to " + uri + " to avoid collision with an in-flight push.");
+ "Rescheduling replication to {} to avoid collision with an in-flight push.", uri);
pool.reschedule(this, Destination.RetryReason.COLLISION);
}
return;
}
- repLog.info("Replication to " + uri + " started...");
+ repLog.info("Replication to {} started...", uri);
Timer1.Context context = metrics.start(config.getName());
try {
long startedAt = context.getStartTime();
@@ -323,15 +323,11 @@
runImpl();
long elapsed = NANOSECONDS.toMillis(context.stop());
repLog.info(
- "Replication to "
- + uri
- + " completed in "
- + (elapsed)
- + "ms, "
- + (delay)
- + "ms delay, "
- + retryCount
- + " retries");
+ "Replication to {} completed in {}ms, {}ms delay, {} retries",
+ uri,
+ elapsed,
+ delay,
+ retryCount);
} catch (RepositoryNotFoundException e) {
stateLog.error(
"Cannot replicate " + projectName + "; Local repository error: " + e.getMessage(),
@@ -345,7 +341,7 @@
if (msg.contains("access denied") || msg.contains("no such repository")) {
createRepository();
} else {
- repLog.error("Cannot replicate " + projectName + "; Remote repository error: " + msg);
+ repLog.error("Cannot replicate {}; Remote repository error: {}", projectName, msg);
}
} catch (NoRemoteRepositoryException e) {
@@ -355,12 +351,12 @@
} catch (TransportException e) {
Throwable cause = e.getCause();
if (cause instanceof JSchException && cause.getMessage().startsWith("UnknownHostKey:")) {
- repLog.error("Cannot replicate to " + uri + ": " + cause.getMessage());
+ repLog.error("Cannot replicate to {}: {}", uri, cause.getMessage());
} else if (e instanceof LockFailureException) {
lockRetryCount++;
// The LockFailureException message contains both URI and reason
// for this failure.
- repLog.error("Cannot replicate to " + e.getMessage());
+ repLog.error("Cannot replicate to {}: {}", uri, e.getMessage());
// The remote push operation should be retried.
if (lockRetryCount <= maxLockRetries) {
@@ -371,16 +367,16 @@
}
} else {
repLog.error(
- "Giving up after "
- + lockRetryCount
- + " of this error during replication to "
- + e.getMessage());
+ "Giving up after {} occurrences of this error: {} during replication to {}",
+ lockRetryCount,
+ e.getMessage(),
+ uri);
}
} else {
if (canceledWhileRunning.get()) {
logCanceledWhileRunningException(e);
} else {
- repLog.error("Cannot replicate to " + uri, e);
+ repLog.error("Cannot replicate to {}", uri, e);
// The remote push operation should be retried.
pool.reschedule(this, Destination.RetryReason.TRANSPORT_ERROR);
}
@@ -398,7 +394,7 @@
}
private void logCanceledWhileRunningException(TransportException e) {
- repLog.info("Cannot replicate to " + uri + "." + " It was canceled while running", e);
+ repLog.info("Cannot replicate to {}. It was canceled while running", uri, e);
}
private void createRepository() {
@@ -406,14 +402,14 @@
try {
Ref head = git.exactRef(Constants.HEAD);
if (replicationQueue.createProject(projectName, head != null ? head.getName() : null)) {
- repLog.warn("Missing repository created; retry replication to " + uri);
+ repLog.warn("Missing repository created; retry replication to {}", uri);
pool.reschedule(this, Destination.RetryReason.REPOSITORY_MISSING);
} else {
repLog.warn(
- "Missing repository could not be created when replicating "
- + uri
- + ". You can only create missing repositories locally, over SSH or when "
- + "using adminUrl in replication.config. See documentation for more information.");
+ "Missing repository could not be created when replicating {}. "
+ + "You can only create missing repositories locally, over SSH or when "
+ + "using adminUrl in replication.config. See documentation for more information.",
+ uri);
}
} catch (IOException ioe) {
stateLog.error(
@@ -448,7 +444,7 @@
return new PushResult();
}
- repLog.info("Push to " + uri + " references: " + todo);
+ repLog.info("Push to {} references: {}", uri, todo);
return tn.push(NullProgressMonitor.INSTANCE, todo);
}
diff --git a/src/main/java/com/googlesource/gerrit/plugins/replication/ReplicationFileBasedConfig.java b/src/main/java/com/googlesource/gerrit/plugins/replication/ReplicationFileBasedConfig.java
index 82e68ed..bec4f20 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/replication/ReplicationFileBasedConfig.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/replication/ReplicationFileBasedConfig.java
@@ -82,11 +82,11 @@
private List<Destination> allDestinations(DestinationFactory destinationFactory)
throws ConfigInvalidException, IOException {
if (!config.getFile().exists()) {
- log.warn("Config file " + config.getFile() + " does not exist; not replicating");
+ log.warn("Config file {} does not exist; not replicating", config.getFile());
return Collections.emptyList();
}
if (config.getFile().length() == 0) {
- log.info("Config file " + config.getFile() + " is empty; not replicating");
+ log.info("Config file {} is empty; not replicating", config.getFile());
return Collections.emptyList();
}
diff --git a/src/main/java/com/googlesource/gerrit/plugins/replication/ReplicationQueue.java b/src/main/java/com/googlesource/gerrit/plugins/replication/ReplicationQueue.java
index 1370bd3..ebf9278 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/replication/ReplicationQueue.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/replication/ReplicationQueue.java
@@ -105,7 +105,7 @@
running = false;
int discarded = config.shutdown();
if (discarded > 0) {
- repLog.warn(String.format("Canceled %d replication events during shutdown", discarded));
+ repLog.warn("Canceled {} replication events during shutdown", discarded);
}
}
@@ -193,19 +193,19 @@
try {
uri = new URIish(url);
} catch (URISyntaxException e) {
- repLog.warn(String.format("adminURL '%s' is invalid: %s", url, e.getMessage()));
+ repLog.warn("adminURL '{}' is invalid: {}", url, e.getMessage());
continue;
}
String path = replaceName(uri.getPath(), projectName.get(), config.isSingleProjectMatch());
if (path == null) {
- repLog.warn(String.format("adminURL %s does not contain ${name}", uri));
+ repLog.warn("adminURL {} does not contain ${name}", uri);
continue;
}
uri = uri.setPath(path);
if (!isSSH(uri)) {
- repLog.warn(String.format("adminURL '%s' is invalid: only SSH is supported", uri));
+ repLog.warn("adminURL '{}' is invalid: only SSH is supported", uri);
continue;
}
@@ -237,11 +237,10 @@
createRemoteSsh(replicateURI, head);
} else {
repLog.warn(
- String.format(
- "Cannot create new project on remote site %s."
- + " Only local paths and SSH URLs are supported"
- + " for remote repository creation",
- replicateURI));
+ "Cannot create new project on remote site {}."
+ + " Only local paths and SSH URLs are supported"
+ + " for remote repository creation",
+ replicateURI);
return false;
}
return true;
@@ -258,7 +257,7 @@
}
repLog.info("Created local repository: {}", uri);
} catch (IOException e) {
- repLog.error(String.format("Error creating local repository %s:\n", uri.getPath()), e);
+ repLog.error("Error creating local repository {}:\n", uri.getPath(), e);
}
}
@@ -274,12 +273,14 @@
repLog.info("Created remote repository: {}", uri);
} catch (IOException e) {
repLog.error(
- String.format(
- "Error creating remote repository at %s:\n"
- + " Exception: %s\n"
- + " Command: %s\n"
- + " Output: %s",
- uri, e, cmd, errStream),
+ "Error creating remote repository at {}:\n"
+ + " Exception: {}\n"
+ + " Command: {}\n"
+ + " Output: {}",
+ uri,
+ e,
+ cmd,
+ errStream,
e);
}
}
@@ -287,17 +288,16 @@
private void deleteProject(URIish replicateURI) {
if (!replicateURI.isRemote()) {
deleteLocally(replicateURI);
- repLog.info("Deleted local repository: " + replicateURI);
+ repLog.info("Deleted local repository: {}", replicateURI);
} else if (isSSH(replicateURI)) {
deleteRemoteSsh(replicateURI);
- repLog.info("Deleted remote repository: " + replicateURI);
+ repLog.info("Deleted remote repository: {}", replicateURI);
} else {
repLog.warn(
- String.format(
- "Cannot delete project on remote site %s."
- + " Only local paths and SSH URLs are supported"
- + " for remote repository deletion",
- replicateURI));
+ "Cannot delete project on remote site {}. "
+ + "Only local paths and SSH URLs are supported"
+ + " for remote repository deletion",
+ replicateURI);
}
}
@@ -305,7 +305,7 @@
try {
recursivelyDelete(new File(uri.getPath()));
} catch (IOException e) {
- repLog.error(String.format("Error deleting local repository %s:\n", uri.getPath()), e);
+ repLog.error("Error deleting local repository {}:\n", uri.getPath(), e);
}
}
@@ -335,12 +335,14 @@
executeRemoteSsh(uri, cmd, errStream);
} catch (IOException e) {
repLog.error(
- String.format(
- "Error deleting remote repository at %s:\n"
- + " Exception: %s\n"
- + " Command: %s\n"
- + " Output: %s",
- uri, e, cmd, errStream),
+ "Error deleting remote repository at {}:\n"
+ + " Exception: {}\n"
+ + " Command: {}\n"
+ + " Output: {}",
+ uri,
+ e,
+ cmd,
+ errStream,
e);
}
}
@@ -352,11 +354,10 @@
updateHeadRemoteSsh(replicateURI, newHead);
} else {
repLog.warn(
- String.format(
- "Cannot update HEAD of project on remote site %s."
- + " Only local paths and SSH URLs are supported"
- + " for remote HEAD update.",
- replicateURI));
+ "Cannot update HEAD of project on remote site {}."
+ + " Only local paths and SSH URLs are supported"
+ + " for remote HEAD update.",
+ replicateURI);
}
}
@@ -369,12 +370,15 @@
executeRemoteSsh(uri, cmd, errStream);
} catch (IOException e) {
repLog.error(
- String.format(
- "Error updating HEAD of remote repository at %s to %s:\n"
- + " Exception: %s\n"
- + " Command: %s\n"
- + " Output: %s",
- uri, newHead, e, cmd, errStream),
+ "Error updating HEAD of remote repository at {} to {}:\n"
+ + " Exception: {}\n"
+ + " Command: {}\n"
+ + " Output: {}",
+ uri,
+ newHead,
+ e,
+ cmd,
+ errStream,
e);
}
}
@@ -386,8 +390,7 @@
u.link(newHead);
}
} catch (IOException e) {
- repLog.error(
- String.format("Failed to update HEAD of repository %s to %s", uri.getPath(), newHead), e);
+ repLog.error("Failed to update HEAD of repository {} to {}", uri.getPath(), newHead, e);
}
}
