public interface  io.vertx.core.spi.transport.Transport extends java.lang.Object
{
public static final int ACCEPTOR_EVENT_LOOP_GROUP;
public static final int IO_EVENT_LOOP_GROUP;
public boolean supportsDomainSockets()
{
io.vertx.core.spi.transport.Transport v;
v := @this: io.vertx.core.spi.transport.Transport;
return 0;
}
public boolean supportFileRegion()
{
io.vertx.core.spi.transport.Transport v;
v := @this: io.vertx.core.spi.transport.Transport;
return 1;
}
public boolean isAvailable()
{
io.vertx.core.spi.transport.Transport v;
v := @this: io.vertx.core.spi.transport.Transport;
return 1;
}
public java.lang.Throwable unavailabilityCause()
{
io.vertx.core.spi.transport.Transport v;
v := @this: io.vertx.core.spi.transport.Transport;
return null;
}
public java.net.SocketAddress convert(io.vertx.core.net.SocketAddress)
{
java.lang.IllegalArgumentException v;
java.net.InetSocketAddress v, v;
io.vertx.core.spi.transport.Transport v;
java.net.InetAddress v;
int v, v;
java.lang.String v;
boolean v;
io.vertx.core.net.SocketAddress v;
v := @this: io.vertx.core.spi.transport.Transport;
v := @parameter: io.vertx.core.net.SocketAddress;
v = interfaceinvoke v.<io.vertx.core.net.SocketAddress: boolean isDomainSocket()>();
if v == 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Domain socket are not supported by JDK transport, you need to use native transport to use them");
throw v;
label:
v = virtualinvoke v.<io.vertx.core.net.impl.SocketAddressImpl: java.net.InetAddress ipAddress()>();
if v == null goto label;
v = new java.net.InetSocketAddress;
v = interfaceinvoke v.<io.vertx.core.net.SocketAddress: int port()>();
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.net.InetAddress,int)>(v, v);
return v;
label:
v = interfaceinvoke v.<io.vertx.core.net.SocketAddress: java.lang.String host()>();
v = interfaceinvoke v.<io.vertx.core.net.SocketAddress: int port()>();
v = staticinvoke <java.net.InetSocketAddress: java.net.InetSocketAddress createUnresolved(java.lang.String,int)>(v, v);
return v;
}
public io.vertx.core.net.SocketAddress convert(java.net.SocketAddress)
{
java.net.SocketAddress v;
io.vertx.core.spi.transport.Transport v;
boolean v;
io.vertx.core.net.SocketAddress v;
v := @this: io.vertx.core.spi.transport.Transport;
v := @parameter: java.net.SocketAddress;
v = v instanceof java.net.InetSocketAddress;
if v == 0 goto label;
v = staticinvoke <io.vertx.core.net.SocketAddress: io.vertx.core.net.SocketAddress inetSocketAddress(java.net.InetSocketAddress)>(v);
return v;
label:
return null;
}
public abstract io.netty.channel.EventLoopGroup eventLoopGroup(int, int, java.util.concurrent.ThreadFactory, int);
public abstract io.netty.channel.socket.DatagramChannel datagramChannel();
public abstract io.netty.channel.socket.DatagramChannel datagramChannel(io.netty.channel.socket.InternetProtocolFamily);
public abstract io.netty.channel.ChannelFactory channelFactory(boolean);
public abstract io.netty.channel.ChannelFactory serverChannelFactory(boolean);
public void configure(io.netty.channel.socket.DatagramChannel, io.vertx.core.datagram.DatagramSocketOptions)
{
io.netty.channel.socket.DatagramChannel v;
io.vertx.core.datagram.DatagramSocketOptions v;
boolean v, v, v, v;
java.net.NetworkInterface v;
io.vertx.core.buffer.impl.PartialPooledByteBufAllocator v;
io.netty.channel.ChannelOption v;
io.vertx.core.spi.transport.Transport v;
java.net.SocketException v;
io.netty.channel.FixedRecvByteBufAllocator v;
io.netty.channel.socket.DatagramChannelConfig v, v, v, v, v, v, v, v, v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Boolean v;
java.lang.String v, v, v, v;
java.lang.IllegalArgumentException v;
v := @this: io.vertx.core.spi.transport.Transport;
v := @parameter: io.netty.channel.socket.DatagramChannel;
v := @parameter: io.vertx.core.datagram.DatagramSocketOptions;
v = interfaceinvoke v.<io.netty.channel.socket.DatagramChannel: io.netty.channel.socket.DatagramChannelConfig config()>();
v = <io.vertx.core.buffer.impl.PartialPooledByteBufAllocator: io.vertx.core.buffer.impl.PartialPooledByteBufAllocator INSTANCE>;
interfaceinvoke v.<io.netty.channel.socket.DatagramChannelConfig: io.netty.channel.socket.DatagramChannelConfig setAllocator(io.netty.buffer.ByteBufAllocator)>(v);
v = virtualinvoke v.<io.vertx.core.datagram.DatagramSocketOptions: int getSendBufferSize()>();
v = (int) -1;
if v == v goto label;
v = interfaceinvoke v.<io.netty.channel.socket.DatagramChannel: io.netty.channel.socket.DatagramChannelConfig config()>();
v = virtualinvoke v.<io.vertx.core.datagram.DatagramSocketOptions: int getSendBufferSize()>();
interfaceinvoke v.<io.netty.channel.socket.DatagramChannelConfig: io.netty.channel.socket.DatagramChannelConfig setSendBufferSize(int)>(v);
label:
v = virtualinvoke v.<io.vertx.core.datagram.DatagramSocketOptions: int getReceiveBufferSize()>();
v = (int) -1;
if v == v goto label;
v = interfaceinvoke v.<io.netty.channel.socket.DatagramChannel: io.netty.channel.socket.DatagramChannelConfig config()>();
v = virtualinvoke v.<io.vertx.core.datagram.DatagramSocketOptions: int getReceiveBufferSize()>();
interfaceinvoke v.<io.netty.channel.socket.DatagramChannelConfig: io.netty.channel.socket.DatagramChannelConfig setReceiveBufferSize(int)>(v);
v = interfaceinvoke v.<io.netty.channel.socket.DatagramChannel: io.netty.channel.socket.DatagramChannelConfig config()>();
v = new io.netty.channel.FixedRecvByteBufAllocator;
v = virtualinvoke v.<io.vertx.core.datagram.DatagramSocketOptions: int getReceiveBufferSize()>();
specialinvoke v.<io.netty.channel.FixedRecvByteBufAllocator: void <init>(int)>(v);
interfaceinvoke v.<io.netty.channel.socket.DatagramChannelConfig: io.netty.channel.socket.DatagramChannelConfig setRecvByteBufAllocator(io.netty.channel.RecvByteBufAllocator)>(v);
label:
v = interfaceinvoke v.<io.netty.channel.socket.DatagramChannel: io.netty.channel.socket.DatagramChannelConfig config()>();
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption SO_REUSEADDR>;
v = virtualinvoke v.<io.vertx.core.datagram.DatagramSocketOptions: boolean isReuseAddress()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
interfaceinvoke v.<io.netty.channel.socket.DatagramChannelConfig: boolean setOption(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
v = virtualinvoke v.<io.vertx.core.datagram.DatagramSocketOptions: int getTrafficClass()>();
v = (int) -1;
if v == v goto label;
v = interfaceinvoke v.<io.netty.channel.socket.DatagramChannel: io.netty.channel.socket.DatagramChannelConfig config()>();
v = virtualinvoke v.<io.vertx.core.datagram.DatagramSocketOptions: int getTrafficClass()>();
interfaceinvoke v.<io.netty.channel.socket.DatagramChannelConfig: io.netty.channel.socket.DatagramChannelConfig setTrafficClass(int)>(v);
label:
v = interfaceinvoke v.<io.netty.channel.socket.DatagramChannel: io.netty.channel.socket.DatagramChannelConfig config()>();
v = virtualinvoke v.<io.vertx.core.datagram.DatagramSocketOptions: boolean isBroadcast()>();
interfaceinvoke v.<io.netty.channel.socket.DatagramChannelConfig: io.netty.channel.socket.DatagramChannelConfig setBroadcast(boolean)>(v);
v = v instanceof io.vertx.core.impl.transports.JDKTransport;
if v == 0 goto label;
v = interfaceinvoke v.<io.netty.channel.socket.DatagramChannel: io.netty.channel.socket.DatagramChannelConfig config()>();
v = virtualinvoke v.<io.vertx.core.datagram.DatagramSocketOptions: boolean isLoopbackModeDisabled()>();
interfaceinvoke v.<io.netty.channel.socket.DatagramChannelConfig: io.netty.channel.socket.DatagramChannelConfig setLoopbackModeDisabled(boolean)>(v);
v = virtualinvoke v.<io.vertx.core.datagram.DatagramSocketOptions: int getMulticastTimeToLive()>();
v = (int) -1;
if v == v goto label;
v = interfaceinvoke v.<io.netty.channel.socket.DatagramChannel: io.netty.channel.socket.DatagramChannelConfig config()>();
v = virtualinvoke v.<io.vertx.core.datagram.DatagramSocketOptions: int getMulticastTimeToLive()>();
interfaceinvoke v.<io.netty.channel.socket.DatagramChannelConfig: io.netty.channel.socket.DatagramChannelConfig setTimeToLive(int)>(v);
label:
v = virtualinvoke v.<io.vertx.core.datagram.DatagramSocketOptions: java.lang.String getMulticastNetworkInterface()>();
if v == null goto label;
label:
v = interfaceinvoke v.<io.netty.channel.socket.DatagramChannel: io.netty.channel.socket.DatagramChannelConfig config()>();
v = virtualinvoke v.<io.vertx.core.datagram.DatagramSocketOptions: java.lang.String getMulticastNetworkInterface()>();
v = staticinvoke <java.net.NetworkInterface: java.net.NetworkInterface getByName(java.lang.String)>(v);
interfaceinvoke v.<io.netty.channel.socket.DatagramChannelConfig: io.netty.channel.socket.DatagramChannelConfig setNetworkInterface(java.net.NetworkInterface)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalArgumentException;
v = virtualinvoke v.<io.vertx.core.datagram.DatagramSocketOptions: java.lang.String getMulticastNetworkInterface()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Could not find network interface with name \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
catch java.net.SocketException from label to label with label;
}
public void configure(io.vertx.core.net.ClientOptionsBase, boolean, io.netty.bootstrap.Bootstrap)
{
java.lang.Integer v, v, v, v, v;
boolean v, v, v, v;
io.netty.channel.ChannelOption v, v, v, v, v, v, v, v, v;
io.vertx.core.spi.transport.Transport v;
io.netty.channel.FixedRecvByteBufAllocator v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Boolean v, v, v;
java.lang.String v, v;
io.netty.bootstrap.Bootstrap v;
io.vertx.core.net.ClientOptionsBase v;
v := @this: io.vertx.core.spi.transport.Transport;
v := @parameter: io.vertx.core.net.ClientOptionsBase;
v := @parameter: boolean;
v := @parameter: io.netty.bootstrap.Bootstrap;
if v != 0 goto label;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption SO_REUSEADDR>;
v = virtualinvoke v.<io.vertx.core.net.ClientOptionsBase: boolean isReuseAddress()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<io.netty.bootstrap.Bootstrap: io.netty.bootstrap.AbstractBootstrap option(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption TCP_NODELAY>;
v = virtualinvoke v.<io.vertx.core.net.ClientOptionsBase: boolean isTcpNoDelay()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<io.netty.bootstrap.Bootstrap: io.netty.bootstrap.AbstractBootstrap option(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption SO_KEEPALIVE>;
v = virtualinvoke v.<io.vertx.core.net.ClientOptionsBase: boolean isTcpKeepAlive()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<io.netty.bootstrap.Bootstrap: io.netty.bootstrap.AbstractBootstrap option(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
label:
v = virtualinvoke v.<io.vertx.core.net.ClientOptionsBase: java.lang.String getLocalAddress()>();
if v == null goto label;
v = virtualinvoke v.<io.vertx.core.net.ClientOptionsBase: java.lang.String getLocalAddress()>();
virtualinvoke v.<io.netty.bootstrap.Bootstrap: io.netty.bootstrap.AbstractBootstrap localAddress(java.lang.String,int)>(v, 0);
label:
v = virtualinvoke v.<io.vertx.core.net.ClientOptionsBase: int getSendBufferSize()>();
v = (int) -1;
if v == v goto label;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption SO_SNDBUF>;
v = virtualinvoke v.<io.vertx.core.net.ClientOptionsBase: int getSendBufferSize()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<io.netty.bootstrap.Bootstrap: io.netty.bootstrap.AbstractBootstrap option(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
label:
v = virtualinvoke v.<io.vertx.core.net.ClientOptionsBase: int getReceiveBufferSize()>();
v = (int) -1;
if v == v goto label;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption SO_RCVBUF>;
v = virtualinvoke v.<io.vertx.core.net.ClientOptionsBase: int getReceiveBufferSize()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<io.netty.bootstrap.Bootstrap: io.netty.bootstrap.AbstractBootstrap option(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption RCVBUF_ALLOCATOR>;
v = new io.netty.channel.FixedRecvByteBufAllocator;
v = virtualinvoke v.<io.vertx.core.net.ClientOptionsBase: int getReceiveBufferSize()>();
specialinvoke v.<io.netty.channel.FixedRecvByteBufAllocator: void <init>(int)>(v);
virtualinvoke v.<io.netty.bootstrap.Bootstrap: io.netty.bootstrap.AbstractBootstrap option(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
label:
v = virtualinvoke v.<io.vertx.core.net.ClientOptionsBase: int getSoLinger()>();
v = (int) -1;
if v == v goto label;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption SO_LINGER>;
v = virtualinvoke v.<io.vertx.core.net.ClientOptionsBase: int getSoLinger()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<io.netty.bootstrap.Bootstrap: io.netty.bootstrap.AbstractBootstrap option(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
label:
v = virtualinvoke v.<io.vertx.core.net.ClientOptionsBase: int getTrafficClass()>();
v = (int) -1;
if v == v goto label;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption IP_TOS>;
v = virtualinvoke v.<io.vertx.core.net.ClientOptionsBase: int getTrafficClass()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<io.netty.bootstrap.Bootstrap: io.netty.bootstrap.AbstractBootstrap option(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption CONNECT_TIMEOUT_MILLIS>;
v = virtualinvoke v.<io.vertx.core.net.ClientOptionsBase: int getConnectTimeout()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<io.netty.bootstrap.Bootstrap: io.netty.bootstrap.AbstractBootstrap option(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
return;
}
public void configure(io.vertx.core.net.NetServerOptions, boolean, io.netty.bootstrap.ServerBootstrap)
{
java.lang.Integer v, v, v, v, v;
boolean v, v, v, v;
io.vertx.core.net.NetServerOptions v;
io.netty.channel.ChannelOption v, v, v, v, v, v, v, v, v;
io.vertx.core.spi.transport.Transport v;
io.netty.channel.FixedRecvByteBufAllocator v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Boolean v, v, v;
io.netty.bootstrap.ServerBootstrap v;
v := @this: io.vertx.core.spi.transport.Transport;
v := @parameter: io.vertx.core.net.NetServerOptions;
v := @parameter: boolean;
v := @parameter: io.netty.bootstrap.ServerBootstrap;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption SO_REUSEADDR>;
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: boolean isReuseAddress()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<io.netty.bootstrap.ServerBootstrap: io.netty.bootstrap.AbstractBootstrap option(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
if v != 0 goto label;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption SO_KEEPALIVE>;
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: boolean isTcpKeepAlive()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<io.netty.bootstrap.ServerBootstrap: io.netty.bootstrap.ServerBootstrap childOption(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption TCP_NODELAY>;
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: boolean isTcpNoDelay()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<io.netty.bootstrap.ServerBootstrap: io.netty.bootstrap.ServerBootstrap childOption(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
label:
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: int getSendBufferSize()>();
v = (int) -1;
if v == v goto label;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption SO_SNDBUF>;
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: int getSendBufferSize()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<io.netty.bootstrap.ServerBootstrap: io.netty.bootstrap.ServerBootstrap childOption(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
label:
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: int getReceiveBufferSize()>();
v = (int) -1;
if v == v goto label;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption SO_RCVBUF>;
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: int getReceiveBufferSize()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<io.netty.bootstrap.ServerBootstrap: io.netty.bootstrap.ServerBootstrap childOption(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption RCVBUF_ALLOCATOR>;
v = new io.netty.channel.FixedRecvByteBufAllocator;
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: int getReceiveBufferSize()>();
specialinvoke v.<io.netty.channel.FixedRecvByteBufAllocator: void <init>(int)>(v);
virtualinvoke v.<io.netty.bootstrap.ServerBootstrap: io.netty.bootstrap.ServerBootstrap childOption(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
label:
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: int getSoLinger()>();
v = (int) -1;
if v == v goto label;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption SO_LINGER>;
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: int getSoLinger()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<io.netty.bootstrap.ServerBootstrap: io.netty.bootstrap.ServerBootstrap childOption(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
label:
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: int getTrafficClass()>();
v = (int) -1;
if v == v goto label;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption IP_TOS>;
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: int getTrafficClass()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<io.netty.bootstrap.ServerBootstrap: io.netty.bootstrap.ServerBootstrap childOption(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
label:
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: int getAcceptBacklog()>();
v = (int) -1;
if v == v goto label;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption SO_BACKLOG>;
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: int getAcceptBacklog()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<io.netty.bootstrap.ServerBootstrap: io.netty.bootstrap.AbstractBootstrap option(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
label:
return;
}
}