public class org.eclipse.jetty.io.ConnectionStatistics extends org.eclipse.jetty.util.component.AbstractLifeCycle implements org.eclipse.jetty.io.Connection$Listener, org.eclipse.jetty.util.component.Dumpable
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.eclipse.jetty.io.ConnectionStatistics
super_class: org.eclipse.jetty.util.component.AbstractLifeCycle
{
private final org.eclipse.jetty.util.statistic.CounterStatistic _connections;
descriptor: Lorg/eclipse/jetty/util/statistic/CounterStatistic;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.eclipse.jetty.util.statistic.SampleStatistic _connectionsDuration;
descriptor: Lorg/eclipse/jetty/util/statistic/SampleStatistic;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.atomic.LongAdder _rcvdBytes;
descriptor: Ljava/util/concurrent/atomic/LongAdder;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.atomic.AtomicLong _bytesInStamp;
descriptor: Ljava/util/concurrent/atomic/AtomicLong;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.atomic.LongAdder _sentBytes;
descriptor: Ljava/util/concurrent/atomic/LongAdder;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.atomic.AtomicLong _bytesOutStamp;
descriptor: Ljava/util/concurrent/atomic/AtomicLong;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.atomic.LongAdder _messagesIn;
descriptor: Ljava/util/concurrent/atomic/LongAdder;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.atomic.AtomicLong _messagesInStamp;
descriptor: Ljava/util/concurrent/atomic/AtomicLong;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.atomic.LongAdder _messagesOut;
descriptor: Ljava/util/concurrent/atomic/LongAdder;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.atomic.AtomicLong _messagesOutStamp;
descriptor: Ljava/util/concurrent/atomic/AtomicLong;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokespecial org.eclipse.jetty.util.component.AbstractLifeCycle.<init>:()V
1: aload 0
new org.eclipse.jetty.util.statistic.CounterStatistic
dup
invokespecial org.eclipse.jetty.util.statistic.CounterStatistic.<init>:()V
putfield org.eclipse.jetty.io.ConnectionStatistics._connections:Lorg/eclipse/jetty/util/statistic/CounterStatistic;
2: aload 0
new org.eclipse.jetty.util.statistic.SampleStatistic
dup
invokespecial org.eclipse.jetty.util.statistic.SampleStatistic.<init>:()V
putfield org.eclipse.jetty.io.ConnectionStatistics._connectionsDuration:Lorg/eclipse/jetty/util/statistic/SampleStatistic;
3: aload 0
new java.util.concurrent.atomic.LongAdder
dup
invokespecial java.util.concurrent.atomic.LongAdder.<init>:()V
putfield org.eclipse.jetty.io.ConnectionStatistics._rcvdBytes:Ljava/util/concurrent/atomic/LongAdder;
4: aload 0
new java.util.concurrent.atomic.AtomicLong
dup
invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
putfield org.eclipse.jetty.io.ConnectionStatistics._bytesInStamp:Ljava/util/concurrent/atomic/AtomicLong;
5: aload 0
new java.util.concurrent.atomic.LongAdder
dup
invokespecial java.util.concurrent.atomic.LongAdder.<init>:()V
putfield org.eclipse.jetty.io.ConnectionStatistics._sentBytes:Ljava/util/concurrent/atomic/LongAdder;
6: aload 0
new java.util.concurrent.atomic.AtomicLong
dup
invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
putfield org.eclipse.jetty.io.ConnectionStatistics._bytesOutStamp:Ljava/util/concurrent/atomic/AtomicLong;
7: aload 0
new java.util.concurrent.atomic.LongAdder
dup
invokespecial java.util.concurrent.atomic.LongAdder.<init>:()V
putfield org.eclipse.jetty.io.ConnectionStatistics._messagesIn:Ljava/util/concurrent/atomic/LongAdder;
8: aload 0
new java.util.concurrent.atomic.AtomicLong
dup
invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
putfield org.eclipse.jetty.io.ConnectionStatistics._messagesInStamp:Ljava/util/concurrent/atomic/AtomicLong;
9: aload 0
new java.util.concurrent.atomic.LongAdder
dup
invokespecial java.util.concurrent.atomic.LongAdder.<init>:()V
putfield org.eclipse.jetty.io.ConnectionStatistics._messagesOut:Ljava/util/concurrent/atomic/LongAdder;
10: aload 0
new java.util.concurrent.atomic.AtomicLong
dup
invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
putfield org.eclipse.jetty.io.ConnectionStatistics._messagesOutStamp:Ljava/util/concurrent/atomic/AtomicLong;
11: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
public void reset();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._connections:Lorg/eclipse/jetty/util/statistic/CounterStatistic;
invokevirtual org.eclipse.jetty.util.statistic.CounterStatistic.reset:()V
1: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._connectionsDuration:Lorg/eclipse/jetty/util/statistic/SampleStatistic;
invokevirtual org.eclipse.jetty.util.statistic.SampleStatistic.reset:()V
2: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._rcvdBytes:Ljava/util/concurrent/atomic/LongAdder;
invokevirtual java.util.concurrent.atomic.LongAdder.reset:()V
3: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._bytesInStamp:Ljava/util/concurrent/atomic/AtomicLong;
invokestatic java.lang.System.nanoTime:()J
invokevirtual java.util.concurrent.atomic.AtomicLong.set:(J)V
4: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._sentBytes:Ljava/util/concurrent/atomic/LongAdder;
invokevirtual java.util.concurrent.atomic.LongAdder.reset:()V
5: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._bytesOutStamp:Ljava/util/concurrent/atomic/AtomicLong;
invokestatic java.lang.System.nanoTime:()J
invokevirtual java.util.concurrent.atomic.AtomicLong.set:(J)V
6: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._messagesIn:Ljava/util/concurrent/atomic/LongAdder;
invokevirtual java.util.concurrent.atomic.LongAdder.reset:()V
7: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._messagesInStamp:Ljava/util/concurrent/atomic/AtomicLong;
invokestatic java.lang.System.nanoTime:()J
invokevirtual java.util.concurrent.atomic.AtomicLong.set:(J)V
8: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._messagesOut:Ljava/util/concurrent/atomic/LongAdder;
invokevirtual java.util.concurrent.atomic.LongAdder.reset:()V
9: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._messagesOutStamp:Ljava/util/concurrent/atomic/AtomicLong;
invokestatic java.lang.System.nanoTime:()J
invokevirtual java.util.concurrent.atomic.AtomicLong.set:(J)V
10: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedOperation(value = "Resets the statistics", impact = "ACTION")
protected void doStart();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.eclipse.jetty.io.ConnectionStatistics.reset:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
Exceptions:
throws java.lang.Exception
public void onOpened(org.eclipse.jetty.io.Connection);
descriptor: (Lorg/eclipse/jetty/io/Connection;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.eclipse.jetty.io.ConnectionStatistics.isStarted:()Z
ifne 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._connections:Lorg/eclipse/jetty/util/statistic/CounterStatistic;
invokevirtual org.eclipse.jetty.util.statistic.CounterStatistic.increment:()J
pop2
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
0 4 1 connection Lorg/eclipse/jetty/io/Connection;
MethodParameters:
Name Flags
connection
public void onClosed(org.eclipse.jetty.io.Connection);
descriptor: (Lorg/eclipse/jetty/io/Connection;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=12, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.eclipse.jetty.io.ConnectionStatistics.isStarted:()Z
ifne 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._connections:Lorg/eclipse/jetty/util/statistic/CounterStatistic;
invokevirtual org.eclipse.jetty.util.statistic.CounterStatistic.decrement:()J
pop2
3: invokestatic java.lang.System.currentTimeMillis:()J
aload 1
invokeinterface org.eclipse.jetty.io.Connection.getCreatedTimeStamp:()J
lsub
lstore 2
start local 2 4: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._connectionsDuration:Lorg/eclipse/jetty/util/statistic/SampleStatistic;
lload 2
invokevirtual org.eclipse.jetty.util.statistic.SampleStatistic.record:(J)V
5: aload 1
invokeinterface org.eclipse.jetty.io.Connection.getBytesIn:()J
lstore 4
start local 4 6: lload 4
lconst_0
lcmp
ifle 8
7: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._rcvdBytes:Ljava/util/concurrent/atomic/LongAdder;
lload 4
invokevirtual java.util.concurrent.atomic.LongAdder.add:(J)V
8: StackMap locals: long long
StackMap stack:
aload 1
invokeinterface org.eclipse.jetty.io.Connection.getBytesOut:()J
lstore 6
start local 6 9: lload 6
lconst_0
lcmp
ifle 11
10: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._sentBytes:Ljava/util/concurrent/atomic/LongAdder;
lload 6
invokevirtual java.util.concurrent.atomic.LongAdder.add:(J)V
11: StackMap locals: long
StackMap stack:
aload 1
invokeinterface org.eclipse.jetty.io.Connection.getMessagesIn:()J
lstore 8
start local 8 12: lload 8
lconst_0
lcmp
ifle 14
13: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._messagesIn:Ljava/util/concurrent/atomic/LongAdder;
lload 8
invokevirtual java.util.concurrent.atomic.LongAdder.add:(J)V
14: StackMap locals: long
StackMap stack:
aload 1
invokeinterface org.eclipse.jetty.io.Connection.getMessagesOut:()J
lstore 10
start local 10 15: lload 10
lconst_0
lcmp
ifle 17
16: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._messagesOut:Ljava/util/concurrent/atomic/LongAdder;
lload 10
invokevirtual java.util.concurrent.atomic.LongAdder.add:(J)V
17: StackMap locals: long
StackMap stack:
return
end local 10 end local 8 end local 6 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
0 18 1 connection Lorg/eclipse/jetty/io/Connection;
4 18 2 elapsed J
6 18 4 bytesIn J
9 18 6 bytesOut J
12 18 8 messagesIn J
15 18 10 messagesOut J
MethodParameters:
Name Flags
connection
public long getReceivedBytes();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._rcvdBytes:Ljava/util/concurrent/atomic/LongAdder;
invokevirtual java.util.concurrent.atomic.LongAdder.sum:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "Total number of bytes received by tracked connections")
public long getReceivedBytesRate();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=7, args_size=1
start local 0 0: invokestatic java.lang.System.nanoTime:()J
lstore 1
start local 1 1: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._bytesInStamp:Ljava/util/concurrent/atomic/AtomicLong;
lload 1
invokevirtual java.util.concurrent.atomic.AtomicLong.getAndSet:(J)J
lstore 3
start local 3 2: getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
lload 1
lload 3
lsub
invokevirtual java.util.concurrent.TimeUnit.toMillis:(J)J
lstore 5
start local 5 3: lload 5
lconst_0
lcmp
ifne 4
lconst_0
goto 5
StackMap locals: long long long
StackMap stack:
4: aload 0
invokevirtual org.eclipse.jetty.io.ConnectionStatistics.getReceivedBytes:()J
ldc 1000
lmul
lload 5
ldiv
StackMap locals:
StackMap stack: long
5: lreturn
end local 5 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
1 6 1 now J
2 6 3 then J
3 6 5 elapsed J
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "Total number of bytes received per second since the last invocation of this method")
public long getSentBytes();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._sentBytes:Ljava/util/concurrent/atomic/LongAdder;
invokevirtual java.util.concurrent.atomic.LongAdder.sum:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "Total number of bytes sent by tracked connections")
public long getSentBytesRate();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=7, args_size=1
start local 0 0: invokestatic java.lang.System.nanoTime:()J
lstore 1
start local 1 1: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._bytesOutStamp:Ljava/util/concurrent/atomic/AtomicLong;
lload 1
invokevirtual java.util.concurrent.atomic.AtomicLong.getAndSet:(J)J
lstore 3
start local 3 2: getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
lload 1
lload 3
lsub
invokevirtual java.util.concurrent.TimeUnit.toMillis:(J)J
lstore 5
start local 5 3: lload 5
lconst_0
lcmp
ifne 4
lconst_0
goto 5
StackMap locals: long long long
StackMap stack:
4: aload 0
invokevirtual org.eclipse.jetty.io.ConnectionStatistics.getSentBytes:()J
ldc 1000
lmul
lload 5
ldiv
StackMap locals:
StackMap stack: long
5: lreturn
end local 5 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
1 6 1 now J
2 6 3 then J
3 6 5 elapsed J
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "Total number of bytes sent per second since the last invocation of this method")
public long getConnectionDurationMax();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._connectionsDuration:Lorg/eclipse/jetty/util/statistic/SampleStatistic;
invokevirtual org.eclipse.jetty.util.statistic.SampleStatistic.getMax:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "The max duration of a connection in ms")
public double getConnectionDurationMean();
descriptor: ()D
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._connectionsDuration:Lorg/eclipse/jetty/util/statistic/SampleStatistic;
invokevirtual org.eclipse.jetty.util.statistic.SampleStatistic.getMean:()D
dreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "The mean duration of a connection in ms")
public double getConnectionDurationStdDev();
descriptor: ()D
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._connectionsDuration:Lorg/eclipse/jetty/util/statistic/SampleStatistic;
invokevirtual org.eclipse.jetty.util.statistic.SampleStatistic.getStdDev:()D
dreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "The standard deviation of the duration of a connection")
public long getConnectionsTotal();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._connections:Lorg/eclipse/jetty/util/statistic/CounterStatistic;
invokevirtual org.eclipse.jetty.util.statistic.CounterStatistic.getTotal:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "The total number of connections opened")
public long getConnections();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._connections:Lorg/eclipse/jetty/util/statistic/CounterStatistic;
invokevirtual org.eclipse.jetty.util.statistic.CounterStatistic.getCurrent:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "The current number of open connections")
public long getConnectionsMax();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._connections:Lorg/eclipse/jetty/util/statistic/CounterStatistic;
invokevirtual org.eclipse.jetty.util.statistic.CounterStatistic.getMax:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "The max number of open connections")
public long getReceivedMessages();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._messagesIn:Ljava/util/concurrent/atomic/LongAdder;
invokevirtual java.util.concurrent.atomic.LongAdder.sum:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "The total number of messages received")
public long getReceivedMessagesRate();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=7, args_size=1
start local 0 0: invokestatic java.lang.System.nanoTime:()J
lstore 1
start local 1 1: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._messagesInStamp:Ljava/util/concurrent/atomic/AtomicLong;
lload 1
invokevirtual java.util.concurrent.atomic.AtomicLong.getAndSet:(J)J
lstore 3
start local 3 2: getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
lload 1
lload 3
lsub
invokevirtual java.util.concurrent.TimeUnit.toMillis:(J)J
lstore 5
start local 5 3: lload 5
lconst_0
lcmp
ifne 4
lconst_0
goto 5
StackMap locals: long long long
StackMap stack:
4: aload 0
invokevirtual org.eclipse.jetty.io.ConnectionStatistics.getReceivedMessages:()J
ldc 1000
lmul
lload 5
ldiv
StackMap locals:
StackMap stack: long
5: lreturn
end local 5 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
1 6 1 now J
2 6 3 then J
3 6 5 elapsed J
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "Total number of messages received per second since the last invocation of this method")
public long getSentMessages();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._messagesOut:Ljava/util/concurrent/atomic/LongAdder;
invokevirtual java.util.concurrent.atomic.LongAdder.sum:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "The total number of messages sent")
public long getSentMessagesRate();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=7, args_size=1
start local 0 0: invokestatic java.lang.System.nanoTime:()J
lstore 1
start local 1 1: aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._messagesOutStamp:Ljava/util/concurrent/atomic/AtomicLong;
lload 1
invokevirtual java.util.concurrent.atomic.AtomicLong.getAndSet:(J)J
lstore 3
start local 3 2: getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
lload 1
lload 3
lsub
invokevirtual java.util.concurrent.TimeUnit.toMillis:(J)J
lstore 5
start local 5 3: lload 5
lconst_0
lcmp
ifne 4
lconst_0
goto 5
StackMap locals: long long long
StackMap stack:
4: aload 0
invokevirtual org.eclipse.jetty.io.ConnectionStatistics.getSentMessages:()J
ldc 1000
lmul
lload 5
ldiv
StackMap locals:
StackMap stack: long
5: lreturn
end local 5 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
1 6 1 now J
2 6 3 then J
3 6 5 elapsed J
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "Total number of messages sent per second since the last invocation of this method")
public java.lang.String dump();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokestatic org.eclipse.jetty.util.component.Dumpable.dump:(Lorg/eclipse/jetty/util/component/Dumpable;)Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
public void dump(java.lang.Appendable, java.lang.String);
descriptor: (Ljava/lang/Appendable;Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=12, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
aload 2
aload 0
iconst_4
anewarray java.lang.Object
dup
iconst_0
1: ldc "connections=%s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._connections:Lorg/eclipse/jetty/util/statistic/CounterStatistic;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
aastore
dup
iconst_1
2: ldc "durations=%s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
getfield org.eclipse.jetty.io.ConnectionStatistics._connectionsDuration:Lorg/eclipse/jetty/util/statistic/SampleStatistic;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
aastore
dup
iconst_2
3: ldc "bytes in/out=%s/%s"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
invokevirtual org.eclipse.jetty.io.ConnectionStatistics.getReceivedBytes:()J
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
iconst_1
aload 0
invokevirtual org.eclipse.jetty.io.ConnectionStatistics.getSentBytes:()J
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
aastore
dup
iconst_3
4: ldc "messages in/out=%s/%s"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
invokevirtual org.eclipse.jetty.io.ConnectionStatistics.getReceivedMessages:()J
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
iconst_1
aload 0
invokevirtual org.eclipse.jetty.io.ConnectionStatistics.getSentMessages:()J
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
aastore
5: invokestatic org.eclipse.jetty.util.component.Dumpable.dumpObjects:(Ljava/lang/Appendable;Ljava/lang/String;Ljava/lang/Object;[Ljava/lang/Object;)V
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
0 7 1 out Ljava/lang/Appendable;
0 7 2 indent Ljava/lang/String;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
out
indent
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=1, args_size=1
start local 0 0: ldc "%s@%x"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.Class.getSimpleName:()Ljava/lang/String;
aastore
dup
iconst_1
aload 0
invokevirtual java.lang.Object.hashCode:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/io/ConnectionStatistics;
}
SourceFile: "ConnectionStatistics.java"
InnerClasses:
public abstract Listener = org.eclipse.jetty.io.Connection$Listener of org.eclipse.jetty.io.Connection
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedObject(value = "Tracks statistics on connections")