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

ManagedSelector$Connect
https://eclipse.org/jetty/jetty-io: 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)
Ludovic Orban (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=6, 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 891
            aload 0 /* this */
            aload 1
            putfield org.eclipse.jetty.io.ManagedSelector$Connect.this$0:Lorg/eclipse/jetty/io/ManagedSelector;
         1: .line 890
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         2: .line 885
            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 892
            aload 0 /* this */
            aload 2 /* channel */
            putfield org.eclipse.jetty.io.ManagedSelector$Connect.channel:Ljava/nio/channels/SelectableChannel;
         4: .line 893
            aload 0 /* this */
            aload 3 /* attachment */
            putfield org.eclipse.jetty.io.ManagedSelector$Connect.attachment:Ljava/lang/Object;
         5: .line 894
            aload 1
            getfield org.eclipse.jetty.io.ManagedSelector._selectorManager:Lorg/eclipse/jetty/io/SelectorManager;
            invokevirtual org.eclipse.jetty.io.SelectorManager.getConnectTimeout:()J
            lstore 4 /* timeout */
        start local 4 // long timeout
         6: .line 895
            lload 4 /* timeout */
            lconst_0
            lcmp
            ifle 8
         7: .line 896
            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 */
            lload 4 /* timeout */
            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;
            goto 9
         8: .line 898
      StackMap locals: org.eclipse.jetty.io.ManagedSelector$Connect org.eclipse.jetty.io.ManagedSelector java.nio.channels.SelectableChannel java.lang.Object long
      StackMap stack:
            aload 0 /* this */
            aconst_null
            putfield org.eclipse.jetty.io.ManagedSelector$Connect.timeout:Lorg/eclipse/jetty/util/thread/Scheduler$Task;
         9: .line 899
      StackMap locals:
      StackMap stack:
            return
        end local 4 // long timeout
        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   10     0        this  Lorg/eclipse/jetty/io/ManagedSelector$Connect;
            0   10     2     channel  Ljava/nio/channels/SelectableChannel;
            0   10     3  attachment  Ljava/lang/Object;
            6   10     4     timeout  J
    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 906
            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 907
            goto 4
         2: .line 908
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 2 /* x */
        start local 2 // java.lang.Throwable x
         3: .line 910
            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 912
      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=4, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.io.ManagedSelector$Connect this
         0: .line 917
            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 919
            getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
            invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
            ifeq 3
         2: .line 920
            getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
            ldc "Channel {} timed out while connecting, closing it"
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ManagedSelector$Connect.channel:Ljava/nio/channels/SelectableChannel;
            invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
         3: .line 921
      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 923
      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 927
            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 5
         1: .line 929
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ManagedSelector$Connect.timeout:Lorg/eclipse/jetty/util/thread/Scheduler$Task;
            ifnull 3
         2: .line 930
            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
         3: .line 931
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ManagedSelector$Connect.channel:Ljava/nio/channels/SelectableChannel;
            invokestatic org.eclipse.jetty.util.IO.close:(Ljava/io/Closeable;)V
         4: .line 932
            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
         5: .line 934
      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    6     0     this  Lorg/eclipse/jetty/io/ManagedSelector$Connect;
            0    6     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 939
            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/ 11.0.0/ org/eclipse/jetty/io/ManagedSelector$Connect.class
