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*Mcom/singularity/ee/service/netviz/config/channel/NetVizActiveFlowGroupManagerjava/lang/ObjectIcom/singularity/ee/service/netviz/service/INetVizServiceLifeCycleListener!NetVizActiveFlowGroupManager.javalog'Lcom/singularity/ee/agent/util/log4j/w;&PROP_ACTIVE_FLOWGROUP_REFRESH_INTERVALLjava/lang/String;0netviz.active.flowgroup.refresh.interval.seconds 
netVizServiceCLcom/singularity/ee/service/netviz/service/INetVizCollectorService; netVizActiveFlowGroupRefreshTaskTLcom/singularity/ee/service/netviz/processing/jobs/NetVizActiveFlowGroupRefreshTask;&netVizActiveFlowGroupRefreshTaskFutureLcom/singularity/ee/util/spi/i;startedZsupportedControllerVersion#Lcom/singularity/ee/util/version/b;propertyReaderJLcom/singularity/ee/service/netviz/config/properties/NetVizPropertyReader;7PROP_ACTIVE_FLOWGROUPS_MIN_SUPPORTED_CONTROLLER_VERSION.netviz.activeflowgroups.min.controller.version"ACIVE_FLOWGROUP_TASK_INITIAL_DELAYIx-ACIVE_FLOWGROUP_TASK_DEFAULT_REFRESH_INTERVALQ?&ACIVE_FLOWGROUP_TASK_CANCELLATION_WAITactiveFlowGroupRefreshIntervalactiveFlowGroupIds"Lcom/singularity/ee/agent/util/cm;bLcom/singularity/ee/agent/util/bounded/collections/BoundedConcurrentLinkedQueue<Ljava/lang/Long;>;<init>U(Lcom/singularity/ee/service/netviz/service/INetVizCollectorService;Ljava/util/Map;)V{(Lcom/singularity/ee/service/netviz/service/INetVizCollectorService;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)V()V (+
,  .Acom/singularity/ee/service/netviz/service/INetVizCollectorService0getNetVizPropertyReaderL()Lcom/singularity/ee/service/netviz/config/properties/NetVizPropertyReader; 23 14  6 com/singularity/ee/agent/util/cm8getFlowGroupRegistryG()Lcom/singularity/ee/service/netviz/metadata/INetVizFlowGroupRegistry; :; 1<Ccom/singularity/ee/service/netviz/metadata/INetVizFlowGroupRegistry>getMaxFlowGroupCount()I @A ?B8com/singularity/ee/util/collections/bounded/BoundsPolicyDEXCEPTION_IF_BOUND_EXCEEDED:Lcom/singularity/ee/util/collections/bounded/BoundsPolicy; FG EHjava/lang/ClassJ
getSimpleName()Ljava/lang/String; LM
KNactive-flowgroups-limitPb(ILcom/singularity/ee/util/collections/bounded/BoundsPolicy;Ljava/lang/String;Ljava/lang/String;)V (R
9S %& U
setProperties(Ljava/util/Map;)V WX
YRcom/singularity/ee/service/netviz/processing/jobs/NetVizActiveFlowGroupRefreshTask[?(Lcom/singularity/ee/service/netviz/config/channel/NetVizActiveFlowGroupManager;Lcom/singularity/ee/service/netviz/metadata/INetVizFlowGroupRegistry;)V (]
\^  `"scheduleActiveFlowGroupRefreshTask b+
c  e,NetViz: Initialized active flowgroup managerg%com/singularity/ee/agent/util/log4j/wiinfo(Ljava/lang/String;)V kl jmthisOLcom/singularity/ee/service/netviz/config/channel/NetVizActiveFlowGroupManager;serviceProperties5Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Ljava/util/Map;drainActiveFlowGroups()Ljava/util/Collection;*()Ljava/util/Collection<Ljava/lang/Long;>;java/util/HashSetw
x,a(Ljava/util/Collection;)V z{
9|activeFlowGroupIdsToController(Ljava/util/Collection<Ljava/lang/Long;>;Ljava/util/Collection;updateActiveFlowGroupIds+(Ljava/util/Collection<Ljava/lang/Long;>;)Vjava/lang/RuntimeException?addAll(Ljava/util/Collection;)Z ??
9?<Failed to add active flowgroupIds={0} with error message={1}?toString ?M
?
getMessage ?M
??java/text/MessageFormat?format9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; ??
??warn ?l j?eLjava/lang/RuntimeException;#getNetVizActiveFlowGroupRefreshTaskV()Lcom/singularity/ee/service/netviz/processing/jobs/NetVizActiveFlowGroupRefreshTask;getAgentServiceContext2()Lcom/singularity/ee/agent/appagent/kernel/spi/H; ?? 1?.com/singularity/ee/agent/appagent/kernel/spi/H?b!()Lcom/singularity/ee/util/spi/h; ?? ??x $ ?)com/singularity/ee/util/spi/AgentTimeUnit?SECONDS+Lcom/singularity/ee/util/spi/AgentTimeUnit; ?? ??com/singularity/ee/util/spi/h?v(Lcom/singularity/ee/util/javaspecific/s;JJLcom/singularity/ee/util/spi/AgentTimeUnit;)Lcom/singularity/ee/util/spi/i; ?? ??  ?  ?java/lang/StringBuilder?
?,9NetVizActiveFlowGroupRefreshTask scheduled to run every [?append-(Ljava/lang/String;)Ljava/lang/StringBuilder; ??
??(I)Ljava/lang/StringBuilder; ??
?? ] seconds?
??8(Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)VHcom/singularity/ee/service/netviz/config/properties/NetVizPropertyReader? readProperty5(Ljava/lang/String;Ljava/util/Map;)Ljava/lang/String; ??
??setSupportedControllerVersion ?l
? com/singularity/ee/util/string/e?(Ljava/lang/String;I)I z?
??getSupportedControllerVersion%()Lcom/singularity/ee/util/version/b;  ?getConfigChannelF()Lcom/singularity/ee/agent/appagent/kernel/spi/IConfigurationChannel; ?? 1?Bcom/singularity/ee/agent/appagent/kernel/spi/IConfigurationChannel?getControllerVersion ?? ??!com/singularity/ee/util/version/b?'(Ljava/lang/String;Ljava/lang/String;)V (?
??Bcom/singularity/ee/service/netviz/constants/NetVizVersionConstants?GA_VERSION_4_4_0 ? ??&(Lcom/singularity/ee/util/version/b;)Z z?
??
VERSION_4_5_0 ? ???NetViz: Incorrect supported controller version={0}. Version should be in format 'd-d-d' and set to correct value. Using default version={1}?
??RNetViz: Active flowgroup ids enabled state={0} with current controller version={1}?supportsControllerVersion ?? 1?java/lang/Boolean?valueOf(Z)Ljava/lang/Boolean; 
?supportedVersioncurrentControllerVersion3Lcom/singularity/ee/util/version/ControllerVersion;stopcom/singularity/ee/util/spi/i(I)Z z
  (NetViz: stopped active flowgroup manager
start(NetViz: started active flowgroup managerrestart +
 X
<clinit>2com/singularity/ee/service/netviz/logging/LogUtils LOG_CONTEXT  %com/singularity/ee/agent/util/log4j/f;(Ljava/lang/String;)Lcom/singularity/ee/agent/util/log4j/w; z
 
ConstantValue SignatureCodeLineNumberTableLocalVariableTableLocalVariableTypeTable
StackMapTable
SourceFile! 
"
 "" "!""#J$%&#' ()$?_*?-*+?/*+?5?7*?9Y*?/?=?C?I?OQ?T?V*,?Z*?\Y**?/?=?_?a*?d?fh?n?%. ?@ ABC+E6H;IPJTK^L& _op__qs' _qr#*tu$`?xY?yL*?V+?}+?%OPQ&op
~?' 
~#v?{$?-*?V+??W?#M?f??Y+??SY,??S????? ?(L?%"V ] W
XZ [$X,^& 
??-op-%?' -%#???$/*?a?%a& opb+$?M**?/????*?a??????????*???f??Y????ò????ö?n?%ef%h*iLk& MopWX$w!**?7+???*?7
+??!????%nopo s&!op!qs' !qr#???$/*??%v& op?l$?{*?/????M*??Y+???*????)*????f??Y+SY*???S?????f??Y*?/*????SY,??S???n?(?O?%2 z{~)0?C?G?O?b?n?r?z?& {op{ l+$R*??? W*???f?n?%? ???& opX${*???*+?Z*?d?f?n?(%?? ???&opqs' qr#?X$X
*?*+??%?? ?&
op
qs' 
qr#?+$@$??Y??????O?ö?!?f!???%
*<)