public abstract class org.apache.tomcat.util.net.SocketWrapperBase$OperationState<A> implements java.lang.Runnable
  minor version: 0
  major version: 59
  flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
  this_class: org.apache.tomcat.util.net.SocketWrapperBase$OperationState
  super_class: java.lang.Object
{
  protected final boolean read;
    descriptor: Z
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL

  protected final java.nio.ByteBuffer[] buffers;
    descriptor: [Ljava/nio/ByteBuffer;
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL

  protected final int offset;
    descriptor: I
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL

  protected final int length;
    descriptor: I
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL

  protected final A attachment;
    descriptor: Ljava/lang/Object;
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL
    Signature: TA;

  protected final long timeout;
    descriptor: J
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL

  protected final java.util.concurrent.TimeUnit unit;
    descriptor: Ljava/util/concurrent/TimeUnit;
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL

  protected final org.apache.tomcat.util.net.SocketWrapperBase$BlockingMode block;
    descriptor: Lorg/apache/tomcat/util/net/SocketWrapperBase$BlockingMode;
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL
    Signature: Lorg/apache/tomcat/util/net/SocketWrapperBase$BlockingMode;

  protected final org.apache.tomcat.util.net.SocketWrapperBase$CompletionCheck check;
    descriptor: Lorg/apache/tomcat/util/net/SocketWrapperBase$CompletionCheck;
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL

  protected final java.nio.channels.CompletionHandler<java.lang.Long, ? super A> handler;
    descriptor: Ljava/nio/channels/CompletionHandler;
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL
    Signature: Ljava/nio/channels/CompletionHandler<Ljava/lang/Long;-TA;>;

  protected final java.util.concurrent.Semaphore semaphore;
    descriptor: Ljava/util/concurrent/Semaphore;
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL

  protected final org.apache.tomcat.util.net.SocketWrapperBase<E>.VectoredIOCompletionHandler<A> completion;
    descriptor: Lorg/apache/tomcat/util/net/SocketWrapperBase$VectoredIOCompletionHandler;
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL
    Signature: Lorg/apache/tomcat/util/net/SocketWrapperBase<TE;>.VectoredIOCompletionHandler<TA;>;

  protected volatile long nBytes;
    descriptor: J
    flags: (0x0044) ACC_PROTECTED, ACC_VOLATILE

  protected volatile org.apache.tomcat.util.net.SocketWrapperBase$CompletionState state;
    descriptor: Lorg/apache/tomcat/util/net/SocketWrapperBase$CompletionState;
    flags: (0x0044) ACC_PROTECTED, ACC_VOLATILE
    Signature: Lorg/apache/tomcat/util/net/SocketWrapperBase$CompletionState;

  protected boolean completionDone;
    descriptor: Z
    flags: (0x0004) ACC_PROTECTED

  final org.apache.tomcat.util.net.SocketWrapperBase this$0;
    descriptor: Lorg/apache/tomcat/util/net/SocketWrapperBase;
    flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC

  protected void <init>(boolean, java.nio.ByteBuffer[], int, int, org.apache.tomcat.util.net.SocketWrapperBase$BlockingMode, long, java.util.concurrent.TimeUnit, A, org.apache.tomcat.util.net.SocketWrapperBase$CompletionCheck, java.nio.channels.CompletionHandler<java.lang.Long, ? super A>, java.util.concurrent.Semaphore, org.apache.tomcat.util.net.SocketWrapperBase<E>.VectoredIOCompletionHandler<A>);
    descriptor: (Lorg/apache/tomcat/util/net/SocketWrapperBase;Z[Ljava/nio/ByteBuffer;IILorg/apache/tomcat/util/net/SocketWrapperBase$BlockingMode;JLjava/util/concurrent/TimeUnit;Ljava/lang/Object;Lorg/apache/tomcat/util/net/SocketWrapperBase$CompletionCheck;Ljava/nio/channels/CompletionHandler;Ljava/util/concurrent/Semaphore;Lorg/apache/tomcat/util/net/SocketWrapperBase$VectoredIOCompletionHandler;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=15, args_size=14
        start local 0 // org.apache.tomcat.util.net.SocketWrapperBase$OperationState this
        start local 2 // boolean read
        start local 3 // java.nio.ByteBuffer[] buffers
        start local 4 // int offset
        start local 5 // int length
        start local 6 // org.apache.tomcat.util.net.SocketWrapperBase$BlockingMode block
        start local 7 // long timeout
        start local 9 // java.util.concurrent.TimeUnit unit
        start local 10 // java.lang.Object attachment
        start local 11 // org.apache.tomcat.util.net.SocketWrapperBase$CompletionCheck check
        start local 12 // java.nio.channels.CompletionHandler handler
        start local 13 // java.util.concurrent.Semaphore semaphore
        start local 14 // org.apache.tomcat.util.net.SocketWrapperBase$VectoredIOCompletionHandler completion
         0: .line 1018
            aload 0 /* this */
            aload 1
            putfield org.apache.tomcat.util.net.SocketWrapperBase$OperationState.this$0:Lorg/apache/tomcat/util/net/SocketWrapperBase;
         1: .line 1015
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         2: .line 1032
            aload 0 /* this */
            lconst_0
            putfield org.apache.tomcat.util.net.SocketWrapperBase$OperationState.nBytes:J
         3: .line 1033
            aload 0 /* this */
            getstatic org.apache.tomcat.util.net.SocketWrapperBase$CompletionState.PENDING:Lorg/apache/tomcat/util/net/SocketWrapperBase$CompletionState;
            putfield org.apache.tomcat.util.net.SocketWrapperBase$OperationState.state:Lorg/apache/tomcat/util/net/SocketWrapperBase$CompletionState;
         4: .line 1034
            aload 0 /* this */
            iconst_1
            putfield org.apache.tomcat.util.net.SocketWrapperBase$OperationState.completionDone:Z
         5: .line 1019
            aload 0 /* this */
            iload 2 /* read */
            putfield org.apache.tomcat.util.net.SocketWrapperBase$OperationState.read:Z
         6: .line 1020
            aload 0 /* this */
            aload 3 /* buffers */
            putfield org.apache.tomcat.util.net.SocketWrapperBase$OperationState.buffers:[Ljava/nio/ByteBuffer;
         7: .line 1021
            aload 0 /* this */
            iload 4 /* offset */
            putfield org.apache.tomcat.util.net.SocketWrapperBase$OperationState.offset:I
         8: .line 1022
            aload 0 /* this */
            iload 5 /* length */
            putfield org.apache.tomcat.util.net.SocketWrapperBase$OperationState.length:I
         9: .line 1023
            aload 0 /* this */
            aload 6 /* block */
            putfield org.apache.tomcat.util.net.SocketWrapperBase$OperationState.block:Lorg/apache/tomcat/util/net/SocketWrapperBase$BlockingMode;
        10: .line 1024
            aload 0 /* this */
            lload 7 /* timeout */
            putfield org.apache.tomcat.util.net.SocketWrapperBase$OperationState.timeout:J
        11: .line 1025
            aload 0 /* this */
            aload 9 /* unit */
            putfield org.apache.tomcat.util.net.SocketWrapperBase$OperationState.unit:Ljava/util/concurrent/TimeUnit;
        12: .line 1026
            aload 0 /* this */
            aload 10 /* attachment */
            putfield org.apache.tomcat.util.net.SocketWrapperBase$OperationState.attachment:Ljava/lang/Object;
        13: .line 1027
            aload 0 /* this */
            aload 11 /* check */
            putfield org.apache.tomcat.util.net.SocketWrapperBase$OperationState.check:Lorg/apache/tomcat/util/net/SocketWrapperBase$CompletionCheck;
        14: .line 1028
            aload 0 /* this */
            aload 12 /* handler */
            putfield org.apache.tomcat.util.net.SocketWrapperBase$OperationState.handler:Ljava/nio/channels/CompletionHandler;
        15: .line 1029
            aload 0 /* this */
            aload 13 /* semaphore */
            putfield org.apache.tomcat.util.net.SocketWrapperBase$OperationState.semaphore:Ljava/util/concurrent/Semaphore;
        16: .line 1030
            aload 0 /* this */
            aload 14 /* completion */
            putfield org.apache.tomcat.util.net.SocketWrapperBase$OperationState.completion:Lorg/apache/tomcat/util/net/SocketWrapperBase$VectoredIOCompletionHandler;
        17: .line 1031
            return
        end local 14 // org.apache.tomcat.util.net.SocketWrapperBase$VectoredIOCompletionHandler completion
        end local 13 // java.util.concurrent.Semaphore semaphore
        end local 12 // java.nio.channels.CompletionHandler handler
        end local 11 // org.apache.tomcat.util.net.SocketWrapperBase$CompletionCheck check
        end local 10 // java.lang.Object attachment
        end local 9 // java.util.concurrent.TimeUnit unit
        end local 7 // long timeout
        end local 6 // org.apache.tomcat.util.net.SocketWrapperBase$BlockingMode block
        end local 5 // int length
        end local 4 // int offset
        end local 3 // java.nio.ByteBuffer[] buffers
        end local 2 // boolean read
        end local 0 // org.apache.tomcat.util.net.SocketWrapperBase$OperationState this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   18     0        this  Lorg/apache/tomcat/util/net/SocketWrapperBase<TE;>.OperationState<TA;>;
            0   18     2        read  Z
            0   18     3     buffers  [Ljava/nio/ByteBuffer;
            0   18     4      offset  I
            0   18     5      length  I
            0   18     6       block  Lorg/apache/tomcat/util/net/SocketWrapperBase$BlockingMode;
            0   18     7     timeout  J
            0   18     9        unit  Ljava/util/concurrent/TimeUnit;
            0   18    10  attachment  TA;
            0   18    11       check  Lorg/apache/tomcat/util/net/SocketWrapperBase$CompletionCheck;
            0   18    12     handler  Ljava/nio/channels/CompletionHandler<Ljava/lang/Long;-TA;>;
            0   18    13   semaphore  Ljava/util/concurrent/Semaphore;
            0   18    14  completion  Lorg/apache/tomcat/util/net/SocketWrapperBase<TE;>.VectoredIOCompletionHandler<TA;>;
    Signature: (Z[Ljava/nio/ByteBuffer;IILorg/apache/tomcat/util/net/SocketWrapperBase$BlockingMode;JLjava/util/concurrent/TimeUnit;TA;Lorg/apache/tomcat/util/net/SocketWrapperBase$CompletionCheck;Ljava/nio/channels/CompletionHandler<Ljava/lang/Long;-TA;>;Ljava/util/concurrent/Semaphore;Lorg/apache/tomcat/util/net/SocketWrapperBase<TE;>.VectoredIOCompletionHandler<TA;>;)V
    MethodParameters:
            Name  Flags
      this$0      final
      read        
      buffers     
      offset      
      length      
      block       
      timeout     
      unit        
      attachment  
      check       
      handler     
      semaphore   
      completion  

  protected abstract boolean isInline();
    descriptor: ()Z
    flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT

  protected boolean process();
    descriptor: ()Z
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=7, locals=2, args_size=1
        start local 0 // org.apache.tomcat.util.net.SocketWrapperBase$OperationState this
         0: .line 1049
            aload 0 /* this */
            getfield org.apache.tomcat.util.net.SocketWrapperBase$OperationState.this$0:Lorg/apache/tomcat/util/net/SocketWrapperBase;
            invokevirtual org.apache.tomcat.util.net.SocketWrapperBase.getEndpoint:()Lorg/apache/tomcat/util/net/AbstractEndpoint;
            invokevirtual org.apache.tomcat.util.net.AbstractEndpoint.getExecutor:()Ljava/util/concurrent/Executor;
            aload 0 /* this */
            invokeinterface java.util.concurrent.Executor.execute:(Ljava/lang/Runnable;)V
         1: .line 1050
            iconst_1
            ireturn
         2: .line 1051
      StackMap locals:
      StackMap stack: java.util.concurrent.RejectedExecutionException
            astore 1 /* ree */
        start local 1 // java.util.concurrent.RejectedExecutionException ree
         3: .line 1052
            getstatic org.apache.tomcat.util.net.SocketWrapperBase.log:Lorg/apache/juli/logging/Log;
            getstatic org.apache.tomcat.util.net.SocketWrapperBase.sm:Lorg/apache/tomcat/util/res/StringManager;
            ldc "endpoint.executor.fail"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            getfield org.apache.tomcat.util.net.SocketWrapperBase$OperationState.this$0:Lorg/apache/tomcat/util/net/SocketWrapperBase;
            aastore
            invokevirtual org.apache.tomcat.util.res.StringManager.getString:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            aload 1 /* ree */
            invokeinterface org.apache.juli.logging.Log.warn:(Ljava/lang/Object;Ljava/lang/Throwable;)V
        end local 1 // java.util.concurrent.RejectedExecutionException ree
         4: goto 8
         5: .line 1053
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 1 /* t */
        start local 1 // java.lang.Throwable t
         6: .line 1054
            aload 1 /* t */
            invokestatic org.apache.tomcat.util.ExceptionUtils.handleThrowable:(Ljava/lang/Throwable;)V
         7: .line 1057
            getstatic org.apache.tomcat.util.net.SocketWrapperBase.log:Lorg/apache/juli/logging/Log;
            getstatic org.apache.tomcat.util.net.SocketWrapperBase.sm:Lorg/apache/tomcat/util/res/StringManager;
            ldc "endpoint.process.fail"
            invokevirtual org.apache.tomcat.util.res.StringManager.getString:(Ljava/lang/String;)Ljava/lang/String;
            aload 1 /* t */
            invokeinterface org.apache.juli.logging.Log.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
        end local 1 // java.lang.Throwable t
         8: .line 1059
      StackMap locals:
      StackMap stack:
            iconst_0
            ireturn
        end local 0 // org.apache.tomcat.util.net.SocketWrapperBase$OperationState this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    9     0  this  Lorg/apache/tomcat/util/net/SocketWrapperBase<TE;>.OperationState<TA;>;
            3    4     1   ree  Ljava/util/concurrent/RejectedExecutionException;
            6    8     1     t  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           0     1       2  Class java.util.concurrent.RejectedExecutionException
           0     1       5  Class java.lang.Throwable

  protected void start();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.tomcat.util.net.SocketWrapperBase$OperationState this
         0: .line 1066
            aload 0 /* this */
            invokevirtual org.apache.tomcat.util.net.SocketWrapperBase$OperationState.run:()V
         1: .line 1067
            return
        end local 0 // org.apache.tomcat.util.net.SocketWrapperBase$OperationState this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/tomcat/util/net/SocketWrapperBase<TE;>.OperationState<TA;>;

  protected void end();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // org.apache.tomcat.util.net.SocketWrapperBase$OperationState this
         0: .line 1073
            return
        end local 0 // org.apache.tomcat.util.net.SocketWrapperBase$OperationState this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/tomcat/util/net/SocketWrapperBase<TE;>.OperationState<TA;>;
}
Signature: <A:Ljava/lang/Object;>Ljava/lang/Object;Ljava/lang/Runnable;
SourceFile: "SocketWrapperBase.java"
NestHost: org.apache.tomcat.util.net.SocketWrapperBase
InnerClasses:
  public final BlockingMode = org.apache.tomcat.util.net.SocketWrapperBase$BlockingMode of org.apache.tomcat.util.net.SocketWrapperBase
  public abstract CompletionCheck = org.apache.tomcat.util.net.SocketWrapperBase$CompletionCheck of org.apache.tomcat.util.net.SocketWrapperBase
  public final CompletionState = org.apache.tomcat.util.net.SocketWrapperBase$CompletionState of org.apache.tomcat.util.net.SocketWrapperBase
  protected abstract OperationState = org.apache.tomcat.util.net.SocketWrapperBase$OperationState of org.apache.tomcat.util.net.SocketWrapperBase
  protected VectoredIOCompletionHandler = org.apache.tomcat.util.net.SocketWrapperBase$VectoredIOCompletionHandler of org.apache.tomcat.util.net.SocketWrapperBase