public abstract class org.apache.zookeeper.server.quorum.LearnerMaster extends java.lang.Object
{
private static final org.slf4j.Logger LOG;
private static final java.lang.String MAX_CONCURRENT_SNAPSYNCS;
private static final int DEFAULT_CONCURRENT_SNAPSYNCS;
private static final java.lang.String MAX_CONCURRENT_DIFF_SYNCS;
private static final int DEFAULT_CONCURRENT_DIFF_SYNCS;
private volatile int maxConcurrentSnapSyncs;
private volatile int maxConcurrentDiffSyncs;
private final org.apache.zookeeper.server.quorum.LearnerSyncThrottler learnerSnapSyncThrottler;
private final org.apache.zookeeper.server.quorum.LearnerSyncThrottler learnerDiffSyncThrottler;
public void <init>()
{
org.apache.zookeeper.server.quorum.LearnerMaster v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType v, v;
int v, v, v, v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottler v, v;
v := @this: org.apache.zookeeper.server.quorum.LearnerMaster;
specialinvoke v.<java.lang.Object: void <init>()>();
v = <org.apache.zookeeper.server.quorum.LearnerMaster: int DEFAULT_CONCURRENT_SNAPSYNCS>;
v.<org.apache.zookeeper.server.quorum.LearnerMaster: int maxConcurrentSnapSyncs> = v;
v = <org.apache.zookeeper.server.quorum.LearnerMaster: int DEFAULT_CONCURRENT_DIFF_SYNCS>;
v.<org.apache.zookeeper.server.quorum.LearnerMaster: int maxConcurrentDiffSyncs> = v;
v = new org.apache.zookeeper.server.quorum.LearnerSyncThrottler;
v = v.<org.apache.zookeeper.server.quorum.LearnerMaster: int maxConcurrentSnapSyncs>;
v = <org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType: org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType SNAP>;
specialinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: void <init>(int,org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType)>(v, v);
v.<org.apache.zookeeper.server.quorum.LearnerMaster: org.apache.zookeeper.server.quorum.LearnerSyncThrottler learnerSnapSyncThrottler> = v;
v = new org.apache.zookeeper.server.quorum.LearnerSyncThrottler;
v = v.<org.apache.zookeeper.server.quorum.LearnerMaster: int maxConcurrentDiffSyncs>;
v = <org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType: org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType DIFF>;
specialinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: void <init>(int,org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType)>(v, v);
v.<org.apache.zookeeper.server.quorum.LearnerMaster: org.apache.zookeeper.server.quorum.LearnerSyncThrottler learnerDiffSyncThrottler> = v;
return;
}
public int getMaxConcurrentSnapSyncs()
{
int v;
org.apache.zookeeper.server.quorum.LearnerMaster v;
v := @this: org.apache.zookeeper.server.quorum.LearnerMaster;
v = v.<org.apache.zookeeper.server.quorum.LearnerMaster: int maxConcurrentSnapSyncs>;
return v;
}
public void setMaxConcurrentSnapSyncs(int)
{
org.slf4j.Logger v;
int v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottler v;
java.lang.Integer v;
org.apache.zookeeper.server.quorum.LearnerMaster v;
v := @this: org.apache.zookeeper.server.quorum.LearnerMaster;
v := @parameter: int;
v = <org.apache.zookeeper.server.quorum.LearnerMaster: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Set maxConcurrentSnapSyncs to {}", v);
v.<org.apache.zookeeper.server.quorum.LearnerMaster: int maxConcurrentSnapSyncs> = v;
v = v.<org.apache.zookeeper.server.quorum.LearnerMaster: org.apache.zookeeper.server.quorum.LearnerSyncThrottler learnerSnapSyncThrottler>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: void setMaxConcurrentSyncs(int)>(v);
return;
}
public int getMaxConcurrentDiffSyncs()
{
int v;
org.apache.zookeeper.server.quorum.LearnerMaster v;
v := @this: org.apache.zookeeper.server.quorum.LearnerMaster;
v = v.<org.apache.zookeeper.server.quorum.LearnerMaster: int maxConcurrentDiffSyncs>;
return v;
}
public void setMaxConcurrentDiffSyncs(int)
{
org.slf4j.Logger v;
int v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottler v;
java.lang.Integer v;
org.apache.zookeeper.server.quorum.LearnerMaster v;
v := @this: org.apache.zookeeper.server.quorum.LearnerMaster;
v := @parameter: int;
v = <org.apache.zookeeper.server.quorum.LearnerMaster: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Set maxConcurrentDiffSyncs to {}", v);
v.<org.apache.zookeeper.server.quorum.LearnerMaster: int maxConcurrentDiffSyncs> = v;
v = v.<org.apache.zookeeper.server.quorum.LearnerMaster: org.apache.zookeeper.server.quorum.LearnerSyncThrottler learnerDiffSyncThrottler>;
virtualinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: void setMaxConcurrentSyncs(int)>(v);
return;
}
public org.apache.zookeeper.server.quorum.LearnerSyncThrottler getLearnerSnapSyncThrottler()
{
org.apache.zookeeper.server.quorum.LearnerSyncThrottler v;
org.apache.zookeeper.server.quorum.LearnerMaster v;
v := @this: org.apache.zookeeper.server.quorum.LearnerMaster;
v = v.<org.apache.zookeeper.server.quorum.LearnerMaster: org.apache.zookeeper.server.quorum.LearnerSyncThrottler learnerSnapSyncThrottler>;
return v;
}
public org.apache.zookeeper.server.quorum.LearnerSyncThrottler getLearnerDiffSyncThrottler()
{
org.apache.zookeeper.server.quorum.LearnerSyncThrottler v;
org.apache.zookeeper.server.quorum.LearnerMaster v;
v := @this: org.apache.zookeeper.server.quorum.LearnerMaster;
v = v.<org.apache.zookeeper.server.quorum.LearnerMaster: org.apache.zookeeper.server.quorum.LearnerSyncThrottler learnerDiffSyncThrottler>;
return v;
}
abstract void addLearnerHandler(org.apache.zookeeper.server.quorum.LearnerHandler);
abstract void removeLearnerHandler(org.apache.zookeeper.server.quorum.LearnerHandler);
abstract void waitForEpochAck(long, org.apache.zookeeper.server.quorum.StateSummary) throws java.io.IOException, java.lang.InterruptedException;
abstract void waitForStartup() throws java.lang.InterruptedException;
abstract long getEpochToPropose(long, long) throws java.lang.InterruptedException, java.io.IOException;
abstract org.apache.zookeeper.server.ZKDatabase getZKDatabase();
abstract void waitForNewLeaderAck(long, long) throws java.lang.InterruptedException;
abstract long getLastProposed();
abstract int getCurrentTick();
abstract int syncTimeout();
abstract int getTickOfNextAckDeadline();
abstract int getTickOfInitialAckDeadline();
abstract long getAndDecrementFollowerCounter();
abstract void processAck(long, long, java.net.SocketAddress);
abstract void touch(long, int);
abstract void revalidateSession(org.apache.zookeeper.server.quorum.QuorumPacket, org.apache.zookeeper.server.quorum.LearnerHandler) throws java.io.IOException;
abstract void submitLearnerRequest(org.apache.zookeeper.server.Request);
abstract long startForwarding(org.apache.zookeeper.server.quorum.LearnerHandler, long);
abstract long getQuorumVerifierVersion();
abstract java.lang.String getPeerInfo(long);
abstract byte[] getQuorumVerifierBytes();
abstract org.apache.zookeeper.server.quorum.auth.QuorumAuthServer getQuorumAuthServer();
abstract void registerLearnerHandlerBean(org.apache.zookeeper.server.quorum.LearnerHandler, java.net.Socket);
abstract void unregisterLearnerHandlerBean(org.apache.zookeeper.server.quorum.LearnerHandler);
static void <clinit>()
{
org.slf4j.Logger v, v, v;
java.lang.Integer v, v, v, v;
int v, v, v, v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/zookeeper/server/quorum/LearnerMaster;");
<org.apache.zookeeper.server.quorum.LearnerMaster: org.slf4j.Logger LOG> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer getInteger(java.lang.String,int)>("zookeeper.leader.maxConcurrentSnapSyncs", 10);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
<org.apache.zookeeper.server.quorum.LearnerMaster: int DEFAULT_CONCURRENT_SNAPSYNCS> = v;
v = <org.apache.zookeeper.server.quorum.LearnerMaster: org.slf4j.Logger LOG>;
v = <org.apache.zookeeper.server.quorum.LearnerMaster: int DEFAULT_CONCURRENT_SNAPSYNCS>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("{} = {}", "zookeeper.leader.maxConcurrentSnapSyncs", v);
v = staticinvoke <java.lang.Integer: java.lang.Integer getInteger(java.lang.String,int)>("zookeeper.leader.maxConcurrentDiffSyncs", 100);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
<org.apache.zookeeper.server.quorum.LearnerMaster: int DEFAULT_CONCURRENT_DIFF_SYNCS> = v;
v = <org.apache.zookeeper.server.quorum.LearnerMaster: org.slf4j.Logger LOG>;
v = <org.apache.zookeeper.server.quorum.LearnerMaster: int DEFAULT_CONCURRENT_DIFF_SYNCS>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("{} = {}", "zookeeper.leader.maxConcurrentDiffSyncs", v);
return;
}
}