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 
class org.apache.cassandra.transport.Server$EventNotifier extends org.apache.cassandra.service.MigrationListener implements org.apache.cassandra.service.IEndpointLifecycleSubscriber
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.apache.cassandra.transport.Server$EventNotifier
  super_class: org.apache.cassandra.service.MigrationListener
{
  private final org.apache.cassandra.transport.Server server;
    descriptor: Lorg/apache/cassandra/transport/Server;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.Map<java.net.InetAddress, org.apache.cassandra.transport.Server$LatestEvent> latestEvents;
    descriptor: Ljava/util/Map;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Map<Ljava/net/InetAddress;Lorg/apache/cassandra/transport/Server$LatestEvent;>;

  private final java.util.Set<java.net.InetAddress> endpointsPendingJoinedNotification;
    descriptor: Ljava/util/Set;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Set<Ljava/net/InetAddress;>;

  private static final java.net.InetAddress bindAll;
    descriptor: Ljava/net/InetAddress;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=3, locals=1, args_size=0
         0: .line 527
            iconst_4
            newarray 8
            invokestatic java.net.InetAddress.getByAddress:([B)Ljava/net/InetAddress;
            putstatic org.apache.cassandra.transport.Server$EventNotifier.bindAll:Ljava/net/InetAddress;
         1: .line 528
            goto 4
         2: .line 529
      StackMap locals:
      StackMap stack: java.net.UnknownHostException
            astore 0 /* e */
        start local 0 // java.net.UnknownHostException e
         3: .line 531
            new java.lang.AssertionError
            dup
            aload 0 /* e */
            invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
            athrow
        end local 0 // java.net.UnknownHostException e
         4: .line 533
      StackMap locals:
      StackMap stack:
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            3    4     0     e  Ljava/net/UnknownHostException;
      Exception table:
        from    to  target  type
           0     1       2  Class java.net.UnknownHostException

  private void <init>(org.apache.cassandra.transport.Server);
    descriptor: (Lorg/apache/cassandra/transport/Server;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // org.apache.cassandra.transport.Server server
         0: .line 535
            aload 0 /* this */
            invokespecial org.apache.cassandra.service.MigrationListener.<init>:()V
         1: .line 516
            aload 0 /* this */
            new java.util.concurrent.ConcurrentHashMap
            dup
            invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
            putfield org.apache.cassandra.transport.Server$EventNotifier.latestEvents:Ljava/util/Map;
         2: .line 519
            aload 0 /* this */
            invokestatic java.util.concurrent.ConcurrentHashMap.newKeySet:()Ljava/util/concurrent/ConcurrentHashMap$KeySetView;
            putfield org.apache.cassandra.transport.Server$EventNotifier.endpointsPendingJoinedNotification:Ljava/util/Set;
         3: .line 537
            aload 0 /* this */
            aload 1 /* server */
            putfield org.apache.cassandra.transport.Server$EventNotifier.server:Lorg/apache/cassandra/transport/Server;
         4: .line 538
            return
        end local 1 // org.apache.cassandra.transport.Server server
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    5     0    this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    5     1  server  Lorg/apache/cassandra/transport/Server;
    MethodParameters:
        Name  Flags
      server  

  private java.net.InetAddress getRpcAddress(java.net.InetAddress);
    descriptor: (Ljava/net/InetAddress;)Ljava/net/InetAddress;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.net.InetAddress endpoint
         0: .line 544
            getstatic org.apache.cassandra.service.StorageService.instance:Lorg/apache/cassandra/service/StorageService;
            aload 1 /* endpoint */
            invokevirtual org.apache.cassandra.service.StorageService.getRpcaddress:(Ljava/net/InetAddress;)Ljava/lang/String;
            invokestatic java.net.InetAddress.getByName:(Ljava/lang/String;)Ljava/net/InetAddress;
            astore 2 /* rpcAddress */
        start local 2 // java.net.InetAddress rpcAddress
         1: .line 549
            aload 2 /* rpcAddress */
            getstatic org.apache.cassandra.transport.Server$EventNotifier.bindAll:Ljava/net/InetAddress;
            invokevirtual java.net.InetAddress.equals:(Ljava/lang/Object;)Z
            ifeq 2
            aload 1 /* endpoint */
            goto 3
      StackMap locals: java.net.InetAddress
      StackMap stack:
         2: aload 2 /* rpcAddress */
      StackMap locals:
      StackMap stack: java.net.InetAddress
         3: areturn
        end local 2 // java.net.InetAddress rpcAddress
         4: .line 551
      StackMap locals: org.apache.cassandra.transport.Server$EventNotifier java.net.InetAddress
      StackMap stack: java.net.UnknownHostException
            astore 2 /* e */
        start local 2 // java.net.UnknownHostException e
         5: .line 555
            getstatic org.apache.cassandra.transport.Server.logger:Lorg/slf4j/Logger;
            ldc "Problem retrieving RPC address for {}"
            aload 1 /* endpoint */
            aload 2 /* e */
            invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
         6: .line 556
            aload 1 /* endpoint */
            areturn
        end local 2 // java.net.UnknownHostException e
        end local 1 // java.net.InetAddress endpoint
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    7     0        this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    7     1    endpoint  Ljava/net/InetAddress;
            1    4     2  rpcAddress  Ljava/net/InetAddress;
            5    7     2           e  Ljava/net/UnknownHostException;
      Exception table:
        from    to  target  type
           0     3       4  Class java.net.UnknownHostException
    MethodParameters:
          Name  Flags
      endpoint  

  private void send(java.net.InetAddress, org.apache.cassandra.transport.Event$NodeEvent);
    descriptor: (Ljava/net/InetAddress;Lorg/apache/cassandra/transport/Event$NodeEvent;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.net.InetAddress endpoint
        start local 2 // org.apache.cassandra.transport.Event$NodeEvent event
         0: .line 562
            getstatic org.apache.cassandra.transport.Server.logger:Lorg/slf4j/Logger;
            invokeinterface org.slf4j.Logger.isTraceEnabled:()Z
            ifeq 2
         1: .line 563
            getstatic org.apache.cassandra.transport.Server.logger:Lorg/slf4j/Logger;
            ldc "Sending event for endpoint {}, rpc address {}"
            aload 1 /* endpoint */
            aload 2 /* event */
            invokevirtual org.apache.cassandra.transport.Event$NodeEvent.nodeAddress:()Ljava/net/InetAddress;
            invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
         2: .line 570
      StackMap locals:
      StackMap stack:
            aload 1 /* endpoint */
            invokestatic org.apache.cassandra.utils.FBUtilities.getBroadcastAddress:()Ljava/net/InetAddress;
            invokevirtual java.net.InetAddress.equals:(Ljava/lang/Object;)Z
            ifne 5
         3: .line 571
            aload 2 /* event */
            invokevirtual org.apache.cassandra.transport.Event$NodeEvent.nodeAddress:()Ljava/net/InetAddress;
            invokestatic org.apache.cassandra.utils.FBUtilities.getBroadcastRpcAddress:()Ljava/net/InetAddress;
            invokevirtual java.net.InetAddress.equals:(Ljava/lang/Object;)Z
            ifeq 5
         4: .line 572
            return
         5: .line 574
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 2 /* event */
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.send:(Lorg/apache/cassandra/transport/Event;)V
         6: .line 575
            return
        end local 2 // org.apache.cassandra.transport.Event$NodeEvent event
        end local 1 // java.net.InetAddress endpoint
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    7     0      this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    7     1  endpoint  Ljava/net/InetAddress;
            0    7     2     event  Lorg/apache/cassandra/transport/Event$NodeEvent;
    MethodParameters:
          Name  Flags
      endpoint  
      event     

  private void send(org.apache.cassandra.transport.Event);
    descriptor: (Lorg/apache/cassandra/transport/Event;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // org.apache.cassandra.transport.Event event
         0: .line 579
            aload 0 /* this */
            getfield org.apache.cassandra.transport.Server$EventNotifier.server:Lorg/apache/cassandra/transport/Server;
            getfield org.apache.cassandra.transport.Server.connectionTracker:Lorg/apache/cassandra/transport/Server$ConnectionTracker;
            aload 1 /* event */
            invokevirtual org.apache.cassandra.transport.Server$ConnectionTracker.send:(Lorg/apache/cassandra/transport/Event;)V
         1: .line 580
            return
        end local 1 // org.apache.cassandra.transport.Event event
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    2     1  event  Lorg/apache/cassandra/transport/Event;
    MethodParameters:
       Name  Flags
      event  

  public void onJoinCluster(java.net.InetAddress);
    descriptor: (Ljava/net/InetAddress;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.net.InetAddress endpoint
         0: .line 584
            getstatic org.apache.cassandra.service.StorageService.instance:Lorg/apache/cassandra/service/StorageService;
            aload 1 /* endpoint */
            invokevirtual org.apache.cassandra.service.StorageService.isRpcReady:(Ljava/net/InetAddress;)Z
            ifne 2
         1: .line 585
            aload 0 /* this */
            getfield org.apache.cassandra.transport.Server$EventNotifier.endpointsPendingJoinedNotification:Ljava/util/Set;
            aload 1 /* endpoint */
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
            goto 3
         2: .line 587
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* endpoint */
            aload 0 /* this */
            aload 1 /* endpoint */
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.getRpcAddress:(Ljava/net/InetAddress;)Ljava/net/InetAddress;
            aload 0 /* this */
            getfield org.apache.cassandra.transport.Server$EventNotifier.server:Lorg/apache/cassandra/transport/Server;
            getfield org.apache.cassandra.transport.Server.socket:Ljava/net/InetSocketAddress;
            invokevirtual java.net.InetSocketAddress.getPort:()I
            invokestatic org.apache.cassandra.transport.Event$TopologyChange.newNode:(Ljava/net/InetAddress;I)Lorg/apache/cassandra/transport/Event$TopologyChange;
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.onTopologyChange:(Ljava/net/InetAddress;Lorg/apache/cassandra/transport/Event$TopologyChange;)V
         3: .line 588
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.net.InetAddress endpoint
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    4     1  endpoint  Ljava/net/InetAddress;
    MethodParameters:
          Name  Flags
      endpoint  

  public void onLeaveCluster(java.net.InetAddress);
    descriptor: (Ljava/net/InetAddress;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.net.InetAddress endpoint
         0: .line 592
            aload 0 /* this */
            aload 1 /* endpoint */
            aload 0 /* this */
            aload 1 /* endpoint */
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.getRpcAddress:(Ljava/net/InetAddress;)Ljava/net/InetAddress;
            aload 0 /* this */
            getfield org.apache.cassandra.transport.Server$EventNotifier.server:Lorg/apache/cassandra/transport/Server;
            getfield org.apache.cassandra.transport.Server.socket:Ljava/net/InetSocketAddress;
            invokevirtual java.net.InetSocketAddress.getPort:()I
            invokestatic org.apache.cassandra.transport.Event$TopologyChange.removedNode:(Ljava/net/InetAddress;I)Lorg/apache/cassandra/transport/Event$TopologyChange;
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.onTopologyChange:(Ljava/net/InetAddress;Lorg/apache/cassandra/transport/Event$TopologyChange;)V
         1: .line 593
            return
        end local 1 // java.net.InetAddress endpoint
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    2     1  endpoint  Ljava/net/InetAddress;
    MethodParameters:
          Name  Flags
      endpoint  

  public void onMove(java.net.InetAddress);
    descriptor: (Ljava/net/InetAddress;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.net.InetAddress endpoint
         0: .line 597
            aload 0 /* this */
            aload 1 /* endpoint */
            aload 0 /* this */
            aload 1 /* endpoint */
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.getRpcAddress:(Ljava/net/InetAddress;)Ljava/net/InetAddress;
            aload 0 /* this */
            getfield org.apache.cassandra.transport.Server$EventNotifier.server:Lorg/apache/cassandra/transport/Server;
            getfield org.apache.cassandra.transport.Server.socket:Ljava/net/InetSocketAddress;
            invokevirtual java.net.InetSocketAddress.getPort:()I
            invokestatic org.apache.cassandra.transport.Event$TopologyChange.movedNode:(Ljava/net/InetAddress;I)Lorg/apache/cassandra/transport/Event$TopologyChange;
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.onTopologyChange:(Ljava/net/InetAddress;Lorg/apache/cassandra/transport/Event$TopologyChange;)V
         1: .line 598
            return
        end local 1 // java.net.InetAddress endpoint
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    2     1  endpoint  Ljava/net/InetAddress;
    MethodParameters:
          Name  Flags
      endpoint  

  public void onUp(java.net.InetAddress);
    descriptor: (Ljava/net/InetAddress;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.net.InetAddress endpoint
         0: .line 602
            aload 0 /* this */
            getfield org.apache.cassandra.transport.Server$EventNotifier.endpointsPendingJoinedNotification:Ljava/util/Set;
            aload 1 /* endpoint */
            invokeinterface java.util.Set.remove:(Ljava/lang/Object;)Z
            ifeq 2
         1: .line 603
            aload 0 /* this */
            aload 1 /* endpoint */
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.onJoinCluster:(Ljava/net/InetAddress;)V
         2: .line 605
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* endpoint */
            aload 0 /* this */
            aload 1 /* endpoint */
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.getRpcAddress:(Ljava/net/InetAddress;)Ljava/net/InetAddress;
            aload 0 /* this */
            getfield org.apache.cassandra.transport.Server$EventNotifier.server:Lorg/apache/cassandra/transport/Server;
            getfield org.apache.cassandra.transport.Server.socket:Ljava/net/InetSocketAddress;
            invokevirtual java.net.InetSocketAddress.getPort:()I
            invokestatic org.apache.cassandra.transport.Event$StatusChange.nodeUp:(Ljava/net/InetAddress;I)Lorg/apache/cassandra/transport/Event$StatusChange;
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.onStatusChange:(Ljava/net/InetAddress;Lorg/apache/cassandra/transport/Event$StatusChange;)V
         3: .line 606
            return
        end local 1 // java.net.InetAddress endpoint
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    4     1  endpoint  Ljava/net/InetAddress;
    MethodParameters:
          Name  Flags
      endpoint  

  public void onDown(java.net.InetAddress);
    descriptor: (Ljava/net/InetAddress;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.net.InetAddress endpoint
         0: .line 610
            aload 0 /* this */
            aload 1 /* endpoint */
            aload 0 /* this */
            aload 1 /* endpoint */
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.getRpcAddress:(Ljava/net/InetAddress;)Ljava/net/InetAddress;
            aload 0 /* this */
            getfield org.apache.cassandra.transport.Server$EventNotifier.server:Lorg/apache/cassandra/transport/Server;
            getfield org.apache.cassandra.transport.Server.socket:Ljava/net/InetSocketAddress;
            invokevirtual java.net.InetSocketAddress.getPort:()I
            invokestatic org.apache.cassandra.transport.Event$StatusChange.nodeDown:(Ljava/net/InetAddress;I)Lorg/apache/cassandra/transport/Event$StatusChange;
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.onStatusChange:(Ljava/net/InetAddress;Lorg/apache/cassandra/transport/Event$StatusChange;)V
         1: .line 611
            return
        end local 1 // java.net.InetAddress endpoint
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    2     1  endpoint  Ljava/net/InetAddress;
    MethodParameters:
          Name  Flags
      endpoint  

  private void onTopologyChange(java.net.InetAddress, org.apache.cassandra.transport.Event$TopologyChange);
    descriptor: (Ljava/net/InetAddress;Lorg/apache/cassandra/transport/Event$TopologyChange;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=5, args_size=3
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.net.InetAddress endpoint
        start local 2 // org.apache.cassandra.transport.Event$TopologyChange event
         0: .line 615
            getstatic org.apache.cassandra.transport.Server.logger:Lorg/slf4j/Logger;
            invokeinterface org.slf4j.Logger.isTraceEnabled:()Z
            ifeq 2
         1: .line 616
            getstatic org.apache.cassandra.transport.Server.logger:Lorg/slf4j/Logger;
            ldc "Topology changed event : {}, {}"
            aload 1 /* endpoint */
            aload 2 /* event */
            getfield org.apache.cassandra.transport.Event$TopologyChange.change:Lorg/apache/cassandra/transport/Event$TopologyChange$Change;
            invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
         2: .line 618
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.transport.Server$EventNotifier.latestEvents:Ljava/util/Map;
            aload 1 /* endpoint */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.apache.cassandra.transport.Server$LatestEvent
            astore 3 /* prev */
        start local 3 // org.apache.cassandra.transport.Server$LatestEvent prev
         3: .line 619
            aload 3 /* prev */
            ifnull 4
            aload 3 /* prev */
            getfield org.apache.cassandra.transport.Server$LatestEvent.topology:Lorg/apache/cassandra/transport/Event$TopologyChange$Change;
            aload 2 /* event */
            getfield org.apache.cassandra.transport.Event$TopologyChange.change:Lorg/apache/cassandra/transport/Event$TopologyChange$Change;
            if_acmpeq 7
         4: .line 621
      StackMap locals: org.apache.cassandra.transport.Server$LatestEvent
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.transport.Server$EventNotifier.latestEvents:Ljava/util/Map;
            aload 1 /* endpoint */
            aload 2 /* event */
            getfield org.apache.cassandra.transport.Event$TopologyChange.change:Lorg/apache/cassandra/transport/Event$TopologyChange$Change;
            aload 3 /* prev */
            invokestatic org.apache.cassandra.transport.Server$LatestEvent.forTopologyChange:(Lorg/apache/cassandra/transport/Event$TopologyChange$Change;Lorg/apache/cassandra/transport/Server$LatestEvent;)Lorg/apache/cassandra/transport/Server$LatestEvent;
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.apache.cassandra.transport.Server$LatestEvent
            astore 4 /* ret */
        start local 4 // org.apache.cassandra.transport.Server$LatestEvent ret
         5: .line 622
            aload 4 /* ret */
            aload 3 /* prev */
            if_acmpne 7
         6: .line 623
            aload 0 /* this */
            aload 1 /* endpoint */
            aload 2 /* event */
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.send:(Ljava/net/InetAddress;Lorg/apache/cassandra/transport/Event$NodeEvent;)V
        end local 4 // org.apache.cassandra.transport.Server$LatestEvent ret
         7: .line 625
      StackMap locals:
      StackMap stack:
            return
        end local 3 // org.apache.cassandra.transport.Server$LatestEvent prev
        end local 2 // org.apache.cassandra.transport.Event$TopologyChange event
        end local 1 // java.net.InetAddress endpoint
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    8     0      this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    8     1  endpoint  Ljava/net/InetAddress;
            0    8     2     event  Lorg/apache/cassandra/transport/Event$TopologyChange;
            3    8     3      prev  Lorg/apache/cassandra/transport/Server$LatestEvent;
            5    7     4       ret  Lorg/apache/cassandra/transport/Server$LatestEvent;
    MethodParameters:
          Name  Flags
      endpoint  
      event     

  private void onStatusChange(java.net.InetAddress, org.apache.cassandra.transport.Event$StatusChange);
    descriptor: (Ljava/net/InetAddress;Lorg/apache/cassandra/transport/Event$StatusChange;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=5, args_size=3
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.net.InetAddress endpoint
        start local 2 // org.apache.cassandra.transport.Event$StatusChange event
         0: .line 629
            getstatic org.apache.cassandra.transport.Server.logger:Lorg/slf4j/Logger;
            invokeinterface org.slf4j.Logger.isTraceEnabled:()Z
            ifeq 2
         1: .line 630
            getstatic org.apache.cassandra.transport.Server.logger:Lorg/slf4j/Logger;
            ldc "Status changed event : {}, {}"
            aload 1 /* endpoint */
            aload 2 /* event */
            getfield org.apache.cassandra.transport.Event$StatusChange.status:Lorg/apache/cassandra/transport/Event$StatusChange$Status;
            invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
         2: .line 632
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.transport.Server$EventNotifier.latestEvents:Ljava/util/Map;
            aload 1 /* endpoint */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.apache.cassandra.transport.Server$LatestEvent
            astore 3 /* prev */
        start local 3 // org.apache.cassandra.transport.Server$LatestEvent prev
         3: .line 633
            aload 3 /* prev */
            ifnull 4
            aload 3 /* prev */
            getfield org.apache.cassandra.transport.Server$LatestEvent.status:Lorg/apache/cassandra/transport/Event$StatusChange$Status;
            aload 2 /* event */
            getfield org.apache.cassandra.transport.Event$StatusChange.status:Lorg/apache/cassandra/transport/Event$StatusChange$Status;
            if_acmpeq 7
         4: .line 635
      StackMap locals: org.apache.cassandra.transport.Server$LatestEvent
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.transport.Server$EventNotifier.latestEvents:Ljava/util/Map;
            aload 1 /* endpoint */
            aload 2 /* event */
            getfield org.apache.cassandra.transport.Event$StatusChange.status:Lorg/apache/cassandra/transport/Event$StatusChange$Status;
            aconst_null
            invokestatic org.apache.cassandra.transport.Server$LatestEvent.forStatusChange:(Lorg/apache/cassandra/transport/Event$StatusChange$Status;Lorg/apache/cassandra/transport/Server$LatestEvent;)Lorg/apache/cassandra/transport/Server$LatestEvent;
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.apache.cassandra.transport.Server$LatestEvent
            astore 4 /* ret */
        start local 4 // org.apache.cassandra.transport.Server$LatestEvent ret
         5: .line 636
            aload 4 /* ret */
            aload 3 /* prev */
            if_acmpne 7
         6: .line 637
            aload 0 /* this */
            aload 1 /* endpoint */
            aload 2 /* event */
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.send:(Ljava/net/InetAddress;Lorg/apache/cassandra/transport/Event$NodeEvent;)V
        end local 4 // org.apache.cassandra.transport.Server$LatestEvent ret
         7: .line 639
      StackMap locals:
      StackMap stack:
            return
        end local 3 // org.apache.cassandra.transport.Server$LatestEvent prev
        end local 2 // org.apache.cassandra.transport.Event$StatusChange event
        end local 1 // java.net.InetAddress endpoint
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    8     0      this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    8     1  endpoint  Ljava/net/InetAddress;
            0    8     2     event  Lorg/apache/cassandra/transport/Event$StatusChange;
            3    8     3      prev  Lorg/apache/cassandra/transport/Server$LatestEvent;
            5    7     4       ret  Lorg/apache/cassandra/transport/Server$LatestEvent;
    MethodParameters:
          Name  Flags
      endpoint  
      event     

  public void onCreateKeyspace(java.lang.String);
    descriptor: (Ljava/lang/String;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.lang.String ksName
         0: .line 643
            aload 0 /* this */
            new org.apache.cassandra.transport.Event$SchemaChange
            dup
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Change.CREATED:Lorg/apache/cassandra/transport/Event$SchemaChange$Change;
            aload 1 /* ksName */
            invokespecial org.apache.cassandra.transport.Event$SchemaChange.<init>:(Lorg/apache/cassandra/transport/Event$SchemaChange$Change;Ljava/lang/String;)V
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.send:(Lorg/apache/cassandra/transport/Event;)V
         1: .line 644
            return
        end local 1 // java.lang.String ksName
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    2     1  ksName  Ljava/lang/String;
    MethodParameters:
        Name  Flags
      ksName  

  public void onCreateColumnFamily(java.lang.String, java.lang.String);
    descriptor: (Ljava/lang/String;Ljava/lang/String;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=3, args_size=3
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.lang.String ksName
        start local 2 // java.lang.String cfName
         0: .line 648
            aload 0 /* this */
            new org.apache.cassandra.transport.Event$SchemaChange
            dup
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Change.CREATED:Lorg/apache/cassandra/transport/Event$SchemaChange$Change;
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Target.TABLE:Lorg/apache/cassandra/transport/Event$SchemaChange$Target;
            aload 1 /* ksName */
            aload 2 /* cfName */
            invokespecial org.apache.cassandra.transport.Event$SchemaChange.<init>:(Lorg/apache/cassandra/transport/Event$SchemaChange$Change;Lorg/apache/cassandra/transport/Event$SchemaChange$Target;Ljava/lang/String;Ljava/lang/String;)V
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.send:(Lorg/apache/cassandra/transport/Event;)V
         1: .line 649
            return
        end local 2 // java.lang.String cfName
        end local 1 // java.lang.String ksName
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    2     1  ksName  Ljava/lang/String;
            0    2     2  cfName  Ljava/lang/String;
    MethodParameters:
        Name  Flags
      ksName  
      cfName  

  public void onCreateUserType(java.lang.String, java.lang.String);
    descriptor: (Ljava/lang/String;Ljava/lang/String;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=3, args_size=3
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.lang.String ksName
        start local 2 // java.lang.String typeName
         0: .line 653
            aload 0 /* this */
            new org.apache.cassandra.transport.Event$SchemaChange
            dup
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Change.CREATED:Lorg/apache/cassandra/transport/Event$SchemaChange$Change;
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Target.TYPE:Lorg/apache/cassandra/transport/Event$SchemaChange$Target;
            aload 1 /* ksName */
            aload 2 /* typeName */
            invokespecial org.apache.cassandra.transport.Event$SchemaChange.<init>:(Lorg/apache/cassandra/transport/Event$SchemaChange$Change;Lorg/apache/cassandra/transport/Event$SchemaChange$Target;Ljava/lang/String;Ljava/lang/String;)V
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.send:(Lorg/apache/cassandra/transport/Event;)V
         1: .line 654
            return
        end local 2 // java.lang.String typeName
        end local 1 // java.lang.String ksName
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    2     1    ksName  Ljava/lang/String;
            0    2     2  typeName  Ljava/lang/String;
    MethodParameters:
          Name  Flags
      ksName    
      typeName  

  public void onCreateFunction(java.lang.String, java.lang.String, java.util.List<org.apache.cassandra.db.marshal.AbstractType<?>>);
    descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=8, locals=4, args_size=4
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.lang.String ksName
        start local 2 // java.lang.String functionName
        start local 3 // java.util.List argTypes
         0: .line 658
            aload 0 /* this */
            new org.apache.cassandra.transport.Event$SchemaChange
            dup
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Change.CREATED:Lorg/apache/cassandra/transport/Event$SchemaChange$Change;
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Target.FUNCTION:Lorg/apache/cassandra/transport/Event$SchemaChange$Target;
         1: .line 659
            aload 1 /* ksName */
            aload 2 /* functionName */
            aload 3 /* argTypes */
            invokestatic org.apache.cassandra.db.marshal.AbstractType.asCQLTypeStringList:(Ljava/util/List;)Ljava/util/List;
            invokespecial org.apache.cassandra.transport.Event$SchemaChange.<init>:(Lorg/apache/cassandra/transport/Event$SchemaChange$Change;Lorg/apache/cassandra/transport/Event$SchemaChange$Target;Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)V
         2: .line 658
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.send:(Lorg/apache/cassandra/transport/Event;)V
         3: .line 660
            return
        end local 3 // java.util.List argTypes
        end local 2 // java.lang.String functionName
        end local 1 // java.lang.String ksName
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    4     0          this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    4     1        ksName  Ljava/lang/String;
            0    4     2  functionName  Ljava/lang/String;
            0    4     3      argTypes  Ljava/util/List<Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;
    Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List<Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;)V
    MethodParameters:
              Name  Flags
      ksName        
      functionName  
      argTypes      

  public void onCreateAggregate(java.lang.String, java.lang.String, java.util.List<org.apache.cassandra.db.marshal.AbstractType<?>>);
    descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=8, locals=4, args_size=4
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.lang.String ksName
        start local 2 // java.lang.String aggregateName
        start local 3 // java.util.List argTypes
         0: .line 664
            aload 0 /* this */
            new org.apache.cassandra.transport.Event$SchemaChange
            dup
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Change.CREATED:Lorg/apache/cassandra/transport/Event$SchemaChange$Change;
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Target.AGGREGATE:Lorg/apache/cassandra/transport/Event$SchemaChange$Target;
         1: .line 665
            aload 1 /* ksName */
            aload 2 /* aggregateName */
            aload 3 /* argTypes */
            invokestatic org.apache.cassandra.db.marshal.AbstractType.asCQLTypeStringList:(Ljava/util/List;)Ljava/util/List;
            invokespecial org.apache.cassandra.transport.Event$SchemaChange.<init>:(Lorg/apache/cassandra/transport/Event$SchemaChange$Change;Lorg/apache/cassandra/transport/Event$SchemaChange$Target;Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)V
         2: .line 664
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.send:(Lorg/apache/cassandra/transport/Event;)V
         3: .line 666
            return
        end local 3 // java.util.List argTypes
        end local 2 // java.lang.String aggregateName
        end local 1 // java.lang.String ksName
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    4     0           this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    4     1         ksName  Ljava/lang/String;
            0    4     2  aggregateName  Ljava/lang/String;
            0    4     3       argTypes  Ljava/util/List<Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;
    Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List<Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;)V
    MethodParameters:
               Name  Flags
      ksName         
      aggregateName  
      argTypes       

  public void onUpdateKeyspace(java.lang.String);
    descriptor: (Ljava/lang/String;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.lang.String ksName
         0: .line 670
            aload 0 /* this */
            new org.apache.cassandra.transport.Event$SchemaChange
            dup
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Change.UPDATED:Lorg/apache/cassandra/transport/Event$SchemaChange$Change;
            aload 1 /* ksName */
            invokespecial org.apache.cassandra.transport.Event$SchemaChange.<init>:(Lorg/apache/cassandra/transport/Event$SchemaChange$Change;Ljava/lang/String;)V
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.send:(Lorg/apache/cassandra/transport/Event;)V
         1: .line 671
            return
        end local 1 // java.lang.String ksName
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    2     1  ksName  Ljava/lang/String;
    MethodParameters:
        Name  Flags
      ksName  

  public void onUpdateColumnFamily(java.lang.String, java.lang.String, boolean);
    descriptor: (Ljava/lang/String;Ljava/lang/String;Z)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=4, args_size=4
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.lang.String ksName
        start local 2 // java.lang.String cfName
        start local 3 // boolean affectsStatements
         0: .line 675
            aload 0 /* this */
            new org.apache.cassandra.transport.Event$SchemaChange
            dup
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Change.UPDATED:Lorg/apache/cassandra/transport/Event$SchemaChange$Change;
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Target.TABLE:Lorg/apache/cassandra/transport/Event$SchemaChange$Target;
            aload 1 /* ksName */
            aload 2 /* cfName */
            invokespecial org.apache.cassandra.transport.Event$SchemaChange.<init>:(Lorg/apache/cassandra/transport/Event$SchemaChange$Change;Lorg/apache/cassandra/transport/Event$SchemaChange$Target;Ljava/lang/String;Ljava/lang/String;)V
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.send:(Lorg/apache/cassandra/transport/Event;)V
         1: .line 676
            return
        end local 3 // boolean affectsStatements
        end local 2 // java.lang.String cfName
        end local 1 // java.lang.String ksName
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    2     0               this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    2     1             ksName  Ljava/lang/String;
            0    2     2             cfName  Ljava/lang/String;
            0    2     3  affectsStatements  Z
    MethodParameters:
                   Name  Flags
      ksName             
      cfName             
      affectsStatements  

  public void onUpdateUserType(java.lang.String, java.lang.String);
    descriptor: (Ljava/lang/String;Ljava/lang/String;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=3, args_size=3
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.lang.String ksName
        start local 2 // java.lang.String typeName
         0: .line 680
            aload 0 /* this */
            new org.apache.cassandra.transport.Event$SchemaChange
            dup
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Change.UPDATED:Lorg/apache/cassandra/transport/Event$SchemaChange$Change;
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Target.TYPE:Lorg/apache/cassandra/transport/Event$SchemaChange$Target;
            aload 1 /* ksName */
            aload 2 /* typeName */
            invokespecial org.apache.cassandra.transport.Event$SchemaChange.<init>:(Lorg/apache/cassandra/transport/Event$SchemaChange$Change;Lorg/apache/cassandra/transport/Event$SchemaChange$Target;Ljava/lang/String;Ljava/lang/String;)V
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.send:(Lorg/apache/cassandra/transport/Event;)V
         1: .line 681
            return
        end local 2 // java.lang.String typeName
        end local 1 // java.lang.String ksName
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    2     1    ksName  Ljava/lang/String;
            0    2     2  typeName  Ljava/lang/String;
    MethodParameters:
          Name  Flags
      ksName    
      typeName  

  public void onUpdateFunction(java.lang.String, java.lang.String, java.util.List<org.apache.cassandra.db.marshal.AbstractType<?>>);
    descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=8, locals=4, args_size=4
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.lang.String ksName
        start local 2 // java.lang.String functionName
        start local 3 // java.util.List argTypes
         0: .line 685
            aload 0 /* this */
            new org.apache.cassandra.transport.Event$SchemaChange
            dup
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Change.UPDATED:Lorg/apache/cassandra/transport/Event$SchemaChange$Change;
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Target.FUNCTION:Lorg/apache/cassandra/transport/Event$SchemaChange$Target;
         1: .line 686
            aload 1 /* ksName */
            aload 2 /* functionName */
            aload 3 /* argTypes */
            invokestatic org.apache.cassandra.db.marshal.AbstractType.asCQLTypeStringList:(Ljava/util/List;)Ljava/util/List;
            invokespecial org.apache.cassandra.transport.Event$SchemaChange.<init>:(Lorg/apache/cassandra/transport/Event$SchemaChange$Change;Lorg/apache/cassandra/transport/Event$SchemaChange$Target;Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)V
         2: .line 685
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.send:(Lorg/apache/cassandra/transport/Event;)V
         3: .line 687
            return
        end local 3 // java.util.List argTypes
        end local 2 // java.lang.String functionName
        end local 1 // java.lang.String ksName
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    4     0          this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    4     1        ksName  Ljava/lang/String;
            0    4     2  functionName  Ljava/lang/String;
            0    4     3      argTypes  Ljava/util/List<Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;
    Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List<Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;)V
    MethodParameters:
              Name  Flags
      ksName        
      functionName  
      argTypes      

  public void onUpdateAggregate(java.lang.String, java.lang.String, java.util.List<org.apache.cassandra.db.marshal.AbstractType<?>>);
    descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=8, locals=4, args_size=4
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.lang.String ksName
        start local 2 // java.lang.String aggregateName
        start local 3 // java.util.List argTypes
         0: .line 691
            aload 0 /* this */
            new org.apache.cassandra.transport.Event$SchemaChange
            dup
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Change.UPDATED:Lorg/apache/cassandra/transport/Event$SchemaChange$Change;
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Target.AGGREGATE:Lorg/apache/cassandra/transport/Event$SchemaChange$Target;
         1: .line 692
            aload 1 /* ksName */
            aload 2 /* aggregateName */
            aload 3 /* argTypes */
            invokestatic org.apache.cassandra.db.marshal.AbstractType.asCQLTypeStringList:(Ljava/util/List;)Ljava/util/List;
            invokespecial org.apache.cassandra.transport.Event$SchemaChange.<init>:(Lorg/apache/cassandra/transport/Event$SchemaChange$Change;Lorg/apache/cassandra/transport/Event$SchemaChange$Target;Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)V
         2: .line 691
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.send:(Lorg/apache/cassandra/transport/Event;)V
         3: .line 693
            return
        end local 3 // java.util.List argTypes
        end local 2 // java.lang.String aggregateName
        end local 1 // java.lang.String ksName
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    4     0           this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    4     1         ksName  Ljava/lang/String;
            0    4     2  aggregateName  Ljava/lang/String;
            0    4     3       argTypes  Ljava/util/List<Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;
    Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List<Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;)V
    MethodParameters:
               Name  Flags
      ksName         
      aggregateName  
      argTypes       

  public void onDropKeyspace(java.lang.String);
    descriptor: (Ljava/lang/String;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.lang.String ksName
         0: .line 697
            aload 0 /* this */
            new org.apache.cassandra.transport.Event$SchemaChange
            dup
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Change.DROPPED:Lorg/apache/cassandra/transport/Event$SchemaChange$Change;
            aload 1 /* ksName */
            invokespecial org.apache.cassandra.transport.Event$SchemaChange.<init>:(Lorg/apache/cassandra/transport/Event$SchemaChange$Change;Ljava/lang/String;)V
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.send:(Lorg/apache/cassandra/transport/Event;)V
         1: .line 698
            return
        end local 1 // java.lang.String ksName
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    2     1  ksName  Ljava/lang/String;
    MethodParameters:
        Name  Flags
      ksName  

  public void onDropColumnFamily(java.lang.String, java.lang.String);
    descriptor: (Ljava/lang/String;Ljava/lang/String;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=3, args_size=3
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.lang.String ksName
        start local 2 // java.lang.String cfName
         0: .line 702
            aload 0 /* this */
            new org.apache.cassandra.transport.Event$SchemaChange
            dup
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Change.DROPPED:Lorg/apache/cassandra/transport/Event$SchemaChange$Change;
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Target.TABLE:Lorg/apache/cassandra/transport/Event$SchemaChange$Target;
            aload 1 /* ksName */
            aload 2 /* cfName */
            invokespecial org.apache.cassandra.transport.Event$SchemaChange.<init>:(Lorg/apache/cassandra/transport/Event$SchemaChange$Change;Lorg/apache/cassandra/transport/Event$SchemaChange$Target;Ljava/lang/String;Ljava/lang/String;)V
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.send:(Lorg/apache/cassandra/transport/Event;)V
         1: .line 703
            return
        end local 2 // java.lang.String cfName
        end local 1 // java.lang.String ksName
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    2     1  ksName  Ljava/lang/String;
            0    2     2  cfName  Ljava/lang/String;
    MethodParameters:
        Name  Flags
      ksName  
      cfName  

  public void onDropUserType(java.lang.String, java.lang.String);
    descriptor: (Ljava/lang/String;Ljava/lang/String;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=3, args_size=3
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.lang.String ksName
        start local 2 // java.lang.String typeName
         0: .line 707
            aload 0 /* this */
            new org.apache.cassandra.transport.Event$SchemaChange
            dup
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Change.DROPPED:Lorg/apache/cassandra/transport/Event$SchemaChange$Change;
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Target.TYPE:Lorg/apache/cassandra/transport/Event$SchemaChange$Target;
            aload 1 /* ksName */
            aload 2 /* typeName */
            invokespecial org.apache.cassandra.transport.Event$SchemaChange.<init>:(Lorg/apache/cassandra/transport/Event$SchemaChange$Change;Lorg/apache/cassandra/transport/Event$SchemaChange$Target;Ljava/lang/String;Ljava/lang/String;)V
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.send:(Lorg/apache/cassandra/transport/Event;)V
         1: .line 708
            return
        end local 2 // java.lang.String typeName
        end local 1 // java.lang.String ksName
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    2     1    ksName  Ljava/lang/String;
            0    2     2  typeName  Ljava/lang/String;
    MethodParameters:
          Name  Flags
      ksName    
      typeName  

  public void onDropFunction(java.lang.String, java.lang.String, java.util.List<org.apache.cassandra.db.marshal.AbstractType<?>>);
    descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=8, locals=4, args_size=4
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.lang.String ksName
        start local 2 // java.lang.String functionName
        start local 3 // java.util.List argTypes
         0: .line 712
            aload 0 /* this */
            new org.apache.cassandra.transport.Event$SchemaChange
            dup
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Change.DROPPED:Lorg/apache/cassandra/transport/Event$SchemaChange$Change;
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Target.FUNCTION:Lorg/apache/cassandra/transport/Event$SchemaChange$Target;
         1: .line 713
            aload 1 /* ksName */
            aload 2 /* functionName */
            aload 3 /* argTypes */
            invokestatic org.apache.cassandra.db.marshal.AbstractType.asCQLTypeStringList:(Ljava/util/List;)Ljava/util/List;
            invokespecial org.apache.cassandra.transport.Event$SchemaChange.<init>:(Lorg/apache/cassandra/transport/Event$SchemaChange$Change;Lorg/apache/cassandra/transport/Event$SchemaChange$Target;Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)V
         2: .line 712
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.send:(Lorg/apache/cassandra/transport/Event;)V
         3: .line 714
            return
        end local 3 // java.util.List argTypes
        end local 2 // java.lang.String functionName
        end local 1 // java.lang.String ksName
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    4     0          this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    4     1        ksName  Ljava/lang/String;
            0    4     2  functionName  Ljava/lang/String;
            0    4     3      argTypes  Ljava/util/List<Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;
    Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List<Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;)V
    MethodParameters:
              Name  Flags
      ksName        
      functionName  
      argTypes      

  public void onDropAggregate(java.lang.String, java.lang.String, java.util.List<org.apache.cassandra.db.marshal.AbstractType<?>>);
    descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=8, locals=4, args_size=4
        start local 0 // org.apache.cassandra.transport.Server$EventNotifier this
        start local 1 // java.lang.String ksName
        start local 2 // java.lang.String aggregateName
        start local 3 // java.util.List argTypes
         0: .line 718
            aload 0 /* this */
            new org.apache.cassandra.transport.Event$SchemaChange
            dup
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Change.DROPPED:Lorg/apache/cassandra/transport/Event$SchemaChange$Change;
            getstatic org.apache.cassandra.transport.Event$SchemaChange$Target.AGGREGATE:Lorg/apache/cassandra/transport/Event$SchemaChange$Target;
         1: .line 719
            aload 1 /* ksName */
            aload 2 /* aggregateName */
            aload 3 /* argTypes */
            invokestatic org.apache.cassandra.db.marshal.AbstractType.asCQLTypeStringList:(Ljava/util/List;)Ljava/util/List;
            invokespecial org.apache.cassandra.transport.Event$SchemaChange.<init>:(Lorg/apache/cassandra/transport/Event$SchemaChange$Change;Lorg/apache/cassandra/transport/Event$SchemaChange$Target;Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)V
         2: .line 718
            invokevirtual org.apache.cassandra.transport.Server$EventNotifier.send:(Lorg/apache/cassandra/transport/Event;)V
         3: .line 720
            return
        end local 3 // java.util.List argTypes
        end local 2 // java.lang.String aggregateName
        end local 1 // java.lang.String ksName
        end local 0 // org.apache.cassandra.transport.Server$EventNotifier this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    4     0           this  Lorg/apache/cassandra/transport/Server$EventNotifier;
            0    4     1         ksName  Ljava/lang/String;
            0    4     2  aggregateName  Ljava/lang/String;
            0    4     3       argTypes  Ljava/util/List<Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;
    Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List<Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;)V
    MethodParameters:
               Name  Flags
      ksName         
      aggregateName  
      argTypes       
}
SourceFile: "Server.java"
NestHost: org.apache.cassandra.transport.Server
InnerClasses:
  public KeySetView = java.util.concurrent.ConcurrentHashMap$KeySetView of java.util.concurrent.ConcurrentHashMap
  public abstract NodeEvent = org.apache.cassandra.transport.Event$NodeEvent of org.apache.cassandra.transport.Event
  public SchemaChange = org.apache.cassandra.transport.Event$SchemaChange of org.apache.cassandra.transport.Event
  public final Change = org.apache.cassandra.transport.Event$SchemaChange$Change of org.apache.cassandra.transport.Event$SchemaChange
  public final Target = org.apache.cassandra.transport.Event$SchemaChange$Target of org.apache.cassandra.transport.Event$SchemaChange
  public StatusChange = org.apache.cassandra.transport.Event$StatusChange of org.apache.cassandra.transport.Event
  public final Status = org.apache.cassandra.transport.Event$StatusChange$Status of org.apache.cassandra.transport.Event$StatusChange
  public TopologyChange = org.apache.cassandra.transport.Event$TopologyChange of org.apache.cassandra.transport.Event
  public final Change = org.apache.cassandra.transport.Event$TopologyChange$Change of org.apache.cassandra.transport.Event$TopologyChange
  public ConnectionTracker = org.apache.cassandra.transport.Server$ConnectionTracker of org.apache.cassandra.transport.Server
  private EventNotifier = org.apache.cassandra.transport.Server$EventNotifier of org.apache.cassandra.transport.Server
  private LatestEvent = org.apache.cassandra.transport.Server$LatestEvent of org.apache.cassandra.transport.Server