Summary Table
Categories |
Total Count |
PII |
0 |
URL |
0 |
DNS |
0 |
EKL |
0 |
IP |
0 |
PORT |
0 |
VsID |
0 |
CF |
0 |
AI |
0 |
VPD |
0 |
PL |
0 |
Other |
0 |
File Content
???? 2 ? 0com/singularity/ee/service/analytics/writer/Sink java/lang/Object 5com/singularity/ee/service/analytics/writer/SinkMBean Sink.java /com/singularity/ee/util/clock/ClockUtils$IClock (com/singularity/ee/util/clock/ClockUtils
IClock FLAG_STOP_PROCESSING I???? !throughputCollectionIntervalClock Lcom/singularity/ee/util/o; "throughputCollectionIntervalMillis inputPollMillis J pendingWriteByteBuffers $Ljava/util/concurrent/BlockingQueue; <Ljava/util/concurrent/BlockingQueue<[Ljava/nio/ByteBuffer;>; asyncTaskStopPoisonInput [Ljava/nio/ByteBuffer; pool 2Lcom/singularity/ee/service/analytics/common/Pool; JLcom/singularity/ee/service/analytics/common/Pool<[Ljava/nio/ByteBuffer;>; numSentMessages Lcom/singularity/ee/util/spi/d;
numSendErrors
latencyMillis (Lcom/singularity/ee/util/javaspecific/d; throughputMsgsPerSec "lastThroughputCollectionTimeMillis throughputMessageCount <init> ?(JLjava/util/concurrent/BlockingQueue;[Ljava/nio/ByteBuffer;Lcom/singularity/ee/service/analytics/common/Pool;ILcom/singularity/ee/util/o;)V ?(JLjava/util/concurrent/BlockingQueue<[Ljava/nio/ByteBuffer;>;[Ljava/nio/ByteBuffer;Lcom/singularity/ee/service/analytics/common/Pool<[Ljava/nio/ByteBuffer;>;ILcom/singularity/ee/util/clock/ClockUtils$IClock;)V ()V % (