public class org.apache.cassandra.tools.NodeProbe implements java.lang.AutoCloseable
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.tools.NodeProbe
super_class: java.lang.Object
{
private static final java.lang.String fmtUrl;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "service:jmx:rmi:///jndi/rmi://[%s]:%d/jmxrmi"
private static final java.lang.String ssObjName;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "org.apache.cassandra.db:type=StorageService"
private static final int defaultPort;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 7199
final java.lang.String host;
descriptor: Ljava/lang/String;
flags: (0x0010) ACC_FINAL
final int port;
descriptor: I
flags: (0x0010) ACC_FINAL
private java.lang.String username;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
private java.lang.String password;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
private javax.management.remote.JMXConnector jmxc;
descriptor: Ljavax/management/remote/JMXConnector;
flags: (0x0002) ACC_PRIVATE
private javax.management.MBeanServerConnection mbeanServerConn;
descriptor: Ljavax/management/MBeanServerConnection;
flags: (0x0002) ACC_PRIVATE
private org.apache.cassandra.db.compaction.CompactionManagerMBean compactionProxy;
descriptor: Lorg/apache/cassandra/db/compaction/CompactionManagerMBean;
flags: (0x0002) ACC_PRIVATE
private org.apache.cassandra.service.StorageServiceMBean ssProxy;
descriptor: Lorg/apache/cassandra/service/StorageServiceMBean;
flags: (0x0002) ACC_PRIVATE
private org.apache.cassandra.gms.GossiperMBean gossProxy;
descriptor: Lorg/apache/cassandra/gms/GossiperMBean;
flags: (0x0002) ACC_PRIVATE
private java.lang.management.MemoryMXBean memProxy;
descriptor: Ljava/lang/management/MemoryMXBean;
flags: (0x0002) ACC_PRIVATE
private org.apache.cassandra.service.GCInspectorMXBean gcProxy;
descriptor: Lorg/apache/cassandra/service/GCInspectorMXBean;
flags: (0x0002) ACC_PRIVATE
private java.lang.management.RuntimeMXBean runtimeProxy;
descriptor: Ljava/lang/management/RuntimeMXBean;
flags: (0x0002) ACC_PRIVATE
private org.apache.cassandra.streaming.StreamManagerMBean streamProxy;
descriptor: Lorg/apache/cassandra/streaming/StreamManagerMBean;
flags: (0x0002) ACC_PRIVATE
public org.apache.cassandra.net.MessagingServiceMBean msProxy;
descriptor: Lorg/apache/cassandra/net/MessagingServiceMBean;
flags: (0x0001) ACC_PUBLIC
private org.apache.cassandra.gms.FailureDetectorMBean fdProxy;
descriptor: Lorg/apache/cassandra/gms/FailureDetectorMBean;
flags: (0x0002) ACC_PRIVATE
private org.apache.cassandra.service.CacheServiceMBean cacheService;
descriptor: Lorg/apache/cassandra/service/CacheServiceMBean;
flags: (0x0002) ACC_PRIVATE
private org.apache.cassandra.service.StorageProxyMBean spProxy;
descriptor: Lorg/apache/cassandra/service/StorageProxyMBean;
flags: (0x0002) ACC_PRIVATE
private org.apache.cassandra.db.HintedHandOffManagerMBean hhProxy;
descriptor: Lorg/apache/cassandra/db/HintedHandOffManagerMBean;
flags: (0x0002) ACC_PRIVATE
private org.apache.cassandra.batchlog.BatchlogManagerMBean bmProxy;
descriptor: Lorg/apache/cassandra/batchlog/BatchlogManagerMBean;
flags: (0x0002) ACC_PRIVATE
private boolean failed;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
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=1, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/tools/NodeProbe;
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 org.apache.cassandra.tools.NodeProbe.$assertionsDisabled:Z
3: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(java.lang.String, int, java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: getstatic org.apache.cassandra.tools.NodeProbe.$assertionsDisabled:Z
ifne 4
aload 3
ifnull 2
aload 3
invokevirtual java.lang.String.isEmpty:()Z
ifne 2
aload 4
ifnull 2
aload 4
invokevirtual java.lang.String.isEmpty:()Z
ifeq 4
StackMap locals: org.apache.cassandra.tools.NodeProbe java.lang.String int java.lang.String java.lang.String
StackMap stack:
2: new java.lang.AssertionError
dup
3: ldc "neither username nor password can be blank"
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
4: StackMap locals:
StackMap stack:
aload 0
aload 1
putfield org.apache.cassandra.tools.NodeProbe.host:Ljava/lang/String;
5: aload 0
iload 2
putfield org.apache.cassandra.tools.NodeProbe.port:I
6: aload 0
aload 3
putfield org.apache.cassandra.tools.NodeProbe.username:Ljava/lang/String;
7: aload 0
aload 4
putfield org.apache.cassandra.tools.NodeProbe.password:Ljava/lang/String;
8: aload 0
invokevirtual org.apache.cassandra.tools.NodeProbe.connect:()V
9: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 10 1 host Ljava/lang/String;
0 10 2 port I
0 10 3 username Ljava/lang/String;
0 10 4 password Ljava/lang/String;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
host
port
username
password
public void <init>(java.lang.String, int);
descriptor: (Ljava/lang/String;I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield org.apache.cassandra.tools.NodeProbe.host:Ljava/lang/String;
2: aload 0
iload 2
putfield org.apache.cassandra.tools.NodeProbe.port:I
3: aload 0
invokevirtual org.apache.cassandra.tools.NodeProbe.connect:()V
4: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 5 1 host Ljava/lang/String;
0 5 2 port I
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
host
port
public void <init>(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield org.apache.cassandra.tools.NodeProbe.host:Ljava/lang/String;
2: aload 0
sipush 7199
putfield org.apache.cassandra.tools.NodeProbe.port:I
3: aload 0
invokevirtual org.apache.cassandra.tools.NodeProbe.connect:()V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 5 1 host Ljava/lang/String;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
host
private void connect();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=4, args_size=1
start local 0 0: new javax.management.remote.JMXServiceURL
dup
ldc "service:jmx:rmi:///jndi/rmi://[%s]:%d/jmxrmi"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
getfield org.apache.cassandra.tools.NodeProbe.host:Ljava/lang/String;
aastore
dup
iconst_1
aload 0
getfield org.apache.cassandra.tools.NodeProbe.port:I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial javax.management.remote.JMXServiceURL.<init>:(Ljava/lang/String;)V
astore 1
start local 1 1: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 2
start local 2 2: aload 0
getfield org.apache.cassandra.tools.NodeProbe.username:Ljava/lang/String;
ifnull 5
3: iconst_2
anewarray java.lang.String
dup
iconst_0
aload 0
getfield org.apache.cassandra.tools.NodeProbe.username:Ljava/lang/String;
aastore
dup
iconst_1
aload 0
getfield org.apache.cassandra.tools.NodeProbe.password:Ljava/lang/String;
aastore
astore 3
start local 3 4: aload 2
ldc "jmx.remote.credentials"
aload 3
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 3 5: StackMap locals: javax.management.remote.JMXServiceURL java.util.Map
StackMap stack:
aload 2
ldc "com.sun.jndi.rmi.factory.socket"
aload 0
invokevirtual org.apache.cassandra.tools.NodeProbe.getRMIClientSocketFactory:()Ljava/rmi/server/RMIClientSocketFactory;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
6: aload 0
aload 1
aload 2
invokestatic javax.management.remote.JMXConnectorFactory.connect:(Ljavax/management/remote/JMXServiceURL;Ljava/util/Map;)Ljavax/management/remote/JMXConnector;
putfield org.apache.cassandra.tools.NodeProbe.jmxc:Ljavax/management/remote/JMXConnector;
7: aload 0
aload 0
getfield org.apache.cassandra.tools.NodeProbe.jmxc:Ljavax/management/remote/JMXConnector;
invokeinterface javax.management.remote.JMXConnector.getMBeanServerConnection:()Ljavax/management/MBeanServerConnection;
putfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
8: new javax.management.ObjectName
dup
ldc "org.apache.cassandra.db:type=StorageService"
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
astore 3
start local 3 9: aload 0
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
aload 3
ldc Lorg/apache/cassandra/service/StorageServiceMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.service.StorageServiceMBean
putfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
10: new javax.management.ObjectName
dup
ldc "org.apache.cassandra.net:type=MessagingService"
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
astore 3
11: aload 0
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
aload 3
ldc Lorg/apache/cassandra/net/MessagingServiceMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.net.MessagingServiceMBean
putfield org.apache.cassandra.tools.NodeProbe.msProxy:Lorg/apache/cassandra/net/MessagingServiceMBean;
12: new javax.management.ObjectName
dup
ldc "org.apache.cassandra.net:type=StreamManager"
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
astore 3
13: aload 0
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
aload 3
ldc Lorg/apache/cassandra/streaming/StreamManagerMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.streaming.StreamManagerMBean
putfield org.apache.cassandra.tools.NodeProbe.streamProxy:Lorg/apache/cassandra/streaming/StreamManagerMBean;
14: new javax.management.ObjectName
dup
ldc "org.apache.cassandra.db:type=CompactionManager"
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
astore 3
15: aload 0
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
aload 3
ldc Lorg/apache/cassandra/db/compaction/CompactionManagerMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.CompactionManagerMBean
putfield org.apache.cassandra.tools.NodeProbe.compactionProxy:Lorg/apache/cassandra/db/compaction/CompactionManagerMBean;
16: new javax.management.ObjectName
dup
ldc "org.apache.cassandra.net:type=FailureDetector"
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
astore 3
17: aload 0
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
aload 3
ldc Lorg/apache/cassandra/gms/FailureDetectorMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.gms.FailureDetectorMBean
putfield org.apache.cassandra.tools.NodeProbe.fdProxy:Lorg/apache/cassandra/gms/FailureDetectorMBean;
18: new javax.management.ObjectName
dup
ldc "org.apache.cassandra.db:type=Caches"
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
astore 3
19: aload 0
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
aload 3
ldc Lorg/apache/cassandra/service/CacheServiceMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.service.CacheServiceMBean
putfield org.apache.cassandra.tools.NodeProbe.cacheService:Lorg/apache/cassandra/service/CacheServiceMBean;
20: new javax.management.ObjectName
dup
ldc "org.apache.cassandra.db:type=StorageProxy"
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
astore 3
21: aload 0
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
aload 3
ldc Lorg/apache/cassandra/service/StorageProxyMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.service.StorageProxyMBean
putfield org.apache.cassandra.tools.NodeProbe.spProxy:Lorg/apache/cassandra/service/StorageProxyMBean;
22: new javax.management.ObjectName
dup
ldc "org.apache.cassandra.db:type=HintedHandoffManager"
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
astore 3
23: aload 0
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
aload 3
ldc Lorg/apache/cassandra/db/HintedHandOffManagerMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.HintedHandOffManagerMBean
putfield org.apache.cassandra.tools.NodeProbe.hhProxy:Lorg/apache/cassandra/db/HintedHandOffManagerMBean;
24: new javax.management.ObjectName
dup
ldc "org.apache.cassandra.service:type=GCInspector"
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
astore 3
25: aload 0
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
aload 3
ldc Lorg/apache/cassandra/service/GCInspectorMXBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.service.GCInspectorMXBean
putfield org.apache.cassandra.tools.NodeProbe.gcProxy:Lorg/apache/cassandra/service/GCInspectorMXBean;
26: new javax.management.ObjectName
dup
ldc "org.apache.cassandra.net:type=Gossiper"
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
astore 3
27: aload 0
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
aload 3
ldc Lorg/apache/cassandra/gms/GossiperMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.gms.GossiperMBean
putfield org.apache.cassandra.tools.NodeProbe.gossProxy:Lorg/apache/cassandra/gms/GossiperMBean;
28: new javax.management.ObjectName
dup
ldc "org.apache.cassandra.db:type=BatchlogManager"
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
astore 3
29: aload 0
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
aload 3
ldc Lorg/apache/cassandra/batchlog/BatchlogManagerMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.batchlog.BatchlogManagerMBean
putfield org.apache.cassandra.tools.NodeProbe.bmProxy:Lorg/apache/cassandra/batchlog/BatchlogManagerMBean;
end local 3 30: goto 35
31: StackMap locals:
StackMap stack: javax.management.MalformedObjectNameException
astore 3
start local 3 32: new java.lang.RuntimeException
dup
33: ldc "Invalid ObjectName? Please report this as a bug."
aload 3
34: invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
athrow
end local 3 35: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
36: ldc "java.lang:type=Memory"
ldc Ljava/lang/management/MemoryMXBean;
37: invokestatic java.lang.management.ManagementFactory.newPlatformMXBeanProxy:(Ljavax/management/MBeanServerConnection;Ljava/lang/String;Ljava/lang/Class;)Ljava/lang/Object;
checkcast java.lang.management.MemoryMXBean
putfield org.apache.cassandra.tools.NodeProbe.memProxy:Ljava/lang/management/MemoryMXBean;
38: aload 0
39: aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
ldc "java.lang:type=Runtime"
ldc Ljava/lang/management/RuntimeMXBean;
40: invokestatic java.lang.management.ManagementFactory.newPlatformMXBeanProxy:(Ljavax/management/MBeanServerConnection;Ljava/lang/String;Ljava/lang/Class;)Ljava/lang/Object;
checkcast java.lang.management.RuntimeMXBean
putfield org.apache.cassandra.tools.NodeProbe.runtimeProxy:Ljava/lang/management/RuntimeMXBean;
41: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 42 0 this Lorg/apache/cassandra/tools/NodeProbe;
1 42 1 jmxUrl Ljavax/management/remote/JMXServiceURL;
2 42 2 env Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
4 5 3 creds [Ljava/lang/String;
9 30 3 name Ljavax/management/ObjectName;
32 35 3 e Ljavax/management/MalformedObjectNameException;
Exception table:
from to target type
8 30 31 Class javax.management.MalformedObjectNameException
Exceptions:
throws java.io.IOException
private java.rmi.server.RMIClientSocketFactory getRMIClientSocketFactory();
descriptor: ()Ljava/rmi/server/RMIClientSocketFactory;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=1, args_size=1
start local 0 0: ldc "ssl.enable"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;)Ljava/lang/String;
invokestatic java.lang.Boolean.parseBoolean:(Ljava/lang/String;)Z
ifeq 2
1: new javax.rmi.ssl.SslRMIClientSocketFactory
dup
invokespecial javax.rmi.ssl.SslRMIClientSocketFactory.<init>:()V
areturn
2: StackMap locals:
StackMap stack:
invokestatic java.rmi.server.RMISocketFactory.getDefaultSocketFactory:()Ljava/rmi/server/RMISocketFactory;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.jmxc:Ljavax/management/remote/JMXConnector;
invokeinterface javax.management.remote.JMXConnector.close:()V
1: goto 4
2: StackMap locals:
StackMap stack: java.rmi.ConnectException
pop
3: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Cassandra has shutdown."
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
4: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/tools/NodeProbe;
Exception table:
from to target type
0 1 2 Class java.rmi.ConnectException
Exceptions:
throws java.io.IOException
public int forceKeyspaceCleanup(int, java.lang.String, java.lang.String[]);
descriptor: (ILjava/lang/String;[Ljava/lang/String;)I
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
iload 1
aload 2
aload 3
invokeinterface org.apache.cassandra.service.StorageServiceMBean.forceKeyspaceCleanup:(ILjava/lang/String;[Ljava/lang/String;)I
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 1 1 jobs I
0 1 2 keyspaceName Ljava/lang/String;
0 1 3 tables [Ljava/lang/String;
Exceptions:
throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
MethodParameters:
Name Flags
jobs
keyspaceName
tables
public int scrub(boolean, boolean, boolean, boolean, int, java.lang.String, java.lang.String[]);
descriptor: (ZZZZILjava/lang/String;[Ljava/lang/String;)I
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=8, locals=8, args_size=8
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
iload 1
iload 2
iload 3
iload 4
iload 5
aload 6
aload 7
invokeinterface org.apache.cassandra.service.StorageServiceMBean.scrub:(ZZZZILjava/lang/String;[Ljava/lang/String;)I
ireturn
end local 7 end local 6 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 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 1 1 disableSnapshot Z
0 1 2 skipCorrupted Z
0 1 3 checkData Z
0 1 4 reinsertOverflowedTTL Z
0 1 5 jobs I
0 1 6 keyspaceName Ljava/lang/String;
0 1 7 tables [Ljava/lang/String;
Exceptions:
throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
MethodParameters:
Name Flags
disableSnapshot
skipCorrupted
checkData
reinsertOverflowedTTL
jobs
keyspaceName
tables
public int verify(boolean, java.lang.String, java.lang.String[]);
descriptor: (ZLjava/lang/String;[Ljava/lang/String;)I
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
iload 1
aload 2
aload 3
invokeinterface org.apache.cassandra.service.StorageServiceMBean.verify:(ZLjava/lang/String;[Ljava/lang/String;)I
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 1 1 extendedVerify Z
0 1 2 keyspaceName Ljava/lang/String;
0 1 3 tableNames [Ljava/lang/String;
Exceptions:
throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
MethodParameters:
Name Flags
extendedVerify
keyspaceName
tableNames
public int upgradeSSTables(java.lang.String, boolean, int, java.lang.String[]);
descriptor: (Ljava/lang/String;ZI[Ljava/lang/String;)I
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=5, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
iload 2
iload 3
aload 4
invokeinterface org.apache.cassandra.service.StorageServiceMBean.upgradeSSTables:(Ljava/lang/String;ZI[Ljava/lang/String;)I
ireturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 1 1 keyspaceName Ljava/lang/String;
0 1 2 excludeCurrentVersion Z
0 1 3 jobs I
0 1 4 tableNames [Ljava/lang/String;
Exceptions:
throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
MethodParameters:
Name Flags
keyspaceName
excludeCurrentVersion
jobs
tableNames
public int garbageCollect(java.lang.String, int, java.lang.String, java.lang.String[]);
descriptor: (Ljava/lang/String;ILjava/lang/String;[Ljava/lang/String;)I
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=5, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
iload 2
aload 3
aload 4
invokeinterface org.apache.cassandra.service.StorageServiceMBean.garbageCollect:(Ljava/lang/String;ILjava/lang/String;[Ljava/lang/String;)I
ireturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 1 1 tombstoneOption Ljava/lang/String;
0 1 2 jobs I
0 1 3 keyspaceName Ljava/lang/String;
0 1 4 tableNames [Ljava/lang/String;
Exceptions:
throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
MethodParameters:
Name Flags
tombstoneOption
jobs
keyspaceName
tableNames
private void checkJobs(java.io.PrintStream, int);
descriptor: (Ljava/io/PrintStream;I)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=3, args_size=3
start local 0 start local 1 start local 2 0: invokestatic org.apache.cassandra.config.DatabaseDescriptor.toolInitialization:()V
1: iload 2
invokestatic org.apache.cassandra.config.DatabaseDescriptor.getConcurrentCompactors:()I
if_icmple 3
2: aload 1
ldc "jobs (%d) is bigger than configured concurrent_compactors (%d) on this host, using at most %d threads"
iconst_3
anewarray java.lang.Object
dup
iconst_0
iload 2
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
invokestatic org.apache.cassandra.config.DatabaseDescriptor.getConcurrentCompactors:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_2
invokestatic org.apache.cassandra.config.DatabaseDescriptor.getConcurrentCompactors:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
3: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 4 1 out Ljava/io/PrintStream;
0 4 2 jobs I
MethodParameters:
Name Flags
out
jobs
public void forceKeyspaceCleanup(java.io.PrintStream, int, java.lang.String, java.lang.String[]);
descriptor: (Ljava/io/PrintStream;ILjava/lang/String;[Ljava/lang/String;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
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 0
aload 1
iload 2
invokevirtual org.apache.cassandra.tools.NodeProbe.checkJobs:(Ljava/io/PrintStream;I)V
1: aload 0
iload 2
aload 3
aload 4
invokevirtual org.apache.cassandra.tools.NodeProbe.forceKeyspaceCleanup:(ILjava/lang/String;[Ljava/lang/String;)I
tableswitch { // 1 - 2
1: 2
2: 5
default: 7
}
2: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield org.apache.cassandra.tools.NodeProbe.failed:Z
3: aload 1
new java.lang.StringBuilder
dup
ldc "Aborted cleaning up at least one table in keyspace "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 3
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", check server logs for more information."
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
4: goto 7
5: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield org.apache.cassandra.tools.NodeProbe.failed:Z
6: aload 1
new java.lang.StringBuilder
dup
ldc "Failed marking some sstables compacting in keyspace "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 3
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", check server logs for more information"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
7: StackMap locals:
StackMap stack:
return
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 Lorg/apache/cassandra/tools/NodeProbe;
0 8 1 out Ljava/io/PrintStream;
0 8 2 jobs I
0 8 3 keyspaceName Ljava/lang/String;
0 8 4 tableNames [Ljava/lang/String;
Exceptions:
throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
MethodParameters:
Name Flags
out
jobs
keyspaceName
tableNames
public void scrub(java.io.PrintStream, boolean, boolean, boolean, boolean, int, java.lang.String, java.lang.String[]);
descriptor: (Ljava/io/PrintStream;ZZZZILjava/lang/String;[Ljava/lang/String;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=8, locals=9, args_size=9
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 start local 8 0: aload 0
aload 1
iload 6
invokevirtual org.apache.cassandra.tools.NodeProbe.checkJobs:(Ljava/io/PrintStream;I)V
1: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
iload 2
iload 3
iload 4
iload 5
iload 6
aload 7
aload 8
invokeinterface org.apache.cassandra.service.StorageServiceMBean.scrub:(ZZZZILjava/lang/String;[Ljava/lang/String;)I
tableswitch { // 1 - 2
1: 2
2: 5
default: 7
}
2: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield org.apache.cassandra.tools.NodeProbe.failed:Z
3: aload 1
new java.lang.StringBuilder
dup
ldc "Aborted scrubbing at least one table in keyspace "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 7
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", check server logs for more information."
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
4: goto 7
5: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield org.apache.cassandra.tools.NodeProbe.failed:Z
6: aload 1
new java.lang.StringBuilder
dup
ldc "Failed marking some sstables compacting in keyspace "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 7
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", check server logs for more information"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
7: StackMap locals:
StackMap stack:
return
end local 8 end local 7 end local 6 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 8 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 8 1 out Ljava/io/PrintStream;
0 8 2 disableSnapshot Z
0 8 3 skipCorrupted Z
0 8 4 checkData Z
0 8 5 reinsertOverflowedTTL Z
0 8 6 jobs I
0 8 7 keyspaceName Ljava/lang/String;
0 8 8 tables [Ljava/lang/String;
Exceptions:
throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
MethodParameters:
Name Flags
out
disableSnapshot
skipCorrupted
checkData
reinsertOverflowedTTL
jobs
keyspaceName
tables
public void verify(java.io.PrintStream, boolean, java.lang.String, java.lang.String[]);
descriptor: (Ljava/io/PrintStream;ZLjava/lang/String;[Ljava/lang/String;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
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 0
iload 2
aload 3
aload 4
invokevirtual org.apache.cassandra.tools.NodeProbe.verify:(ZLjava/lang/String;[Ljava/lang/String;)I
tableswitch { // 1 - 2
1: 1
2: 4
default: 6
}
1: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield org.apache.cassandra.tools.NodeProbe.failed:Z
2: aload 1
new java.lang.StringBuilder
dup
ldc "Aborted verifying at least one table in keyspace "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 3
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", check server logs for more information."
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
3: goto 6
4: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield org.apache.cassandra.tools.NodeProbe.failed:Z
5: aload 1
new java.lang.StringBuilder
dup
ldc "Failed marking some sstables compacting in keyspace "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 3
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", check server logs for more information"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
6: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 7 1 out Ljava/io/PrintStream;
0 7 2 extendedVerify Z
0 7 3 keyspaceName Ljava/lang/String;
0 7 4 tableNames [Ljava/lang/String;
Exceptions:
throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
MethodParameters:
Name Flags
out
extendedVerify
keyspaceName
tableNames
public void upgradeSSTables(java.io.PrintStream, java.lang.String, boolean, int, java.lang.String[]);
descriptor: (Ljava/io/PrintStream;Ljava/lang/String;ZI[Ljava/lang/String;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=5, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
aload 1
iload 4
invokevirtual org.apache.cassandra.tools.NodeProbe.checkJobs:(Ljava/io/PrintStream;I)V
1: aload 0
aload 2
iload 3
iload 4
aload 5
invokevirtual org.apache.cassandra.tools.NodeProbe.upgradeSSTables:(Ljava/lang/String;ZI[Ljava/lang/String;)I
tableswitch { // 1 - 2
1: 2
2: 5
default: 7
}
2: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield org.apache.cassandra.tools.NodeProbe.failed:Z
3: aload 1
new java.lang.StringBuilder
dup
ldc "Aborted upgrading sstables for at least one table in keyspace "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", check server logs for more information."
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
4: goto 7
5: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield org.apache.cassandra.tools.NodeProbe.failed:Z
6: aload 1
new java.lang.StringBuilder
dup
ldc "Failed marking some sstables compacting in keyspace "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", check server logs for more information"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
7: StackMap locals:
StackMap stack:
return
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 8 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 8 1 out Ljava/io/PrintStream;
0 8 2 keyspaceName Ljava/lang/String;
0 8 3 excludeCurrentVersion Z
0 8 4 jobs I
0 8 5 tableNames [Ljava/lang/String;
Exceptions:
throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
MethodParameters:
Name Flags
out
keyspaceName
excludeCurrentVersion
jobs
tableNames
public void garbageCollect(java.io.PrintStream, java.lang.String, int, java.lang.String, java.lang.String[]);
descriptor: (Ljava/io/PrintStream;Ljava/lang/String;ILjava/lang/String;[Ljava/lang/String;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=5, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
aload 2
iload 3
aload 4
aload 5
invokevirtual org.apache.cassandra.tools.NodeProbe.garbageCollect:(Ljava/lang/String;ILjava/lang/String;[Ljava/lang/String;)I
ifeq 3
1: aload 0
iconst_1
putfield org.apache.cassandra.tools.NodeProbe.failed:Z
2: aload 1
new java.lang.StringBuilder
dup
ldc "Aborted garbage collection for at least one table in keyspace "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 4
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", check server logs for more information."
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
3: StackMap locals:
StackMap stack:
return
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 4 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 4 1 out Ljava/io/PrintStream;
0 4 2 tombstoneOption Ljava/lang/String;
0 4 3 jobs I
0 4 4 keyspaceName Ljava/lang/String;
0 4 5 tableNames [Ljava/lang/String;
Exceptions:
throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
MethodParameters:
Name Flags
out
tombstoneOption
jobs
keyspaceName
tableNames
public void forceUserDefinedCompaction(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.compactionProxy:Lorg/apache/cassandra/db/compaction/CompactionManagerMBean;
aload 1
invokeinterface org.apache.cassandra.db.compaction.CompactionManagerMBean.forceUserDefinedCompaction:(Ljava/lang/String;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 datafiles Ljava/lang/String;
Exceptions:
throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
MethodParameters:
Name Flags
datafiles
public void forceKeyspaceCompaction(boolean, java.lang.String, java.lang.String[]);
descriptor: (ZLjava/lang/String;[Ljava/lang/String;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
iload 1
aload 2
aload 3
invokeinterface org.apache.cassandra.service.StorageServiceMBean.forceKeyspaceCompaction:(ZLjava/lang/String;[Ljava/lang/String;)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 splitOutput Z
0 2 2 keyspaceName Ljava/lang/String;
0 2 3 tableNames [Ljava/lang/String;
Exceptions:
throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
MethodParameters:
Name Flags
splitOutput
keyspaceName
tableNames
public void relocateSSTables(int, java.lang.String, java.lang.String[]);
descriptor: (ILjava/lang/String;[Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
iload 1
aload 2
aload 3
invokeinterface org.apache.cassandra.service.StorageServiceMBean.relocateSSTables:(ILjava/lang/String;[Ljava/lang/String;)I
pop
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 jobs I
0 2 2 keyspace Ljava/lang/String;
0 2 3 cfnames [Ljava/lang/String;
Exceptions:
throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
MethodParameters:
Name Flags
jobs
keyspace
cfnames
public void forceKeyspaceCompactionForTokenRange(java.lang.String, java.lang.String, java.lang.String, java.lang.String[]);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=5, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
aload 2
aload 3
aload 4
invokeinterface org.apache.cassandra.service.StorageServiceMBean.forceKeyspaceCompactionForTokenRange:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;)V
1: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 keyspaceName Ljava/lang/String;
0 2 2 startToken Ljava/lang/String;
0 2 3 endToken Ljava/lang/String;
0 2 4 tableNames [Ljava/lang/String;
Exceptions:
throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
MethodParameters:
Name Flags
keyspaceName
startToken final
endToken final
tableNames
public void forceKeyspaceFlush(java.lang.String, java.lang.String[]);
descriptor: (Ljava/lang/String;[Ljava/lang/String;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
aload 2
invokeinterface org.apache.cassandra.service.StorageServiceMBean.forceKeyspaceFlush:(Ljava/lang/String;[Ljava/lang/String;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 keyspaceName Ljava/lang/String;
0 2 2 tableNames [Ljava/lang/String;
Exceptions:
throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
MethodParameters:
Name Flags
keyspaceName
tableNames
public void repairAsync(java.io.PrintStream, java.lang.String, java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Ljava/io/PrintStream;Ljava/lang/String;Ljava/util/Map;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=8, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new org.apache.cassandra.tools.RepairRunner
dup
aload 1
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 2
aload 3
invokespecial org.apache.cassandra.tools.RepairRunner.<init>:(Ljava/io/PrintStream;Lorg/apache/cassandra/service/StorageServiceMBean;Ljava/lang/String;Ljava/util/Map;)V
astore 4
start local 4 1: aload 0
getfield org.apache.cassandra.tools.NodeProbe.jmxc:Ljavax/management/remote/JMXConnector;
aload 4
aconst_null
aconst_null
invokeinterface javax.management.remote.JMXConnector.addConnectionNotificationListener:(Ljavax/management/NotificationListener;Ljavax/management/NotificationFilter;Ljava/lang/Object;)V
2: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 4
aconst_null
aconst_null
invokeinterface org.apache.cassandra.service.StorageServiceMBean.addNotificationListener:(Ljavax/management/NotificationListener;Ljavax/management/NotificationFilter;Ljava/lang/Object;)V
3: aload 4
invokevirtual org.apache.cassandra.tools.RepairRunner.run:()V
4: goto 14
5: StackMap locals: org.apache.cassandra.tools.NodeProbe java.io.PrintStream java.lang.String java.util.Map org.apache.cassandra.tools.RepairRunner
StackMap stack: java.lang.Exception
astore 5
start local 5 6: new java.io.IOException
dup
aload 5
invokespecial java.io.IOException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 5 7: StackMap locals:
StackMap stack: java.lang.Throwable
astore 6
8: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 4
invokeinterface org.apache.cassandra.service.StorageServiceMBean.removeNotificationListener:(Ljavax/management/NotificationListener;)V
9: aload 0
getfield org.apache.cassandra.tools.NodeProbe.jmxc:Ljavax/management/remote/JMXConnector;
aload 4
invokeinterface javax.management.remote.JMXConnector.removeConnectionNotificationListener:(Ljavax/management/NotificationListener;)V
10: goto 13
11: StackMap locals: org.apache.cassandra.tools.NodeProbe java.io.PrintStream java.lang.String java.util.Map org.apache.cassandra.tools.RepairRunner top java.lang.Throwable
StackMap stack: java.lang.Throwable
astore 7
start local 7 12: aload 1
new java.lang.StringBuilder
dup
ldc "Exception occurred during clean-up. "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 7
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
end local 7 13: StackMap locals:
StackMap stack:
aload 6
athrow
14: StackMap locals: org.apache.cassandra.tools.NodeProbe java.io.PrintStream java.lang.String java.util.Map org.apache.cassandra.tools.RepairRunner
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 4
invokeinterface org.apache.cassandra.service.StorageServiceMBean.removeNotificationListener:(Ljavax/management/NotificationListener;)V
15: aload 0
getfield org.apache.cassandra.tools.NodeProbe.jmxc:Ljavax/management/remote/JMXConnector;
aload 4
invokeinterface javax.management.remote.JMXConnector.removeConnectionNotificationListener:(Ljavax/management/NotificationListener;)V
16: goto 19
17: StackMap locals:
StackMap stack: java.lang.Throwable
astore 7
start local 7 18: aload 1
new java.lang.StringBuilder
dup
ldc "Exception occurred during clean-up. "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 7
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
end local 7 19: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 20 1 out Ljava/io/PrintStream;
0 20 2 keyspace Ljava/lang/String;
0 20 3 options Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
1 20 4 runner Lorg/apache/cassandra/tools/RepairRunner;
6 7 5 e Ljava/lang/Exception;
12 13 7 e Ljava/lang/Throwable;
18 19 7 e Ljava/lang/Throwable;
Exception table:
from to target type
1 4 5 Class java.lang.Exception
1 7 7 any
8 10 11 Class java.lang.Throwable
14 16 17 Class java.lang.Throwable
Exceptions:
throws java.io.IOException
Signature: (Ljava/io/PrintStream;Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
out final
keyspace final
options
public java.util.Map<org.apache.cassandra.metrics.TableMetrics$Sampler, javax.management.openmbean.CompositeData> getPartitionSample(java.lang.String, java.lang.String, int, int, int, java.util.List<org.apache.cassandra.metrics.TableMetrics$Sampler>);
descriptor: (Ljava/lang/String;Ljava/lang/String;IIILjava/util/List;)Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=11, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
aload 1
aload 2
invokevirtual org.apache.cassandra.tools.NodeProbe.getCfsProxy:(Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/db/ColumnFamilyStoreMBean;
astore 7
start local 7 1: aload 6
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 9
goto 4
StackMap locals: org.apache.cassandra.tools.NodeProbe java.lang.String java.lang.String int int int java.util.List org.apache.cassandra.db.ColumnFamilyStoreMBean top java.util.Iterator
StackMap stack:
2: aload 9
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.metrics.TableMetrics$Sampler
astore 8
start local 8 3: aload 7
aload 8
invokevirtual org.apache.cassandra.metrics.TableMetrics$Sampler.name:()Ljava/lang/String;
iload 3
invokeinterface org.apache.cassandra.db.ColumnFamilyStoreMBean.beginLocalSampling:(Ljava/lang/String;I)V
end local 8 4: StackMap locals:
StackMap stack:
aload 9
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
5: iload 4
i2l
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokestatic com.google.common.util.concurrent.Uninterruptibles.sleepUninterruptibly:(JLjava/util/concurrent/TimeUnit;)V
6: invokestatic com.google.common.collect.Maps.newHashMap:()Ljava/util/HashMap;
astore 8
start local 8 7: aload 6
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 10
goto 10
StackMap locals: org.apache.cassandra.tools.NodeProbe java.lang.String java.lang.String int int int java.util.List org.apache.cassandra.db.ColumnFamilyStoreMBean java.util.Map top java.util.Iterator
StackMap stack:
8: aload 10
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.metrics.TableMetrics$Sampler
astore 9
start local 9 9: aload 8
aload 9
aload 7
aload 9
invokevirtual org.apache.cassandra.metrics.TableMetrics$Sampler.name:()Ljava/lang/String;
iload 5
invokeinterface org.apache.cassandra.db.ColumnFamilyStoreMBean.finishLocalSampling:(Ljava/lang/String;I)Ljavax/management/openmbean/CompositeData;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 9 10: StackMap locals:
StackMap stack:
aload 10
invokeinterface java.util.Iterator.hasNext:()Z
ifne 8
11: aload 8
areturn
end local 8 end local 7 end local 6 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 12 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 12 1 ks Ljava/lang/String;
0 12 2 cf Ljava/lang/String;
0 12 3 capacity I
0 12 4 duration I
0 12 5 count I
0 12 6 samplers Ljava/util/List<Lorg/apache/cassandra/metrics/TableMetrics$Sampler;>;
1 12 7 cfsProxy Lorg/apache/cassandra/db/ColumnFamilyStoreMBean;
3 4 8 sampler Lorg/apache/cassandra/metrics/TableMetrics$Sampler;
7 12 8 result Ljava/util/Map<Lorg/apache/cassandra/metrics/TableMetrics$Sampler;Ljavax/management/openmbean/CompositeData;>;
9 10 9 sampler Lorg/apache/cassandra/metrics/TableMetrics$Sampler;
Exceptions:
throws javax.management.openmbean.OpenDataException
Signature: (Ljava/lang/String;Ljava/lang/String;IIILjava/util/List<Lorg/apache/cassandra/metrics/TableMetrics$Sampler;>;)Ljava/util/Map<Lorg/apache/cassandra/metrics/TableMetrics$Sampler;Ljavax/management/openmbean/CompositeData;>;
MethodParameters:
Name Flags
ks
cf
capacity
duration
count
samplers
public void invalidateCounterCache();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.cacheService:Lorg/apache/cassandra/service/CacheServiceMBean;
invokeinterface org.apache.cassandra.service.CacheServiceMBean.invalidateCounterCache:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void invalidateKeyCache();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.cacheService:Lorg/apache/cassandra/service/CacheServiceMBean;
invokeinterface org.apache.cassandra.service.CacheServiceMBean.invalidateKeyCache:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void invalidateRowCache();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.cacheService:Lorg/apache/cassandra/service/CacheServiceMBean;
invokeinterface org.apache.cassandra.service.CacheServiceMBean.invalidateRowCache:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void drain();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.drain:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
Exceptions:
throws java.io.IOException, java.lang.InterruptedException, java.util.concurrent.ExecutionException
public java.util.Map<java.lang.String, java.lang.String> getTokenToEndpointMap();
descriptor: ()Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getTokenToEndpointMap:()Ljava/util/Map;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
public java.util.List<java.lang.String> getLiveNodes();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getLiveNodes:()Ljava/util/List;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/List<Ljava/lang/String;>;
public java.util.List<java.lang.String> getJoiningNodes();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getJoiningNodes:()Ljava/util/List;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/List<Ljava/lang/String;>;
public java.util.List<java.lang.String> getLeavingNodes();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getLeavingNodes:()Ljava/util/List;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/List<Ljava/lang/String;>;
public java.util.List<java.lang.String> getMovingNodes();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getMovingNodes:()Ljava/util/List;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/List<Ljava/lang/String;>;
public java.util.List<java.lang.String> getUnreachableNodes();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getUnreachableNodes:()Ljava/util/List;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/List<Ljava/lang/String;>;
public java.util.Map<java.lang.String, java.lang.String> getLoadMap();
descriptor: ()Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getLoadMap:()Ljava/util/Map;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
public java.util.Map<java.net.InetAddress, java.lang.Float> getOwnership();
descriptor: ()Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getOwnership:()Ljava/util/Map;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/Map<Ljava/net/InetAddress;Ljava/lang/Float;>;
public java.util.Map<java.net.InetAddress, java.lang.Float> effectiveOwnership(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
invokeinterface org.apache.cassandra.service.StorageServiceMBean.effectiveOwnership:(Ljava/lang/String;)Ljava/util/Map;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 1 1 keyspace Ljava/lang/String;
Exceptions:
throws java.lang.IllegalStateException
Signature: (Ljava/lang/String;)Ljava/util/Map<Ljava/net/InetAddress;Ljava/lang/Float;>;
MethodParameters:
Name Flags
keyspace
public org.apache.cassandra.service.CacheServiceMBean getCacheServiceMBean();
descriptor: ()Lorg/apache/cassandra/service/CacheServiceMBean;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=1
start local 0 0: ldc "org.apache.cassandra.db:type=Caches"
astore 1
start local 1 1: aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
new javax.management.ObjectName
dup
aload 1
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
ldc Lorg/apache/cassandra/service/CacheServiceMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.service.CacheServiceMBean
2: areturn
3: StackMap locals: org.apache.cassandra.tools.NodeProbe java.lang.String
StackMap stack: javax.management.MalformedObjectNameException
astore 2
start local 2 4: new java.lang.RuntimeException
dup
aload 2
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/tools/NodeProbe;
1 5 1 cachePath Ljava/lang/String;
4 5 2 e Ljavax/management/MalformedObjectNameException;
Exception table:
from to target type
1 2 3 Class javax.management.MalformedObjectNameException
public double[] getAndResetGCStats();
descriptor: ()[D
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.gcProxy:Lorg/apache/cassandra/service/GCInspectorMXBean;
invokeinterface org.apache.cassandra.service.GCInspectorMXBean.getAndResetStats:()[D
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public java.util.Iterator<java.util.Map$Entry<java.lang.String, org.apache.cassandra.db.ColumnFamilyStoreMBean>> getColumnFamilyStoreMBeanProxies();
descriptor: ()Ljava/util/Iterator;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: new org.apache.cassandra.tools.ColumnFamilyStoreMBeanIterator
dup
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
invokespecial org.apache.cassandra.tools.ColumnFamilyStoreMBeanIterator.<init>:(Ljavax/management/MBeanServerConnection;)V
1: areturn
2: StackMap locals:
StackMap stack: javax.management.MalformedObjectNameException
astore 1
start local 1 3: new java.lang.RuntimeException
dup
ldc "Invalid ObjectName? Please report this as a bug."
aload 1
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
athrow
end local 1 4: StackMap locals:
StackMap stack: java.io.IOException
astore 1
start local 1 5: new java.lang.RuntimeException
dup
ldc "Could not retrieve list of stat mbeans."
aload 1
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/tools/NodeProbe;
3 4 1 e Ljavax/management/MalformedObjectNameException;
5 6 1 e Ljava/io/IOException;
Exception table:
from to target type
0 1 2 Class javax.management.MalformedObjectNameException
0 1 4 Class java.io.IOException
Signature: ()Ljava/util/Iterator<Ljava/util/Map$Entry<Ljava/lang/String;Lorg/apache/cassandra/db/ColumnFamilyStoreMBean;>;>;
public org.apache.cassandra.db.compaction.CompactionManagerMBean getCompactionManagerProxy();
descriptor: ()Lorg/apache/cassandra/db/compaction/CompactionManagerMBean;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.compactionProxy:Lorg/apache/cassandra/db/compaction/CompactionManagerMBean;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public java.util.List<java.lang.String> getTokens();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getTokens:()Ljava/util/List;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/List<Ljava/lang/String;>;
public java.util.List<java.lang.String> getTokens(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getTokens:(Ljava/lang/String;)Ljava/util/List;
1: areturn
2: StackMap locals:
StackMap stack: java.net.UnknownHostException
astore 2
start local 2 3: new java.lang.RuntimeException
dup
aload 2
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 4 1 endpoint Ljava/lang/String;
3 4 2 e Ljava/net/UnknownHostException;
Exception table:
from to target type
0 1 2 Class java.net.UnknownHostException
Signature: (Ljava/lang/String;)Ljava/util/List<Ljava/lang/String;>;
MethodParameters:
Name Flags
endpoint
public java.lang.String getLocalHostId();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getLocalHostId:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public java.util.Map<java.lang.String, java.lang.String> getHostIdMap();
descriptor: ()Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getEndpointToHostId:()Ljava/util/Map;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
public java.lang.String getLoadString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getLoadString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public java.lang.String getReleaseVersion();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getReleaseVersion:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public int getCurrentGenerationNumber();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getCurrentGenerationNumber:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public long getUptime();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.runtimeProxy:Ljava/lang/management/RuntimeMXBean;
invokeinterface java.lang.management.RuntimeMXBean.getUptime:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public java.lang.management.MemoryUsage getHeapMemoryUsage();
descriptor: ()Ljava/lang/management/MemoryUsage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.memProxy:Ljava/lang/management/MemoryMXBean;
invokeinterface java.lang.management.MemoryMXBean.getHeapMemoryUsage:()Ljava/lang/management/MemoryUsage;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void takeSnapshot(java.lang.String, java.lang.String, java.util.Map<java.lang.String, java.lang.String>, java.lang.String[]);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/util/Map;[Ljava/lang/String;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=10, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 2
ifnull 5
1: aload 4
arraylength
iconst_1
if_icmpeq 3
2: new java.io.IOException
dup
ldc "When specifying the table for a snapshot, you must specify one and only one keyspace"
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
aload 3
iconst_1
anewarray java.lang.String
dup
iconst_0
new java.lang.StringBuilder
dup
aload 4
iconst_0
aaload
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "."
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
aastore
invokeinterface org.apache.cassandra.service.StorageServiceMBean.takeSnapshot:(Ljava/lang/String;Ljava/util/Map;[Ljava/lang/String;)V
4: goto 6
5: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
aload 3
aload 4
invokeinterface org.apache.cassandra.service.StorageServiceMBean.takeSnapshot:(Ljava/lang/String;Ljava/util/Map;[Ljava/lang/String;)V
6: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 7 1 snapshotName Ljava/lang/String;
0 7 2 table Ljava/lang/String;
0 7 3 options Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
0 7 4 keyspaces [Ljava/lang/String;
Exceptions:
throws java.io.IOException
Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;[Ljava/lang/String;)V
MethodParameters:
Name Flags
snapshotName
table
options
keyspaces
public void takeMultipleTableSnapshot(java.lang.String, java.util.Map<java.lang.String, java.lang.String>, java.lang.String[]);
descriptor: (Ljava/lang/String;Ljava/util/Map;[Ljava/lang/String;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 3
ifnull 3
aload 3
arraylength
ifeq 3
1: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
aload 2
aload 3
invokeinterface org.apache.cassandra.service.StorageServiceMBean.takeSnapshot:(Ljava/lang/String;Ljava/util/Map;[Ljava/lang/String;)V
2: goto 4
3: StackMap locals:
StackMap stack:
new java.io.IOException
dup
ldc "The column family List for a snapshot should not be empty or null"
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 5 1 snapshotName Ljava/lang/String;
0 5 2 options Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
0 5 3 tableList [Ljava/lang/String;
Exceptions:
throws java.io.IOException
Signature: (Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;[Ljava/lang/String;)V
MethodParameters:
Name Flags
snapshotName
options
tableList
public void clearSnapshot(java.lang.String, java.lang.String[]);
descriptor: (Ljava/lang/String;[Ljava/lang/String;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
aload 2
invokeinterface org.apache.cassandra.service.StorageServiceMBean.clearSnapshot:(Ljava/lang/String;[Ljava/lang/String;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 tag Ljava/lang/String;
0 2 2 keyspaces [Ljava/lang/String;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
tag
keyspaces
public java.util.Map<java.lang.String, javax.management.openmbean.TabularData> getSnapshotDetails();
descriptor: ()Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getSnapshotDetails:()Ljava/util/Map;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/Map<Ljava/lang/String;Ljavax/management/openmbean/TabularData;>;
public long trueSnapshotsSize();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.trueSnapshotsSize:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public boolean isJoined();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.isJoined:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public boolean isDrained();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.isDrained:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public boolean isDraining();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.isDraining:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public boolean isBootstrapMode();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.isBootstrapMode:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void joinRing();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.joinRing:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
Exceptions:
throws java.io.IOException
public void decommission();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.decommission:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
Exceptions:
throws java.lang.InterruptedException
public void move(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
invokeinterface org.apache.cassandra.service.StorageServiceMBean.move:(Ljava/lang/String;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 newToken Ljava/lang/String;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
newToken
public void removeNode(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
invokeinterface org.apache.cassandra.service.StorageServiceMBean.removeNode:(Ljava/lang/String;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 token Ljava/lang/String;
MethodParameters:
Name Flags
token
public java.lang.String getRemovalStatus();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getRemovalStatus:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void forceRemoveCompletion();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.forceRemoveCompletion:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void assassinateEndpoint(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.gossProxy:Lorg/apache/cassandra/gms/GossiperMBean;
aload 1
invokeinterface org.apache.cassandra.gms.GossiperMBean.assassinateEndpoint:(Ljava/lang/String;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 address Ljava/lang/String;
Exceptions:
throws java.net.UnknownHostException
MethodParameters:
Name Flags
address
public void setCompactionThreshold(java.lang.String, java.lang.String, int, int);
descriptor: (Ljava/lang/String;Ljava/lang/String;II)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
invokevirtual org.apache.cassandra.tools.NodeProbe.getCfsProxy:(Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/db/ColumnFamilyStoreMBean;
astore 5
start local 5 1: aload 5
iload 3
iload 4
invokeinterface org.apache.cassandra.db.ColumnFamilyStoreMBean.setCompactionThresholds:(II)V
2: return
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 3 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 3 1 ks Ljava/lang/String;
0 3 2 cf Ljava/lang/String;
0 3 3 minimumCompactionThreshold I
0 3 4 maximumCompactionThreshold I
1 3 5 cfsProxy Lorg/apache/cassandra/db/ColumnFamilyStoreMBean;
MethodParameters:
Name Flags
ks
cf
minimumCompactionThreshold
maximumCompactionThreshold
public void disableAutoCompaction(java.lang.String, java.lang.String[]);
descriptor: (Ljava/lang/String;[Ljava/lang/String;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
aload 2
invokeinterface org.apache.cassandra.service.StorageServiceMBean.disableAutoCompaction:(Ljava/lang/String;[Ljava/lang/String;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 ks Ljava/lang/String;
0 2 2 tables [Ljava/lang/String;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
ks
tables
public void enableAutoCompaction(java.lang.String, java.lang.String[]);
descriptor: (Ljava/lang/String;[Ljava/lang/String;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
aload 2
invokeinterface org.apache.cassandra.service.StorageServiceMBean.enableAutoCompaction:(Ljava/lang/String;[Ljava/lang/String;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 ks Ljava/lang/String;
0 2 2 tableNames [Ljava/lang/String;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
ks
tableNames
public void setIncrementalBackupsEnabled(boolean);
descriptor: (Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
iload 1
invokeinterface org.apache.cassandra.service.StorageServiceMBean.setIncrementalBackupsEnabled:(Z)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 enabled Z
MethodParameters:
Name Flags
enabled
public boolean isIncrementalBackupsEnabled();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.isIncrementalBackupsEnabled:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void setCacheCapacities(int, int, int);
descriptor: (III)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: ldc "org.apache.cassandra.db:type=Caches"
astore 4
start local 4 1: aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
new javax.management.ObjectName
dup
aload 4
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
ldc Lorg/apache/cassandra/service/CacheServiceMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.service.CacheServiceMBean
astore 5
start local 5 2: aload 5
iload 1
i2l
invokeinterface org.apache.cassandra.service.CacheServiceMBean.setKeyCacheCapacityInMB:(J)V
3: aload 5
iload 2
i2l
invokeinterface org.apache.cassandra.service.CacheServiceMBean.setRowCacheCapacityInMB:(J)V
4: aload 5
iload 3
i2l
invokeinterface org.apache.cassandra.service.CacheServiceMBean.setCounterCacheCapacityInMB:(J)V
end local 5 end local 4 5: goto 8
6: StackMap locals:
StackMap stack: javax.management.MalformedObjectNameException
astore 4
start local 4 7: new java.lang.RuntimeException
dup
aload 4
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 4 8: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 9 1 keyCacheCapacity I
0 9 2 rowCacheCapacity I
0 9 3 counterCacheCapacity I
1 5 4 keyCachePath Ljava/lang/String;
2 5 5 cacheMBean Lorg/apache/cassandra/service/CacheServiceMBean;
7 8 4 e Ljavax/management/MalformedObjectNameException;
Exception table:
from to target type
0 5 6 Class javax.management.MalformedObjectNameException
MethodParameters:
Name Flags
keyCacheCapacity
rowCacheCapacity
counterCacheCapacity
public void setCacheKeysToSave(int, int, int);
descriptor: (III)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: ldc "org.apache.cassandra.db:type=Caches"
astore 4
start local 4 1: aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
new javax.management.ObjectName
dup
aload 4
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
ldc Lorg/apache/cassandra/service/CacheServiceMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.service.CacheServiceMBean
astore 5
start local 5 2: aload 5
iload 1
invokeinterface org.apache.cassandra.service.CacheServiceMBean.setKeyCacheKeysToSave:(I)V
3: aload 5
iload 2
invokeinterface org.apache.cassandra.service.CacheServiceMBean.setRowCacheKeysToSave:(I)V
4: aload 5
iload 3
invokeinterface org.apache.cassandra.service.CacheServiceMBean.setCounterCacheKeysToSave:(I)V
end local 5 end local 4 5: goto 8
6: StackMap locals:
StackMap stack: javax.management.MalformedObjectNameException
astore 4
start local 4 7: new java.lang.RuntimeException
dup
aload 4
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 4 8: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 9 1 keyCacheKeysToSave I
0 9 2 rowCacheKeysToSave I
0 9 3 counterCacheKeysToSave I
1 5 4 keyCachePath Ljava/lang/String;
2 5 5 cacheMBean Lorg/apache/cassandra/service/CacheServiceMBean;
7 8 4 e Ljavax/management/MalformedObjectNameException;
Exception table:
from to target type
0 5 6 Class javax.management.MalformedObjectNameException
MethodParameters:
Name Flags
keyCacheKeysToSave
rowCacheKeysToSave
counterCacheKeysToSave
public void setHintedHandoffThrottleInKB(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
iload 1
invokeinterface org.apache.cassandra.service.StorageServiceMBean.setHintedHandoffThrottleInKB:(I)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 throttleInKB I
MethodParameters:
Name Flags
throttleInKB
public java.util.List<java.net.InetAddress> getEndpoints(java.lang.String, java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
aload 2
aload 3
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getNaturalEndpoints:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Ljava/util/List;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 1 1 keyspace Ljava/lang/String;
0 1 2 cf Ljava/lang/String;
0 1 3 key Ljava/lang/String;
Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Ljava/util/List<Ljava/net/InetAddress;>;
MethodParameters:
Name Flags
keyspace
cf
key
public java.util.List<java.lang.String> getSSTables(java.lang.String, java.lang.String, java.lang.String, boolean);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Z)Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
invokevirtual org.apache.cassandra.tools.NodeProbe.getCfsProxy:(Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/db/ColumnFamilyStoreMBean;
astore 5
start local 5 1: aload 5
aload 3
iload 4
invokeinterface org.apache.cassandra.db.ColumnFamilyStoreMBean.getSSTablesForKey:(Ljava/lang/String;Z)Ljava/util/List;
areturn
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 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 keyspace Ljava/lang/String;
0 2 2 cf Ljava/lang/String;
0 2 3 key Ljava/lang/String;
0 2 4 hexFormat Z
1 2 5 cfsProxy Lorg/apache/cassandra/db/ColumnFamilyStoreMBean;
Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Z)Ljava/util/List<Ljava/lang/String;>;
MethodParameters:
Name Flags
keyspace
cf
key
hexFormat
public java.util.Set<org.apache.cassandra.streaming.StreamState> getStreamStatus();
descriptor: ()Ljava/util/Set;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.streamProxy:Lorg/apache/cassandra/streaming/StreamManagerMBean;
invokeinterface org.apache.cassandra.streaming.StreamManagerMBean.getCurrentStreams:()Ljava/util/Set;
new org.apache.cassandra.tools.NodeProbe$1
dup
aload 0
invokespecial org.apache.cassandra.tools.NodeProbe$1.<init>:(Lorg/apache/cassandra/tools/NodeProbe;)V
invokestatic com.google.common.collect.Iterables.transform:(Ljava/lang/Iterable;Lcom/google/common/base/Function;)Ljava/lang/Iterable;
invokestatic com.google.common.collect.Sets.newHashSet:(Ljava/lang/Iterable;)Ljava/util/HashSet;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/Set<Lorg/apache/cassandra/streaming/StreamState;>;
public java.lang.String getOperationMode();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getOperationMode:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public boolean isStarting();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.isStarting:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void truncate(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
aload 2
invokeinterface org.apache.cassandra.service.StorageServiceMBean.truncate:(Ljava/lang/String;Ljava/lang/String;)V
1: goto 6
2: StackMap locals:
StackMap stack: java.util.concurrent.TimeoutException
astore 3
start local 3 3: new java.lang.RuntimeException
dup
ldc "Error while executing truncate"
aload 3
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
athrow
end local 3 4: StackMap locals:
StackMap stack: java.io.IOException
astore 3
start local 3 5: new java.lang.RuntimeException
dup
ldc "Error while executing truncate"
aload 3
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
athrow
end local 3 6: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 7 1 keyspaceName Ljava/lang/String;
0 7 2 tableName Ljava/lang/String;
3 4 3 e Ljava/util/concurrent/TimeoutException;
5 6 3 e Ljava/io/IOException;
Exception table:
from to target type
0 1 2 Class java.util.concurrent.TimeoutException
0 1 4 Class java.io.IOException
MethodParameters:
Name Flags
keyspaceName
tableName
public org.apache.cassandra.locator.EndpointSnitchInfoMBean getEndpointSnitchInfoProxy();
descriptor: ()Lorg/apache/cassandra/locator/EndpointSnitchInfoMBean;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
new javax.management.ObjectName
dup
ldc "org.apache.cassandra.db:type=EndpointSnitchInfo"
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
ldc Lorg/apache/cassandra/locator/EndpointSnitchInfoMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.locator.EndpointSnitchInfoMBean
1: areturn
2: StackMap locals:
StackMap stack: javax.management.MalformedObjectNameException
astore 1
start local 1 3: new java.lang.RuntimeException
dup
aload 1
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/tools/NodeProbe;
3 4 1 e Ljavax/management/MalformedObjectNameException;
Exception table:
from to target type
0 1 2 Class javax.management.MalformedObjectNameException
public org.apache.cassandra.locator.DynamicEndpointSnitchMBean getDynamicEndpointSnitchInfoProxy();
descriptor: ()Lorg/apache/cassandra/locator/DynamicEndpointSnitchMBean;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
new javax.management.ObjectName
dup
ldc "org.apache.cassandra.db:type=DynamicEndpointSnitch"
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
ldc Lorg/apache/cassandra/locator/DynamicEndpointSnitchMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.locator.DynamicEndpointSnitchMBean
1: areturn
2: StackMap locals:
StackMap stack: javax.management.MalformedObjectNameException
astore 1
start local 1 3: new java.lang.RuntimeException
dup
aload 1
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/tools/NodeProbe;
3 4 1 e Ljavax/management/MalformedObjectNameException;
Exception table:
from to target type
0 1 2 Class javax.management.MalformedObjectNameException
public org.apache.cassandra.db.ColumnFamilyStoreMBean getCfsProxy(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/db/ColumnFamilyStoreMBean;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=8, args_size=3
start local 0 start local 1 start local 2 0: aconst_null
astore 3
start local 3 1: aload 2
ldc "."
invokevirtual java.lang.String.contains:(Ljava/lang/CharSequence;)Z
ifeq 2
ldc "IndexColumnFamilies"
goto 3
StackMap locals: org.apache.cassandra.db.ColumnFamilyStoreMBean
StackMap stack:
2: ldc "ColumnFamilies"
StackMap locals:
StackMap stack: java.lang.String
3: astore 4
start local 4 4: aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
5: new javax.management.ObjectName
dup
new java.lang.StringBuilder
dup
ldc "org.apache.cassandra.db:type=*"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 4
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ",keyspace="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ",columnfamily="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
aconst_null
6: invokeinterface javax.management.MBeanServerConnection.queryNames:(Ljavax/management/ObjectName;Ljavax/management/QueryExp;)Ljava/util/Set;
astore 5
start local 5 7: aload 5
invokeinterface java.util.Set.isEmpty:()Z
ifeq 9
8: new javax.management.MalformedObjectNameException
dup
ldc "couldn't find that bean"
invokespecial javax.management.MalformedObjectNameException.<init>:(Ljava/lang/String;)V
athrow
9: StackMap locals: java.lang.String java.util.Set
StackMap stack:
getstatic org.apache.cassandra.tools.NodeProbe.$assertionsDisabled:Z
ifne 10
aload 5
invokeinterface java.util.Set.size:()I
iconst_1
if_icmpeq 10
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
10: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 7
goto 13
StackMap locals: org.apache.cassandra.tools.NodeProbe java.lang.String java.lang.String org.apache.cassandra.db.ColumnFamilyStoreMBean java.lang.String java.util.Set top java.util.Iterator
StackMap stack:
11: aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast javax.management.ObjectName
astore 6
start local 6 12: aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
aload 6
ldc Lorg/apache/cassandra/db/ColumnFamilyStoreMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStoreMBean
astore 3
end local 6 13: StackMap locals:
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 11
end local 5 end local 4 14: goto 21
15: StackMap locals: org.apache.cassandra.tools.NodeProbe java.lang.String java.lang.String org.apache.cassandra.db.ColumnFamilyStoreMBean
StackMap stack: javax.management.MalformedObjectNameException
pop
16: getstatic java.lang.System.err:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "ColumnFamilyStore for "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "/"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " not found."
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
17: iconst_1
invokestatic java.lang.System.exit:(I)V
goto 21
18: StackMap locals:
StackMap stack: java.io.IOException
astore 4
start local 4 19: getstatic java.lang.System.err:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "ColumnFamilyStore for "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "/"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " not found: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 4
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
20: iconst_1
invokestatic java.lang.System.exit:(I)V
end local 4 21: StackMap locals:
StackMap stack:
aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 22 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 22 1 ks Ljava/lang/String;
0 22 2 cf Ljava/lang/String;
1 22 3 cfsProxy Lorg/apache/cassandra/db/ColumnFamilyStoreMBean;
4 14 4 type Ljava/lang/String;
7 14 5 beans Ljava/util/Set<Ljavax/management/ObjectName;>;
12 13 6 bean Ljavax/management/ObjectName;
19 21 4 e Ljava/io/IOException;
Exception table:
from to target type
1 14 15 Class javax.management.MalformedObjectNameException
1 14 18 Class java.io.IOException
MethodParameters:
Name Flags
ks
cf
public org.apache.cassandra.service.StorageProxyMBean getSpProxy();
descriptor: ()Lorg/apache/cassandra/service/StorageProxyMBean;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.spProxy:Lorg/apache/cassandra/service/StorageProxyMBean;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public java.lang.String getEndpoint();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getHostIdToEndpoint:()Ljava/util/Map;
astore 1
start local 1 1: aload 1
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getLocalHostId:()Ljava/lang/String;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
1 2 1 hostIdToEndpoint Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
public java.lang.String getDataCenter();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.tools.NodeProbe.getEndpointSnitchInfoProxy:()Lorg/apache/cassandra/locator/EndpointSnitchInfoMBean;
invokeinterface org.apache.cassandra.locator.EndpointSnitchInfoMBean.getDatacenter:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public java.lang.String getRack();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.tools.NodeProbe.getEndpointSnitchInfoProxy:()Lorg/apache/cassandra/locator/EndpointSnitchInfoMBean;
invokeinterface org.apache.cassandra.locator.EndpointSnitchInfoMBean.getRack:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public java.util.List<java.lang.String> getKeyspaces();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getKeyspaces:()Ljava/util/List;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/List<Ljava/lang/String;>;
public java.util.List<java.lang.String> getNonSystemKeyspaces();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getNonSystemKeyspaces:()Ljava/util/List;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/List<Ljava/lang/String;>;
public java.util.List<java.lang.String> getNonLocalStrategyKeyspaces();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getNonLocalStrategyKeyspaces:()Ljava/util/List;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/List<Ljava/lang/String;>;
public java.lang.String getClusterName();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getClusterName:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public java.lang.String getPartitioner();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getPartitionerName:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void disableHintedHandoff();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.spProxy:Lorg/apache/cassandra/service/StorageProxyMBean;
iconst_0
invokeinterface org.apache.cassandra.service.StorageProxyMBean.setHintedHandoffEnabled:(Z)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void enableHintedHandoff();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.spProxy:Lorg/apache/cassandra/service/StorageProxyMBean;
iconst_1
invokeinterface org.apache.cassandra.service.StorageProxyMBean.setHintedHandoffEnabled:(Z)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
public boolean isHandoffEnabled();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.spProxy:Lorg/apache/cassandra/service/StorageProxyMBean;
invokeinterface org.apache.cassandra.service.StorageProxyMBean.getHintedHandoffEnabled:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void enableHintsForDC(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.spProxy:Lorg/apache/cassandra/service/StorageProxyMBean;
aload 1
invokeinterface org.apache.cassandra.service.StorageProxyMBean.enableHintsForDC:(Ljava/lang/String;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 dc Ljava/lang/String;
MethodParameters:
Name Flags
dc
public void disableHintsForDC(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.spProxy:Lorg/apache/cassandra/service/StorageProxyMBean;
aload 1
invokeinterface org.apache.cassandra.service.StorageProxyMBean.disableHintsForDC:(Ljava/lang/String;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 dc Ljava/lang/String;
MethodParameters:
Name Flags
dc
public java.util.Set<java.lang.String> getHintedHandoffDisabledDCs();
descriptor: ()Ljava/util/Set;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.spProxy:Lorg/apache/cassandra/service/StorageProxyMBean;
invokeinterface org.apache.cassandra.service.StorageProxyMBean.getHintedHandoffDisabledDCs:()Ljava/util/Set;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/Set<Ljava/lang/String;>;
public java.util.Map<java.lang.String, java.lang.String> getViewBuildStatuses(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
aload 2
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getViewBuildStatuses:(Ljava/lang/String;Ljava/lang/String;)Ljava/util/Map;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 1 1 keyspace Ljava/lang/String;
0 1 2 view Ljava/lang/String;
Signature: (Ljava/lang/String;Ljava/lang/String;)Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
MethodParameters:
Name Flags
keyspace
view
public void pauseHintsDelivery();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.hhProxy:Lorg/apache/cassandra/db/HintedHandOffManagerMBean;
iconst_1
invokeinterface org.apache.cassandra.db.HintedHandOffManagerMBean.pauseHintsDelivery:(Z)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void resumeHintsDelivery();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.hhProxy:Lorg/apache/cassandra/db/HintedHandOffManagerMBean;
iconst_0
invokeinterface org.apache.cassandra.db.HintedHandOffManagerMBean.pauseHintsDelivery:(Z)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void truncateHints(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.hhProxy:Lorg/apache/cassandra/db/HintedHandOffManagerMBean;
aload 1
invokeinterface org.apache.cassandra.db.HintedHandOffManagerMBean.deleteHintsForEndpoint:(Ljava/lang/String;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 host Ljava/lang/String;
MethodParameters:
Name Flags
host final
public void truncateHints();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.hhProxy:Lorg/apache/cassandra/db/HintedHandOffManagerMBean;
invokeinterface org.apache.cassandra.db.HintedHandOffManagerMBean.truncateAllHints:()V
1: goto 4
2: StackMap locals:
StackMap stack: java.lang.Exception
astore 1
start local 1 3: new java.lang.RuntimeException
dup
ldc "Error while executing truncate hints"
aload 1
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
athrow
end local 1 4: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/tools/NodeProbe;
3 4 1 e Ljava/lang/Exception;
Exception table:
from to target type
0 1 2 Class java.util.concurrent.ExecutionException
0 1 2 Class java.lang.InterruptedException
public void refreshSizeEstimates();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.refreshSizeEstimates:()V
1: goto 4
2: StackMap locals:
StackMap stack: java.util.concurrent.ExecutionException
astore 1
start local 1 3: new java.lang.RuntimeException
dup
ldc "Error while refreshing system.size_estimates"
aload 1
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
athrow
end local 1 4: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/tools/NodeProbe;
3 4 1 e Ljava/util/concurrent/ExecutionException;
Exception table:
from to target type
0 1 2 Class java.util.concurrent.ExecutionException
public void stopNativeTransport();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.stopNativeTransport:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void startNativeTransport();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.startNativeTransport:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
public boolean isNativeTransportRunning();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.isNativeTransportRunning:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void stopGossiping();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.stopGossiping:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void startGossiping();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.startGossiping:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
public boolean isGossipRunning();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.isGossipRunning:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void stopThriftServer();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.stopRPCServer:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void startThriftServer();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.startRPCServer:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
public boolean isThriftServerRunning();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.isRPCServerRunning:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void stopCassandraDaemon();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.stopDaemon:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
public boolean isInitialized();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.isInitialized:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void setCompactionThroughput(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
iload 1
invokeinterface org.apache.cassandra.service.StorageServiceMBean.setCompactionThroughputMbPerSec:(I)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 value I
MethodParameters:
Name Flags
value
public int getCompactionThroughput();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getCompactionThroughputMbPerSec:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void setConcurrentCompactors(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
iload 1
invokeinterface org.apache.cassandra.service.StorageServiceMBean.setConcurrentCompactors:(I)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 value I
MethodParameters:
Name Flags
value
public int getConcurrentCompactors();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getConcurrentCompactors:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public long getTimeout(java.lang.String);
descriptor: (Ljava/lang/String;)J
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 1
dup
astore 2
invokevirtual java.lang.String.hashCode:()I
lookupswitch { // 8
-1644339357: 1
-379001259: 2
3351788: 3
3496342: 4
108280125: 5
113399775: 6
427581060: 7
1852984678: 8
default: 17
}
StackMap locals: java.lang.String
StackMap stack:
1: aload 2
ldc "counterwrite"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 13
goto 17
StackMap locals:
StackMap stack:
2: aload 2
ldc "streamingsocket"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 16
goto 17
StackMap locals:
StackMap stack:
3: aload 2
ldc "misc"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 9
goto 17
StackMap locals:
StackMap stack:
4: aload 2
ldc "read"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 10
goto 17
StackMap locals:
StackMap stack:
5: aload 2
ldc "range"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 11
goto 17
StackMap locals:
StackMap stack:
6: aload 2
ldc "write"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 12
goto 17
StackMap locals:
StackMap stack:
7: aload 2
ldc "cascontention"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 14
goto 17
StackMap locals:
StackMap stack:
8: aload 2
ldc "truncate"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 15
goto 17
9: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getRpcTimeout:()J
lreturn
10: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getReadRpcTimeout:()J
lreturn
11: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getRangeRpcTimeout:()J
lreturn
12: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getWriteRpcTimeout:()J
lreturn
13: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getCounterWriteRpcTimeout:()J
lreturn
14: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getCasContentionTimeout:()J
lreturn
15: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getTruncateRpcTimeout:()J
lreturn
16: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getStreamingSocketTimeout:()I
i2l
lreturn
17: StackMap locals:
StackMap stack:
new java.lang.RuntimeException
dup
ldc "Timeout type requires one of (read, range, write, counterwrite, cascontention, truncate, streamingsocket, misc (general rpc_timeout_in_ms))"
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 18 1 type Ljava/lang/String;
MethodParameters:
Name Flags
type
public int getStreamThroughput();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getStreamThroughputMbPerSec:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public int getInterDCStreamThroughput();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getInterDCStreamThroughputMbPerSec:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public double getTraceProbability();
descriptor: ()D
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getTraceProbability:()D
dreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public int getExceptionCount();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic org.apache.cassandra.metrics.StorageMetrics.exceptions:Lcom/codahale/metrics/Counter;
invokevirtual com.codahale.metrics.Counter.getCount:()J
l2i
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public java.util.Map<java.lang.String, java.lang.Integer> getDroppedMessages();
descriptor: ()Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.msProxy:Lorg/apache/cassandra/net/MessagingServiceMBean;
invokeinterface org.apache.cassandra.net.MessagingServiceMBean.getDroppedMessages:()Ljava/util/Map;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/Map<Ljava/lang/String;Ljava/lang/Integer;>;
public void loadNewSSTables(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
aload 2
invokeinterface org.apache.cassandra.service.StorageServiceMBean.loadNewSSTables:(Ljava/lang/String;Ljava/lang/String;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 ksName Ljava/lang/String;
0 2 2 cfName Ljava/lang/String;
MethodParameters:
Name Flags
ksName
cfName
public void rebuildIndex(java.lang.String, java.lang.String, java.lang.String[]);
descriptor: (Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
aload 2
aload 3
invokeinterface org.apache.cassandra.service.StorageServiceMBean.rebuildSecondaryIndex:(Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 ksName Ljava/lang/String;
0 2 2 cfName Ljava/lang/String;
0 2 3 idxNames [Ljava/lang/String;
MethodParameters:
Name Flags
ksName
cfName
idxNames
public java.lang.String getGossipInfo();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.fdProxy:Lorg/apache/cassandra/gms/FailureDetectorMBean;
invokeinterface org.apache.cassandra.gms.FailureDetectorMBean.getAllEndpointStates:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void stop(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.compactionProxy:Lorg/apache/cassandra/db/compaction/CompactionManagerMBean;
aload 1
invokeinterface org.apache.cassandra.db.compaction.CompactionManagerMBean.stopCompaction:(Ljava/lang/String;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 string Ljava/lang/String;
MethodParameters:
Name Flags
string
public void setTimeout(java.lang.String, long);
descriptor: (Ljava/lang/String;J)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=3
start local 0 start local 1 start local 2 0: lload 2
lconst_0
lcmp
ifge 2
1: new java.lang.RuntimeException
dup
ldc "timeout must be non-negative"
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 1
dup
astore 4
invokevirtual java.lang.String.hashCode:()I
lookupswitch { // 8
-1644339357: 3
-379001259: 4
3351788: 5
3496342: 6
108280125: 7
113399775: 8
427581060: 9
1852984678: 10
default: 29
}
StackMap locals: java.lang.String
StackMap stack:
3: aload 4
ldc "counterwrite"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 19
goto 29
StackMap locals:
StackMap stack:
4: aload 4
ldc "streamingsocket"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 25
goto 29
StackMap locals:
StackMap stack:
5: aload 4
ldc "misc"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 11
goto 29
StackMap locals:
StackMap stack:
6: aload 4
ldc "read"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 13
goto 29
StackMap locals:
StackMap stack:
7: aload 4
ldc "range"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 15
goto 29
StackMap locals:
StackMap stack:
8: aload 4
ldc "write"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 17
goto 29
StackMap locals:
StackMap stack:
9: aload 4
ldc "cascontention"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 21
goto 29
StackMap locals:
StackMap stack:
10: aload 4
ldc "truncate"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 23
goto 29
11: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
lload 2
invokeinterface org.apache.cassandra.service.StorageServiceMBean.setRpcTimeout:(J)V
12: goto 30
13: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
lload 2
invokeinterface org.apache.cassandra.service.StorageServiceMBean.setReadRpcTimeout:(J)V
14: goto 30
15: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
lload 2
invokeinterface org.apache.cassandra.service.StorageServiceMBean.setRangeRpcTimeout:(J)V
16: goto 30
17: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
lload 2
invokeinterface org.apache.cassandra.service.StorageServiceMBean.setWriteRpcTimeout:(J)V
18: goto 30
19: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
lload 2
invokeinterface org.apache.cassandra.service.StorageServiceMBean.setCounterWriteRpcTimeout:(J)V
20: goto 30
21: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
lload 2
invokeinterface org.apache.cassandra.service.StorageServiceMBean.setCasContentionTimeout:(J)V
22: goto 30
23: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
lload 2
invokeinterface org.apache.cassandra.service.StorageServiceMBean.setTruncateRpcTimeout:(J)V
24: goto 30
25: StackMap locals:
StackMap stack:
lload 2
ldc 2147483647
lcmp
ifle 27
26: new java.lang.RuntimeException
dup
ldc "streamingsocket timeout must be less than 2147483647"
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
athrow
27: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
lload 2
l2i
invokeinterface org.apache.cassandra.service.StorageServiceMBean.setStreamingSocketTimeout:(I)V
28: goto 30
29: StackMap locals:
StackMap stack:
new java.lang.RuntimeException
dup
ldc "Timeout type requires one of (read, range, write, counterwrite, cascontention, truncate, streamingsocket, misc (general rpc_timeout_in_ms))"
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
athrow
30: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 31 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 31 1 type Ljava/lang/String;
0 31 2 value J
MethodParameters:
Name Flags
type
value
public void stopById(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.compactionProxy:Lorg/apache/cassandra/db/compaction/CompactionManagerMBean;
aload 1
invokeinterface org.apache.cassandra.db.compaction.CompactionManagerMBean.stopCompactionById:(Ljava/lang/String;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 compactionId Ljava/lang/String;
MethodParameters:
Name Flags
compactionId
public void setStreamThroughput(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
iload 1
invokeinterface org.apache.cassandra.service.StorageServiceMBean.setStreamThroughputMbPerSec:(I)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 value I
MethodParameters:
Name Flags
value
public void setInterDCStreamThroughput(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
iload 1
invokeinterface org.apache.cassandra.service.StorageServiceMBean.setInterDCStreamThroughputMbPerSec:(I)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 value I
MethodParameters:
Name Flags
value
public void setTraceProbability(double);
descriptor: (D)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
dload 1
invokeinterface org.apache.cassandra.service.StorageServiceMBean.setTraceProbability:(D)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 value D
MethodParameters:
Name Flags
value
public java.lang.String getSchemaVersion();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getSchemaVersion:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public java.util.List<java.lang.String> describeRing(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
invokeinterface org.apache.cassandra.service.StorageServiceMBean.describeRingJMX:(Ljava/lang/String;)Ljava/util/List;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 1 1 keyspaceName Ljava/lang/String;
Exceptions:
throws java.io.IOException
Signature: (Ljava/lang/String;)Ljava/util/List<Ljava/lang/String;>;
MethodParameters:
Name Flags
keyspaceName
public void rebuild(java.lang.String, java.lang.String, java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
aload 2
aload 3
aload 4
invokeinterface org.apache.cassandra.service.StorageServiceMBean.rebuild:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V
1: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 2 1 sourceDc Ljava/lang/String;
0 2 2 keyspace Ljava/lang/String;
0 2 3 tokens Ljava/lang/String;
0 2 4 specificSources Ljava/lang/String;
MethodParameters:
Name Flags
sourceDc
keyspace
tokens
specificSources
public java.util.List<java.lang.String> sampleKeyRange();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.sampleKeyRange:()Ljava/util/List;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/List<Ljava/lang/String;>;
public void resetLocalSchema();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.resetLocalSchema:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
Exceptions:
throws java.io.IOException
public void reloadLocalSchema();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.reloadLocalSchema:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
public boolean isFailed();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.failed:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public long getReadRepairAttempted();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.spProxy:Lorg/apache/cassandra/service/StorageProxyMBean;
invokeinterface org.apache.cassandra.service.StorageProxyMBean.getReadRepairAttempted:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public long getReadRepairRepairedBlocking();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.spProxy:Lorg/apache/cassandra/service/StorageProxyMBean;
invokeinterface org.apache.cassandra.service.StorageProxyMBean.getReadRepairRepairedBlocking:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public long getReadRepairRepairedBackground();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.spProxy:Lorg/apache/cassandra/service/StorageProxyMBean;
invokeinterface org.apache.cassandra.service.StorageProxyMBean.getReadRepairRepairedBackground:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public java.lang.Object getCacheMetric(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 2
dup
astore 3
invokevirtual java.lang.String.hashCode:()I
lookupswitch { // 9
-1990013238: 1
-1703482637: 2
-1646235418: 3
-1606413246: 4
-328612892: 5
-3180326: 6
2249568: 7
2577441: 8
73079920: 9
default: 34
}
StackMap locals: java.lang.String
StackMap stack:
1: aload 3
ldc "Misses"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 16
goto 34
StackMap locals:
StackMap stack:
2: aload 3
ldc "HitRate"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 10
goto 34
StackMap locals:
StackMap stack:
3: aload 3
ldc "MissLatencyUnit"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 28
goto 34
StackMap locals:
StackMap stack:
4: aload 3
ldc "MissLatency"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 22
goto 34
StackMap locals:
StackMap stack:
5: aload 3
ldc "Requests"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 16
goto 34
StackMap locals:
StackMap stack:
6: aload 3
ldc "Capacity"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 10
goto 34
StackMap locals:
StackMap stack:
7: aload 3
ldc "Hits"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 16
goto 34
StackMap locals:
StackMap stack:
8: aload 3
ldc "Size"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 10
goto 34
StackMap locals:
StackMap stack:
9: aload 3
ldc "Entries"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 10
goto 34
10: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
11: new javax.management.ObjectName
dup
new java.lang.StringBuilder
dup
ldc "org.apache.cassandra.metrics:type=Cache,scope="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ",name="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
12: ldc Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$JmxGaugeMBean;
13: invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxGaugeMBean
14: invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxGaugeMBean.getValue:()Ljava/lang/Object;
15: areturn
16: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
17: new javax.management.ObjectName
dup
new java.lang.StringBuilder
dup
ldc "org.apache.cassandra.metrics:type=Cache,scope="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ",name="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
18: ldc Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$JmxMeterMBean;
19: invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxMeterMBean
20: invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxMeterMBean.getCount:()J
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
21: areturn
22: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
23: new javax.management.ObjectName
dup
new java.lang.StringBuilder
dup
ldc "org.apache.cassandra.metrics:type=Cache,scope="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ",name="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
24: ldc Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$JmxTimerMBean;
25: invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxTimerMBean
26: invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxTimerMBean.getMean:()D
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
27: areturn
28: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
29: new javax.management.ObjectName
dup
new java.lang.StringBuilder
dup
ldc "org.apache.cassandra.metrics:type=Cache,scope="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ",name=MissLatency"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
30: ldc Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$JmxTimerMBean;
31: invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxTimerMBean
32: invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxTimerMBean.getDurationUnit:()Ljava/lang/String;
33: areturn
34: StackMap locals:
StackMap stack:
new java.lang.RuntimeException
dup
ldc "Unknown cache metric name."
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
athrow
35: StackMap locals: org.apache.cassandra.tools.NodeProbe java.lang.String java.lang.String
StackMap stack: javax.management.MalformedObjectNameException
astore 3
start local 3 36: new java.lang.RuntimeException
dup
aload 3
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 37 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 37 1 cacheType Ljava/lang/String;
0 37 2 metricName Ljava/lang/String;
36 37 3 e Ljavax/management/MalformedObjectNameException;
Exception table:
from to target type
0 15 35 Class javax.management.MalformedObjectNameException
16 21 35 Class javax.management.MalformedObjectNameException
22 27 35 Class javax.management.MalformedObjectNameException
28 33 35 Class javax.management.MalformedObjectNameException
34 35 35 Class javax.management.MalformedObjectNameException
MethodParameters:
Name Flags
cacheType
metricName
public java.lang.Object getThreadPoolMetric(java.lang.String, java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
aload 1
aload 2
aload 3
invokestatic org.apache.cassandra.metrics.ThreadPoolMetrics.getJmxMetric:(Ljavax/management/MBeanServerConnection;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Object;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 1 1 pathName Ljava/lang/String;
0 1 2 poolName Ljava/lang/String;
0 1 3 metricName Ljava/lang/String;
MethodParameters:
Name Flags
pathName
poolName
metricName
public com.google.common.collect.Multimap<java.lang.String, java.lang.String> getThreadPools();
descriptor: ()Lcom/google/common/collect/Multimap;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
invokestatic org.apache.cassandra.metrics.ThreadPoolMetrics.getJmxThreadPools:(Ljavax/management/MBeanServerConnection;)Lcom/google/common/collect/Multimap;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Lcom/google/common/collect/Multimap<Ljava/lang/String;Ljava/lang/String;>;
public int getNumberOfTables();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.spProxy:Lorg/apache/cassandra/service/StorageProxyMBean;
invokeinterface org.apache.cassandra.service.StorageProxyMBean.getNumberOfTables:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public java.lang.Object getColumnFamilyMetric(java.lang.String, java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aconst_null
astore 4
start local 4 1: aload 1
invokestatic com.google.common.base.Strings.isNullOrEmpty:(Ljava/lang/String;)Z
ifne 7
aload 2
invokestatic com.google.common.base.Strings.isNullOrEmpty:(Ljava/lang/String;)Z
ifne 7
2: aload 2
ldc "."
invokevirtual java.lang.String.contains:(Ljava/lang/CharSequence;)Z
ifeq 3
ldc "IndexTable"
goto 4
StackMap locals: javax.management.ObjectName
StackMap stack:
3: ldc "Table"
StackMap locals:
StackMap stack: java.lang.String
4: astore 5
start local 5 5: new javax.management.ObjectName
dup
ldc "org.apache.cassandra.metrics:type=%s,keyspace=%s,scope=%s,name=%s"
iconst_4
anewarray java.lang.Object
dup
iconst_0
aload 5
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
dup
iconst_3
aload 3
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
astore 4
end local 5 6: goto 11
7: StackMap locals:
StackMap stack:
aload 1
invokestatic com.google.common.base.Strings.isNullOrEmpty:(Ljava/lang/String;)Z
ifne 10
8: new javax.management.ObjectName
dup
ldc "org.apache.cassandra.metrics:type=Keyspace,keyspace=%s,name=%s"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
dup
iconst_1
aload 3
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
astore 4
9: goto 11
10: StackMap locals:
StackMap stack:
new javax.management.ObjectName
dup
ldc "org.apache.cassandra.metrics:type=Table,name=%s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 3
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
astore 4
11: StackMap locals:
StackMap stack:
aload 3
dup
astore 5
invokevirtual java.lang.String.hashCode:()I
lookupswitch { // 37
-1951202055: 12
-1887333593: 13
-1867190954: 14
-1866587829: 15
-1763863388: 16
-1667508752: 17
-1477475695: 18
-1465837505: 19
-1370758488: 20
-1114239206: 21
-1006440446: 22
-667833728: 23
-463587056: 24
-393169043: 25
-321785512: 26
-238574638: 27
74042690: 28
143897221: 29
263309627: 30
443978857: 31
630998566: 32
701129331: 33
797304881: 34
845374896: 35
881876584: 36
912468547: 37
1086144931: 38
1109151815: 39
1173199038: 40
1375251065: 41
1387870821: 42
1539939201: 43
1545839031: 44
1671916245: 45
1935395083: 46
1988130602: 47
2014525360: 48
default: 57
}
StackMap locals: java.lang.String
StackMap stack:
12: aload 5
ldc "MinPartitionSize"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
13: aload 5
ldc "MaxPartitionSize"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
14: aload 5
ldc "SSTablesPerReadHistogram"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 55
goto 57
StackMap locals:
StackMap stack:
15: aload 5
ldc "BloomFilterDiskSpaceUsed"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
16: aload 5
ldc "CompressionMetadataOffHeapMemoryUsed"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
17: aload 5
ldc "ReadTotalLatency"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 51
goto 57
StackMap locals:
StackMap stack:
18: aload 5
ldc "CoordinatorScanLatency"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 53
goto 57
StackMap locals:
StackMap stack:
19: aload 5
ldc "WriteLatency"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 53
goto 57
StackMap locals:
StackMap stack:
20: aload 5
ldc "RecentBloomFilterFalseRatio"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
21: aload 5
ldc "LiveDiskSpaceUsed"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 51
goto 57
StackMap locals:
StackMap stack:
22: aload 5
ldc "TotalDiskSpaceUsed"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 51
goto 57
StackMap locals:
StackMap stack:
23: aload 5
ldc "LiveScannedHistogram"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 55
goto 57
StackMap locals:
StackMap stack:
24: aload 5
ldc "KeyCacheHitRate"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
25: aload 5
ldc "LiveSSTableCount"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
26: aload 5
ldc "CoordinatorReadLatency"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 53
goto 57
StackMap locals:
StackMap stack:
27: aload 5
ldc "BloomFilterFalsePositives"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
28: aload 5
ldc "MemtableSwitchCount"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 51
goto 57
StackMap locals:
StackMap stack:
29: aload 5
ldc "IndexSummaryOffHeapMemoryUsed"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
30: aload 5
ldc "PendingFlushes"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 51
goto 57
StackMap locals:
StackMap stack:
31: aload 5
ldc "TombstoneScannedHistogram"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 55
goto 57
StackMap locals:
StackMap stack:
32: aload 5
ldc "MeanPartitionSize"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
33: aload 5
ldc "SpeculativeRetries"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 51
goto 57
StackMap locals:
StackMap stack:
34: aload 5
ldc "PercentRepaired"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
35: aload 5
ldc "MemtableLiveDataSize"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
36: aload 5
ldc "ReadLatency"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 53
goto 57
StackMap locals:
StackMap stack:
37: aload 5
ldc "BloomFilterFalseRatio"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
38: aload 5
ldc "MemtableOffHeapSize"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
39: aload 5
ldc "EstimatedColumnCountHistogram"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
40: aload 5
ldc "BloomFilterOffHeapMemoryUsed"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
41: aload 5
ldc "WriteTotalLatency"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 51
goto 57
StackMap locals:
StackMap stack:
42: aload 5
ldc "CompressionRatio"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
43: aload 5
ldc "EstimatedPartitionCount"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
44: aload 5
ldc "RecentBloomFilterFalsePositives"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
45: aload 5
ldc "EstimatedPartitionSizeHistogram"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
46: aload 5
ldc "MemtableColumnsCount"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
StackMap locals:
StackMap stack:
47: aload 5
ldc "DroppedMutations"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 51
goto 57
StackMap locals:
StackMap stack:
48: aload 5
ldc "SnapshotsSize"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 49
goto 57
49: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
aload 4
ldc Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$JmxGaugeMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxGaugeMBean
invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxGaugeMBean.getValue:()Ljava/lang/Object;
50: areturn
51: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
aload 4
ldc Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$JmxCounterMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxCounterMBean
invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxCounterMBean.getCount:()J
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
52: areturn
53: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
aload 4
ldc Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$JmxTimerMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
54: areturn
55: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
aload 4
ldc Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$JmxHistogramMBean;
invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
56: areturn
57: StackMap locals:
StackMap stack:
new java.lang.RuntimeException
dup
new java.lang.StringBuilder
dup
ldc "Unknown table metric "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 3
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
athrow
end local 4 58: StackMap locals: org.apache.cassandra.tools.NodeProbe java.lang.String java.lang.String java.lang.String
StackMap stack: javax.management.MalformedObjectNameException
astore 4
start local 4 59: new java.lang.RuntimeException
dup
aload 4
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 60 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 60 1 ks Ljava/lang/String;
0 60 2 cf Ljava/lang/String;
0 60 3 metricName Ljava/lang/String;
1 58 4 oName Ljavax/management/ObjectName;
5 6 5 type Ljava/lang/String;
59 60 4 e Ljavax/management/MalformedObjectNameException;
Exception table:
from to target type
0 50 58 Class javax.management.MalformedObjectNameException
51 52 58 Class javax.management.MalformedObjectNameException
53 54 58 Class javax.management.MalformedObjectNameException
55 56 58 Class javax.management.MalformedObjectNameException
57 58 58 Class javax.management.MalformedObjectNameException
MethodParameters:
Name Flags
ks
cf
metricName
public org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxTimerMBean getProxyMetric(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$JmxTimerMBean;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
1: new javax.management.ObjectName
dup
new java.lang.StringBuilder
dup
ldc "org.apache.cassandra.metrics:type=ClientRequest,scope="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ",name=Latency"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
2: ldc Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$JmxTimerMBean;
3: invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxTimerMBean
4: areturn
5: StackMap locals:
StackMap stack: javax.management.MalformedObjectNameException
astore 2
start local 2 6: new java.lang.RuntimeException
dup
aload 2
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 7 1 scope Ljava/lang/String;
6 7 2 e Ljavax/management/MalformedObjectNameException;
Exception table:
from to target type
0 4 5 Class javax.management.MalformedObjectNameException
MethodParameters:
Name Flags
scope
public java.lang.Object getCompactionMetric(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=2
start local 0 start local 1 0: aload 1
dup
astore 2
invokevirtual java.lang.String.hashCode:()I
lookupswitch { // 5
-363499487: 1
-203081717: 2
302677751: 3
316783703: 4
551065635: 5
default: 22
}
StackMap locals: java.lang.String
StackMap stack:
1: aload 2
ldc "TotalCompactionsCompleted"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 17
goto 22
StackMap locals:
StackMap stack:
2: aload 2
ldc "PendingTasksByTableName"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 11
goto 22
StackMap locals:
StackMap stack:
3: aload 2
ldc "BytesCompacted"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 6
goto 22
StackMap locals:
StackMap stack:
4: aload 2
ldc "PendingTasks"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 11
goto 22
StackMap locals:
StackMap stack:
5: aload 2
ldc "CompletedTasks"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 11
goto 22
6: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
7: new javax.management.ObjectName
dup
new java.lang.StringBuilder
dup
ldc "org.apache.cassandra.metrics:type=Compaction,name="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
8: ldc Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$JmxCounterMBean;
9: invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
10: areturn
11: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
12: new javax.management.ObjectName
dup
new java.lang.StringBuilder
dup
ldc "org.apache.cassandra.metrics:type=Compaction,name="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
13: ldc Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$JmxGaugeMBean;
14: invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxGaugeMBean
15: invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxGaugeMBean.getValue:()Ljava/lang/Object;
16: areturn
17: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
18: new javax.management.ObjectName
dup
new java.lang.StringBuilder
dup
ldc "org.apache.cassandra.metrics:type=Compaction,name="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
19: ldc Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$JmxMeterMBean;
20: invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
21: areturn
22: StackMap locals:
StackMap stack:
new java.lang.RuntimeException
dup
ldc "Unknown compaction metric."
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
athrow
23: StackMap locals: org.apache.cassandra.tools.NodeProbe java.lang.String
StackMap stack: javax.management.MalformedObjectNameException
astore 2
start local 2 24: new java.lang.RuntimeException
dup
aload 2
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 25 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 25 1 metricName Ljava/lang/String;
24 25 2 e Ljavax/management/MalformedObjectNameException;
Exception table:
from to target type
0 10 23 Class javax.management.MalformedObjectNameException
11 16 23 Class javax.management.MalformedObjectNameException
17 21 23 Class javax.management.MalformedObjectNameException
22 23 23 Class javax.management.MalformedObjectNameException
MethodParameters:
Name Flags
metricName
public long getStorageMetric(java.lang.String);
descriptor: (Ljava/lang/String;)J
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.mbeanServerConn:Ljavax/management/MBeanServerConnection;
1: new javax.management.ObjectName
dup
new java.lang.StringBuilder
dup
ldc "org.apache.cassandra.metrics:type=Storage,name="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial javax.management.ObjectName.<init>:(Ljava/lang/String;)V
2: ldc Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$JmxCounterMBean;
3: invokestatic javax.management.JMX.newMBeanProxy:(Ljavax/management/MBeanServerConnection;Ljavax/management/ObjectName;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxCounterMBean
4: invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxCounterMBean.getCount:()J
5: lreturn
6: StackMap locals:
StackMap stack: javax.management.MalformedObjectNameException
astore 2
start local 2 7: new java.lang.RuntimeException
dup
aload 2
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 8 1 metricName Ljava/lang/String;
7 8 2 e Ljavax/management/MalformedObjectNameException;
Exception table:
from to target type
0 5 6 Class javax.management.MalformedObjectNameException
MethodParameters:
Name Flags
metricName
public double[] metricPercentilesAsArray(org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxHistogramMBean);
descriptor: (Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$JmxHistogramMBean;)[D
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: bipush 7
newarray 7
dup
iconst_0
aload 1
invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxHistogramMBean.get50thPercentile:()D
dastore
dup
iconst_1
1: aload 1
invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxHistogramMBean.get75thPercentile:()D
dastore
dup
iconst_2
2: aload 1
invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxHistogramMBean.get95thPercentile:()D
dastore
dup
iconst_3
3: aload 1
invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxHistogramMBean.get98thPercentile:()D
dastore
dup
iconst_4
4: aload 1
invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxHistogramMBean.get99thPercentile:()D
dastore
dup
iconst_5
5: aload 1
invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxHistogramMBean.getMin:()J
l2d
dastore
dup
bipush 6
6: aload 1
invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxHistogramMBean.getMax:()J
l2d
dastore
7: areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 8 1 metric Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$JmxHistogramMBean;
MethodParameters:
Name Flags
metric
public double[] metricPercentilesAsArray(org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxTimerMBean);
descriptor: (Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$JmxTimerMBean;)[D
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: bipush 7
newarray 7
dup
iconst_0
aload 1
invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxTimerMBean.get50thPercentile:()D
dastore
dup
iconst_1
1: aload 1
invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxTimerMBean.get75thPercentile:()D
dastore
dup
iconst_2
2: aload 1
invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxTimerMBean.get95thPercentile:()D
dastore
dup
iconst_3
3: aload 1
invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxTimerMBean.get98thPercentile:()D
dastore
dup
iconst_4
4: aload 1
invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxTimerMBean.get99thPercentile:()D
dastore
dup
iconst_5
5: aload 1
invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxTimerMBean.getMin:()D
dastore
dup
bipush 6
6: aload 1
invokeinterface org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxTimerMBean.getMax:()D
dastore
7: areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 8 1 metric Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$JmxTimerMBean;
MethodParameters:
Name Flags
metric
public javax.management.openmbean.TabularData getCompactionHistory();
descriptor: ()Ljavax/management/openmbean/TabularData;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.compactionProxy:Lorg/apache/cassandra/db/compaction/CompactionManagerMBean;
invokeinterface org.apache.cassandra.db.compaction.CompactionManagerMBean.getCompactionHistory:()Ljavax/management/openmbean/TabularData;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void reloadTriggers();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.spProxy:Lorg/apache/cassandra/service/StorageProxyMBean;
invokeinterface org.apache.cassandra.service.StorageProxyMBean.reloadTriggerClasses:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/tools/NodeProbe;
public void setLoggingLevel(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 1
aload 2
invokeinterface org.apache.cassandra.service.StorageServiceMBean.setLoggingLevel:(Ljava/lang/String;Ljava/lang/String;)V
1: goto 4
2: StackMap locals:
StackMap stack: java.lang.Exception
astore 3
start local 3 3: new java.lang.RuntimeException
dup
new java.lang.StringBuilder
dup
ldc "Error setting log for "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " on level "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ". Please check logback configuration and ensure to have <jmxConfigurator /> set"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
aload 3
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
athrow
end local 3 4: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 5 1 classQualifier Ljava/lang/String;
0 5 2 level Ljava/lang/String;
3 4 3 e Ljava/lang/Exception;
Exception table:
from to target type
0 1 2 Class java.lang.Exception
MethodParameters:
Name Flags
classQualifier
level
public java.util.Map<java.lang.String, java.lang.String> getLoggingLevels();
descriptor: ()Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.getLoggingLevels:()Ljava/util/Map;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/NodeProbe;
Signature: ()Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
public void resumeBootstrap(java.io.PrintStream);
descriptor: (Ljava/io/PrintStream;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=2
start local 0 start local 1 0: new org.apache.cassandra.tools.BootstrapMonitor
dup
aload 1
invokespecial org.apache.cassandra.tools.BootstrapMonitor.<init>:(Ljava/io/PrintStream;)V
astore 2
start local 2 1: aload 0
getfield org.apache.cassandra.tools.NodeProbe.jmxc:Ljavax/management/remote/JMXConnector;
aload 2
aconst_null
aconst_null
invokeinterface javax.management.remote.JMXConnector.addConnectionNotificationListener:(Ljavax/management/NotificationListener;Ljavax/management/NotificationFilter;Ljava/lang/Object;)V
2: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 2
aconst_null
aconst_null
invokeinterface org.apache.cassandra.service.StorageServiceMBean.addNotificationListener:(Ljavax/management/NotificationListener;Ljavax/management/NotificationFilter;Ljava/lang/Object;)V
3: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
invokeinterface org.apache.cassandra.service.StorageServiceMBean.resumeBootstrap:()Z
ifeq 7
4: aload 1
ldc "Resuming bootstrap"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
5: aload 2
invokevirtual org.apache.cassandra.tools.BootstrapMonitor.awaitCompletion:()V
6: goto 18
7: StackMap locals: org.apache.cassandra.tools.BootstrapMonitor
StackMap stack:
aload 1
ldc "Node is already bootstrapped."
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
8: goto 18
9: StackMap locals:
StackMap stack: java.lang.Exception
astore 3
start local 3 10: new java.io.IOException
dup
aload 3
invokespecial java.io.IOException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 3 11: StackMap locals:
StackMap stack: java.lang.Throwable
astore 4
12: aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 2
invokeinterface org.apache.cassandra.service.StorageServiceMBean.removeNotificationListener:(Ljavax/management/NotificationListener;)V
13: aload 0
getfield org.apache.cassandra.tools.NodeProbe.jmxc:Ljavax/management/remote/JMXConnector;
aload 2
invokeinterface javax.management.remote.JMXConnector.removeConnectionNotificationListener:(Ljavax/management/NotificationListener;)V
14: goto 17
15: StackMap locals: org.apache.cassandra.tools.NodeProbe java.io.PrintStream org.apache.cassandra.tools.BootstrapMonitor top java.lang.Throwable
StackMap stack: java.lang.Throwable
astore 5
start local 5 16: aload 1
new java.lang.StringBuilder
dup
ldc "Exception occurred during clean-up. "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 5
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
end local 5 17: StackMap locals:
StackMap stack:
aload 4
athrow
18: StackMap locals: org.apache.cassandra.tools.NodeProbe java.io.PrintStream org.apache.cassandra.tools.BootstrapMonitor
StackMap stack:
aload 0
getfield org.apache.cassandra.tools.NodeProbe.ssProxy:Lorg/apache/cassandra/service/StorageServiceMBean;
aload 2
invokeinterface org.apache.cassandra.service.StorageServiceMBean.removeNotificationListener:(Ljavax/management/NotificationListener;)V
19: aload 0
getfield org.apache.cassandra.tools.NodeProbe.jmxc:Ljavax/management/remote/JMXConnector;
aload 2
invokeinterface javax.management.remote.JMXConnector.removeConnectionNotificationListener:(Ljavax/management/NotificationListener;)V
20: goto 23
21: StackMap locals:
StackMap stack: java.lang.Throwable
astore 5
start local 5 22: aload 1
new java.lang.StringBuilder
dup
ldc "Exception occurred during clean-up. "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 5
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
end local 5 23: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Lorg/apache/cassandra/tools/NodeProbe;
0 24 1 out Ljava/io/PrintStream;
1 24 2 monitor Lorg/apache/cassandra/tools/BootstrapMonitor;
10 11 3 e Ljava/lang/Exception;
16 17 5 e Ljava/lang/Throwable;
22 23 5 e Ljava/lang/Throwable;
Exception table:
from to target type
1 8 9 Class java.lang.Exception
1 11 11 any
12 14 15 Class java.lang.Throwable
18 20 21 Class java.lang.Throwable
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
out
public void replayBatchlog();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.bmProxy:Lorg/apache/cassandra/batchlog/BatchlogManagerMBean;
invokeinterface org.apache.cassandra.batchlog.BatchlogManagerMBean.forceBatchlogReplay:()V
1: goto 4
2: StackMap locals:
StackMap stack: java.lang.Exception
astore 1
start local 1 3: new java.io.IOException
dup
aload 1
invokespecial java.io.IOException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 1 4: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/tools/NodeProbe;
3 4 1 e Ljava/lang/Exception;
Exception table:
from to target type
0 1 2 Class java.lang.Exception
Exceptions:
throws java.io.IOException
public javax.management.openmbean.TabularData getFailureDetectorPhilValues();
descriptor: ()Ljavax/management/openmbean/TabularData;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.tools.NodeProbe.fdProxy:Lorg/apache/cassandra/gms/FailureDetectorMBean;
invokeinterface org.apache.cassandra.gms.FailureDetectorMBean.getPhiValues:()Ljavax/management/openmbean/TabularData;
1: areturn
2: StackMap locals:
StackMap stack: javax.management.openmbean.OpenDataException
astore 1
start local 1 3: new java.lang.RuntimeException
dup
aload 1
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/tools/NodeProbe;
3 4 1 e Ljavax/management/openmbean/OpenDataException;
Exception table:
from to target type
0 1 2 Class javax.management.openmbean.OpenDataException
}
SourceFile: "NodeProbe.java"
NestMembers:
org.apache.cassandra.tools.NodeProbe$1
InnerClasses:
public abstract Entry = java.util.Map$Entry of java.util.Map
public abstract JmxCounterMBean = org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxCounterMBean of org.apache.cassandra.metrics.CassandraMetricsRegistry
public abstract JmxGaugeMBean = org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxGaugeMBean of org.apache.cassandra.metrics.CassandraMetricsRegistry
public abstract JmxHistogramMBean = org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxHistogramMBean of org.apache.cassandra.metrics.CassandraMetricsRegistry
public abstract JmxMeterMBean = org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxMeterMBean of org.apache.cassandra.metrics.CassandraMetricsRegistry
public abstract JmxTimerMBean = org.apache.cassandra.metrics.CassandraMetricsRegistry$JmxTimerMBean of org.apache.cassandra.metrics.CassandraMetricsRegistry
public final Sampler = org.apache.cassandra.metrics.TableMetrics$Sampler of org.apache.cassandra.metrics.TableMetrics
org.apache.cassandra.tools.NodeProbe$1