package org.ehcache.clustered.common.internal.messages;
import java.util.HashSet;
import java.util.Set;
public class ClusterTierReconnectMessage {
private final Set<Long> hashInvalidationsInProgress;
private boolean clearInProgress = false;
private final Set<Long> locksHeld;
public ClusterTierReconnectMessage() {
hashInvalidationsInProgress = new HashSet<>();
locksHeld = new HashSet<>();
}
public ClusterTierReconnectMessage(Set<Long> hashInvalidationsInProgress, Set<Long> locksHeld, boolean clearInProgress) {
this.hashInvalidationsInProgress = hashInvalidationsInProgress;
this.locksHeld = locksHeld;
this.clearInProgress = clearInProgress;
}
public void addInvalidationsInProgress(Set<Long> hashInvalidationsInProgress) {
this.hashInvalidationsInProgress.addAll(hashInvalidationsInProgress);
}
public void addLocksHeld(Set<Long> locksHeld) {
this.locksHeld.addAll(locksHeld);
}
public Set<Long> getInvalidationsInProgress() {
return hashInvalidationsInProgress;
}
public void clearInProgress() {
clearInProgress = true;
}
public boolean isClearInProgress() {
return clearInProgress;
}
public Set<Long> getLocksHeld() {
return locksHeld;
}
}