class org.apache.cassandra.transport.SimpleClient$Initializer extends io.netty.channel.ChannelInitializer<io.netty.channel.Channel>
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.apache.cassandra.transport.SimpleClient$Initializer
super_class: io.netty.channel.ChannelInitializer
{
final org.apache.cassandra.transport.SimpleClient this$0;
descriptor: Lorg/apache/cassandra/transport/SimpleClient;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
private void <init>(org.apache.cassandra.transport.SimpleClient);
descriptor: (Lorg/apache/cassandra/transport/SimpleClient;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 // org.apache.cassandra.transport.SimpleClient$Initializer this
0: .line 277
aload 0 /* this */
aload 1
putfield org.apache.cassandra.transport.SimpleClient$Initializer.this$0:Lorg/apache/cassandra/transport/SimpleClient;
aload 0 /* this */
invokespecial io.netty.channel.ChannelInitializer.<init>:()V
return
end local 0 // org.apache.cassandra.transport.SimpleClient$Initializer this
LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/transport/SimpleClient$Initializer;
MethodParameters:
Name Flags
this$0 final
protected void initChannel(io.netty.channel.Channel);
descriptor: (Lio/netty/channel/Channel;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=6, locals=3, args_size=2
start local 0 // org.apache.cassandra.transport.SimpleClient$Initializer this
start local 1 // io.netty.channel.Channel channel
0: .line 281
aload 0 /* this */
getfield org.apache.cassandra.transport.SimpleClient$Initializer.this$0:Lorg/apache/cassandra/transport/SimpleClient;
new org.apache.cassandra.transport.Connection
dup
aload 1 /* channel */
aload 0 /* this */
getfield org.apache.cassandra.transport.SimpleClient$Initializer.this$0:Lorg/apache/cassandra/transport/SimpleClient;
getfield org.apache.cassandra.transport.SimpleClient.version:Lorg/apache/cassandra/transport/ProtocolVersion;
aload 0 /* this */
getfield org.apache.cassandra.transport.SimpleClient$Initializer.this$0:Lorg/apache/cassandra/transport/SimpleClient;
getfield org.apache.cassandra.transport.SimpleClient.tracker:Lorg/apache/cassandra/transport/Connection$Tracker;
invokespecial org.apache.cassandra.transport.Connection.<init>:(Lio/netty/channel/Channel;Lorg/apache/cassandra/transport/ProtocolVersion;Lorg/apache/cassandra/transport/Connection$Tracker;)V
putfield org.apache.cassandra.transport.SimpleClient.connection:Lorg/apache/cassandra/transport/Connection;
1: .line 282
aload 1 /* channel */
getstatic org.apache.cassandra.transport.Connection.attributeKey:Lio/netty/util/AttributeKey;
invokeinterface io.netty.channel.Channel.attr:(Lio/netty/util/AttributeKey;)Lio/netty/util/Attribute;
aload 0 /* this */
getfield org.apache.cassandra.transport.SimpleClient$Initializer.this$0:Lorg/apache/cassandra/transport/SimpleClient;
getfield org.apache.cassandra.transport.SimpleClient.connection:Lorg/apache/cassandra/transport/Connection;
invokeinterface io.netty.util.Attribute.set:(Ljava/lang/Object;)V
2: .line 284
aload 1 /* channel */
invokeinterface io.netty.channel.Channel.pipeline:()Lio/netty/channel/ChannelPipeline;
astore 2 /* pipeline */
start local 2 // io.netty.channel.ChannelPipeline pipeline
3: .line 285
aload 2 /* pipeline */
ldc "frameDecoder"
new org.apache.cassandra.transport.Frame$Decoder
dup
aload 0 /* this */
getfield org.apache.cassandra.transport.SimpleClient$Initializer.this$0:Lorg/apache/cassandra/transport/SimpleClient;
getfield org.apache.cassandra.transport.SimpleClient.connectionFactory:Lorg/apache/cassandra/transport/Connection$Factory;
getstatic org.apache.cassandra.transport.ProtocolVersionLimit.SERVER_DEFAULT:Lorg/apache/cassandra/transport/ProtocolVersionLimit;
invokespecial org.apache.cassandra.transport.Frame$Decoder.<init>:(Lorg/apache/cassandra/transport/Connection$Factory;Lorg/apache/cassandra/transport/ProtocolVersionLimit;)V
invokeinterface io.netty.channel.ChannelPipeline.addLast:(Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
4: .line 286
aload 2 /* pipeline */
ldc "frameEncoder"
getstatic org.apache.cassandra.transport.SimpleClient.frameEncoder:Lorg/apache/cassandra/transport/Frame$Encoder;
invokeinterface io.netty.channel.ChannelPipeline.addLast:(Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
5: .line 288
aload 2 /* pipeline */
ldc "frameDecompressor"
getstatic org.apache.cassandra.transport.SimpleClient.frameDecompressor:Lorg/apache/cassandra/transport/Frame$Decompressor;
invokeinterface io.netty.channel.ChannelPipeline.addLast:(Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
6: .line 289
aload 2 /* pipeline */
ldc "frameCompressor"
getstatic org.apache.cassandra.transport.SimpleClient.frameCompressor:Lorg/apache/cassandra/transport/Frame$Compressor;
invokeinterface io.netty.channel.ChannelPipeline.addLast:(Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
7: .line 291
aload 2 /* pipeline */
ldc "messageDecoder"
getstatic org.apache.cassandra.transport.SimpleClient.messageDecoder:Lorg/apache/cassandra/transport/Message$ProtocolDecoder;
invokeinterface io.netty.channel.ChannelPipeline.addLast:(Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
8: .line 292
aload 2 /* pipeline */
ldc "messageEncoder"
getstatic org.apache.cassandra.transport.SimpleClient.messageEncoder:Lorg/apache/cassandra/transport/Message$ProtocolEncoder;
invokeinterface io.netty.channel.ChannelPipeline.addLast:(Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
9: .line 294
aload 2 /* pipeline */
ldc "handler"
aload 0 /* this */
getfield org.apache.cassandra.transport.SimpleClient$Initializer.this$0:Lorg/apache/cassandra/transport/SimpleClient;
getfield org.apache.cassandra.transport.SimpleClient.responseHandler:Lorg/apache/cassandra/transport/SimpleClient$ResponseHandler;
invokeinterface io.netty.channel.ChannelPipeline.addLast:(Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
10: .line 295
return
end local 2 // io.netty.channel.ChannelPipeline pipeline
end local 1 // io.netty.channel.Channel channel
end local 0 // org.apache.cassandra.transport.SimpleClient$Initializer this
LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/cassandra/transport/SimpleClient$Initializer;
0 11 1 channel Lio/netty/channel/Channel;
3 11 2 pipeline Lio/netty/channel/ChannelPipeline;
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
channel
}
Signature: Lio/netty/channel/ChannelInitializer<Lio/netty/channel/Channel;>;
SourceFile: "SimpleClient.java"
NestHost: org.apache.cassandra.transport.SimpleClient
InnerClasses:
public abstract Factory = org.apache.cassandra.transport.Connection$Factory of org.apache.cassandra.transport.Connection
public abstract Tracker = org.apache.cassandra.transport.Connection$Tracker of org.apache.cassandra.transport.Connection
public Decoder = org.apache.cassandra.transport.Frame$Decoder of org.apache.cassandra.transport.Frame
private Initializer = org.apache.cassandra.transport.SimpleClient$Initializer of org.apache.cassandra.transport.SimpleClient