public class org.apache.cassandra.thrift.THsHaDisruptorServer extends com.thinkaurelius.thrift.TDisruptorServer
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.thrift.THsHaDisruptorServer
super_class: com.thinkaurelius.thrift.TDisruptorServer
{
private static final org.slf4j.Logger logger;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/thrift/THsHaDisruptorServer;
invokevirtual java.lang.Class.getName:()Ljava/lang/String;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/String;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.thrift.THsHaDisruptorServer.logger:Lorg/slf4j/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(com.thinkaurelius.thrift.TDisruptorServer$Args);
descriptor: (Lcom/thinkaurelius/thrift/TDisruptorServer$Args;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial com.thinkaurelius.thrift.TDisruptorServer.<init>:(Lcom/thinkaurelius/thrift/TDisruptorServer$Args;)V
1: getstatic org.apache.cassandra.thrift.THsHaDisruptorServer.logger:Lorg/slf4j/Logger;
ldc "Starting up {}"
aload 0
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;)V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/thrift/THsHaDisruptorServer;
0 3 1 args Lcom/thinkaurelius/thrift/TDisruptorServer$Args;
MethodParameters:
Name Flags
args
protected void beforeInvoke(com.thinkaurelius.thrift.Message);
descriptor: (Lcom/thinkaurelius/thrift/Message;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
getfield com.thinkaurelius.thrift.Message.transport:Lorg/apache/thrift/transport/TNonblockingTransport;
checkcast org.apache.thrift.transport.TNonblockingSocket
astore 2
start local 2 1: getstatic org.apache.cassandra.thrift.ThriftSessionManager.instance:Lorg/apache/cassandra/thrift/ThriftSessionManager;
aload 2
invokevirtual org.apache.thrift.transport.TNonblockingSocket.getSocketChannel:()Ljava/nio/channels/SocketChannel;
invokevirtual java.nio.channels.SocketChannel.socket:()Ljava/net/Socket;
invokevirtual java.net.Socket.getRemoteSocketAddress:()Ljava/net/SocketAddress;
invokevirtual org.apache.cassandra.thrift.ThriftSessionManager.setCurrentSocket:(Ljava/net/SocketAddress;)V
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/thrift/THsHaDisruptorServer;
0 3 1 buffer Lcom/thinkaurelius/thrift/Message;
1 3 2 socket Lorg/apache/thrift/transport/TNonblockingSocket;
MethodParameters:
Name Flags
buffer
public void beforeClose(com.thinkaurelius.thrift.Message);
descriptor: (Lcom/thinkaurelius/thrift/Message;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
getfield com.thinkaurelius.thrift.Message.transport:Lorg/apache/thrift/transport/TNonblockingTransport;
checkcast org.apache.thrift.transport.TNonblockingSocket
astore 2
start local 2 1: getstatic org.apache.cassandra.thrift.ThriftSessionManager.instance:Lorg/apache/cassandra/thrift/ThriftSessionManager;
aload 2
invokevirtual org.apache.thrift.transport.TNonblockingSocket.getSocketChannel:()Ljava/nio/channels/SocketChannel;
invokevirtual java.nio.channels.SocketChannel.socket:()Ljava/net/Socket;
invokevirtual java.net.Socket.getRemoteSocketAddress:()Ljava/net/SocketAddress;
invokevirtual org.apache.cassandra.thrift.ThriftSessionManager.connectionComplete:(Ljava/net/SocketAddress;)V
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/thrift/THsHaDisruptorServer;
0 3 1 buffer Lcom/thinkaurelius/thrift/Message;
1 3 2 socket Lorg/apache/thrift/transport/TNonblockingSocket;
MethodParameters:
Name Flags
buffer
}
SourceFile: "THsHaDisruptorServer.java"
NestMembers:
org.apache.cassandra.thrift.THsHaDisruptorServer$Factory
InnerClasses:
public Args = com.thinkaurelius.thrift.TDisruptorServer$Args of com.thinkaurelius.thrift.TDisruptorServer
public Factory = org.apache.cassandra.thrift.THsHaDisruptorServer$Factory of org.apache.cassandra.thrift.THsHaDisruptorServer