public class io.netty.channel.socket.oio.OioServerSocketChannel extends io.netty.channel.oio.AbstractOioMessageChannel implements io.netty.channel.socket.ServerSocketChannel
{
private static final io.netty.util.internal.logging.InternalLogger logger;
private static final io.netty.channel.ChannelMetadata METADATA;
final java.net.ServerSocket socket;
private final io.netty.channel.socket.oio.OioServerSocketChannelConfig config;
private static java.net.ServerSocket newServerSocket()
{
java.net.ServerSocket v;
io.netty.channel.ChannelException v;
java.io.IOException v;
label:
v = new java.net.ServerSocket;
specialinvoke v.<java.net.ServerSocket: void <init>()>();
label:
return v;
label:
v := @caughtexception;
v = new io.netty.channel.ChannelException;
specialinvoke v.<io.netty.channel.ChannelException: void <init>(java.lang.String,java.lang.Throwable)>("failed to create a server socket", v);
throw v;
catch java.io.IOException from label to label with label;
}
public void <init>()
{
io.netty.channel.socket.oio.OioServerSocketChannel v;
java.net.ServerSocket v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
v = staticinvoke <io.netty.channel.socket.oio.OioServerSocketChannel: java.net.ServerSocket newServerSocket()>();
specialinvoke v.<io.netty.channel.socket.oio.OioServerSocketChannel: void <init>(java.net.ServerSocket)>(v);
return;
}
public void <init>(java.net.ServerSocket)
{
java.lang.Throwable v;
java.net.ServerSocket v;
io.netty.channel.ChannelException v;
io.netty.channel.socket.oio.OioServerSocketChannel v;
java.io.IOException v;
io.netty.channel.socket.oio.DefaultOioServerSocketChannelConfig v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
v := @parameter: java.net.ServerSocket;
specialinvoke v.<io.netty.channel.oio.AbstractOioMessageChannel: void <init>(io.netty.channel.Channel)>(null);
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "socket");
label:
virtualinvoke v.<java.net.ServerSocket: void setSoTimeout(int)>(1000);
label:
goto label;
label:
v := @caughtexception;
v = new io.netty.channel.ChannelException;
specialinvoke v.<io.netty.channel.ChannelException: void <init>(java.lang.String,java.lang.Throwable)>("Failed to set the server socket timeout.", v);
throw v;
label:
v := @caughtexception;
throw v;
label:
v.<io.netty.channel.socket.oio.OioServerSocketChannel: java.net.ServerSocket socket> = v;
v = new io.netty.channel.socket.oio.DefaultOioServerSocketChannelConfig;
specialinvoke v.<io.netty.channel.socket.oio.DefaultOioServerSocketChannelConfig: void <init>(io.netty.channel.socket.oio.OioServerSocketChannel,java.net.ServerSocket)>(v, v);
v.<io.netty.channel.socket.oio.OioServerSocketChannel: io.netty.channel.socket.oio.OioServerSocketChannelConfig config> = v;
return;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public java.net.InetSocketAddress localAddress()
{
io.netty.channel.socket.oio.OioServerSocketChannel v;
java.net.SocketAddress v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
v = specialinvoke v.<io.netty.channel.oio.AbstractOioMessageChannel: java.net.SocketAddress localAddress()>();
return v;
}
public io.netty.channel.ChannelMetadata metadata()
{
io.netty.channel.socket.oio.OioServerSocketChannel v;
io.netty.channel.ChannelMetadata v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
v = <io.netty.channel.socket.oio.OioServerSocketChannel: io.netty.channel.ChannelMetadata METADATA>;
return v;
}
public io.netty.channel.socket.oio.OioServerSocketChannelConfig config()
{
io.netty.channel.socket.oio.OioServerSocketChannel v;
io.netty.channel.socket.oio.OioServerSocketChannelConfig v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
v = v.<io.netty.channel.socket.oio.OioServerSocketChannel: io.netty.channel.socket.oio.OioServerSocketChannelConfig config>;
return v;
}
public java.net.InetSocketAddress remoteAddress()
{
io.netty.channel.socket.oio.OioServerSocketChannel v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
return null;
}
public boolean isOpen()
{
java.net.ServerSocket v;
io.netty.channel.socket.oio.OioServerSocketChannel v;
boolean v, v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
v = v.<io.netty.channel.socket.oio.OioServerSocketChannel: java.net.ServerSocket socket>;
v = virtualinvoke v.<java.net.ServerSocket: boolean isClosed()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isActive()
{
java.net.ServerSocket v;
io.netty.channel.socket.oio.OioServerSocketChannel v;
boolean v, v, v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
v = virtualinvoke v.<io.netty.channel.socket.oio.OioServerSocketChannel: boolean isOpen()>();
if v == 0 goto label;
v = v.<io.netty.channel.socket.oio.OioServerSocketChannel: java.net.ServerSocket socket>;
v = virtualinvoke v.<java.net.ServerSocket: boolean isBound()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
protected java.net.SocketAddress localAddress0()
{
io.netty.channel.socket.oio.OioServerSocketChannel v;
java.net.ServerSocket v;
java.net.SocketAddress v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
v = v.<io.netty.channel.socket.oio.OioServerSocketChannel: java.net.ServerSocket socket>;
v = staticinvoke <io.netty.util.internal.SocketUtils: java.net.SocketAddress localSocketAddress(java.net.ServerSocket)>(v);
return v;
}
protected void doBind(java.net.SocketAddress) throws java.lang.Exception
{
java.net.ServerSocket v;
io.netty.channel.socket.oio.OioServerSocketChannelConfig v;
java.net.SocketAddress v;
int v;
io.netty.channel.socket.oio.OioServerSocketChannel v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
v := @parameter: java.net.SocketAddress;
v = v.<io.netty.channel.socket.oio.OioServerSocketChannel: java.net.ServerSocket socket>;
v = v.<io.netty.channel.socket.oio.OioServerSocketChannel: io.netty.channel.socket.oio.OioServerSocketChannelConfig config>;
v = interfaceinvoke v.<io.netty.channel.socket.oio.OioServerSocketChannelConfig: int getBacklog()>();
virtualinvoke v.<java.net.ServerSocket: void bind(java.net.SocketAddress,int)>(v, v);
return;
}
protected void doClose() throws java.lang.Exception
{
io.netty.channel.socket.oio.OioServerSocketChannel v;
java.net.ServerSocket v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
v = v.<io.netty.channel.socket.oio.OioServerSocketChannel: java.net.ServerSocket socket>;
virtualinvoke v.<java.net.ServerSocket: void close()>();
return;
}
protected int doReadMessages(java.util.List) throws java.lang.Exception
{
java.lang.Throwable v;
java.net.Socket v;
io.netty.channel.socket.oio.OioServerSocketChannel v;
java.net.ServerSocket v, v;
java.util.List v;
io.netty.channel.socket.oio.OioSocketChannel v;
io.netty.util.internal.logging.InternalLogger v;
java.net.SocketTimeoutException v;
int v;
boolean v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
v := @parameter: java.util.List;
v = v.<io.netty.channel.socket.oio.OioServerSocketChannel: java.net.ServerSocket socket>;
v = virtualinvoke v.<java.net.ServerSocket: boolean isClosed()>();
if v == 0 goto label;
v = (int) -1;
return v;
label:
v = v.<io.netty.channel.socket.oio.OioServerSocketChannel: java.net.ServerSocket socket>;
v = virtualinvoke v.<java.net.ServerSocket: java.net.Socket accept()>();
label:
v = new io.netty.channel.socket.oio.OioSocketChannel;
specialinvoke v.<io.netty.channel.socket.oio.OioSocketChannel: void <init>(io.netty.channel.Channel,java.net.Socket)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return 1;
label:
v := @caughtexception;
v = <io.netty.channel.socket.oio.OioServerSocketChannel: io.netty.util.internal.logging.InternalLogger logger>;
interfaceinvoke v.<io.netty.util.internal.logging.InternalLogger: void warn(java.lang.String,java.lang.Throwable)>("Failed to create a new channel from an accepted socket.", v);
label:
goto label;
label:
v := @caughtexception;
label:
return 0;
catch java.lang.Throwable from label to label with label;
catch java.net.SocketTimeoutException from label to label with label;
catch java.net.SocketTimeoutException from label to label with label;
}
protected void doWrite(io.netty.channel.ChannelOutboundBuffer) throws java.lang.Exception
{
io.netty.channel.ChannelOutboundBuffer v;
io.netty.channel.socket.oio.OioServerSocketChannel v;
java.lang.UnsupportedOperationException v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
v := @parameter: io.netty.channel.ChannelOutboundBuffer;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
protected java.lang.Object filterOutboundMessage(java.lang.Object) throws java.lang.Exception
{
io.netty.channel.socket.oio.OioServerSocketChannel v;
java.lang.UnsupportedOperationException v;
java.lang.Object v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
v := @parameter: java.lang.Object;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
protected void doConnect(java.net.SocketAddress, java.net.SocketAddress) throws java.lang.Exception
{
java.lang.UnsupportedOperationException v;
java.net.SocketAddress v, v;
io.netty.channel.socket.oio.OioServerSocketChannel v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
v := @parameter: java.net.SocketAddress;
v := @parameter: java.net.SocketAddress;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
protected java.net.SocketAddress remoteAddress0()
{
io.netty.channel.socket.oio.OioServerSocketChannel v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
return null;
}
protected void doDisconnect() throws java.lang.Exception
{
io.netty.channel.socket.oio.OioServerSocketChannel v;
java.lang.UnsupportedOperationException v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
protected void setReadPending(boolean)
{
io.netty.channel.socket.oio.OioServerSocketChannel v;
boolean v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
v := @parameter: boolean;
specialinvoke v.<io.netty.channel.oio.AbstractOioMessageChannel: void setReadPending(boolean)>(v);
return;
}
final void clearReadPending0()
{
io.netty.channel.socket.oio.OioServerSocketChannel v;
v := @this: io.netty.channel.socket.oio.OioServerSocketChannel;
specialinvoke v.<io.netty.channel.oio.AbstractOioMessageChannel: void clearReadPending()>();
return;
}
static void <clinit>()
{
io.netty.channel.ChannelMetadata v;
io.netty.util.internal.logging.InternalLogger v;
v = staticinvoke <io.netty.util.internal.logging.InternalLoggerFactory: io.netty.util.internal.logging.InternalLogger getInstance(java.lang.Class)>(class "Lio/netty/channel/socket/oio/OioServerSocketChannel;");
<io.netty.channel.socket.oio.OioServerSocketChannel: io.netty.util.internal.logging.InternalLogger logger> = v;
v = new io.netty.channel.ChannelMetadata;
specialinvoke v.<io.netty.channel.ChannelMetadata: void <init>(boolean,int)>(0, 1);
<io.netty.channel.socket.oio.OioServerSocketChannel: io.netty.channel.ChannelMetadata METADATA> = v;
return;
}
}