https://cassandra.apache.org: The Apache Cassandra Project develops a highly scalable second-generation distributed database, bringing together Dynamo's fully distributed design and Bigtable's ColumnFamily-based data model.
  • Andres de la Peña
  • Avinash Lakshman
  • Aleksey Yeschenko
  • Aaron Morton
  • Ariel Weisberg
  • Blake Eggleston
  • Benedict Elliott Smith
  • Benjamin Lerer
  • Branimir Lambov
  • Brandon Williams
  • Carl Yeksigian
  • David Brosiusd
  • Dikang Gu
  • Eric Evans
  • Gary Dusbabek
  • Chris Goffinet
  • Alex Petrov
  • Laine Jaakko Olavi
  • T Jake Luciani
  • Jason Brown
  • Jonathan Ellis
  • Jake Farrell
  • Jeff Jirsa
  • Joel Knighton
  • Josh McKenzie
  • Johan Oskarsson
  • Jun Rao
  • Jay Zhuang
  • Sankalp Kohli
  • Marcus Eriksson
  • Michael Semb Wever
  • Mikhail Stepura
  • Michael Shuler
  • Paulo Motta
  • Prashant Malik
  • Robert Stupp
  • Peter Schuller
  • Sam Tunnicliffe
  • Sylvain Lebresne
  • Stefania Alborghetti
  • Tyler Hobbs
  • Vijay Parthasarathy
  • Pavel Yaskevich
  • Yuki Morishita
  • Nate McCall 
public class org.apache.cassandra.locator.CloudstackSnitch extends org.apache.cassandra.locator.AbstractNetworkTopologySnitch
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.locator.CloudstackSnitch
  super_class: org.apache.cassandra.locator.AbstractNetworkTopologySnitch
{
  protected static final org.slf4j.Logger logger;
    descriptor: Lorg/slf4j/Logger;
    flags: (0x001c) ACC_PROTECTED, ACC_STATIC, ACC_FINAL

  protected static final java.lang.String ZONE_NAME_QUERY_URI;
    descriptor: Ljava/lang/String;
    flags: (0x001c) ACC_PROTECTED, ACC_STATIC, ACC_FINAL
    ConstantValue: "/latest/meta-data/availability-zone"

  private java.util.Map<java.net.InetAddress, java.util.Map<java.lang.String, java.lang.String>> savedEndpoints;
    descriptor: Ljava/util/Map;
    flags: (0x0002) ACC_PRIVATE
    Signature: Ljava/util/Map<Ljava/net/InetAddress;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;>;

  private static final java.lang.String DEFAULT_DC;
    descriptor: Ljava/lang/String;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: "UNKNOWN-DC"

  private static final java.lang.String DEFAULT_RACK;
    descriptor: Ljava/lang/String;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: "UNKNOWN-RACK"

  private static final java.lang.String[] LEASE_FILES;
    descriptor: [Ljava/lang/String;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  protected java.lang.String csZoneDc;
    descriptor: Ljava/lang/String;
    flags: (0x0004) ACC_PROTECTED

  protected java.lang.String csZoneRack;
    descriptor: Ljava/lang/String;
    flags: (0x0004) ACC_PROTECTED

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=4, locals=0, args_size=0
         0: .line 56
            ldc Lorg/apache/cassandra/locator/CloudstackSnitch;
            invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
            putstatic org.apache.cassandra.locator.CloudstackSnitch.logger:Lorg/slf4j/Logger;
         1: .line 64
            iconst_2
            anewarray java.lang.String
            dup
            iconst_0
         2: .line 65
            ldc "file:///var/lib/dhcp/dhclient.eth0.leases"
            aastore
            dup
            iconst_1
         3: .line 66
            ldc "file:///var/lib/dhclient/dhclient.eth0.leases"
            aastore
         4: .line 63
            putstatic org.apache.cassandra.locator.CloudstackSnitch.LEASE_FILES:[Ljava/lang/String;
         5: .line 67
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=4, args_size=1
        start local 0 // org.apache.cassandra.locator.CloudstackSnitch this
         0: .line 72
            aload 0 /* this */
            invokespecial org.apache.cassandra.locator.AbstractNetworkTopologySnitch.<init>:()V
         1: .line 74
            aload 0 /* this */
            invokevirtual org.apache.cassandra.locator.CloudstackSnitch.csMetadataEndpoint:()Ljava/lang/String;
            astore 1 /* endpoint */
        start local 1 // java.lang.String endpoint
         2: .line 75
            aload 0 /* this */
            new java.lang.StringBuilder
            dup
            aload 1 /* endpoint */
            invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            ldc "/latest/meta-data/availability-zone"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual org.apache.cassandra.locator.CloudstackSnitch.csQueryMetadata:(Ljava/lang/String;)Ljava/lang/String;
            astore 2 /* zone */
        start local 2 // java.lang.String zone
         3: .line 76
            aload 2 /* zone */
            ldc "-"
            invokevirtual java.lang.String.split:(Ljava/lang/String;)[Ljava/lang/String;
            astore 3 /* zone_parts */
        start local 3 // java.lang.String[] zone_parts
         4: .line 78
            aload 3 /* zone_parts */
            arraylength
            iconst_3
            if_icmpeq 6
         5: .line 80
            new org.apache.cassandra.exceptions.ConfigurationException
            dup
            new java.lang.StringBuilder
            dup
            ldc "CloudstackSnitch cannot handle invalid zone format: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* zone */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
            athrow
         6: .line 82
      StackMap locals: org.apache.cassandra.locator.CloudstackSnitch java.lang.String java.lang.String java.lang.String[]
      StackMap stack:
            aload 0 /* this */
            new java.lang.StringBuilder
            dup
            aload 3 /* zone_parts */
            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 3 /* zone_parts */
            iconst_1
            aaload
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            putfield org.apache.cassandra.locator.CloudstackSnitch.csZoneDc:Ljava/lang/String;
         7: .line 83
            aload 0 /* this */
            aload 3 /* zone_parts */
            iconst_2
            aaload
            putfield org.apache.cassandra.locator.CloudstackSnitch.csZoneRack:Ljava/lang/String;
         8: .line 84
            return
        end local 3 // java.lang.String[] zone_parts
        end local 2 // java.lang.String zone
        end local 1 // java.lang.String endpoint
        end local 0 // org.apache.cassandra.locator.CloudstackSnitch this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    9     0        this  Lorg/apache/cassandra/locator/CloudstackSnitch;
            2    9     1    endpoint  Ljava/lang/String;
            3    9     2        zone  Ljava/lang/String;
            4    9     3  zone_parts  [Ljava/lang/String;
    Exceptions:
      throws java.io.IOException, org.apache.cassandra.exceptions.ConfigurationException

  public java.lang.String getRack(java.net.InetAddress);
    descriptor: (Ljava/net/InetAddress;)Ljava/lang/String;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // org.apache.cassandra.locator.CloudstackSnitch this
        start local 1 // java.net.InetAddress endpoint
         0: .line 88
            aload 1 /* endpoint */
            invokestatic org.apache.cassandra.utils.FBUtilities.getBroadcastAddress:()Ljava/net/InetAddress;
            invokevirtual java.net.InetAddress.equals:(Ljava/lang/Object;)Z
            ifeq 2
         1: .line 89
            aload 0 /* this */
            getfield org.apache.cassandra.locator.CloudstackSnitch.csZoneRack:Ljava/lang/String;
            areturn
         2: .line 90
      StackMap locals:
      StackMap stack:
            getstatic org.apache.cassandra.gms.Gossiper.instance:Lorg/apache/cassandra/gms/Gossiper;
            aload 1 /* endpoint */
            invokevirtual org.apache.cassandra.gms.Gossiper.getEndpointStateForEndpoint:(Ljava/net/InetAddress;)Lorg/apache/cassandra/gms/EndpointState;
            astore 2 /* state */
        start local 2 // org.apache.cassandra.gms.EndpointState state
         3: .line 91
            aload 2 /* state */
            ifnull 4
            aload 2 /* state */
            getstatic org.apache.cassandra.gms.ApplicationState.RACK:Lorg/apache/cassandra/gms/ApplicationState;
            invokevirtual org.apache.cassandra.gms.EndpointState.getApplicationState:(Lorg/apache/cassandra/gms/ApplicationState;)Lorg/apache/cassandra/gms/VersionedValue;
            ifnonnull 9
         4: .line 93
      StackMap locals: org.apache.cassandra.gms.EndpointState
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.locator.CloudstackSnitch.savedEndpoints:Ljava/util/Map;
            ifnonnull 6
         5: .line 94
            aload 0 /* this */
            invokestatic org.apache.cassandra.db.SystemKeyspace.loadDcRackInfo:()Ljava/util/Map;
            putfield org.apache.cassandra.locator.CloudstackSnitch.savedEndpoints:Ljava/util/Map;
         6: .line 95
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.locator.CloudstackSnitch.savedEndpoints:Ljava/util/Map;
            aload 1 /* endpoint */
            invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
            ifeq 8
         7: .line 96
            aload 0 /* this */
            getfield org.apache.cassandra.locator.CloudstackSnitch.savedEndpoints:Ljava/util/Map;
            aload 1 /* endpoint */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.Map
            ldc "rack"
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.lang.String
            areturn
         8: .line 97
      StackMap locals:
      StackMap stack:
            ldc "UNKNOWN-RACK"
            areturn
         9: .line 99
      StackMap locals:
      StackMap stack:
            aload 2 /* state */
            getstatic org.apache.cassandra.gms.ApplicationState.RACK:Lorg/apache/cassandra/gms/ApplicationState;
            invokevirtual org.apache.cassandra.gms.EndpointState.getApplicationState:(Lorg/apache/cassandra/gms/ApplicationState;)Lorg/apache/cassandra/gms/VersionedValue;
            getfield org.apache.cassandra.gms.VersionedValue.value:Ljava/lang/String;
            areturn
        end local 2 // org.apache.cassandra.gms.EndpointState state
        end local 1 // java.net.InetAddress endpoint
        end local 0 // org.apache.cassandra.locator.CloudstackSnitch this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   10     0      this  Lorg/apache/cassandra/locator/CloudstackSnitch;
            0   10     1  endpoint  Ljava/net/InetAddress;
            3   10     2     state  Lorg/apache/cassandra/gms/EndpointState;
    MethodParameters:
          Name  Flags
      endpoint  

  public java.lang.String getDatacenter(java.net.InetAddress);
    descriptor: (Ljava/net/InetAddress;)Ljava/lang/String;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // org.apache.cassandra.locator.CloudstackSnitch this
        start local 1 // java.net.InetAddress endpoint
         0: .line 104
            aload 1 /* endpoint */
            invokestatic org.apache.cassandra.utils.FBUtilities.getBroadcastAddress:()Ljava/net/InetAddress;
            invokevirtual java.net.InetAddress.equals:(Ljava/lang/Object;)Z
            ifeq 2
         1: .line 105
            aload 0 /* this */
            getfield org.apache.cassandra.locator.CloudstackSnitch.csZoneDc:Ljava/lang/String;
            areturn
         2: .line 106
      StackMap locals:
      StackMap stack:
            getstatic org.apache.cassandra.gms.Gossiper.instance:Lorg/apache/cassandra/gms/Gossiper;
            aload 1 /* endpoint */
            invokevirtual org.apache.cassandra.gms.Gossiper.getEndpointStateForEndpoint:(Ljava/net/InetAddress;)Lorg/apache/cassandra/gms/EndpointState;
            astore 2 /* state */
        start local 2 // org.apache.cassandra.gms.EndpointState state
         3: .line 107
            aload 2 /* state */
            ifnull 4
            aload 2 /* state */
            getstatic org.apache.cassandra.gms.ApplicationState.DC:Lorg/apache/cassandra/gms/ApplicationState;
            invokevirtual org.apache.cassandra.gms.EndpointState.getApplicationState:(Lorg/apache/cassandra/gms/ApplicationState;)Lorg/apache/cassandra/gms/VersionedValue;
            ifnonnull 9
         4: .line 109
      StackMap locals: org.apache.cassandra.gms.EndpointState
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.locator.CloudstackSnitch.savedEndpoints:Ljava/util/Map;
            ifnonnull 6
         5: .line 110
            aload 0 /* this */
            invokestatic org.apache.cassandra.db.SystemKeyspace.loadDcRackInfo:()Ljava/util/Map;
            putfield org.apache.cassandra.locator.CloudstackSnitch.savedEndpoints:Ljava/util/Map;
         6: .line 111
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.locator.CloudstackSnitch.savedEndpoints:Ljava/util/Map;
            aload 1 /* endpoint */
            invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
            ifeq 8
         7: .line 112
            aload 0 /* this */
            getfield org.apache.cassandra.locator.CloudstackSnitch.savedEndpoints:Ljava/util/Map;
            aload 1 /* endpoint */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.Map
            ldc "data_center"
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.lang.String
            areturn
         8: .line 113
      StackMap locals:
      StackMap stack:
            ldc "UNKNOWN-DC"
            areturn
         9: .line 115
      StackMap locals:
      StackMap stack:
            aload 2 /* state */
            getstatic org.apache.cassandra.gms.ApplicationState.DC:Lorg/apache/cassandra/gms/ApplicationState;
            invokevirtual org.apache.cassandra.gms.EndpointState.getApplicationState:(Lorg/apache/cassandra/gms/ApplicationState;)Lorg/apache/cassandra/gms/VersionedValue;
            getfield org.apache.cassandra.gms.VersionedValue.value:Ljava/lang/String;
            areturn
        end local 2 // org.apache.cassandra.gms.EndpointState state
        end local 1 // java.net.InetAddress endpoint
        end local 0 // org.apache.cassandra.locator.CloudstackSnitch this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   10     0      this  Lorg/apache/cassandra/locator/CloudstackSnitch;
            0   10     1  endpoint  Ljava/net/InetAddress;
            3   10     2     state  Lorg/apache/cassandra/gms/EndpointState;
    MethodParameters:
          Name  Flags
      endpoint  

  java.lang.String csQueryMetadata(java.lang.String);
    descriptor: (Ljava/lang/String;)Ljava/lang/String;
    flags: (0x0000) 
    Code:
      stack=5, locals=8, args_size=2
        start local 0 // org.apache.cassandra.locator.CloudstackSnitch this
        start local 1 // java.lang.String url
         0: .line 120
            aconst_null
            astore 2 /* conn */
        start local 2 // java.net.HttpURLConnection conn
         1: .line 121
            aconst_null
            astore 3 /* is */
        start local 3 // java.io.DataInputStream is
         2: .line 125
            new java.net.URL
            dup
            aload 1 /* url */
            invokespecial java.net.URL.<init>:(Ljava/lang/String;)V
            invokevirtual java.net.URL.openConnection:()Ljava/net/URLConnection;
            checkcast java.net.HttpURLConnection
            astore 2 /* conn */
         3: .line 126
            goto 6
         4: .line 127
      StackMap locals: org.apache.cassandra.locator.CloudstackSnitch java.lang.String java.net.HttpURLConnection java.io.DataInputStream
      StackMap stack: java.lang.Exception
            pop
         5: .line 129
            new org.apache.cassandra.exceptions.ConfigurationException
            dup
            new java.lang.StringBuilder
            dup
            ldc "CloudstackSnitch cannot query wrong metadata URL: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* url */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
            athrow
         6: .line 133
      StackMap locals:
      StackMap stack:
            aload 2 /* conn */
            ldc "GET"
            invokevirtual java.net.HttpURLConnection.setRequestMethod:(Ljava/lang/String;)V
         7: .line 134
            aload 2 /* conn */
            invokevirtual java.net.HttpURLConnection.getResponseCode:()I
            sipush 200
            if_icmpeq 9
         8: .line 136
            new org.apache.cassandra.exceptions.ConfigurationException
            dup
            ldc "CloudstackSnitch was unable to query metadata."
            invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
            athrow
         9: .line 139
      StackMap locals:
      StackMap stack:
            aload 2 /* conn */
            invokevirtual java.net.HttpURLConnection.getContentLength:()I
            istore 4 /* cl */
        start local 4 // int cl
        10: .line 140
            iload 4 /* cl */
            newarray 8
            astore 5 /* b */
        start local 5 // byte[] b
        11: .line 141
            new java.io.DataInputStream
            dup
            new java.io.BufferedInputStream
            dup
            aload 2 /* conn */
            invokevirtual java.net.HttpURLConnection.getInputStream:()Ljava/io/InputStream;
            invokespecial java.io.BufferedInputStream.<init>:(Ljava/io/InputStream;)V
            invokespecial java.io.DataInputStream.<init>:(Ljava/io/InputStream;)V
            astore 3 /* is */
        12: .line 142
            aload 3 /* is */
            aload 5 /* b */
            invokevirtual java.io.DataInputStream.readFully:([B)V
        13: .line 143
            new java.lang.String
            dup
            aload 5 /* b */
            getstatic java.nio.charset.StandardCharsets.UTF_8:Ljava/nio/charset/Charset;
            invokespecial java.lang.String.<init>:([BLjava/nio/charset/Charset;)V
            astore 7
        14: .line 146
            iconst_1
            anewarray java.io.Closeable
            dup
            iconst_0
        15: .line 147
            aload 3 /* is */
            aastore
            invokestatic org.apache.cassandra.io.util.FileUtils.close:([Ljava/io/Closeable;)V
        16: .line 148
            aload 2 /* conn */
            invokevirtual java.net.HttpURLConnection.disconnect:()V
        17: .line 143
            aload 7
            areturn
        end local 5 // byte[] b
        end local 4 // int cl
        18: .line 146
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 6
            iconst_1
            anewarray java.io.Closeable
            dup
            iconst_0
        19: .line 147
            aload 3 /* is */
            aastore
            invokestatic org.apache.cassandra.io.util.FileUtils.close:([Ljava/io/Closeable;)V
        20: .line 148
            aload 2 /* conn */
            invokevirtual java.net.HttpURLConnection.disconnect:()V
        21: .line 149
            aload 6
            athrow
        end local 3 // java.io.DataInputStream is
        end local 2 // java.net.HttpURLConnection conn
        end local 1 // java.lang.String url
        end local 0 // org.apache.cassandra.locator.CloudstackSnitch this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   22     0  this  Lorg/apache/cassandra/locator/CloudstackSnitch;
            0   22     1   url  Ljava/lang/String;
            1   22     2  conn  Ljava/net/HttpURLConnection;
            2   22     3    is  Ljava/io/DataInputStream;
           10   18     4    cl  I
           11   18     5     b  [B
      Exception table:
        from    to  target  type
           2     3       4  Class java.lang.Exception
           6    14      18  any
    Exceptions:
      throws org.apache.cassandra.exceptions.ConfigurationException, java.io.IOException
    MethodParameters:
      Name  Flags
      url   

  java.lang.String csMetadataEndpoint();
    descriptor: ()Ljava/lang/String;
    flags: (0x0000) 
    Code:
      stack=5, locals=6, args_size=1
        start local 0 // org.apache.cassandra.locator.CloudstackSnitch this
         0: .line 154
            getstatic org.apache.cassandra.locator.CloudstackSnitch.LEASE_FILES:[Ljava/lang/String;
            dup
            astore 4
            arraylength
            istore 3
            iconst_0
            istore 2
            goto 9
      StackMap locals: org.apache.cassandra.locator.CloudstackSnitch top int int java.lang.String[]
      StackMap stack:
         1: aload 4
            iload 2
            aaload
            astore 1 /* lease_uri */
        start local 1 // java.lang.String lease_uri
         2: .line 158
            new java.io.File
            dup
            new java.net.URI
            dup
            aload 1 /* lease_uri */
            invokespecial java.net.URI.<init>:(Ljava/lang/String;)V
            invokespecial java.io.File.<init>:(Ljava/net/URI;)V
            astore 5 /* lease_file */
        start local 5 // java.io.File lease_file
         3: .line 159
            aload 5 /* lease_file */
            invokevirtual java.io.File.exists:()Z
            ifeq 8
         4: .line 161
            aload 0 /* this */
            aload 5 /* lease_file */
            invokevirtual org.apache.cassandra.locator.CloudstackSnitch.csEndpointFromLease:(Ljava/io/File;)Ljava/lang/String;
         5: areturn
        end local 5 // java.io.File lease_file
         6: .line 164
      StackMap locals: org.apache.cassandra.locator.CloudstackSnitch java.lang.String int int java.lang.String[]
      StackMap stack: java.lang.Exception
            astore 5 /* e */
        start local 5 // java.lang.Exception e
         7: .line 166
            aload 5 /* e */
            invokestatic org.apache.cassandra.utils.JVMStabilityInspector.inspectThrowable:(Ljava/lang/Throwable;)V
        end local 5 // java.lang.Exception e
        end local 1 // java.lang.String lease_uri
         8: .line 154
      StackMap locals: org.apache.cassandra.locator.CloudstackSnitch top int int java.lang.String[]
      StackMap stack:
            iinc 2 1
      StackMap locals:
      StackMap stack:
         9: iload 2
            iload 3
            if_icmplt 1
        10: .line 172
            new org.apache.cassandra.exceptions.ConfigurationException
            dup
            ldc "No valid DHCP lease file could be found."
            invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
            athrow
        end local 0 // org.apache.cassandra.locator.CloudstackSnitch this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   11     0        this  Lorg/apache/cassandra/locator/CloudstackSnitch;
            2    8     1   lease_uri  Ljava/lang/String;
            3    6     5  lease_file  Ljava/io/File;
            7    8     5           e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           2     5       6  Class java.lang.Exception
    Exceptions:
      throws org.apache.cassandra.exceptions.ConfigurationException

  java.lang.String csEndpointFromLease(java.io.File);
    descriptor: (Ljava/io/File;)Ljava/lang/String;
    flags: (0x0000) 
    Code:
      stack=5, locals=9, args_size=2
        start local 0 // org.apache.cassandra.locator.CloudstackSnitch this
        start local 1 // java.io.File lease
         0: .line 178
            aconst_null
            astore 3 /* endpoint */
        start local 3 // java.lang.String endpoint
         1: .line 179
            ldc "^[ \t]*option dhcp-server-identifier (.*);$"
            invokestatic java.util.regex.Pattern.compile:(Ljava/lang/String;)Ljava/util/regex/Pattern;
            astore 4 /* identifierPattern */
        start local 4 // java.util.regex.Pattern identifierPattern
         2: .line 181
            aconst_null
            astore 5
            aconst_null
            astore 6
         3: new java.io.BufferedReader
            dup
            new java.io.FileReader
            dup
            aload 1 /* lease */
            invokespecial java.io.FileReader.<init>:(Ljava/io/File;)V
            invokespecial java.io.BufferedReader.<init>:(Ljava/io/Reader;)V
            astore 7 /* reader */
        start local 7 // java.io.BufferedReader reader
         4: .line 184
            goto 9
        start local 2 // java.lang.String line
         5: .line 186
      StackMap locals: org.apache.cassandra.locator.CloudstackSnitch java.io.File java.lang.String java.lang.String java.util.regex.Pattern java.lang.Throwable java.lang.Throwable java.io.BufferedReader
      StackMap stack:
            aload 4 /* identifierPattern */
            aload 2 /* line */
            invokevirtual java.util.regex.Pattern.matcher:(Ljava/lang/CharSequence;)Ljava/util/regex/Matcher;
            astore 8 /* matcher */
        start local 8 // java.util.regex.Matcher matcher
         6: .line 188
            aload 8 /* matcher */
            invokevirtual java.util.regex.Matcher.find:()Z
            ifeq 9
         7: .line 190
            aload 8 /* matcher */
            iconst_1
            invokevirtual java.util.regex.Matcher.group:(I)Ljava/lang/String;
            astore 3 /* endpoint */
         8: .line 191
            goto 11
        end local 8 // java.util.regex.Matcher matcher
        end local 2 // java.lang.String line
         9: .line 184
      StackMap locals: org.apache.cassandra.locator.CloudstackSnitch java.io.File top java.lang.String java.util.regex.Pattern java.lang.Throwable java.lang.Throwable java.io.BufferedReader
      StackMap stack:
            aload 7 /* reader */
            invokevirtual java.io.BufferedReader.readLine:()Ljava/lang/String;
            dup
            astore 2 /* line */
        start local 2 // java.lang.String line
        10: ifnonnull 5
        11: .line 194
      StackMap locals: org.apache.cassandra.locator.CloudstackSnitch java.io.File java.lang.String java.lang.String java.util.regex.Pattern java.lang.Throwable java.lang.Throwable java.io.BufferedReader
      StackMap stack:
            aload 7 /* reader */
            ifnull 19
            aload 7 /* reader */
            invokevirtual java.io.BufferedReader.close:()V
            goto 19
        end local 2 // java.lang.String line
      StackMap locals: org.apache.cassandra.locator.CloudstackSnitch java.io.File top java.lang.String java.util.regex.Pattern java.lang.Throwable java.lang.Throwable java.io.BufferedReader
      StackMap stack: java.lang.Throwable
        12: astore 5
            aload 7 /* reader */
            ifnull 13
            aload 7 /* reader */
            invokevirtual java.io.BufferedReader.close:()V
        end local 7 // java.io.BufferedReader reader
      StackMap locals:
      StackMap stack:
        13: aload 5
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        14: astore 6
            aload 5
            ifnonnull 15
            aload 6
            astore 5
            goto 16
      StackMap locals:
      StackMap stack:
        15: aload 5
            aload 6
            if_acmpeq 16
            aload 5
            aload 6
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        16: aload 5
            athrow
        17: .line 195
      StackMap locals: org.apache.cassandra.locator.CloudstackSnitch java.io.File top java.lang.String java.util.regex.Pattern
      StackMap stack: java.lang.Exception
            pop
        18: .line 197
            new org.apache.cassandra.exceptions.ConfigurationException
            dup
            ldc "CloudstackSnitch cannot access lease file."
            invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
            athrow
        start local 2 // java.lang.String line
        19: .line 200
      StackMap locals: org.apache.cassandra.locator.CloudstackSnitch java.io.File java.lang.String java.lang.String java.util.regex.Pattern
      StackMap stack:
            aload 3 /* endpoint */
            ifnonnull 21
        20: .line 202
            new org.apache.cassandra.exceptions.ConfigurationException
            dup
            ldc "No metadata server could be found in lease file."
            invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
            athrow
        21: .line 205
      StackMap locals:
      StackMap stack:
            new java.lang.StringBuilder
            dup
            ldc "http://"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 3 /* endpoint */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            areturn
        end local 4 // java.util.regex.Pattern identifierPattern
        end local 3 // java.lang.String endpoint
        end local 2 // java.lang.String line
        end local 1 // java.io.File lease
        end local 0 // org.apache.cassandra.locator.CloudstackSnitch this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0   22     0               this  Lorg/apache/cassandra/locator/CloudstackSnitch;
            0   22     1              lease  Ljava/io/File;
            5    9     2               line  Ljava/lang/String;
           10   12     2               line  Ljava/lang/String;
           19   22     2               line  Ljava/lang/String;
            1   22     3           endpoint  Ljava/lang/String;
            2   22     4  identifierPattern  Ljava/util/regex/Pattern;
            4   13     7             reader  Ljava/io/BufferedReader;
            6    9     8            matcher  Ljava/util/regex/Matcher;
      Exception table:
        from    to  target  type
           4    11      12  any
           3    14      14  any
           2    17      17  Class java.lang.Exception
    Exceptions:
      throws org.apache.cassandra.exceptions.ConfigurationException
    MethodParameters:
       Name  Flags
      lease  
}
SourceFile: "CloudstackSnitch.java"