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

????24com/singularity/ee/service/analytics/writer/HttpSink0com/singularity/ee/service/analytics/writer/Sink
HttpSink.java/com/singularity/ee/util/clock/ClockUtils$IClock(com/singularity/ee/util/clock/ClockUtilsIClock3org/apache/http/client/config/RequestConfig$Builder +org/apache/http/client/config/RequestConfig
Builder+org/apache/http/config/SocketConfig$Builder#org/apache/http/config/SocketConfigLOGGER'Lcom/singularity/ee/agent/util/log4j/w;
PROTOCOL_HTTPLjava/lang/String;httpPROTOCOL_HTTPShttpsNANOS_PER_MILLISECONDIB@sinkParameters<Lcom/singularity/ee/service/analytics/writer/SinkParameters;
httpClient1Lorg/apache/http/impl/client/CloseableHttpClient;reusableHttpPost)Lorg/apache/http/client/methods/HttpPost;reusableClientContext3Lorg/apache/http/client/protocol/HttpClientContext;reusableJsonEntity@Lcom/singularity/ee/service/analytics/writer/ReusableJsonEntity;$assertionsDisabledZ<init>?(JLjava/util/concurrent/BlockingQueue;[Ljava/nio/ByteBuffer;Lcom/singularity/ee/service/analytics/common/Pool;Lcom/singularity/ee/service/analytics/writer/SinkParameters;)V?(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;)V:com/singularity/ee/service/analytics/writer/SinkParameters/"throughputCollectionIntervalMillis 1 02!throughputCollectionIntervalClockLcom/singularity/ee/util/o; 45 06?(JLjava/util/concurrent/BlockingQueue;[Ljava/nio/ByteBuffer;Lcom/singularity/ee/service/analytics/common/Pool;ILcom/singularity/ee/util/o;)V ,8
9 ! ;isAuthenticationRequired()Z =>
0?java/lang/StringBuilderA()V ,C
BD
serverUrlHttp F 0Gappend-(Ljava/lang/String;)Ljava/lang/StringBuilder; IJ
BK/M accountName O 0PtoString()Ljava/lang/String; RS
BT'org/apache/http/client/methods/HttpPostV(Ljava/lang/String;)V ,X
WY $% [X-Analytics-Agent-Access-Key] accessKey _ 0` addHeader'(Ljava/lang/String;Ljava/lang/String;)V bc
Wd"java/util/concurrent/BlockingQueuef[Ljava/nio/ByteBuffer;h0com/singularity/ee/service/analytics/common/Poolj1org/apache/http/client/protocol/HttpClientContextlcreate5()Lorg/apache/http/client/protocol/HttpClientContext; no
mp &' r>com/singularity/ee/service/analytics/writer/ReusableJsonEntitytK([Ljava/nio/ByteBuffer;Lcom/singularity/ee/service/analytics/common/Pool;)V ,v
uw () y setEntity(Lorg/apache/http/HttpEntity;)V {|
W}&org/apache/http/config/RegistryBuilder*()Lorg/apache/http/config/RegistryBuilder; n?
??java/lang/String?trim ?S
??java/util/Locale?USLjava/util/Locale; ?? ?? toLowerCase&(Ljava/util/Locale;)Ljava/lang/String; ??
??
startsWith(Ljava/lang/String;)Z ??
??3org/apache/http/conn/ssl/SSLConnectionSocketFactory?getSocketFactory7()Lorg/apache/http/conn/ssl/SSLConnectionSocketFactory; ??
??registerN(Ljava/lang/String;Ljava/lang/Object;)Lorg/apache/http/config/RegistryBuilder; ??
??8org/apache/http/conn/socket/PlainConnectionSocketFactory?<()Lorg/apache/http/conn/socket/PlainConnectionSocketFactory; ??
??"java/lang/IllegalArgumentException?<The specified scheme in the server URL [%s] is not supported?java/lang/Object?format9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; ??
??
?Y<org/apache/http/impl/conn/PoolingHttpClientConnectionManager?build#()Lorg/apache/http/config/Registry; ??
??$(Lorg/apache/http/config/Registry;)V ,?
?? setMaxTotal(I)V ??
??setDefaultMaxPerRoute ??
??custom7()Lorg/apache/http/client/config/RequestConfig$Builder; ??
?connectionTimeoutMillis ? 0?setSocketTimeout8(I)Lorg/apache/http/client/config/RequestConfig$Builder; ??
?setConnectTimeout ??
?/()Lorg/apache/http/client/config/RequestConfig; ??
?-org/apache/http/impl/client/HttpClientBuilder?1()Lorg/apache/http/impl/client/HttpClientBuilder; n?
??/()Lorg/apache/http/config/SocketConfig$Builder; ??
?setSoReuseAddress0(Z)Lorg/apache/http/config/SocketConfig$Builder; ??
?'()Lorg/apache/http/config/SocketConfig; ??
?setDefaultSocketConfigV(Lorg/apache/http/config/SocketConfig;)Lorg/apache/http/impl/client/HttpClientBuilder; ??
??setDefaultRequestConfig^(Lorg/apache/http/client/config/RequestConfig;)Lorg/apache/http/impl/client/HttpClientBuilder; ??
??setConnectionManagerc(Lorg/apache/http/conn/HttpClientConnectionManager;)Lorg/apache/http/impl/client/HttpClientBuilder; ??
??disableAutomaticRetries ??
??3()Lorg/apache/http/impl/client/CloseableHttpClient; ??
?? "# ?urlthis6Lcom/singularity/ee/service/analytics/writer/HttpSink;inputPollMillisJpendingWriteByteBuffers<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;registryBuilder_Lorg/apache/http/config/RegistryBuilder<Lorg/apache/http/conn/socket/ConnectionSocketFactory;>;(Lorg/apache/http/config/RegistryBuilder;normalizedServerUrlconnectionManager>Lorg/apache/http/impl/conn/PoolingHttpClientConnectionManager;
requestConfig-Lorg/apache/http/client/config/RequestConfig;resetabort 
C
W  C
W
clear(Z)V 
u
writeToOutput(Ljava/util/List;)J+(Ljava/util/List<[Ljava/nio/ByteBuffer;>;)Jjava/io/IOExceptionjava/lang/RuntimeExceptionjava/lang/InterruptedExceptionjava/lang/SystemnanoTime()J 
 sendAttemptMax " 0#doWrite %
&
latencyMillis(Lcom/singularity/ee/util/javaspecific/d; () *A.??&com/singularity/ee/util/javaspecific/d.a(D)V 01
/2computeThroughputAndReset 4C
5  71Error occurred while attempting to send data to [9]. Retry attempts remaining [;(I)Ljava/lang/StringBuilder; I=
B>]@%com/singularity/ee/agent/util/log4j/wBwarn*(Ljava/lang/String;Ljava/lang/Throwable;)V DE CFThread will pause for [HsendAttemptPauseMillis J? 0K(J)Ljava/lang/StringBuilder; IM
BN] millis before re-attemptingPinfo RX CSjava/lang/ThreadUsleep(J)V WX
VYjava/util/List[Thread was interrupted] DX C_
currentThread()Ljava/lang/Thread; ab
Vc interrupt eC
Vf *+ hjava/lang/AssertionErrorj
kD
writeResponseeLjava/lang/RuntimeException;ie Ljava/lang/InterruptedException; remainingLjava/io/IOException;attemptsources(Ljava/util/List<[Ljava/nio/ByteBuffer;>;Ljava/util/List; exceptionstartTimeNanossize()I z{ \|reuse(Ljava/util/List;)Z ~
u?????????/org/apache/http/impl/client/CloseableHttpClient?execute?(Lorg/apache/http/client/methods/HttpUriRequest;Lorg/apache/http/protocol/HttpContext;)Lorg/apache/http/client/methods/CloseableHttpResponse; ??
??4org/apache/http/client/methods/CloseableHttpResponse?
getStatusLine()Lorg/apache/http/StatusLine; ?? ??org/apache/http/StatusLine?
getStatusCode ?{ ??numSentMessagesLcom/singularity/ee/util/spi/d; ?? ?com/singularity/ee/util/spi/d? addAndGet(J)J ?? ??throughputMessageCount ? ?
consumeEntity9(Lorg/apache/http/client/methods/CloseableHttpResponse;)V ??
?readErrorEntityJ(Lorg/apache/http/client/methods/CloseableHttpResponse;)Ljava/lang/String; ??
?Remote server at [?] returned:
Status code: ?
Reason: ?getReasonPhrase ?S ?? ?
Y
numSendErrors ?? ?org/apache/commons/io/IOUtils? closeQuietly(Ljava/io/Closeable;)V ??
??java/lang/Throwable?entity
statusLineLorg/apache/http/StatusLine;statusbeforecurrentMessageCountresponse6Lorg/apache/http/client/methods/CloseableHttpResponse;success getEntity()Lorg/apache/http/HttpEntity; ?? ?? org/apache/http/util/EntityUtils?consume ?|
??org/apache/http/HttpEntity?DError occurred while closing HTTP connection after a successful send? RE C?responseEntityLorg/apache/http/HttpEntity;0com/singularity/ee/service/analytics/common/Util?
CHARSET_UTF_8Ljava/nio/charset/Charset; ?? ??J(Lorg/apache/http/HttpEntity;Ljava/nio/charset/Charset;)Ljava/lang/String; R?
??GError occurred while closing HTTP connection after an unsuccessful send?Unreadable entity?close

?C
??,Error occurred while closing HTTP connection?<clinit>java/lang/Class?desiredAssertionStatus ?>
??4com.singularity.ee.service.analytics.writer.HttpSink?%com/singularity/ee/agent/util/log4j/f?;(Ljava/lang/String;)Lcom/singularity/ee/agent/util/log4j/w; 0?
??
ConstantValueCode
StackMapTableLineNumberTableLocalVariableTableLocalVariableTypeTable Signature
Exceptions InnerClasses
SourceFile 
??? !"#$%&'()*+,-?? D*-?3?7?:*?<?@?B?BY?E?H?LN?L?Q?L?U:*?WY?Z?\*?\^?a?e?*?WY?H?Z?\*?q?s*?uY?x?z*?\*?z?~??:?H??????:???????W?1???????W???Y???YS???????Y????:  ?? ???????????:
*???????
?? ???????%?agik0?M????!9<=">C?P@^AaBqDxE?F?H?I?J?K?L?M?O?S?T?UVXZ[\^#_2`7a:b=cCd?p C?D??D??D??D?hD?D !?????I %
 D??D????. C?M*?\? *?\?*?z???ghij? ???+ ?M?!B6*?<?$??*+?'7*?+?!!e?,o?3*?6?:?:*?<?$d6M?8?BY?E:?L*?<?H?L<?L??A?L?U?G?N?8?BY?EI?L*?<?L?OQ?L?U?T*?<?L?Z?:?8^?`?d?g? ???7?i?,? ?kY?l?,?3439????2? jD?\???bnpqst-u1v4w6y9z;{G|J~????????????????q?????f
m?6no?pqG?r;?ns ?t????uw?xs?y? ?uv%??
.+?}=*?z+?????+?}>:6*??*?\*?s??:??:??6?=??*?????X*Y??`????6?W??:?Y?BY?E??L*?<?H?L??L??????L???L??L?L?U????*??
??X??*?\?*?z??-: ?*??
??X??*?\?*?z? ???#??R??M\?? ?SW??
\???\??~????? ?#?4?=?F?d?p?z?????????????????????????????+??\ ?M?=???F??.??.uw'?? ??# ?+ .uv
????*??L+??M?8?,??? ???? ??? ?????  ns????
???? *??L+???M?8?,??????????????  ns ?????C??#*??*???*????L?8?+?G? ?U ??? ????"?? ns#???C?A????i????8?? @?
+,