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?8com/singularity/ee/service/analytics/writer/WriterMaster?Ljava/lang/Object;Lcom/singularity/ee/service/analytics/common/Pool<[Ljava/nio/ByteBuffer;>;Lcom/singularity/ee/service/analytics/writer/WriterMasterMBean;java/lang/Object0com/singularity/ee/service/analytics/common/Pool=com/singularity/ee/service/analytics/writer/WriterMasterMBeanWriterMaster.javaASYNC_TASK_STOP_POISON_INPUT[Ljava/nio/ByteBuffer;NAME_WRITER_THREADLjava/lang/String;appdynamics-analytics-writerWRITER_MASTER_MBEAN_NAME,AppDynamics:type=Analytics,name=WriterMasterSINK_MBEAN_NAME_TEMPLATE'AppDynamics:type=Analytics,name=Sink-%sLOGGER'Lcom/singularity/ee/agent/util/log4j/w;
parameters>Lcom/singularity/ee/service/analytics/writer/WriterParameters;sinkParameters<Lcom/singularity/ee/service/analytics/writer/SinkParameters;pendingWriteByteBuffers)Ljava/util/concurrent/ArrayBlockingQueue;ALjava/util/concurrent/ArrayBlockingQueue<[Ljava/nio/ByteBuffer;>;sinkWriterThreadPoolLcom/singularity/ee/util/spi/j;tlsByteBufferList?Lcom/singularity/ee/service/analytics/writer/TlsByteBufferList;bufferSupplierAndPoolCLcom/singularity/ee/service/analytics/writer/BufferSupplierAndPool;sinksLjava/util/List;DLjava/util/List<Lcom/singularity/ee/service/analytics/writer/Sink;>;sinkWriterTaskRefsELjava/util/List<Lcom/singularity/ee/util/spi/IAgentScheduledFuture;>;<init>}(Lcom/singularity/ee/service/analytics/writer/WriterParameters;Lcom/singularity/ee/service/analytics/writer/SinkParameters;)V()V +-
.%com/singularity/ee/util/collections/f0d-()Ljava/util/concurrent/CopyOnWriteArrayList; 23
14 &' 6 )' 8  :  <'java/util/concurrent/ArrayBlockingQueue><com/singularity/ee/service/analytics/writer/WriterParameters@maxUnflushedInputsInQI BC AD(I)V +F
?G  Ijava/util/ArrayListK
LG0com/singularity/ee/util/javaspecific/scheduler/jN
O.(com/singularity/ee/agent/configuration/kQ5(Lcom/singularity/ee/util/javaspecific/scheduler/j;)V +S
RTgetNumOfSinkWriterTasks()I VW
AX  Zag(ILjava/lang/String;Ljava/util/List;Lcom/singularity/ee/util/logging/b;)Lcom/singularity/ee/util/spi/j; \]
R^ ! `Acom/singularity/ee/service/analytics/writer/BufferSupplierAndPoolbmaxPooledBuffers dC Ae
cG $% h=com/singularity/ee/service/analytics/writer/TlsByteBufferListj
k. "# mjava/lang/StringBuildero
p.$Initialized with writer parameters [rappend-(Ljava/lang/String;)Ljava/lang/StringBuilder; tu
pv-(Ljava/lang/Object;)Ljava/lang/StringBuilder; tx
py] and sink parameters [{]}toString()Ljava/lang/String; ?
p?%com/singularity/ee/agent/util/log4j/w?info(Ljava/lang/String;)V ?? ??this:Lcom/singularity/ee/service/analytics/writer/WriterMaster;agentThreadListenersRLjava/util/List<Lcom/singularity/ee/agent/configuration/spi/AgentThreadListener;>;agentExecutorFactoryELcom/singularity/ee/util/javaspecific/scheduler/AgentExecutorFactory;'agentSchedulerThreadPoolExecutorFactoryULcom/singularity/ee/agent/configuration/impl/AgentSchedulerThreadPoolExecutorFactory;
getParameters@()Lcom/singularity/ee/service/analytics/writer/WriterParameters;getNumPendingWriteItemssize ?W
??getNumByteBufferFreePool
c?getSinkWriterTaskRefs()Ljava/util/List;G()Ljava/util/List<Lcom/singularity/ee/util/spi/IAgentScheduledFuture;>;startjava/io/IOException?java/lang/Error?java/lang/Exception?java/util/List? ??Starting?inputPollMillisJ ?? A? ?newSink?(JLjava/util/concurrent/BlockingQueue;[Ljava/nio/ByteBuffer;Lcom/singularity/ee/service/analytics/common/Pool;Lcom/singularity/ee/service/analytics/writer/SinkParameters;)Lcom/singularity/ee/service/analytics/writer/Sink; ??
?:com/singularity/ee/service/analytics/writer/SinkWriterTask?:com/singularity/ee/service/analytics/writer/SinkParameters?getSendBatchMax ?W
??6(Lcom/singularity/ee/service/analytics/writer/Sink;I)V +?
??)com/singularity/ee/util/spi/AgentTimeUnit? MILLISECONDS+Lcom/singularity/ee/util/spi/AgentTimeUnit; ?? ??com/singularity/ee/util/spi/j?u(Lcom/singularity/ee/util/javaspecific/s;JLcom/singularity/ee/util/spi/AgentTimeUnit;)Lcom/singularity/ee/util/spi/i; \? ??add(Ljava/lang/Object;)Z ?? ??/(Ljava/util/Collection;Ljava/util/Collection;)V \?
1?&java/lang/management/ManagementFactory?getPlatformMBeanServer ()Ljavax/management/MBeanServer; ??
??javax/management/ObjectName? +?
??javax/management/MBeanServer?
registerMBeanR(Ljava/lang/Object;Ljavax/management/ObjectName;)Ljavax/management/ObjectInstance; ?? ??java/lang/Integer?valueOf(I)Ljava/lang/Integer; ??
??java/lang/String?format9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; ??
??get(I)Ljava/lang/Object; ?? ??&Error occurred while registering MBean?warn*(Ljava/lang/String;Ljava/lang/Throwable;)V ?? ??*Exception occurred while registering MBean?Started?sink2Lcom/singularity/ee/service/analytics/writer/Sink;writer<Lcom/singularity/ee/service/analytics/writer/SinkWriterTask;sinkWriterTaskRef3Lcom/singularity/ee/util/spi/IAgentScheduledFuture;imbsLjavax/management/MBeanServer;nameLjavax/management/ObjectName;eLjava/lang/Error;Ljava/lang/Exception;numOfSinkWriterTasks tempSinkstempSinkWriterTaskRefs
(JLjava/util/concurrent/BlockingQueue<[Ljava/nio/ByteBuffer;>;[Ljava/nio/ByteBuffer;Lcom/singularity/ee/service/analytics/common/Pool<[Ljava/nio/ByteBuffer;>;Lcom/singularity/ee/service/analytics/writer/SinkParameters;)Lcom/singularity/ee/service/analytics/writer/Sink;4com/singularity/ee/service/analytics/writer/HttpSink
?(JLjava/util/concurrent/BlockingQueue;[Ljava/nio/ByteBuffer;Lcom/singularity/ee/service/analytics/common/Pool;Lcom/singularity/ee/service/analytics/writer/SinkParameters;)V +
 
<Ljava/util/concurrent/BlockingQueue<[Ljava/nio/ByteBuffer;>;$Ljava/util/concurrent/BlockingQueue;asyncTaskStopPoisonInputpoolJLcom/singularity/ee/service/analytics/common/Pool<[Ljava/nio/ByteBuffer;>;2Lcom/singularity/ee/service/analytics/common/Pool;flush(Ljava/lang/StringBuilder;)Z)java/nio/charset/CharacterCodingExceptionlength W
p()Ljava/lang/Object; ?
k0com/singularity/ee/service/analytics/common/Util
utf8Encode?(Ljava/lang/StringBuilder;Ljava/util/ArrayList;Lcom/singularity/ee/service/analytics/common/Supplier;Lcom/singularity/ee/service/analytics/common/Pool;)[Ljava/nio/ByteBuffer; !"
 # java/nio/ByteBuffer& remaining (W
')maxMessageSizeBytes +C A,yMessage of size [%d] bytes was not placed on the Writer Master queue since it exceeded the max message size of [%d] bytes. ?? ?0resetAndReturn([Ljava/nio/ByteBuffer;)V 23
4trimDownStringBuilder(Ljava/lang/StringBuilder;)V 67
8 acceptInput([Ljava/nio/ByteBuffer;)Z :;
<java/lang/Throwable>
byteBufferLjava/nio/ByteBuffer;
totalBytessuccessZ byteBuffersbyteBuffersLengthsbLjava/lang/StringBuilder;discard(Ljava/nio/ByteBuffer;)V 2J
cKgetNumRunningSinkscom/singularity/ee/util/spi/iNb()Z PQ ORnumOfRunningSinksgetNumPendingMessagesgetBufferSizeBytesgetNumSentMessages()J0com/singularity/ee/service/analytics/writer/SinkY WX
Z[numOfSentMessagesgetNumSendErrors ^X
Z_numOfSendErrorsgetThroughputMsgsPerSec()D bc
ZdthroughputMsgsPerSecD
clearCounters h-
Zi com/singularity/ee/util/string/ek(Ljava/lang/StringBuilder;)I \m
lnmaxTlsCharBufferLength pC Aq(Ljava/lang/StringBuilder;I)V Ps
lt P7
lvoffer x?
?ydestroy(Z)VStopping}unregisterMBean (Ljavax/management/ObjectName;)V ? ??(Error occurred while unregistering MBean?stopAsyncChannelWriterTask ?|
?clear ?-
??
c?close ?-
Z?
Stopped but [?(I)Ljava/lang/StringBuilder; t?
p?5] messages could not be written out in the time given?Stopped?graceful
numOfSinksjava/lang/InterruptedException?%java/util/concurrent/TimeoutException?FQueue appears to be full. Special 'stop' message could not be enqueued??Waiting for background writer task to process enqueued messages??(J)Ljava/lang/Object; \? O?XBackground writer task has already exited as it appears to have encountered an exception?(Z)Z \? O? \- ??SECONDS ?? ??/(JLcom/singularity/ee/util/spi/AgentTimeUnit;)Z \? ??8Waiting for background task to complete their processing? com/singularity/ee/agent/util/b1? P-
??IStop routine was interrupted before the background task could be shutdown? Ljava/lang/InterruptedException;attempt asyncTask(Ljava/lang/Object;)V<clinit>8com.singularity.ee.service.analytics.writer.WriterMaster?%com/singularity/ee/agent/util/log4j/f?;(Ljava/lang/String;)Lcom/singularity/ee/agent/util/log4j/w; \?
??
ConstantValue SignatureCodeLineNumberTableLocalVariableTableLocalVariableTypeTable
StackMapTable
Exceptions
SourceFile!
 
???? !"#$%&'?()'?*+,?I?*?/*?5?7*?5?9*+?;*,?=*??Y+?E?H?J?LY?MN?OY?P:?RY?U:*+?Y-?[?_?a*?cY+?f?g?i*?kY?l?n?[?pY?qs?w+?z|?w,?z~?w??????BKD H ILMO+Q4R=SHULV[Yj[u\?^?>?????4k?'=b??HW??? 4k?????/*?;??a? ???W?2*?J????e? ???W?2*?i????i? ?????/*?9??m? ????!?-??$*?9?????[???*?;?Y<?LY?MM?LY?MN6?W**?;??*?J??**?=??:??Y*?=????:*?a ????:,??W-??W????*?7,??*?9-???:??Y??:*??W6?8??Y?Y??S???:*?7????W????":?[????:?[????[?????????? ??.
?&???Y?-???:B?P?
?~v w
z{?(?1?:?S?e?o?v????????????????????????????? ?
??#???
S5??e#??v??4Z?C?;?C?T??I? 
$??C(?'1?'?(?(1?*??????? Y-?????>???? ???? ?? ?+???+*?n??L*?i*?i?$M,??,?Y>??66?,2:?*`6????*?;?-6?5?[/?Y??SY??S??1*,?56*+?9?*,?=6?*,?56*+?9?*+?9?
:*+?9?? ?????????/ ?'p%??A?pG? ?v?? ?? ?+?.?7?=?G?M?V?]?k?w?????????????????????????????\ =
@A1?C.}BCVU+C?CD ?E (?FC????GH?I7?>*+?9??
?????GH23??=+??+2N*?i-?L+S????? ????? ?????* @A?C??E MW??<<*?9??=>?**?9???O:??S???????? ?%??"?? ??"?1?4?:?4"??,?C<??:TC 0?CUW?2*?J????? ??VW?.?? ? ??WX??: @*?7??>6?&*?7???Z:? ?\a@?????? ?"??" %*28?4%
??)?C:??8]? .?C^X??: @*?7??>6?&*?7???Z:? ?`a@?????? ?"??" " #$%%*&2#8*?4%
??)?C:??8a? .?Cbc??:H*?7??>6?&*?7???Z:? '?ecH????'?? ?"??"/1 23%4*52289?4%
??)?C:??8fg .?Ch-??.*?7??<=?*?7???ZN-?-?j????? ? ??>
?@A#B'?-E?*?? !?C.??
$?C67?p#+?o*?;?r?+*?;?r?u+?w+?u???OPQS"T?#??#GH:;?= *?J+?z??[? ?? E {|??[~??*?7??=??N??Y??:-??6?+??Y?Y??S???:-??????N?[?-??*??*?J??>*?J??*?i??6?#*?7???Z:????????(?[?pY?q??w????w??????[????]`??( ?/???-B? ??(
?fh ikl$m,o5pOqWo]u`satmxr{z|?}?????????????????f
/.?CD?$9a ?
???&?C?????D??Czl?C?|??*?9??=>??*?9???O:??m?`6
?V*?J???z??[????[??????W?%:? :?:?[???? ??????W???w*?a??*?a
??????[??????N???[?-???Ydg?Ydl?Ydq??????/? ?O?X?D?D????B??z?
?? ?%?(?,?6?C?N?Y?d?g?i?l?n?q?s??????????????????????????\ i?s/Z?C r?? ??C???????D
??CA2??3 *+?%?5??.?  ???-?-?'??¸?[??
/3??