org.eclipse.jetty/jetty-io/11.0.0 : org/eclipse/jetty/io/NetworkTrafficSocketChannelEndPoint.class

NetworkTrafficSocketChannelEndPoint
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)
public class org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint extends org.eclipse.jetty.io.SocketChannelEndPoint
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint
  super_class: org.eclipse.jetty.io.SocketChannelEndPoint
{
  private static final org.slf4j.Logger LOG;
    descriptor: Lorg/slf4j/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final org.eclipse.jetty.io.NetworkTrafficListener listener;
    descriptor: Lorg/eclipse/jetty/io/NetworkTrafficListener;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 35
            ldc Lorg/eclipse/jetty/io/NetworkTrafficSocketChannelEndPoint;
            invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
            putstatic org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.LOG:Lorg/slf4j/Logger;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(java.nio.channels.SocketChannel, org.eclipse.jetty.io.ManagedSelector, java.nio.channels.SelectionKey, org.eclipse.jetty.util.thread.Scheduler, long, org.eclipse.jetty.io.NetworkTrafficListener);
    descriptor: (Ljava/nio/channels/SocketChannel;Lorg/eclipse/jetty/io/ManagedSelector;Ljava/nio/channels/SelectionKey;Lorg/eclipse/jetty/util/thread/Scheduler;JLorg/eclipse/jetty/io/NetworkTrafficListener;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=8, args_size=7
        start local 0 // org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint this
        start local 1 // java.nio.channels.SocketChannel channel
        start local 2 // org.eclipse.jetty.io.ManagedSelector selectSet
        start local 3 // java.nio.channels.SelectionKey key
        start local 4 // org.eclipse.jetty.util.thread.Scheduler scheduler
        start local 5 // long idleTimeout
        start local 7 // org.eclipse.jetty.io.NetworkTrafficListener listener
         0: .line 41
            aload 0 /* this */
            aload 1 /* channel */
            aload 2 /* selectSet */
            aload 3 /* key */
            aload 4 /* scheduler */
            invokespecial org.eclipse.jetty.io.SocketChannelEndPoint.<init>:(Ljava/nio/channels/SocketChannel;Lorg/eclipse/jetty/io/ManagedSelector;Ljava/nio/channels/SelectionKey;Lorg/eclipse/jetty/util/thread/Scheduler;)V
         1: .line 42
            aload 0 /* this */
            lload 5 /* idleTimeout */
            invokevirtual org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.setIdleTimeout:(J)V
         2: .line 43
            aload 0 /* this */
            aload 7 /* listener */
            putfield org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.listener:Lorg/eclipse/jetty/io/NetworkTrafficListener;
         3: .line 44
            return
        end local 7 // org.eclipse.jetty.io.NetworkTrafficListener listener
        end local 5 // long idleTimeout
        end local 4 // org.eclipse.jetty.util.thread.Scheduler scheduler
        end local 3 // java.nio.channels.SelectionKey key
        end local 2 // org.eclipse.jetty.io.ManagedSelector selectSet
        end local 1 // java.nio.channels.SocketChannel channel
        end local 0 // org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    4     0         this  Lorg/eclipse/jetty/io/NetworkTrafficSocketChannelEndPoint;
            0    4     1      channel  Ljava/nio/channels/SocketChannel;
            0    4     2    selectSet  Lorg/eclipse/jetty/io/ManagedSelector;
            0    4     3          key  Ljava/nio/channels/SelectionKey;
            0    4     4    scheduler  Lorg/eclipse/jetty/util/thread/Scheduler;
            0    4     5  idleTimeout  J
            0    4     7     listener  Lorg/eclipse/jetty/io/NetworkTrafficListener;
    MethodParameters:
             Name  Flags
      channel      
      selectSet    
      key          
      scheduler    
      idleTimeout  
      listener     

  public int fill(java.nio.ByteBuffer);
    descriptor: (Ljava/nio/ByteBuffer;)I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint this
        start local 1 // java.nio.ByteBuffer buffer
         0: .line 49
            aload 0 /* this */
            aload 1 /* buffer */
            invokespecial org.eclipse.jetty.io.SocketChannelEndPoint.fill:(Ljava/nio/ByteBuffer;)I
            istore 2 /* read */
        start local 2 // int read
         1: .line 50
            aload 0 /* this */
            aload 1 /* buffer */
            iload 2 /* read */
            invokevirtual org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.notifyIncoming:(Ljava/nio/ByteBuffer;I)V
         2: .line 51
            iload 2 /* read */
            ireturn
        end local 2 // int read
        end local 1 // java.nio.ByteBuffer buffer
        end local 0 // org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    3     0    this  Lorg/eclipse/jetty/io/NetworkTrafficSocketChannelEndPoint;
            0    3     1  buffer  Ljava/nio/ByteBuffer;
            1    3     2    read  I
    Exceptions:
      throws java.io.IOException
    MethodParameters:
        Name  Flags
      buffer  

  public boolean flush(java.nio.ByteBuffer[]);
    descriptor: ([Ljava/nio/ByteBuffer;)Z
    flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
    Code:
      stack=5, locals=10, args_size=2
        start local 0 // org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint this
        start local 1 // java.nio.ByteBuffer[] buffers
         0: .line 57
            iconst_1
            istore 2 /* flushed */
        start local 2 // boolean flushed
         1: .line 58
            aload 1 /* buffers */
            dup
            astore 6
            arraylength
            istore 5
            iconst_0
            istore 4
            goto 13
      StackMap locals: org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint java.nio.ByteBuffer[] int top int int java.nio.ByteBuffer[]
      StackMap stack:
         2: aload 6
            iload 4
            aaload
            astore 3 /* b */
        start local 3 // java.nio.ByteBuffer b
         3: .line 60
            aload 3 /* b */
            invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
            ifeq 12
         4: .line 62
            aload 3 /* b */
            invokevirtual java.nio.ByteBuffer.position:()I
            istore 7 /* position */
        start local 7 // int position
         5: .line 63
            aload 3 /* b */
            invokevirtual java.nio.ByteBuffer.slice:()Ljava/nio/ByteBuffer;
            astore 8 /* view */
        start local 8 // java.nio.ByteBuffer view
         6: .line 64
            aload 0 /* this */
            iconst_1
            anewarray java.nio.ByteBuffer
            dup
            iconst_0
            aload 3 /* b */
            aastore
            invokespecial org.eclipse.jetty.io.SocketChannelEndPoint.flush:([Ljava/nio/ByteBuffer;)Z
            istore 2 /* flushed */
         7: .line 65
            aload 3 /* b */
            invokevirtual java.nio.ByteBuffer.position:()I
            iload 7 /* position */
            isub
            istore 9 /* l */
        start local 9 // int l
         8: .line 66
            aload 8 /* view */
            aload 8 /* view */
            invokevirtual java.nio.ByteBuffer.position:()I
            iload 9 /* l */
            iadd
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
            pop
         9: .line 67
            aload 0 /* this */
            aload 8 /* view */
            invokevirtual org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.notifyOutgoing:(Ljava/nio/ByteBuffer;)V
        10: .line 68
            iload 2 /* flushed */
            ifne 12
        11: .line 69
            goto 14
        end local 9 // int l
        end local 8 // java.nio.ByteBuffer view
        end local 7 // int position
        end local 3 // java.nio.ByteBuffer b
        12: .line 58
      StackMap locals:
      StackMap stack:
            iinc 4 1
      StackMap locals:
      StackMap stack:
        13: iload 4
            iload 5
            if_icmplt 2
        14: .line 72
      StackMap locals: org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint java.nio.ByteBuffer[] int
      StackMap stack:
            iload 2 /* flushed */
            ireturn
        end local 2 // boolean flushed
        end local 1 // java.nio.ByteBuffer[] buffers
        end local 0 // org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   15     0      this  Lorg/eclipse/jetty/io/NetworkTrafficSocketChannelEndPoint;
            0   15     1   buffers  [Ljava/nio/ByteBuffer;
            1   15     2   flushed  Z
            3   12     3         b  Ljava/nio/ByteBuffer;
            5   12     7  position  I
            6   12     8      view  Ljava/nio/ByteBuffer;
            8   12     9         l  I
    Exceptions:
      throws java.io.IOException
    MethodParameters:
         Name  Flags
      buffers  

  public void onOpen();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=1
        start local 0 // org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint this
         0: .line 78
            aload 0 /* this */
            invokespecial org.eclipse.jetty.io.SocketChannelEndPoint.onOpen:()V
         1: .line 79
            aload 0 /* this */
            getfield org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.listener:Lorg/eclipse/jetty/io/NetworkTrafficListener;
            ifnull 6
         2: .line 83
            aload 0 /* this */
            getfield org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.listener:Lorg/eclipse/jetty/io/NetworkTrafficListener;
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.getChannel:()Ljava/nio/channels/SocketChannel;
            invokevirtual java.nio.channels.SocketChannel.socket:()Ljava/net/Socket;
            invokeinterface org.eclipse.jetty.io.NetworkTrafficListener.opened:(Ljava/net/Socket;)V
         3: .line 84
            goto 6
         4: .line 85
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 1 /* x */
        start local 1 // java.lang.Throwable x
         5: .line 87
            getstatic org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.LOG:Lorg/slf4j/Logger;
            ldc "Exception while invoking listener {}"
            aload 0 /* this */
            getfield org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.listener:Lorg/eclipse/jetty/io/NetworkTrafficListener;
            aload 1 /* x */
            invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
        end local 1 // java.lang.Throwable x
         6: .line 90
      StackMap locals:
      StackMap stack:
            return
        end local 0 // org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lorg/eclipse/jetty/io/NetworkTrafficSocketChannelEndPoint;
            5    6     1     x  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           2     3       4  Class java.lang.Throwable

  public void onClose(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint this
        start local 1 // java.lang.Throwable failure
         0: .line 95
            aload 0 /* this */
            aload 1 /* failure */
            invokespecial org.eclipse.jetty.io.SocketChannelEndPoint.onClose:(Ljava/lang/Throwable;)V
         1: .line 96
            aload 0 /* this */
            getfield org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.listener:Lorg/eclipse/jetty/io/NetworkTrafficListener;
            ifnull 6
         2: .line 100
            aload 0 /* this */
            getfield org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.listener:Lorg/eclipse/jetty/io/NetworkTrafficListener;
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.getChannel:()Ljava/nio/channels/SocketChannel;
            invokevirtual java.nio.channels.SocketChannel.socket:()Ljava/net/Socket;
            invokeinterface org.eclipse.jetty.io.NetworkTrafficListener.closed:(Ljava/net/Socket;)V
         3: .line 101
            goto 6
         4: .line 102
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 2 /* x */
        start local 2 // java.lang.Throwable x
         5: .line 104
            getstatic org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.LOG:Lorg/slf4j/Logger;
            ldc "Exception while invoking listener {}"
            aload 0 /* this */
            getfield org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.listener:Lorg/eclipse/jetty/io/NetworkTrafficListener;
            aload 2 /* x */
            invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
        end local 2 // java.lang.Throwable x
         6: .line 107
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Throwable failure
        end local 0 // org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    7     0     this  Lorg/eclipse/jetty/io/NetworkTrafficSocketChannelEndPoint;
            0    7     1  failure  Ljava/lang/Throwable;
            5    6     2        x  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           2     3       4  Class java.lang.Throwable
    MethodParameters:
         Name  Flags
      failure  

  public void notifyIncoming(java.nio.ByteBuffer, int);
    descriptor: (Ljava/nio/ByteBuffer;I)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=3
        start local 0 // org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint this
        start local 1 // java.nio.ByteBuffer buffer
        start local 2 // int read
         0: .line 111
            aload 0 /* this */
            getfield org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.listener:Lorg/eclipse/jetty/io/NetworkTrafficListener;
            ifnull 6
            iload 2 /* read */
            ifle 6
         1: .line 115
            aload 1 /* buffer */
            invokevirtual java.nio.ByteBuffer.asReadOnlyBuffer:()Ljava/nio/ByteBuffer;
            astore 3 /* view */
        start local 3 // java.nio.ByteBuffer view
         2: .line 116
            aload 0 /* this */
            getfield org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.listener:Lorg/eclipse/jetty/io/NetworkTrafficListener;
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.getChannel:()Ljava/nio/channels/SocketChannel;
            invokevirtual java.nio.channels.SocketChannel.socket:()Ljava/net/Socket;
            aload 3 /* view */
            invokeinterface org.eclipse.jetty.io.NetworkTrafficListener.incoming:(Ljava/net/Socket;Ljava/nio/ByteBuffer;)V
        end local 3 // java.nio.ByteBuffer view
         3: .line 117
            goto 6
         4: .line 118
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 3 /* x */
        start local 3 // java.lang.Throwable x
         5: .line 120
            getstatic org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.LOG:Lorg/slf4j/Logger;
            ldc "Exception while invoking listener {}"
            aload 0 /* this */
            getfield org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.listener:Lorg/eclipse/jetty/io/NetworkTrafficListener;
            aload 3 /* x */
            invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
        end local 3 // java.lang.Throwable x
         6: .line 123
      StackMap locals:
      StackMap stack:
            return
        end local 2 // int read
        end local 1 // java.nio.ByteBuffer buffer
        end local 0 // org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    7     0    this  Lorg/eclipse/jetty/io/NetworkTrafficSocketChannelEndPoint;
            0    7     1  buffer  Ljava/nio/ByteBuffer;
            0    7     2    read  I
            2    3     3    view  Ljava/nio/ByteBuffer;
            5    6     3       x  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           1     3       4  Class java.lang.Throwable
    MethodParameters:
        Name  Flags
      buffer  
      read    

  public void notifyOutgoing(java.nio.ByteBuffer);
    descriptor: (Ljava/nio/ByteBuffer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint this
        start local 1 // java.nio.ByteBuffer view
         0: .line 127
            aload 0 /* this */
            getfield org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.listener:Lorg/eclipse/jetty/io/NetworkTrafficListener;
            ifnull 5
            aload 1 /* view */
            invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
            ifeq 5
         1: .line 131
            aload 0 /* this */
            getfield org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.listener:Lorg/eclipse/jetty/io/NetworkTrafficListener;
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.getChannel:()Ljava/nio/channels/SocketChannel;
            invokevirtual java.nio.channels.SocketChannel.socket:()Ljava/net/Socket;
            aload 1 /* view */
            invokeinterface org.eclipse.jetty.io.NetworkTrafficListener.outgoing:(Ljava/net/Socket;Ljava/nio/ByteBuffer;)V
         2: .line 132
            goto 5
         3: .line 133
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 2 /* x */
        start local 2 // java.lang.Throwable x
         4: .line 135
            getstatic org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.LOG:Lorg/slf4j/Logger;
            ldc "Exception while invoking listener {}"
            aload 0 /* this */
            getfield org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint.listener:Lorg/eclipse/jetty/io/NetworkTrafficListener;
            aload 2 /* x */
            invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
        end local 2 // java.lang.Throwable x
         5: .line 138
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.nio.ByteBuffer view
        end local 0 // org.eclipse.jetty.io.NetworkTrafficSocketChannelEndPoint this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lorg/eclipse/jetty/io/NetworkTrafficSocketChannelEndPoint;
            0    6     1  view  Ljava/nio/ByteBuffer;
            4    5     2     x  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           1     2       3  Class java.lang.Throwable
    MethodParameters:
      Name  Flags
      view  
}
SourceFile: "NetworkTrafficSocketChannelEndPoint.java"
/

org.eclipse.jetty/ jetty-io/ 11.0.0/ org/eclipse/jetty/io/NetworkTrafficSocketChannelEndPoint.class
