class org.apache.zookeeper.server.quorum.LearnerTest$TestLearner extends org.apache.zookeeper.server.quorum.Learner
{
private int passSocketConnectOnAttempt;
private int socketConnectAttempt;
private long timeMultiplier;
private java.net.Socket socketToBeCreated;
private java.util.Set unreachableAddresses;
void <init>()
{
java.util.Set v;
org.apache.zookeeper.server.quorum.LearnerTest$TestLearner v;
v := @this: org.apache.zookeeper.server.quorum.LearnerTest$TestLearner;
specialinvoke v.<org.apache.zookeeper.server.quorum.Learner: void <init>()>();
v.<org.apache.zookeeper.server.quorum.LearnerTest$TestLearner: int passSocketConnectOnAttempt> = 10;
v.<org.apache.zookeeper.server.quorum.LearnerTest$TestLearner: int socketConnectAttempt> = 0;
v.<org.apache.zookeeper.server.quorum.LearnerTest$TestLearner: long timeMultiplier> = 0L;
v.<org.apache.zookeeper.server.quorum.LearnerTest$TestLearner: java.net.Socket socketToBeCreated> = null;
v = staticinvoke <java.util.Collections: java.util.Set emptySet()>();
v.<org.apache.zookeeper.server.quorum.LearnerTest$TestLearner: java.util.Set unreachableAddresses> = v;
return;
}
private void setTimeMultiplier(long)
{
long v;
org.apache.zookeeper.server.quorum.LearnerTest$TestLearner v;
v := @this: org.apache.zookeeper.server.quorum.LearnerTest$TestLearner;
v := @parameter: long;
v.<org.apache.zookeeper.server.quorum.LearnerTest$TestLearner: long timeMultiplier> = v;
return;
}
private void setPassConnectAttempt(int)
{
int v;
org.apache.zookeeper.server.quorum.LearnerTest$TestLearner v;
v := @this: org.apache.zookeeper.server.quorum.LearnerTest$TestLearner;
v := @parameter: int;
v.<org.apache.zookeeper.server.quorum.LearnerTest$TestLearner: int passSocketConnectOnAttempt> = v;
return;
}
protected long nanoTime()
{
int v;
long v, v;
org.apache.zookeeper.server.quorum.LearnerTest$TestLearner v;
v := @this: org.apache.zookeeper.server.quorum.LearnerTest$TestLearner;
v = v.<org.apache.zookeeper.server.quorum.LearnerTest$TestLearner: int socketConnectAttempt>;
v = v.<org.apache.zookeeper.server.quorum.LearnerTest$TestLearner: long timeMultiplier>;
v = v * v;
return v;
}
private int getSockConnectAttempt()
{
int v;
org.apache.zookeeper.server.quorum.LearnerTest$TestLearner v;
v := @this: org.apache.zookeeper.server.quorum.LearnerTest$TestLearner;
v = v.<org.apache.zookeeper.server.quorum.LearnerTest$TestLearner: int socketConnectAttempt>;
return v;
}
private void setSocketToBeCreated(java.net.Socket)
{
java.net.Socket v;
org.apache.zookeeper.server.quorum.LearnerTest$TestLearner v;
v := @this: org.apache.zookeeper.server.quorum.LearnerTest$TestLearner;
v := @parameter: java.net.Socket;
v.<org.apache.zookeeper.server.quorum.LearnerTest$TestLearner: java.net.Socket socketToBeCreated> = v;
return;
}
private void setUnreachableAddresses(java.util.Set)
{
java.util.Set v;
org.apache.zookeeper.server.quorum.LearnerTest$TestLearner v;
v := @this: org.apache.zookeeper.server.quorum.LearnerTest$TestLearner;
v := @parameter: java.util.Set;
v.<org.apache.zookeeper.server.quorum.LearnerTest$TestLearner: java.util.Set unreachableAddresses> = v;
return;
}
protected void sockConnect(java.net.Socket, java.net.InetSocketAddress, int) throws java.io.IOException
{
java.lang.Throwable v;
java.net.Socket v;
java.util.Set v;
java.io.IOException v;
java.net.InetSocketAddress v;
int v, v, v, v;
org.apache.zookeeper.server.quorum.LearnerTest$TestLearner v;
boolean v;
v := @this: org.apache.zookeeper.server.quorum.LearnerTest$TestLearner;
v := @parameter: java.net.Socket;
v := @parameter: java.net.InetSocketAddress;
v := @parameter: int;
entermonitor v;
label:
v = v.<org.apache.zookeeper.server.quorum.LearnerTest$TestLearner: int socketConnectAttempt>;
v = v + 1;
v.<org.apache.zookeeper.server.quorum.LearnerTest$TestLearner: int socketConnectAttempt> = v;
v = v.<org.apache.zookeeper.server.quorum.LearnerTest$TestLearner: int passSocketConnectOnAttempt>;
if v < v goto label;
v = v.<org.apache.zookeeper.server.quorum.LearnerTest$TestLearner: java.util.Set unreachableAddresses>;
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>("Test injected Socket.connect() error.");
throw v;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
protected java.net.Socket createSocket() throws org.apache.zookeeper.common.X509Exception, java.io.IOException
{
java.net.Socket v, v, v;
org.apache.zookeeper.server.quorum.LearnerTest$TestLearner v;
v := @this: org.apache.zookeeper.server.quorum.LearnerTest$TestLearner;
v = v.<org.apache.zookeeper.server.quorum.LearnerTest$TestLearner: java.net.Socket socketToBeCreated>;
if v == null goto label;
v = v.<org.apache.zookeeper.server.quorum.LearnerTest$TestLearner: java.net.Socket socketToBeCreated>;
return v;
label:
v = specialinvoke v.<org.apache.zookeeper.server.quorum.Learner: java.net.Socket createSocket()>();
return v;
}
}