public class org.apache.zookeeper.TestableZooKeeper extends org.apache.zookeeper.admin.ZooKeeperAdmin
{
public void <init>(java.lang.String, int, org.apache.zookeeper.Watcher) throws java.io.IOException
{
org.apache.zookeeper.TestableZooKeeper v;
org.apache.zookeeper.Watcher v;
int v;
java.lang.String v;
v := @this: org.apache.zookeeper.TestableZooKeeper;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: org.apache.zookeeper.Watcher;
specialinvoke v.<org.apache.zookeeper.admin.ZooKeeperAdmin: void <init>(java.lang.String,int,org.apache.zookeeper.Watcher)>(v, v, v);
return;
}
public void setXid(int)
{
int v;
org.apache.zookeeper.ClientCnxn v;
org.apache.zookeeper.TestableZooKeeper v;
v := @this: org.apache.zookeeper.TestableZooKeeper;
v := @parameter: int;
v = v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.ClientCnxn cnxn>;
v.<org.apache.zookeeper.ClientCnxn: int xid> = v;
return;
}
public int checkXid()
{
int v;
org.apache.zookeeper.ClientCnxn v;
org.apache.zookeeper.TestableZooKeeper v;
v := @this: org.apache.zookeeper.TestableZooKeeper;
v = v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.ClientCnxn cnxn>;
v = v.<org.apache.zookeeper.ClientCnxn: int xid>;
return v;
}
public void testableConnloss() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.zookeeper.ClientCnxn$SendThread v;
org.apache.zookeeper.TestableZooKeeper v;
org.apache.zookeeper.ClientCnxn v, v;
v := @this: org.apache.zookeeper.TestableZooKeeper;
v = v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.ClientCnxn cnxn>;
entermonitor v;
label:
v = v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.ClientCnxn cnxn>;
v = v.<org.apache.zookeeper.ClientCnxn: org.apache.zookeeper.ClientCnxn$SendThread sendThread>;
virtualinvoke v.<org.apache.zookeeper.ClientCnxn$SendThread: void testableCloseSocket()>();
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public boolean pauseCnxn(long)
{
java.util.concurrent.TimeUnit v;
java.util.concurrent.CountDownLatch v;
org.apache.zookeeper.TestableZooKeeper v;
java.lang.InterruptedException v;
long v;
boolean v;
org.apache.zookeeper.TestableZooKeeper$1 v;
v := @this: org.apache.zookeeper.TestableZooKeeper;
v := @parameter: long;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = new org.apache.zookeeper.TestableZooKeeper$1;
specialinvoke v.<org.apache.zookeeper.TestableZooKeeper$1: void <init>(org.apache.zookeeper.TestableZooKeeper,java.util.concurrent.CountDownLatch,long)>(v, v, v);
virtualinvoke v.<org.apache.zookeeper.TestableZooKeeper$1: void start()>();
label:
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(v, v);
label:
return v;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.InterruptedException: void printStackTrace()>();
return 0;
catch java.lang.InterruptedException from label to label with label;
}
public java.net.SocketAddress testableLocalSocketAddress()
{
java.net.SocketAddress v;
org.apache.zookeeper.TestableZooKeeper v;
v := @this: org.apache.zookeeper.TestableZooKeeper;
v = specialinvoke v.<org.apache.zookeeper.admin.ZooKeeperAdmin: java.net.SocketAddress testableLocalSocketAddress()>();
return v;
}
public java.net.SocketAddress testableRemoteSocketAddress()
{
java.net.SocketAddress v;
org.apache.zookeeper.TestableZooKeeper v;
v := @this: org.apache.zookeeper.TestableZooKeeper;
v = specialinvoke v.<org.apache.zookeeper.admin.ZooKeeperAdmin: java.net.SocketAddress testableRemoteSocketAddress()>();
return v;
}
public long testableLastZxid()
{
org.apache.zookeeper.ClientCnxn v;
long v;
org.apache.zookeeper.TestableZooKeeper v;
v := @this: org.apache.zookeeper.TestableZooKeeper;
v = v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.ClientCnxn cnxn>;
v = virtualinvoke v.<org.apache.zookeeper.ClientCnxn: long getLastZxid()>();
return v;
}
public org.apache.zookeeper.proto.ReplyHeader submitRequest(org.apache.zookeeper.proto.RequestHeader, org.apache.jute.Record, org.apache.jute.Record, org.apache.zookeeper.ZooKeeper$WatchRegistration) throws java.lang.InterruptedException
{
org.apache.zookeeper.proto.RequestHeader v;
org.apache.zookeeper.TestableZooKeeper v;
org.apache.zookeeper.ZooKeeper$WatchRegistration v;
org.apache.zookeeper.ClientCnxn v;
org.apache.jute.Record v, v;
org.apache.zookeeper.proto.ReplyHeader v;
v := @this: org.apache.zookeeper.TestableZooKeeper;
v := @parameter: org.apache.zookeeper.proto.RequestHeader;
v := @parameter: org.apache.jute.Record;
v := @parameter: org.apache.jute.Record;
v := @parameter: org.apache.zookeeper.ZooKeeper$WatchRegistration;
v = v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.ClientCnxn cnxn>;
v = virtualinvoke v.<org.apache.zookeeper.ClientCnxn: org.apache.zookeeper.proto.ReplyHeader submitRequest(org.apache.zookeeper.proto.RequestHeader,org.apache.jute.Record,org.apache.jute.Record,org.apache.zookeeper.ZooKeeper$WatchRegistration)>(v, v, v, v);
return v;
}
public void disconnect()
{
org.apache.zookeeper.ClientCnxn v;
org.apache.zookeeper.TestableZooKeeper v;
v := @this: org.apache.zookeeper.TestableZooKeeper;
v = v.<org.apache.zookeeper.TestableZooKeeper: org.apache.zookeeper.ClientCnxn cnxn>;
virtualinvoke v.<org.apache.zookeeper.ClientCnxn: void disconnect()>();
return;
}
}