public final class io.netty.channel.kqueue.KQueueDatagramChannel extends io.netty.channel.kqueue.AbstractKQueueChannel implements io.netty.channel.socket.DatagramChannel
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: io.netty.channel.kqueue.KQueueDatagramChannel
super_class: io.netty.channel.kqueue.AbstractKQueueChannel
{
private static final io.netty.channel.ChannelMetadata METADATA;
descriptor: Lio/netty/channel/ChannelMetadata;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final java.lang.String EXPECTED_TYPES;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private volatile boolean connected;
descriptor: Z
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private final io.netty.channel.kqueue.KQueueDatagramChannelConfig config;
descriptor: Lio/netty/channel/kqueue/KQueueDatagramChannelConfig;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
static final boolean $assertionsDisabled;
descriptor: Z
flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=0, args_size=0
0: ldc Lio/netty/channel/kqueue/KQueueDatagramChannel;
invokevirtual java.lang.Class.desiredAssertionStatus:()Z
ifne 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: putstatic io.netty.channel.kqueue.KQueueDatagramChannel.$assertionsDisabled:Z
3: new io.netty.channel.ChannelMetadata
dup
iconst_1
invokespecial io.netty.channel.ChannelMetadata.<init>:(Z)V
putstatic io.netty.channel.kqueue.KQueueDatagramChannel.METADATA:Lio/netty/channel/ChannelMetadata;
4: new java.lang.StringBuilder
dup
ldc " (expected: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc Lio/netty/channel/socket/DatagramPacket;
invokestatic io.netty.util.internal.StringUtil.simpleClassName:(Ljava/lang/Class;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
5: ldc Lio/netty/channel/AddressedEnvelope;
invokestatic io.netty.util.internal.StringUtil.simpleClassName:(Ljava/lang/Class;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
bipush 60
invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
6: ldc Lio/netty/buffer/ByteBuf;
invokestatic io.netty.util.internal.StringUtil.simpleClassName:(Ljava/lang/Class;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
7: ldc Ljava/net/InetSocketAddress;
invokestatic io.netty.util.internal.StringUtil.simpleClassName:(Ljava/lang/Class;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ">, "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
8: ldc Lio/netty/buffer/ByteBuf;
invokestatic io.netty.util.internal.StringUtil.simpleClassName:(Ljava/lang/Class;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
bipush 41
invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
9: invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
10: putstatic io.netty.channel.kqueue.KQueueDatagramChannel.EXPECTED_TYPES:Ljava/lang/String;
11: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
aconst_null
invokestatic io.netty.channel.kqueue.BsdSocket.newSocketDgram:()Lio/netty/channel/kqueue/BsdSocket;
iconst_0
invokespecial io.netty.channel.kqueue.AbstractKQueueChannel.<init>:(Lio/netty/channel/Channel;Lio/netty/channel/kqueue/BsdSocket;Z)V
1: aload 0
new io.netty.channel.kqueue.KQueueDatagramChannelConfig
dup
aload 0
invokespecial io.netty.channel.kqueue.KQueueDatagramChannelConfig.<init>:(Lio/netty/channel/kqueue/KQueueDatagramChannel;)V
putfield io.netty.channel.kqueue.KQueueDatagramChannel.config:Lio/netty/channel/kqueue/KQueueDatagramChannelConfig;
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
public void <init>(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
new io.netty.channel.kqueue.BsdSocket
dup
iload 1
invokespecial io.netty.channel.kqueue.BsdSocket.<init>:(I)V
iconst_1
invokespecial io.netty.channel.kqueue.KQueueDatagramChannel.<init>:(Lio/netty/channel/kqueue/BsdSocket;Z)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 2 1 fd I
MethodParameters:
Name Flags
fd
void <init>(io.netty.channel.kqueue.BsdSocket, boolean);
descriptor: (Lio/netty/channel/kqueue/BsdSocket;Z)V
flags: (0x0000)
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aconst_null
aload 1
iload 2
invokespecial io.netty.channel.kqueue.AbstractKQueueChannel.<init>:(Lio/netty/channel/Channel;Lio/netty/channel/kqueue/BsdSocket;Z)V
1: aload 0
new io.netty.channel.kqueue.KQueueDatagramChannelConfig
dup
aload 0
invokespecial io.netty.channel.kqueue.KQueueDatagramChannelConfig.<init>:(Lio/netty/channel/kqueue/KQueueDatagramChannel;)V
putfield io.netty.channel.kqueue.KQueueDatagramChannel.config:Lio/netty/channel/kqueue/KQueueDatagramChannelConfig;
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 3 1 socket Lio/netty/channel/kqueue/BsdSocket;
0 3 2 active Z
MethodParameters:
Name Flags
socket
active
public java.net.InetSocketAddress remoteAddress();
descriptor: ()Ljava/net/InetSocketAddress;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial io.netty.channel.kqueue.AbstractKQueueChannel.remoteAddress:()Ljava/net/SocketAddress;
checkcast java.net.InetSocketAddress
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
public java.net.InetSocketAddress localAddress();
descriptor: ()Ljava/net/InetSocketAddress;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial io.netty.channel.kqueue.AbstractKQueueChannel.localAddress:()Ljava/net/SocketAddress;
checkcast java.net.InetSocketAddress
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
public io.netty.channel.ChannelMetadata metadata();
descriptor: ()Lio/netty/channel/ChannelMetadata;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: getstatic io.netty.channel.kqueue.KQueueDatagramChannel.METADATA:Lio/netty/channel/ChannelMetadata;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
public boolean isActive();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.netty.channel.kqueue.KQueueDatagramChannel.socket:Lio/netty/channel/kqueue/BsdSocket;
invokevirtual io.netty.channel.kqueue.BsdSocket.isOpen:()Z
ifeq 3
aload 0
getfield io.netty.channel.kqueue.KQueueDatagramChannel.config:Lio/netty/channel/kqueue/KQueueDatagramChannelConfig;
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannelConfig.getActiveOnOpen:()Z
ifeq 1
aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.isRegistered:()Z
ifne 2
StackMap locals:
StackMap stack:
1: aload 0
getfield io.netty.channel.kqueue.KQueueDatagramChannel.active:Z
ifeq 3
StackMap locals:
StackMap stack:
2: iconst_1
ireturn
StackMap locals:
StackMap stack:
3: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
public boolean isConnected();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.netty.channel.kqueue.KQueueDatagramChannel.connected:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
public io.netty.channel.ChannelFuture joinGroup(java.net.InetAddress);
descriptor: (Ljava/net/InetAddress;)Lio/netty/channel/ChannelFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.newPromise:()Lio/netty/channel/ChannelPromise;
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.joinGroup:(Ljava/net/InetAddress;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 1 1 multicastAddress Ljava/net/InetAddress;
MethodParameters:
Name Flags
multicastAddress
public io.netty.channel.ChannelFuture joinGroup(java.net.InetAddress, io.netty.channel.ChannelPromise);
descriptor: (Ljava/net/InetAddress;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
1: aload 1
2: aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.localAddress:()Ljava/net/InetSocketAddress;
invokevirtual java.net.InetSocketAddress.getAddress:()Ljava/net/InetAddress;
invokestatic java.net.NetworkInterface.getByInetAddress:(Ljava/net/InetAddress;)Ljava/net/NetworkInterface;
3: aconst_null
aload 2
4: invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.joinGroup:(Ljava/net/InetAddress;Ljava/net/NetworkInterface;Ljava/net/InetAddress;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
5: areturn
6: StackMap locals:
StackMap stack: java.net.SocketException
astore 3
start local 3 7: aload 2
aload 3
invokeinterface io.netty.channel.ChannelPromise.setFailure:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelPromise;
pop
end local 3 8: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 9 1 multicastAddress Ljava/net/InetAddress;
0 9 2 promise Lio/netty/channel/ChannelPromise;
7 8 3 e Ljava/net/SocketException;
Exception table:
from to target type
0 5 6 Class java.net.SocketException
MethodParameters:
Name Flags
multicastAddress
promise
public io.netty.channel.ChannelFuture joinGroup(java.net.InetSocketAddress, java.net.NetworkInterface);
descriptor: (Ljava/net/InetSocketAddress;Ljava/net/NetworkInterface;)Lio/netty/channel/ChannelFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.newPromise:()Lio/netty/channel/ChannelPromise;
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.joinGroup:(Ljava/net/InetSocketAddress;Ljava/net/NetworkInterface;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 1 1 multicastAddress Ljava/net/InetSocketAddress;
0 1 2 networkInterface Ljava/net/NetworkInterface;
MethodParameters:
Name Flags
multicastAddress
networkInterface
public io.netty.channel.ChannelFuture joinGroup(java.net.InetSocketAddress, java.net.NetworkInterface, io.netty.channel.ChannelPromise);
descriptor: (Ljava/net/InetSocketAddress;Ljava/net/NetworkInterface;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
invokevirtual java.net.InetSocketAddress.getAddress:()Ljava/net/InetAddress;
aload 2
aconst_null
aload 3
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.joinGroup:(Ljava/net/InetAddress;Ljava/net/NetworkInterface;Ljava/net/InetAddress;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 1 1 multicastAddress Ljava/net/InetSocketAddress;
0 1 2 networkInterface Ljava/net/NetworkInterface;
0 1 3 promise Lio/netty/channel/ChannelPromise;
MethodParameters:
Name Flags
multicastAddress
networkInterface
promise
public io.netty.channel.ChannelFuture joinGroup(java.net.InetAddress, java.net.NetworkInterface, java.net.InetAddress);
descriptor: (Ljava/net/InetAddress;Ljava/net/NetworkInterface;Ljava/net/InetAddress;)Lio/netty/channel/ChannelFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.newPromise:()Lio/netty/channel/ChannelPromise;
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.joinGroup:(Ljava/net/InetAddress;Ljava/net/NetworkInterface;Ljava/net/InetAddress;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 1 1 multicastAddress Ljava/net/InetAddress;
0 1 2 networkInterface Ljava/net/NetworkInterface;
0 1 3 source Ljava/net/InetAddress;
MethodParameters:
Name Flags
multicastAddress
networkInterface
source
public io.netty.channel.ChannelFuture joinGroup(java.net.InetAddress, java.net.NetworkInterface, java.net.InetAddress, io.netty.channel.ChannelPromise);
descriptor: (Ljava/net/InetAddress;Ljava/net/NetworkInterface;Ljava/net/InetAddress;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 1
ifnonnull 2
1: new java.lang.NullPointerException
dup
ldc "multicastAddress"
invokespecial java.lang.NullPointerException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 2
ifnonnull 4
3: new java.lang.NullPointerException
dup
ldc "networkInterface"
invokespecial java.lang.NullPointerException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
aload 4
new java.lang.UnsupportedOperationException
dup
ldc "Multicast not supported"
invokespecial java.lang.UnsupportedOperationException.<init>:(Ljava/lang/String;)V
invokeinterface io.netty.channel.ChannelPromise.setFailure:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelPromise;
pop
5: aload 4
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 6 1 multicastAddress Ljava/net/InetAddress;
0 6 2 networkInterface Ljava/net/NetworkInterface;
0 6 3 source Ljava/net/InetAddress;
0 6 4 promise Lio/netty/channel/ChannelPromise;
MethodParameters:
Name Flags
multicastAddress final
networkInterface final
source final
promise final
public io.netty.channel.ChannelFuture leaveGroup(java.net.InetAddress);
descriptor: (Ljava/net/InetAddress;)Lio/netty/channel/ChannelFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.newPromise:()Lio/netty/channel/ChannelPromise;
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.leaveGroup:(Ljava/net/InetAddress;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 1 1 multicastAddress Ljava/net/InetAddress;
MethodParameters:
Name Flags
multicastAddress
public io.netty.channel.ChannelFuture leaveGroup(java.net.InetAddress, io.netty.channel.ChannelPromise);
descriptor: (Ljava/net/InetAddress;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
1: aload 1
aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.localAddress:()Ljava/net/InetSocketAddress;
invokevirtual java.net.InetSocketAddress.getAddress:()Ljava/net/InetAddress;
invokestatic java.net.NetworkInterface.getByInetAddress:(Ljava/net/InetAddress;)Ljava/net/NetworkInterface;
aconst_null
aload 2
2: invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.leaveGroup:(Ljava/net/InetAddress;Ljava/net/NetworkInterface;Ljava/net/InetAddress;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
3: areturn
4: StackMap locals:
StackMap stack: java.net.SocketException
astore 3
start local 3 5: aload 2
aload 3
invokeinterface io.netty.channel.ChannelPromise.setFailure:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelPromise;
pop
end local 3 6: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 7 1 multicastAddress Ljava/net/InetAddress;
0 7 2 promise Lio/netty/channel/ChannelPromise;
5 6 3 e Ljava/net/SocketException;
Exception table:
from to target type
0 3 4 Class java.net.SocketException
MethodParameters:
Name Flags
multicastAddress
promise
public io.netty.channel.ChannelFuture leaveGroup(java.net.InetSocketAddress, java.net.NetworkInterface);
descriptor: (Ljava/net/InetSocketAddress;Ljava/net/NetworkInterface;)Lio/netty/channel/ChannelFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.newPromise:()Lio/netty/channel/ChannelPromise;
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.leaveGroup:(Ljava/net/InetSocketAddress;Ljava/net/NetworkInterface;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 1 1 multicastAddress Ljava/net/InetSocketAddress;
0 1 2 networkInterface Ljava/net/NetworkInterface;
MethodParameters:
Name Flags
multicastAddress
networkInterface
public io.netty.channel.ChannelFuture leaveGroup(java.net.InetSocketAddress, java.net.NetworkInterface, io.netty.channel.ChannelPromise);
descriptor: (Ljava/net/InetSocketAddress;Ljava/net/NetworkInterface;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
invokevirtual java.net.InetSocketAddress.getAddress:()Ljava/net/InetAddress;
aload 2
aconst_null
aload 3
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.leaveGroup:(Ljava/net/InetAddress;Ljava/net/NetworkInterface;Ljava/net/InetAddress;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 1 1 multicastAddress Ljava/net/InetSocketAddress;
0 1 2 networkInterface Ljava/net/NetworkInterface;
0 1 3 promise Lio/netty/channel/ChannelPromise;
MethodParameters:
Name Flags
multicastAddress
networkInterface
promise
public io.netty.channel.ChannelFuture leaveGroup(java.net.InetAddress, java.net.NetworkInterface, java.net.InetAddress);
descriptor: (Ljava/net/InetAddress;Ljava/net/NetworkInterface;Ljava/net/InetAddress;)Lio/netty/channel/ChannelFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.newPromise:()Lio/netty/channel/ChannelPromise;
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.leaveGroup:(Ljava/net/InetAddress;Ljava/net/NetworkInterface;Ljava/net/InetAddress;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 1 1 multicastAddress Ljava/net/InetAddress;
0 1 2 networkInterface Ljava/net/NetworkInterface;
0 1 3 source Ljava/net/InetAddress;
MethodParameters:
Name Flags
multicastAddress
networkInterface
source
public io.netty.channel.ChannelFuture leaveGroup(java.net.InetAddress, java.net.NetworkInterface, java.net.InetAddress, io.netty.channel.ChannelPromise);
descriptor: (Ljava/net/InetAddress;Ljava/net/NetworkInterface;Ljava/net/InetAddress;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 1
ifnonnull 2
1: new java.lang.NullPointerException
dup
ldc "multicastAddress"
invokespecial java.lang.NullPointerException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 2
ifnonnull 4
3: new java.lang.NullPointerException
dup
ldc "networkInterface"
invokespecial java.lang.NullPointerException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
aload 4
new java.lang.UnsupportedOperationException
dup
ldc "Multicast not supported"
invokespecial java.lang.UnsupportedOperationException.<init>:(Ljava/lang/String;)V
invokeinterface io.netty.channel.ChannelPromise.setFailure:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelPromise;
pop
5: aload 4
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 6 1 multicastAddress Ljava/net/InetAddress;
0 6 2 networkInterface Ljava/net/NetworkInterface;
0 6 3 source Ljava/net/InetAddress;
0 6 4 promise Lio/netty/channel/ChannelPromise;
MethodParameters:
Name Flags
multicastAddress final
networkInterface final
source final
promise final
public io.netty.channel.ChannelFuture block(java.net.InetAddress, java.net.NetworkInterface, java.net.InetAddress);
descriptor: (Ljava/net/InetAddress;Ljava/net/NetworkInterface;Ljava/net/InetAddress;)Lio/netty/channel/ChannelFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.newPromise:()Lio/netty/channel/ChannelPromise;
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.block:(Ljava/net/InetAddress;Ljava/net/NetworkInterface;Ljava/net/InetAddress;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 1 1 multicastAddress Ljava/net/InetAddress;
0 1 2 networkInterface Ljava/net/NetworkInterface;
0 1 3 sourceToBlock Ljava/net/InetAddress;
MethodParameters:
Name Flags
multicastAddress
networkInterface
sourceToBlock
public io.netty.channel.ChannelFuture block(java.net.InetAddress, java.net.NetworkInterface, java.net.InetAddress, io.netty.channel.ChannelPromise);
descriptor: (Ljava/net/InetAddress;Ljava/net/NetworkInterface;Ljava/net/InetAddress;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 1
ifnonnull 2
1: new java.lang.NullPointerException
dup
ldc "multicastAddress"
invokespecial java.lang.NullPointerException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 3
ifnonnull 4
3: new java.lang.NullPointerException
dup
ldc "sourceToBlock"
invokespecial java.lang.NullPointerException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
aload 2
ifnonnull 6
5: new java.lang.NullPointerException
dup
ldc "networkInterface"
invokespecial java.lang.NullPointerException.<init>:(Ljava/lang/String;)V
athrow
6: StackMap locals:
StackMap stack:
aload 4
new java.lang.UnsupportedOperationException
dup
ldc "Multicast not supported"
invokespecial java.lang.UnsupportedOperationException.<init>:(Ljava/lang/String;)V
invokeinterface io.netty.channel.ChannelPromise.setFailure:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelPromise;
pop
7: aload 4
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 8 1 multicastAddress Ljava/net/InetAddress;
0 8 2 networkInterface Ljava/net/NetworkInterface;
0 8 3 sourceToBlock Ljava/net/InetAddress;
0 8 4 promise Lio/netty/channel/ChannelPromise;
MethodParameters:
Name Flags
multicastAddress final
networkInterface final
sourceToBlock final
promise final
public io.netty.channel.ChannelFuture block(java.net.InetAddress, java.net.InetAddress);
descriptor: (Ljava/net/InetAddress;Ljava/net/InetAddress;)Lio/netty/channel/ChannelFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.newPromise:()Lio/netty/channel/ChannelPromise;
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.block:(Ljava/net/InetAddress;Ljava/net/InetAddress;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 1 1 multicastAddress Ljava/net/InetAddress;
0 1 2 sourceToBlock Ljava/net/InetAddress;
MethodParameters:
Name Flags
multicastAddress
sourceToBlock
public io.netty.channel.ChannelFuture block(java.net.InetAddress, java.net.InetAddress, io.netty.channel.ChannelPromise);
descriptor: (Ljava/net/InetAddress;Ljava/net/InetAddress;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
1: aload 1
2: aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.localAddress:()Ljava/net/InetSocketAddress;
invokevirtual java.net.InetSocketAddress.getAddress:()Ljava/net/InetAddress;
invokestatic java.net.NetworkInterface.getByInetAddress:(Ljava/net/InetAddress;)Ljava/net/NetworkInterface;
3: aload 2
aload 3
4: invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.block:(Ljava/net/InetAddress;Ljava/net/NetworkInterface;Ljava/net/InetAddress;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
5: areturn
6: StackMap locals:
StackMap stack: java.lang.Throwable
astore 4
start local 4 7: aload 3
aload 4
invokeinterface io.netty.channel.ChannelPromise.setFailure:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelPromise;
pop
end local 4 8: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 9 1 multicastAddress Ljava/net/InetAddress;
0 9 2 sourceToBlock Ljava/net/InetAddress;
0 9 3 promise Lio/netty/channel/ChannelPromise;
7 8 4 e Ljava/lang/Throwable;
Exception table:
from to target type
0 5 6 Class java.lang.Throwable
MethodParameters:
Name Flags
multicastAddress
sourceToBlock
promise
protected io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe newUnsafe();
descriptor: ()Lio/netty/channel/kqueue/AbstractKQueueChannel$AbstractKQueueUnsafe;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe
dup
aload 0
invokespecial io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe.<init>:(Lio/netty/channel/kqueue/KQueueDatagramChannel;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
protected void doBind(java.net.SocketAddress);
descriptor: (Ljava/net/SocketAddress;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial io.netty.channel.kqueue.AbstractKQueueChannel.doBind:(Ljava/net/SocketAddress;)V
1: aload 0
iconst_1
putfield io.netty.channel.kqueue.KQueueDatagramChannel.active:Z
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 3 1 localAddress Ljava/net/SocketAddress;
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
localAddress
protected void doWrite(io.netty.channel.ChannelOutboundBuffer);
descriptor: (Lio/netty/channel/ChannelOutboundBuffer;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: StackMap locals:
StackMap stack:
aload 1
invokevirtual io.netty.channel.ChannelOutboundBuffer.current:()Ljava/lang/Object;
astore 2
start local 2 1: aload 2
ifnonnull 4
2: aload 0
iconst_0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.writeFilter:(Z)V
3: goto 20
4: StackMap locals: java.lang.Object
StackMap stack:
iconst_0
istore 3
start local 3 5: aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.config:()Lio/netty/channel/kqueue/KQueueDatagramChannelConfig;
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannelConfig.getWriteSpinCount:()I
istore 4
start local 4 6: goto 11
7: StackMap locals: int int
StackMap stack:
aload 0
aload 2
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.doWriteMessage:(Ljava/lang/Object;)Z
ifeq 10
8: iconst_1
istore 3
9: goto 12
10: StackMap locals:
StackMap stack:
iinc 4 -1
StackMap locals:
StackMap stack:
11: iload 4
ifgt 7
end local 4 12: StackMap locals:
StackMap stack:
iload 3
ifeq 15
13: aload 1
invokevirtual io.netty.channel.ChannelOutboundBuffer.remove:()Z
pop
14: goto 0
15: StackMap locals:
StackMap stack:
aload 0
iconst_1
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.writeFilter:(Z)V
16: goto 20
end local 3 17: StackMap locals: io.netty.channel.kqueue.KQueueDatagramChannel io.netty.channel.ChannelOutboundBuffer java.lang.Object
StackMap stack: java.io.IOException
astore 3
start local 3 18: aload 1
aload 3
invokevirtual io.netty.channel.ChannelOutboundBuffer.remove:(Ljava/lang/Throwable;)Z
pop
end local 3 end local 2 19: goto 0
20: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 21 1 in Lio/netty/channel/ChannelOutboundBuffer;
1 19 2 msg Ljava/lang/Object;
5 17 3 done Z
6 12 4 i I
18 19 3 e Ljava/io/IOException;
Exception table:
from to target type
4 16 17 Class java.io.IOException
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
in
private boolean doWriteMessage(java.lang.Object);
descriptor: (Ljava/lang/Object;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=9, args_size=2
start local 0 start local 1 0: aload 1
instanceof io.netty.channel.AddressedEnvelope
ifeq 6
1: aload 1
checkcast io.netty.channel.AddressedEnvelope
2: astore 4
start local 4 3: aload 4
invokeinterface io.netty.channel.AddressedEnvelope.content:()Ljava/lang/Object;
checkcast io.netty.buffer.ByteBuf
astore 2
start local 2 4: aload 4
invokeinterface io.netty.channel.AddressedEnvelope.recipient:()Ljava/net/SocketAddress;
checkcast java.net.InetSocketAddress
astore 3
end local 4 start local 3 5: goto 8
end local 3 end local 2 6: StackMap locals:
StackMap stack:
aload 1
checkcast io.netty.buffer.ByteBuf
astore 2
start local 2 7: aconst_null
astore 3
start local 3 8: StackMap locals: io.netty.buffer.ByteBuf java.net.InetSocketAddress
StackMap stack:
aload 2
invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
istore 4
start local 4 9: iload 4
ifne 11
10: iconst_1
ireturn
11: StackMap locals: int
StackMap stack:
aload 2
invokevirtual io.netty.buffer.ByteBuf.hasMemoryAddress:()Z
ifeq 20
12: aload 2
invokevirtual io.netty.buffer.ByteBuf.memoryAddress:()J
lstore 7
start local 7 13: aload 3
ifnonnull 16
14: aload 0
getfield io.netty.channel.kqueue.KQueueDatagramChannel.socket:Lio/netty/channel/kqueue/BsdSocket;
lload 7
aload 2
invokevirtual io.netty.buffer.ByteBuf.readerIndex:()I
aload 2
invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
invokevirtual io.netty.channel.kqueue.BsdSocket.writeAddress:(JII)I
i2l
lstore 5
start local 5 15: goto 39
end local 5 16: StackMap locals: io.netty.channel.kqueue.KQueueDatagramChannel java.lang.Object io.netty.buffer.ByteBuf java.net.InetSocketAddress int top top long
StackMap stack:
aload 0
getfield io.netty.channel.kqueue.KQueueDatagramChannel.socket:Lio/netty/channel/kqueue/BsdSocket;
lload 7
aload 2
invokevirtual io.netty.buffer.ByteBuf.readerIndex:()I
aload 2
invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
17: aload 3
invokevirtual java.net.InetSocketAddress.getAddress:()Ljava/net/InetAddress;
aload 3
invokevirtual java.net.InetSocketAddress.getPort:()I
18: invokevirtual io.netty.channel.kqueue.BsdSocket.sendToAddress:(JIILjava/net/InetAddress;I)I
i2l
lstore 5
end local 7 start local 5 19: goto 39
end local 5 StackMap locals: io.netty.channel.kqueue.KQueueDatagramChannel java.lang.Object io.netty.buffer.ByteBuf java.net.InetSocketAddress int
StackMap stack:
20: aload 2
invokevirtual io.netty.buffer.ByteBuf.nioBufferCount:()I
iconst_1
if_icmple 32
21: aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.eventLoop:()Lio/netty/channel/EventLoop;
checkcast io.netty.channel.kqueue.KQueueEventLoop
invokevirtual io.netty.channel.kqueue.KQueueEventLoop.cleanArray:()Lio/netty/channel/unix/IovArray;
astore 7
start local 7 22: aload 7
aload 2
invokevirtual io.netty.channel.unix.IovArray.add:(Lio/netty/buffer/ByteBuf;)Z
pop
23: aload 7
invokevirtual io.netty.channel.unix.IovArray.count:()I
istore 8
start local 8 24: getstatic io.netty.channel.kqueue.KQueueDatagramChannel.$assertionsDisabled:Z
ifne 25
iload 8
ifne 25
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
25: StackMap locals: io.netty.channel.kqueue.KQueueDatagramChannel java.lang.Object io.netty.buffer.ByteBuf java.net.InetSocketAddress int top top io.netty.channel.unix.IovArray int
StackMap stack:
aload 3
ifnonnull 28
26: aload 0
getfield io.netty.channel.kqueue.KQueueDatagramChannel.socket:Lio/netty/channel/kqueue/BsdSocket;
aload 7
iconst_0
invokevirtual io.netty.channel.unix.IovArray.memoryAddress:(I)J
iload 8
invokevirtual io.netty.channel.kqueue.BsdSocket.writevAddresses:(JI)J
lstore 5
start local 5 27: goto 39
end local 5 28: StackMap locals:
StackMap stack:
aload 0
getfield io.netty.channel.kqueue.KQueueDatagramChannel.socket:Lio/netty/channel/kqueue/BsdSocket;
aload 7
iconst_0
invokevirtual io.netty.channel.unix.IovArray.memoryAddress:(I)J
iload 8
29: aload 3
invokevirtual java.net.InetSocketAddress.getAddress:()Ljava/net/InetAddress;
aload 3
invokevirtual java.net.InetSocketAddress.getPort:()I
30: invokevirtual io.netty.channel.kqueue.BsdSocket.sendToAddresses:(JILjava/net/InetAddress;I)I
i2l
lstore 5
end local 8 end local 7 start local 5 31: goto 39
end local 5 32: StackMap locals: io.netty.channel.kqueue.KQueueDatagramChannel java.lang.Object io.netty.buffer.ByteBuf java.net.InetSocketAddress int
StackMap stack:
aload 2
aload 2
invokevirtual io.netty.buffer.ByteBuf.readerIndex:()I
aload 2
invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
invokevirtual io.netty.buffer.ByteBuf.internalNioBuffer:(II)Ljava/nio/ByteBuffer;
astore 7
start local 7 33: aload 3
ifnonnull 36
34: aload 0
getfield io.netty.channel.kqueue.KQueueDatagramChannel.socket:Lio/netty/channel/kqueue/BsdSocket;
aload 7
aload 7
invokevirtual java.nio.ByteBuffer.position:()I
aload 7
invokevirtual java.nio.ByteBuffer.limit:()I
invokevirtual io.netty.channel.kqueue.BsdSocket.write:(Ljava/nio/ByteBuffer;II)I
i2l
lstore 5
start local 5 35: goto 39
end local 5 36: StackMap locals: io.netty.channel.kqueue.KQueueDatagramChannel java.lang.Object io.netty.buffer.ByteBuf java.net.InetSocketAddress int top top java.nio.ByteBuffer
StackMap stack:
aload 0
getfield io.netty.channel.kqueue.KQueueDatagramChannel.socket:Lio/netty/channel/kqueue/BsdSocket;
aload 7
aload 7
invokevirtual java.nio.ByteBuffer.position:()I
aload 7
invokevirtual java.nio.ByteBuffer.limit:()I
37: aload 3
invokevirtual java.net.InetSocketAddress.getAddress:()Ljava/net/InetAddress;
aload 3
invokevirtual java.net.InetSocketAddress.getPort:()I
38: invokevirtual io.netty.channel.kqueue.BsdSocket.sendTo:(Ljava/nio/ByteBuffer;IILjava/net/InetAddress;I)I
i2l
lstore 5
end local 7 start local 5 39: StackMap locals: io.netty.channel.kqueue.KQueueDatagramChannel java.lang.Object io.netty.buffer.ByteBuf java.net.InetSocketAddress int long
StackMap stack:
lload 5
lconst_0
lcmp
ifle 40
iconst_1
ireturn
StackMap locals:
StackMap stack:
40: iconst_0
ireturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 41 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 41 1 msg Ljava/lang/Object;
4 6 2 data Lio/netty/buffer/ByteBuf;
7 41 2 data Lio/netty/buffer/ByteBuf;
5 6 3 remoteAddress Ljava/net/InetSocketAddress;
8 41 3 remoteAddress Ljava/net/InetSocketAddress;
3 5 4 envelope Lio/netty/channel/AddressedEnvelope<Lio/netty/buffer/ByteBuf;Ljava/net/InetSocketAddress;>;
9 41 4 dataLen I
15 16 5 writtenBytes J
19 20 5 writtenBytes J
27 28 5 writtenBytes J
31 32 5 writtenBytes J
35 36 5 writtenBytes J
39 41 5 writtenBytes J
13 19 7 memoryAddress J
22 31 7 array Lio/netty/channel/unix/IovArray;
24 31 8 cnt I
33 39 7 nioData Ljava/nio/ByteBuffer;
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
msg
protected java.lang.Object filterOutboundMessage(java.lang.Object);
descriptor: (Ljava/lang/Object;)Ljava/lang/Object;
flags: (0x0004) ACC_PROTECTED
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: aload 1
instanceof io.netty.channel.socket.DatagramPacket
ifeq 7
1: aload 1
checkcast io.netty.channel.socket.DatagramPacket
astore 2
start local 2 2: aload 2
invokevirtual io.netty.channel.socket.DatagramPacket.content:()Ljava/lang/Object;
checkcast io.netty.buffer.ByteBuf
astore 3
start local 3 3: aload 3
invokestatic io.netty.channel.unix.UnixChannelUtil.isBufferCopyNeededForWrite:(Lio/netty/buffer/ByteBuf;)Z
ifeq 5
4: new io.netty.channel.socket.DatagramPacket
dup
aload 0
aload 2
aload 3
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.newDirectBuffer:(Ljava/lang/Object;Lio/netty/buffer/ByteBuf;)Lio/netty/buffer/ByteBuf;
aload 2
invokevirtual io.netty.channel.socket.DatagramPacket.recipient:()Ljava/net/SocketAddress;
checkcast java.net.InetSocketAddress
invokespecial io.netty.channel.socket.DatagramPacket.<init>:(Lio/netty/buffer/ByteBuf;Ljava/net/InetSocketAddress;)V
goto 6
StackMap locals: io.netty.channel.socket.DatagramPacket io.netty.buffer.ByteBuf
StackMap stack:
5: aload 1
6: StackMap locals:
StackMap stack: java.lang.Object
areturn
end local 3 end local 2 7: StackMap locals:
StackMap stack:
aload 1
instanceof io.netty.buffer.ByteBuf
ifeq 12
8: aload 1
checkcast io.netty.buffer.ByteBuf
astore 2
start local 2 9: aload 2
invokestatic io.netty.channel.unix.UnixChannelUtil.isBufferCopyNeededForWrite:(Lio/netty/buffer/ByteBuf;)Z
ifeq 10
aload 0
aload 2
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.newDirectBuffer:(Lio/netty/buffer/ByteBuf;)Lio/netty/buffer/ByteBuf;
goto 11
StackMap locals: io.netty.buffer.ByteBuf
StackMap stack:
10: aload 2
StackMap locals:
StackMap stack: io.netty.buffer.ByteBuf
11: areturn
end local 2 12: StackMap locals:
StackMap stack:
aload 1
instanceof io.netty.channel.AddressedEnvelope
ifeq 24
13: aload 1
checkcast io.netty.channel.AddressedEnvelope
astore 2
start local 2 14: aload 2
invokeinterface io.netty.channel.AddressedEnvelope.content:()Ljava/lang/Object;
instanceof io.netty.buffer.ByteBuf
ifeq 24
15: aload 2
invokeinterface io.netty.channel.AddressedEnvelope.recipient:()Ljava/net/SocketAddress;
ifnull 16
aload 2
invokeinterface io.netty.channel.AddressedEnvelope.recipient:()Ljava/net/SocketAddress;
instanceof java.net.InetSocketAddress
ifeq 24
16: StackMap locals: io.netty.channel.AddressedEnvelope
StackMap stack:
aload 2
invokeinterface io.netty.channel.AddressedEnvelope.content:()Ljava/lang/Object;
checkcast io.netty.buffer.ByteBuf
astore 3
start local 3 17: aload 3
invokestatic io.netty.channel.unix.UnixChannelUtil.isBufferCopyNeededForWrite:(Lio/netty/buffer/ByteBuf;)Z
ifeq 22
18: new io.netty.channel.DefaultAddressedEnvelope
dup
19: aload 0
aload 2
aload 3
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.newDirectBuffer:(Ljava/lang/Object;Lio/netty/buffer/ByteBuf;)Lio/netty/buffer/ByteBuf;
aload 2
invokeinterface io.netty.channel.AddressedEnvelope.recipient:()Ljava/net/SocketAddress;
checkcast java.net.InetSocketAddress
20: invokespecial io.netty.channel.DefaultAddressedEnvelope.<init>:(Ljava/lang/Object;Ljava/net/SocketAddress;)V
21: goto 23
StackMap locals: io.netty.buffer.ByteBuf
StackMap stack:
22: aload 2
23: StackMap locals:
StackMap stack: io.netty.channel.AddressedEnvelope
areturn
end local 3 end local 2 24: StackMap locals:
StackMap stack:
new java.lang.UnsupportedOperationException
dup
25: new java.lang.StringBuilder
dup
ldc "unsupported message type: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokestatic io.netty.util.internal.StringUtil.simpleClassName:(Ljava/lang/Object;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
getstatic io.netty.channel.kqueue.KQueueDatagramChannel.EXPECTED_TYPES:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
26: invokespecial java.lang.UnsupportedOperationException.<init>:(Ljava/lang/String;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 27 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 27 1 msg Ljava/lang/Object;
2 7 2 packet Lio/netty/channel/socket/DatagramPacket;
3 7 3 content Lio/netty/buffer/ByteBuf;
9 12 2 buf Lio/netty/buffer/ByteBuf;
14 24 2 e Lio/netty/channel/AddressedEnvelope<Ljava/lang/Object;Ljava/net/SocketAddress;>;
17 24 3 content Lio/netty/buffer/ByteBuf;
MethodParameters:
Name Flags
msg
public io.netty.channel.kqueue.KQueueDatagramChannelConfig config();
descriptor: ()Lio/netty/channel/kqueue/KQueueDatagramChannelConfig;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.netty.channel.kqueue.KQueueDatagramChannel.config:Lio/netty/channel/kqueue/KQueueDatagramChannelConfig;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
protected void doDisconnect();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
getfield io.netty.channel.kqueue.KQueueDatagramChannel.socket:Lio/netty/channel/kqueue/BsdSocket;
invokevirtual io.netty.channel.kqueue.BsdSocket.disconnect:()V
1: aload 0
aload 0
iconst_0
dup_x1
putfield io.netty.channel.kqueue.KQueueDatagramChannel.active:Z
putfield io.netty.channel.kqueue.KQueueDatagramChannel.connected:Z
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
Exceptions:
throws java.lang.Exception
protected boolean doConnect(java.net.SocketAddress, java.net.SocketAddress);
descriptor: (Ljava/net/SocketAddress;Ljava/net/SocketAddress;)Z
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokespecial io.netty.channel.kqueue.AbstractKQueueChannel.doConnect:(Ljava/net/SocketAddress;Ljava/net/SocketAddress;)Z
ifeq 3
1: aload 0
iconst_1
putfield io.netty.channel.kqueue.KQueueDatagramChannel.connected:Z
2: iconst_1
ireturn
3: StackMap locals:
StackMap stack:
iconst_0
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
0 4 1 remoteAddress Ljava/net/SocketAddress;
0 4 2 localAddress Ljava/net/SocketAddress;
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
remoteAddress
localAddress
protected void doClose();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokespecial io.netty.channel.kqueue.AbstractKQueueChannel.doClose:()V
1: aload 0
iconst_0
putfield io.netty.channel.kqueue.KQueueDatagramChannel.connected:Z
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/netty/channel/kqueue/KQueueDatagramChannel;
Exceptions:
throws java.lang.Exception
public boolean isOpen();
descriptor: ()Z
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.netty.channel.kqueue.AbstractKQueueChannel.isOpen:()Z
ireturn
LocalVariableTable:
Start End Slot Name Signature
public io.netty.channel.socket.DatagramChannelConfig config();
descriptor: ()Lio/netty/channel/socket/DatagramChannelConfig;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.config:()Lio/netty/channel/kqueue/KQueueDatagramChannelConfig;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.netty.channel.kqueue.KQueueChannelConfig config();
descriptor: ()Lio/netty/channel/kqueue/KQueueChannelConfig;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.config:()Lio/netty/channel/kqueue/KQueueDatagramChannelConfig;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.netty.channel.ChannelConfig config();
descriptor: ()Lio/netty/channel/ChannelConfig;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.config:()Lio/netty/channel/kqueue/KQueueDatagramChannelConfig;
areturn
LocalVariableTable:
Start End Slot Name Signature
public java.net.SocketAddress localAddress();
descriptor: ()Ljava/net/SocketAddress;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.localAddress:()Ljava/net/InetSocketAddress;
areturn
LocalVariableTable:
Start End Slot Name Signature
protected io.netty.channel.AbstractChannel$AbstractUnsafe newUnsafe();
descriptor: ()Lio/netty/channel/AbstractChannel$AbstractUnsafe;
flags: (0x1044) ACC_PROTECTED, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.newUnsafe:()Lio/netty/channel/kqueue/AbstractKQueueChannel$AbstractKQueueUnsafe;
areturn
LocalVariableTable:
Start End Slot Name Signature
public java.net.SocketAddress remoteAddress();
descriptor: ()Ljava/net/SocketAddress;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.netty.channel.kqueue.KQueueDatagramChannel.remoteAddress:()Ljava/net/InetSocketAddress;
areturn
LocalVariableTable:
Start End Slot Name Signature
}
SourceFile: "KQueueDatagramChannel.java"
NestMembers:
io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe
InnerClasses:
protected abstract AbstractUnsafe = io.netty.channel.AbstractChannel$AbstractUnsafe of io.netty.channel.AbstractChannel
abstract AbstractKQueueUnsafe = io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe of io.netty.channel.kqueue.AbstractKQueueChannel
final KQueueDatagramChannelUnsafe = io.netty.channel.kqueue.KQueueDatagramChannel$KQueueDatagramChannelUnsafe of io.netty.channel.kqueue.KQueueDatagramChannel