Skip to content

Commit

Permalink
Fix style
Browse files Browse the repository at this point in the history
  • Loading branch information
Ufuk Yılmaz committed Sep 23, 2021
1 parent 5197eee commit b8cb865
Showing 1 changed file with 4 additions and 2 deletions.
Expand Up @@ -88,6 +88,7 @@
public class ClusterJoinManager {

public static final String STALE_JOIN_PREVENTION_DURATION_PROP = "hazelcast.stale.join.prevention.duration.seconds";
private static final int DEFAULT_STALE_JOIN_PREVENTION_DURATION_IN_SECS = 30;
private static final int CLUSTER_OPERATION_RETRY_COUNT = 100;

private final ILogger logger;
Expand All @@ -113,8 +114,8 @@ public class ClusterJoinManager {
private final ConcurrentMap<UUID, Long> leftMembersUuids = new ConcurrentHashMap<>();
private final long maxWaitMillisBeforeJoin;
private final long waitMillisBeforeJoin;

private final long staleJoinPreventionDurationInMillis;

private long firstJoinRequest;
private long timeToStartJoin;
private volatile boolean joinInProgress;
Expand All @@ -131,7 +132,8 @@ public class ClusterJoinManager {

maxWaitMillisBeforeJoin = node.getProperties().getMillis(ClusterProperty.MAX_WAIT_SECONDS_BEFORE_JOIN);
waitMillisBeforeJoin = node.getProperties().getMillis(ClusterProperty.WAIT_SECONDS_BEFORE_JOIN);
staleJoinPreventionDurationInMillis = TimeUnit.SECONDS.toMillis(Integer.getInteger(STALE_JOIN_PREVENTION_DURATION_PROP, 30));
staleJoinPreventionDurationInMillis = TimeUnit.SECONDS.toMillis(
Integer.getInteger(STALE_JOIN_PREVENTION_DURATION_PROP, DEFAULT_STALE_JOIN_PREVENTION_DURATION_IN_SECS));
}

boolean isJoinInProgress() {
Expand Down

0 comments on commit b8cb865

Please sign in to comment.