public class oadd.org.apache.zookeeper.server.quorum.PrependableSocket extends java.net.Socket
{
private java.io.PushbackInputStream pushbackInputStream;
public void <init>(java.net.SocketImpl) throws java.io.IOException
{
java.net.SocketImpl v;
oadd.org.apache.zookeeper.server.quorum.PrependableSocket v;
v := @this: oadd.org.apache.zookeeper.server.quorum.PrependableSocket;
v := @parameter: java.net.SocketImpl;
specialinvoke v.<java.net.Socket: void <init>(java.net.SocketImpl)>(v);
return;
}
public java.io.InputStream getInputStream() throws java.io.IOException
{
java.io.PushbackInputStream v, v;
oadd.org.apache.zookeeper.server.quorum.PrependableSocket v;
java.io.InputStream v;
v := @this: oadd.org.apache.zookeeper.server.quorum.PrependableSocket;
v = v.<oadd.org.apache.zookeeper.server.quorum.PrependableSocket: java.io.PushbackInputStream pushbackInputStream>;
if v != null goto label;
v = specialinvoke v.<java.net.Socket: java.io.InputStream getInputStream()>();
return v;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.PrependableSocket: java.io.PushbackInputStream pushbackInputStream>;
return v;
}
public void prependToInputStream(byte[], int, int) throws java.io.IOException
{
byte[] v;
java.io.PushbackInputStream v, v;
oadd.org.apache.zookeeper.server.quorum.PrependableSocket v;
java.io.IOException v;
int v, v;
java.io.InputStream v;
v := @this: oadd.org.apache.zookeeper.server.quorum.PrependableSocket;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
if v != 0 goto label;
return;
label:
v = v.<oadd.org.apache.zookeeper.server.quorum.PrependableSocket: java.io.PushbackInputStream pushbackInputStream>;
if v == null goto label;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>("prependToInputStream() called more than once");
throw v;
label:
v = new java.io.PushbackInputStream;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.PrependableSocket: java.io.InputStream getInputStream()>();
specialinvoke v.<java.io.PushbackInputStream: void <init>(java.io.InputStream,int)>(v, v);
virtualinvoke v.<java.io.PushbackInputStream: void unread(byte[],int,int)>(v, v, v);
v.<oadd.org.apache.zookeeper.server.quorum.PrependableSocket: java.io.PushbackInputStream pushbackInputStream> = v;
return;
}
}