org.eclipse.jetty/jetty-io/10.0.0-alpha0 : org/eclipse/jetty/io/ManagedSelector$Connect.class

ManagedSelector$Connect
http://www.eclipse.org/jetty: The Eclipse Jetty Project (Webtide)
Greg Wilkins (Webtide, LLC)
Jan Bartel (Webtide, LLC)
Jesse McConnell (Webtide, LLC)
Joakim Erdfelt (Webtide, LLC)
Simone Bordet (Webtide, LLC)
David Jencks (IBM)
Olivier Lamy (Webtide, LLC)
class org.eclipse.jetty.io.ManagedSelector$Connect implements org.eclipse.jetty.io.ManagedSelector$SelectorUpdate, java.lang.Runnable
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.eclipse.jetty.io.ManagedSelector$Connect
  super_class: java.lang.Object
{
  private final java.util.concurrent.atomic.AtomicBoolean failed;
    descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.nio.channels.SelectableChannel channel;
    descriptor: Ljava/nio/channels/SelectableChannel;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.lang.Object attachment;
    descriptor: Ljava/lang/Object;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.eclipse.jetty.util.thread.Scheduler$Task timeout;
    descriptor: Lorg/eclipse/jetty/util/thread/Scheduler$Task;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  final org.eclipse.jetty.io.ManagedSelector this$0;
    descriptor: Lorg/eclipse/jetty/io/ManagedSelector;
    flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC

  void <init>(org.eclipse.jetty.io.ManagedSelector, java.nio.channels.SelectableChannel, java.lang.Object);
    descriptor: (Lorg/eclipse/jetty/io/ManagedSelector;Ljava/nio/channels/SelectableChannel;Ljava/lang/Object;)V
    flags: (0x0000) 
    Code:
      stack=6, locals=4, args_size=4
        start local 0 // org.eclipse.jetty.io.ManagedSelector$Connect this
        start local 2 // java.nio.channels.SelectableChannel channel
        start local 3 // java.lang.Object attachment
         0: .line 776
            aload 0 /* this */
            aload 1
            putfield org.eclipse.jetty.io.ManagedSelector$Connect.this$0:Lorg/eclipse/jetty/io/ManagedSelector;
         1: .line 775
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         2: .line 770
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicBoolean
            dup
            invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:()V
            putfield org.eclipse.jetty.io.ManagedSelector$Connect.failed:Ljava/util/concurrent/atomic/AtomicBoolean;
         3: .line 777
            aload 0 /* this */
            aload 2 /* channel */
            putfield org.eclipse.jetty.io.ManagedSelector$Connect.channel:Ljava/nio/channels/SelectableChannel;
         4: .line 778
            aload 0 /* this */
            aload 3 /* attachment */
            putfield org.eclipse.jetty.io.ManagedSelector$Connect.attachment:Ljava/lang/Object;
         5: .line 779
            aload 0 /* this */
            aload 1
            getfield org.eclipse.jetty.io.ManagedSelector._selectorManager:Lorg/eclipse/jetty/io/SelectorManager;
            invokevirtual org.eclipse.jetty.io.SelectorManager.getScheduler:()Lorg/eclipse/jetty/util/thread/Scheduler;
            aload 0 /* this */
            aload 1
            getfield org.eclipse.jetty.io.ManagedSelector._selectorManager:Lorg/eclipse/jetty/io/SelectorManager;
            invokevirtual org.eclipse.jetty.io.SelectorManager.getConnectTimeout:()J
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            invokeinterface org.eclipse.jetty.util.thread.Scheduler.schedule:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lorg/eclipse/jetty/util/thread/Scheduler$Task;
            putfield org.eclipse.jetty.io.ManagedSelector$Connect.timeout:Lorg/eclipse/jetty/util/thread/Scheduler$Task;
         6: .line 780
            return
        end local 3 // java.lang.Object attachment
        end local 2 // java.nio.channels.SelectableChannel channel
        end local 0 // org.eclipse.jetty.io.ManagedSelector$Connect this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    7     0        this  Lorg/eclipse/jetty/io/ManagedSelector$Connect;
            0    7     2     channel  Ljava/nio/channels/SelectableChannel;
            0    7     3  attachment  Ljava/lang/Object;
    MethodParameters:
            Name  Flags
      this$0      final
      channel     
      attachment  

  public void update(java.nio.channels.Selector);
    descriptor: (Ljava/nio/channels/Selector;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // org.eclipse.jetty.io.ManagedSelector$Connect this
        start local 1 // java.nio.channels.Selector selector
         0: .line 787
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ManagedSelector$Connect.channel:Ljava/nio/channels/SelectableChannel;
            aload 1 /* selector */
            bipush 8
            aload 0 /* this */
            invokevirtual java.nio.channels.SelectableChannel.register:(Ljava/nio/channels/Selector;ILjava/lang/Object;)Ljava/nio/channels/SelectionKey;
            pop
         1: .line 788
            goto 4
         2: .line 789
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 2 /* x */
        start local 2 // java.lang.Throwable x
         3: .line 791
            aload 0 /* this */
            aload 2 /* x */
            invokevirtual org.eclipse.jetty.io.ManagedSelector$Connect.failed:(Ljava/lang/Throwable;)V
        end local 2 // java.lang.Throwable x
         4: .line 793
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.nio.channels.Selector selector
        end local 0 // org.eclipse.jetty.io.ManagedSelector$Connect this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    5     0      this  Lorg/eclipse/jetty/io/ManagedSelector$Connect;
            0    5     1  selector  Ljava/nio/channels/Selector;
            3    4     2         x  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           0     1       2  Class java.lang.Throwable
    MethodParameters:
          Name  Flags
      selector  

  public void run();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.io.ManagedSelector$Connect this
         0: .line 798
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ManagedSelector$Connect.this$0:Lorg/eclipse/jetty/io/ManagedSelector;
            getfield org.eclipse.jetty.io.ManagedSelector._selectorManager:Lorg/eclipse/jetty/io/SelectorManager;
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ManagedSelector$Connect.channel:Ljava/nio/channels/SelectableChannel;
            invokevirtual org.eclipse.jetty.io.SelectorManager.isConnectionPending:(Ljava/nio/channels/SelectableChannel;)Z
            ifeq 4
         1: .line 800
            getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 3
         2: .line 801
            getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "Channel {} timed out while connecting, closing it"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ManagedSelector$Connect.channel:Ljava/nio/channels/SelectableChannel;
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
         3: .line 802
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            new java.net.SocketTimeoutException
            dup
            ldc "Connect Timeout"
            invokespecial java.net.SocketTimeoutException.<init>:(Ljava/lang/String;)V
            invokevirtual org.eclipse.jetty.io.ManagedSelector$Connect.failed:(Ljava/lang/Throwable;)V
         4: .line 804
      StackMap locals:
      StackMap stack:
            return
        end local 0 // org.eclipse.jetty.io.ManagedSelector$Connect this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lorg/eclipse/jetty/io/ManagedSelector$Connect;

  public void failed(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // org.eclipse.jetty.io.ManagedSelector$Connect this
        start local 1 // java.lang.Throwable failure
         0: .line 808
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ManagedSelector$Connect.failed:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_0
            iconst_1
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
            ifeq 4
         1: .line 810
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ManagedSelector$Connect.timeout:Lorg/eclipse/jetty/util/thread/Scheduler$Task;
            invokeinterface org.eclipse.jetty.util.thread.Scheduler$Task.cancel:()Z
            pop
         2: .line 811
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ManagedSelector$Connect.channel:Ljava/nio/channels/SelectableChannel;
            invokestatic org.eclipse.jetty.io.ManagedSelector.closeNoExceptions:(Ljava/io/Closeable;)V
         3: .line 812
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ManagedSelector$Connect.this$0:Lorg/eclipse/jetty/io/ManagedSelector;
            getfield org.eclipse.jetty.io.ManagedSelector._selectorManager:Lorg/eclipse/jetty/io/SelectorManager;
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ManagedSelector$Connect.channel:Ljava/nio/channels/SelectableChannel;
            aload 1 /* failure */
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ManagedSelector$Connect.attachment:Ljava/lang/Object;
            invokevirtual org.eclipse.jetty.io.SelectorManager.connectionFailed:(Ljava/nio/channels/SelectableChannel;Ljava/lang/Throwable;Ljava/lang/Object;)V
         4: .line 814
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Throwable failure
        end local 0 // org.eclipse.jetty.io.ManagedSelector$Connect this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    5     0     this  Lorg/eclipse/jetty/io/ManagedSelector$Connect;
            0    5     1  failure  Ljava/lang/Throwable;
    MethodParameters:
         Name  Flags
      failure  

  public java.lang.String toString();
    descriptor: ()Ljava/lang/String;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.io.ManagedSelector$Connect this
         0: .line 819
            ldc "Connect@%x{%s,%s}"
            iconst_3
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            invokevirtual java.lang.Object.hashCode:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_1
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ManagedSelector$Connect.channel:Ljava/nio/channels/SelectableChannel;
            aastore
            dup
            iconst_2
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ManagedSelector$Connect.attachment:Ljava/lang/Object;
            aastore
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            areturn
        end local 0 // org.eclipse.jetty.io.ManagedSelector$Connect this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/io/ManagedSelector$Connect;
}
SourceFile: "ManagedSelector.java"
NestHost: org.eclipse.jetty.io.ManagedSelector
InnerClasses:
  Connect = org.eclipse.jetty.io.ManagedSelector$Connect of org.eclipse.jetty.io.ManagedSelector
  public abstract SelectorUpdate = org.eclipse.jetty.io.ManagedSelector$SelectorUpdate of org.eclipse.jetty.io.ManagedSelector
  public abstract Task = org.eclipse.jetty.util.thread.Scheduler$Task of org.eclipse.jetty.util.thread.Scheduler
/

org.eclipse.jetty/ jetty-io/ 10.0.0-alpha0/ org/eclipse/jetty/io/ManagedSelector$Connect.class
