diff options
Diffstat (limited to 'src/main/java/com/googlesource/gerrit/plugins/replication/DestinationConfiguration.java')
-rw-r--r-- | src/main/java/com/googlesource/gerrit/plugins/replication/DestinationConfiguration.java | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/src/main/java/com/googlesource/gerrit/plugins/replication/DestinationConfiguration.java b/src/main/java/com/googlesource/gerrit/plugins/replication/DestinationConfiguration.java index 4b757ea..1b39374 100644 --- a/src/main/java/com/googlesource/gerrit/plugins/replication/DestinationConfiguration.java +++ b/src/main/java/com/googlesource/gerrit/plugins/replication/DestinationConfiguration.java @@ -31,7 +31,7 @@ public class DestinationConfiguration implements RemoteConfiguration { private final int rescheduleDelay; private final int retryDelay; private final int drainQueueAttempts; - private final int lockErrorMaxRetries; + private final int updateRefErrorMaxRetries; private final ImmutableList<String> adminUrls; private final int poolThreads; private final boolean createMissingRepos; @@ -60,8 +60,11 @@ public class DestinationConfiguration implements RemoteConfiguration { Math.max(0, getInt(remoteConfig, cfg, "drainQueueAttempts", DEFAULT_DRAIN_QUEUE_ATTEMPTS)); poolThreads = Math.max(0, getInt(remoteConfig, cfg, "threads", 1)); authGroupNames = ImmutableList.copyOf(cfg.getStringList("remote", name, "authGroup")); - lockErrorMaxRetries = cfg.getInt("replication", "lockErrorMaxRetries", 0); - + updateRefErrorMaxRetries = + cfg.getInt( + "replication", + "updateRefErrorMaxRetries", + cfg.getInt("replication", "lockErrorMaxRetries", 0)); createMissingRepos = cfg.getBoolean("remote", name, "createMissingRepositories", true); replicatePermissions = cfg.getBoolean("remote", name, "replicatePermissions", true); replicateProjectDeletions = cfg.getBoolean("remote", name, "replicateProjectDeletions", false); @@ -106,8 +109,8 @@ public class DestinationConfiguration implements RemoteConfiguration { return poolThreads; } - public int getLockErrorMaxRetries() { - return lockErrorMaxRetries; + public int getUpdateRefErrorMaxRetries() { + return updateRefErrorMaxRetries; } @Override |