test_class.declarator: logger = Logger.getLogger(PushAgentTest.class.getCanonicalName())
test_class.modifier: protected static final
test_class.original_string: protected static final Logger logger = Logger.getLogger(PushAgentTest.class.getCanonicalName());
test_class.type: Logger
test_class.var_name: logger
test_class.declarator: proxy
test_class.modifier: private
test_class.original_string: private PushAgent proxy;
test_class.type: PushAgent
test_class.var_name: proxy
test_class.declarator: startTime = System.currentTimeMillis() / 1000 / 60 * 60
test_class.modifier: private
test_class.original_string: private long startTime = System.currentTimeMillis() / 1000 / 60 * 60;
test_class.type: long
test_class.var_name: startTime
test_class.declarator: port
test_class.modifier: private
test_class.original_string: private int port;
test_class.type: int
test_class.var_name: port
test_class.declarator: tracePort
test_class.modifier: private
test_class.original_string: private int tracePort;
test_class.type: int
test_class.var_name: tracePort
test_class.declarator: customTracePort
test_class.modifier: private
test_class.original_string: private int customTracePort;
test_class.type: int
test_class.var_name: customTracePort
test_class.declarator: ddPort
test_class.modifier: private
test_class.original_string: private int ddPort;
test_class.type: int
test_class.var_name: ddPort
test_class.declarator: deltaPort
test_class.modifier: private
test_class.original_string: private int deltaPort;
test_class.type: int
test_class.var_name: deltaPort
test_class.declarator: sslSocketFactory
test_class.modifier: private static
test_class.original_string: private static SSLSocketFactory sslSocketFactory;
test_class.type: SSLSocketFactory
test_class.var_name: sslSocketFactory
test_class.declarator: mockPointHandler =
        MockReportableEntityHandlerFactory.getMockReportPointHandler()
test_class.modifier: private
test_class.original_string: private ReportableEntityHandler<ReportPoint, String> mockPointHandler =
        MockReportableEntityHandlerFactory.getMockReportPointHandler();
test_class.type: ReportableEntityHandler<ReportPoint, String>
test_class.var_name: mockPointHandler
test_class.declarator: mockSourceTagHandler =
        MockReportableEntityHandlerFactory.getMockSourceTagHandler()
test_class.modifier: private
test_class.original_string: private ReportableEntityHandler<ReportSourceTag, SourceTag> mockSourceTagHandler =
        MockReportableEntityHandlerFactory.getMockSourceTagHandler();
test_class.type: ReportableEntityHandler<ReportSourceTag, SourceTag>
test_class.var_name: mockSourceTagHandler
test_class.declarator: mockHistogramHandler =
        MockReportableEntityHandlerFactory.getMockHistogramHandler()
test_class.modifier: private
test_class.original_string: private ReportableEntityHandler<ReportPoint, String> mockHistogramHandler =
        MockReportableEntityHandlerFactory.getMockHistogramHandler();
test_class.type: ReportableEntityHandler<ReportPoint, String>
test_class.var_name: mockHistogramHandler
test_class.declarator: mockTraceHandler =
        MockReportableEntityHandlerFactory.getMockTraceHandler()
test_class.modifier: private
test_class.original_string: private ReportableEntityHandler<Span, String> mockTraceHandler =
        MockReportableEntityHandlerFactory.getMockTraceHandler();
test_class.type: ReportableEntityHandler<Span, String>
test_class.var_name: mockTraceHandler
test_class.declarator: mockTraceSpanLogsHandler =
        MockReportableEntityHandlerFactory.getMockTraceSpanLogsHandler()
test_class.modifier: private
test_class.original_string: private ReportableEntityHandler<SpanLogs, String> mockTraceSpanLogsHandler =
        MockReportableEntityHandlerFactory.getMockTraceSpanLogsHandler();
test_class.type: ReportableEntityHandler<SpanLogs, String>
test_class.var_name: mockTraceSpanLogsHandler
test_class.declarator: mockEventHandler =
        MockReportableEntityHandlerFactory.getMockEventHandlerImpl()
test_class.modifier: private
test_class.original_string: private ReportableEntityHandler<ReportEvent, Event> mockEventHandler =
        MockReportableEntityHandlerFactory.getMockEventHandlerImpl();
test_class.type: ReportableEntityHandler<ReportEvent, Event>
test_class.var_name: mockEventHandler
test_class.declarator: mockWavefrontSender = EasyMock.createMock(WavefrontSender.class)
test_class.modifier: private
test_class.original_string: private WavefrontSender mockWavefrontSender = EasyMock.createMock(WavefrontSender.class);
test_class.type: WavefrontSender
test_class.var_name: mockWavefrontSender
test_class.declarator: mockSenderTask = EasyMock.createNiceMock(SenderTask.class)
test_class.modifier: private
test_class.original_string: private SenderTask<String> mockSenderTask = EasyMock.createNiceMock(SenderTask.class);
test_class.type: SenderTask<String>
test_class.var_name: mockSenderTask
test_class.declarator: mockSenderTasks = ImmutableList.of(mockSenderTask)
test_class.modifier: private
test_class.original_string: private Collection<SenderTask<String>> mockSenderTasks = ImmutableList.of(mockSenderTask);
test_class.type: Collection<SenderTask<String>>
test_class.var_name: mockSenderTasks
test_class.declarator: PREPROCESSED_APPLICATION_TAG_VALUE = "preprocessedApplication"
test_class.modifier: private final
test_class.original_string: private final String PREPROCESSED_APPLICATION_TAG_VALUE = "preprocessedApplication";
test_class.type: String
test_class.var_name: PREPROCESSED_APPLICATION_TAG_VALUE
test_class.declarator: PREPROCESSED_SERVICE_TAG_VALUE = "preprocessedService"
test_class.modifier: private final
test_class.original_string: private final String PREPROCESSED_SERVICE_TAG_VALUE = "preprocessedService";
test_class.type: String
test_class.var_name: PREPROCESSED_SERVICE_TAG_VALUE
test_class.declarator: PREPROCESSED_CLUSTER_TAG_VALUE = "preprocessedCluster"
test_class.modifier: private final
test_class.original_string: private final String PREPROCESSED_CLUSTER_TAG_VALUE = "preprocessedCluster";
test_class.type: String
test_class.var_name: PREPROCESSED_CLUSTER_TAG_VALUE
test_class.declarator: PREPROCESSED_SHARD_TAG_VALUE = "preprocessedShard"
test_class.modifier: private final
test_class.original_string: private final String PREPROCESSED_SHARD_TAG_VALUE = "preprocessedShard";
test_class.type: String
test_class.var_name: PREPROCESSED_SHARD_TAG_VALUE
test_class.declarator: PREPROCESSED_SOURCE_VALUE = "preprocessedSource"
test_class.modifier: private final
test_class.original_string: private final String PREPROCESSED_SOURCE_VALUE = "preprocessedSource";
test_class.type: String
test_class.var_name: PREPROCESSED_SOURCE_VALUE
test_class.declarator: mockSenderTaskFactory = new SenderTaskFactory() {
      @SuppressWarnings("unchecked")
      @Override
      public Collection<SenderTask<String>> createSenderTasks(@Nonnull HandlerKey handlerKey) {
        return mockSenderTasks;
      }
  
      @Override
      public void shutdown() {
      }
  
      @Override
      public void shutdown(@Nonnull String handle) {
      }
  
      @Override
      public void drainBuffersToQueue(QueueingReason reason) {
      }
    }
test_class.modifier: private
test_class.original_string: private SenderTaskFactory mockSenderTaskFactory = new SenderTaskFactory() {
      @SuppressWarnings("unchecked")
      @Override
      public Collection<SenderTask<String>> createSenderTasks(@Nonnull HandlerKey handlerKey) {
        return mockSenderTasks;
      }
  
      @Override
      public void shutdown() {
      }
  
      @Override
      public void shutdown(@Nonnull String handle) {
      }
  
      @Override
      public void drainBuffersToQueue(QueueingReason reason) {
      }
    };
test_class.type: SenderTaskFactory
test_class.var_name: mockSenderTaskFactory
test_class.declarator: mockHandlerFactory =
        MockReportableEntityHandlerFactory.createMockHandlerFactory(mockPointHandler,
            mockSourceTagHandler, mockHistogramHandler, mockTraceHandler,
            mockTraceSpanLogsHandler, mockEventHandler)
test_class.modifier: private
test_class.original_string: private ReportableEntityHandlerFactory mockHandlerFactory =
        MockReportableEntityHandlerFactory.createMockHandlerFactory(mockPointHandler,
            mockSourceTagHandler, mockHistogramHandler, mockTraceHandler,
            mockTraceSpanLogsHandler, mockEventHandler);
test_class.type: ReportableEntityHandlerFactory
test_class.var_name: mockHandlerFactory
test_class.declarator: mockHttpClient = EasyMock.createMock(HttpClient.class)
test_class.modifier: private
test_class.original_string: private HttpClient mockHttpClient = EasyMock.createMock(HttpClient.class);
test_class.type: HttpClient
test_class.var_name: mockHttpClient
test_class.file: proxy/src/test/java/com/wavefront/agent/PushAgentTest.java
test_class.identifier: PushAgentTest
test_case.body: @Test
    public void testWavefrontUnifiedPortHandlerPlaintextUncompressed() throws Exception {
      port = findAvailablePort(2888);
      int securePort = findAvailablePort(2889);
      proxy.proxyConfig.privateCertPath = getClass().getClassLoader().getResource("demo.cert").getPath();
      proxy.proxyConfig.privateKeyPath = getClass().getClassLoader().getResource("demo.key").getPath();
      proxy.proxyConfig.tlsPorts = "1,23 , 4,   , " + securePort +"  ,6";
      proxy.initSslContext();
      proxy.proxyConfig.pushListenerPorts = port + "," + securePort;
      SpanSampler sampler = new SpanSampler(new RateSampler(1.0D),
          proxy.proxyConfig.isTraceAlwaysSampleErrors());
      proxy.startGraphiteListener(String.valueOf(port), mockHandlerFactory, null, sampler);
      proxy.startGraphiteListener(String.valueOf(securePort), mockHandlerFactory, null, sampler);
      waitUntilListenerIsOnline(port);
      waitUntilListenerIsOnline(securePort);
      reset(mockPointHandler);
      mockPointHandler.report(ReportPoint.newBuilder().setTable("dummy").
          setMetric("metric.test").setHost("test1").setTimestamp(startTime * 1000).setValue(0.0d).build());
      expectLastCall();
      mockPointHandler.report(ReportPoint.newBuilder().setTable("dummy").
          setMetric("metric.test").setHost("test2").setTimestamp((startTime + 1) * 1000).setValue(1.0d).build());
      expectLastCall();
      replay(mockPointHandler);
  
      // try plaintext over tcp first
      Socket socket = SocketFactory.getDefault().createSocket("localhost", port);
      BufferedOutputStream stream = new BufferedOutputStream(socket.getOutputStream());
      String payloadStr = "metric.test 0 " + startTime + " source=test1\n" +
          "metric.test 1 " + (startTime + 1) + " source=test2\n";
      stream.write(payloadStr.getBytes());
      stream.flush();
      socket.close();
      verifyWithTimeout(500, mockPointHandler);
  
      reset(mockPointHandler);
      mockPointHandler.report(ReportPoint.newBuilder().setTable("dummy").
              setMetric("metric.test").setHost("test3").setTimestamp(startTime * 1000).setValue(0.0d).build());
      expectLastCall();
      mockPointHandler.report(ReportPoint.newBuilder().setTable("dummy").
              setMetric("metric.test").setHost("test4").setTimestamp((startTime + 1) * 1000).setValue(1.0d).build());
      expectLastCall();
      replay(mockPointHandler);
  
      // secure test
      socket = sslSocketFactory.createSocket("localhost", securePort);
      stream = new BufferedOutputStream(socket.getOutputStream());
      payloadStr = "metric.test 0 " + startTime + " source=test3\n" +
              "metric.test 1 " + (startTime + 1) + " source=test4\n";
      stream.write(payloadStr.getBytes());
      stream.flush();
      socket.close();
      verifyWithTimeout(500, mockPointHandler);
    }
test_case.class_method_signature: PushAgentTest.testWavefrontUnifiedPortHandlerPlaintextUncompressed()
test_case.full_signature: @Test public void testWavefrontUnifiedPortHandlerPlaintextUncompressed()
test_case.identifier: testWavefrontUnifiedPortHandlerPlaintextUncompressed
test_case.invocations: findAvailablePort findAvailablePort getPath getResource getClassLoader getClass getPath getResource getClassLoader getClass initSslContext isTraceAlwaysSampleErrors startGraphiteListener valueOf startGraphiteListener valueOf waitUntilListenerIsOnline waitUntilListenerIsOnline reset report build setValue setTimestamp setHost setMetric setTable newBuilder expectLastCall report build setValue setTimestamp setHost setMetric setTable newBuilder expectLastCall replay createSocket getDefault getOutputStream write getBytes flush close verifyWithTimeout reset report build setValue setTimestamp setHost setMetric setTable newBuilder expectLastCall report build setValue setTimestamp setHost setMetric setTable newBuilder expectLastCall replay createSocket getOutputStream write getBytes flush close verifyWithTimeout
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testWavefrontUnifiedPortHandlerPlaintextUncompressed()
focal_class.declarator: listeners = new HashMap<>()
focal_class.modifier: protected final
focal_class.original_string: protected final Map<Integer, Thread> listeners = new HashMap<>();
focal_class.type: Map<Integer, Thread>
focal_class.var_name: listeners
focal_class.declarator: childChannelOptions =
        new IdentityHashMap<>()
focal_class.modifier: protected final
focal_class.original_string: protected final IdentityHashMap<ChannelOption<?>, Object> childChannelOptions =
        new IdentityHashMap<>();
focal_class.type: IdentityHashMap<ChannelOption<?>, Object>
focal_class.var_name: childChannelOptions
focal_class.declarator: histogramExecutor
focal_class.modifier: protected
focal_class.original_string: protected ScheduledExecutorService histogramExecutor;
focal_class.type: ScheduledExecutorService
focal_class.var_name: histogramExecutor
focal_class.declarator: histogramFlushExecutor
focal_class.modifier: protected
focal_class.original_string: protected ScheduledExecutorService histogramFlushExecutor;
focal_class.type: ScheduledExecutorService
focal_class.var_name: histogramFlushExecutor
focal_class.declarator: histogramFlushRunnables = new ArrayList<>()
focal_class.modifier: @VisibleForTesting
    protected
focal_class.original_string: @VisibleForTesting
    protected List<Runnable> histogramFlushRunnables = new ArrayList<>();
focal_class.type: List<Runnable>
focal_class.var_name: histogramFlushRunnables
focal_class.declarator: bindErrors = Metrics.newCounter(
        ExpectedAgentMetric.LISTENERS_BIND_ERRORS.metricName)
focal_class.modifier: protected final
focal_class.original_string: protected final Counter bindErrors = Metrics.newCounter(
        ExpectedAgentMetric.LISTENERS_BIND_ERRORS.metricName);
focal_class.type: Counter
focal_class.var_name: bindErrors
focal_class.declarator: taskQueueFactory
focal_class.modifier: protected
focal_class.original_string: protected TaskQueueFactory taskQueueFactory;
focal_class.type: TaskQueueFactory
focal_class.var_name: taskQueueFactory
focal_class.declarator: remoteHostAnnotator
focal_class.modifier: protected
focal_class.original_string: protected SharedGraphiteHostAnnotator remoteHostAnnotator;
focal_class.type: SharedGraphiteHostAnnotator
focal_class.var_name: remoteHostAnnotator
focal_class.declarator: hostnameResolver
focal_class.modifier: protected
focal_class.original_string: protected Function<InetAddress, String> hostnameResolver;
focal_class.type: Function<InetAddress, String>
focal_class.var_name: hostnameResolver
focal_class.declarator: senderTaskFactory
focal_class.modifier: protected
focal_class.original_string: protected SenderTaskFactoryImpl senderTaskFactory;
focal_class.type: SenderTaskFactoryImpl
focal_class.var_name: senderTaskFactory
focal_class.declarator: queueingFactory
focal_class.modifier: protected
focal_class.original_string: protected QueueingFactory queueingFactory;
focal_class.type: QueueingFactory
focal_class.var_name: queueingFactory
focal_class.declarator: histogramRecompressor = null
focal_class.modifier: protected
focal_class.original_string: protected Function<Histogram, Histogram> histogramRecompressor = null;
focal_class.type: Function<Histogram, Histogram>
focal_class.var_name: histogramRecompressor
focal_class.declarator: handlerFactory
focal_class.modifier: protected
focal_class.original_string: protected ReportableEntityHandlerFactoryImpl handlerFactory;
focal_class.type: ReportableEntityHandlerFactoryImpl
focal_class.var_name: handlerFactory
focal_class.declarator: deltaCounterHandlerFactory
focal_class.modifier: protected
focal_class.original_string: protected ReportableEntityHandlerFactory deltaCounterHandlerFactory;
focal_class.type: ReportableEntityHandlerFactory
focal_class.var_name: deltaCounterHandlerFactory
focal_class.declarator: healthCheckManager
focal_class.modifier: protected
focal_class.original_string: protected HealthCheckManager healthCheckManager;
focal_class.type: HealthCheckManager
focal_class.var_name: healthCheckManager
focal_class.declarator: tokenAuthenticator = TokenAuthenticator.DUMMY_AUTHENTICATOR
focal_class.modifier: protected
focal_class.original_string: protected TokenAuthenticator tokenAuthenticator = TokenAuthenticator.DUMMY_AUTHENTICATOR;
focal_class.type: TokenAuthenticator
focal_class.var_name: tokenAuthenticator
focal_class.declarator: decoderSupplier = lazySupplier(() ->
        ImmutableMap.<ReportableEntityType, ReportableEntityDecoder<?, ?>>builder().
            put(ReportableEntityType.POINT, new ReportPointDecoder(() -> "unknown",
                proxyConfig.getCustomSourceTags())).
            put(ReportableEntityType.SOURCE_TAG, new ReportSourceTagDecoder()).
            put(ReportableEntityType.HISTOGRAM, new ReportPointDecoderWrapper(
                new HistogramDecoder("unknown"))).
            put(ReportableEntityType.TRACE, new SpanDecoder("unknown")).
            put(ReportableEntityType.TRACE_SPAN_LOGS, new SpanLogsDecoder()).
            put(ReportableEntityType.EVENT, new EventDecoder()).build())
focal_class.modifier: protected final
focal_class.original_string: protected final Supplier<Map<ReportableEntityType, ReportableEntityDecoder<?, ?>>>
        decoderSupplier = lazySupplier(() ->
        ImmutableMap.<ReportableEntityType, ReportableEntityDecoder<?, ?>>builder().
            put(ReportableEntityType.POINT, new ReportPointDecoder(() -> "unknown",
                proxyConfig.getCustomSourceTags())).
            put(ReportableEntityType.SOURCE_TAG, new ReportSourceTagDecoder()).
            put(ReportableEntityType.HISTOGRAM, new ReportPointDecoderWrapper(
                new HistogramDecoder("unknown"))).
            put(ReportableEntityType.TRACE, new SpanDecoder("unknown")).
            put(ReportableEntityType.TRACE_SPAN_LOGS, new SpanLogsDecoder()).
            put(ReportableEntityType.EVENT, new EventDecoder()).build());
focal_class.type: Supplier<Map<ReportableEntityType, ReportableEntityDecoder<?, ?>>>
focal_class.var_name: decoderSupplier
focal_class.declarator: rateSampler = new RateSampler(1.0d)
focal_class.modifier: protected final
focal_class.original_string: protected final RateSampler rateSampler = new RateSampler(1.0d);
focal_class.type: RateSampler
focal_class.var_name: rateSampler
focal_class.declarator: blockedPointsLogger
focal_class.modifier: private
focal_class.original_string: private Logger blockedPointsLogger;
focal_class.type: Logger
focal_class.var_name: blockedPointsLogger
focal_class.declarator: blockedHistogramsLogger
focal_class.modifier: private
focal_class.original_string: private Logger blockedHistogramsLogger;
focal_class.type: Logger
focal_class.var_name: blockedHistogramsLogger
focal_class.declarator: blockedSpansLogger
focal_class.modifier: private
focal_class.original_string: private Logger blockedSpansLogger;
focal_class.type: Logger
focal_class.var_name: blockedSpansLogger
focal_class.file: proxy/src/main/java/com/wavefront/agent/PushAgent.java
focal_class.identifier: PushAgent
focal_class.class_method_signature: PushAgent.main(String[] args)
focal_class.full_signature: public static void main(String[] args)
focal_class.identifier: main
focal_class.modifiers: public static
focal_class.parameters: (String[] args)
focal_class.return: void
focal_class.signature: void main(String[] args)
focal_class.class_method_signature: PushAgent.setupMemoryGuard()
focal_class.full_signature: protected void setupMemoryGuard()
focal_class.identifier: setupMemoryGuard
focal_class.modifiers: protected
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void setupMemoryGuard()
focal_class.class_method_signature: PushAgent.startListeners()
focal_class.full_signature: @Override protected void startListeners()
focal_class.identifier: startListeners
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void startListeners()
focal_class.class_method_signature: PushAgent.getSslContext(String port)
focal_class.full_signature: @Nullable protected SslContext getSslContext(String port)
focal_class.identifier: getSslContext
focal_class.modifiers: @Nullable protected
focal_class.parameters: (String port)
focal_class.return: SslContext
focal_class.signature: SslContext getSslContext(String port)
focal_class.class_method_signature: PushAgent.getCorsConfig(String port)
focal_class.full_signature: @Nullable protected CorsConfig getCorsConfig(String port)
focal_class.identifier: getCorsConfig
focal_class.modifiers: @Nullable protected
focal_class.parameters: (String port)
focal_class.return: CorsConfig
focal_class.signature: CorsConfig getCorsConfig(String port)
focal_class.class_method_signature: PushAgent.startJsonListener(String strPort, ReportableEntityHandlerFactory handlerFactory)
focal_class.full_signature: protected void startJsonListener(String strPort, ReportableEntityHandlerFactory handlerFactory)
focal_class.identifier: startJsonListener
focal_class.modifiers: protected
focal_class.parameters: (String strPort, ReportableEntityHandlerFactory handlerFactory)
focal_class.return: void
focal_class.signature: void startJsonListener(String strPort, ReportableEntityHandlerFactory handlerFactory)
focal_class.class_method_signature: PushAgent.startWriteHttpJsonListener(String strPort,
                                              ReportableEntityHandlerFactory handlerFactory)
focal_class.full_signature: protected void startWriteHttpJsonListener(String strPort,
                                              ReportableEntityHandlerFactory handlerFactory)
focal_class.identifier: startWriteHttpJsonListener
focal_class.modifiers: protected
focal_class.parameters: (String strPort,
                                              ReportableEntityHandlerFactory handlerFactory)
focal_class.return: void
focal_class.signature: void startWriteHttpJsonListener(String strPort,
                                              ReportableEntityHandlerFactory handlerFactory)
focal_class.class_method_signature: PushAgent.startOpenTsdbListener(final String strPort,
                                         ReportableEntityHandlerFactory handlerFactory)
focal_class.full_signature: protected void startOpenTsdbListener(final String strPort,
                                         ReportableEntityHandlerFactory handlerFactory)
focal_class.identifier: startOpenTsdbListener
focal_class.modifiers: protected
focal_class.parameters: (final String strPort,
                                         ReportableEntityHandlerFactory handlerFactory)
focal_class.return: void
focal_class.signature: void startOpenTsdbListener(final String strPort,
                                         ReportableEntityHandlerFactory handlerFactory)
focal_class.class_method_signature: PushAgent.startDataDogListener(final String strPort,
                                        ReportableEntityHandlerFactory handlerFactory,
                                        HttpClient httpClient)
focal_class.full_signature: protected void startDataDogListener(final String strPort,
                                        ReportableEntityHandlerFactory handlerFactory,
                                        HttpClient httpClient)
focal_class.identifier: startDataDogListener
focal_class.modifiers: protected
focal_class.parameters: (final String strPort,
                                        ReportableEntityHandlerFactory handlerFactory,
                                        HttpClient httpClient)
focal_class.return: void
focal_class.signature: void startDataDogListener(final String strPort,
                                        ReportableEntityHandlerFactory handlerFactory,
                                        HttpClient httpClient)
focal_class.class_method_signature: PushAgent.startPickleListener(String strPort,
                                       ReportableEntityHandlerFactory handlerFactory,
                                       GraphiteFormatter formatter)
focal_class.full_signature: protected void startPickleListener(String strPort,
                                       ReportableEntityHandlerFactory handlerFactory,
                                       GraphiteFormatter formatter)
focal_class.identifier: startPickleListener
focal_class.modifiers: protected
focal_class.parameters: (String strPort,
                                       ReportableEntityHandlerFactory handlerFactory,
                                       GraphiteFormatter formatter)
focal_class.return: void
focal_class.signature: void startPickleListener(String strPort,
                                       ReportableEntityHandlerFactory handlerFactory,
                                       GraphiteFormatter formatter)
focal_class.class_method_signature: PushAgent.startTraceListener(final String strPort,
                                      ReportableEntityHandlerFactory handlerFactory,
                                      SpanSampler sampler)
focal_class.full_signature: protected void startTraceListener(final String strPort,
                                      ReportableEntityHandlerFactory handlerFactory,
                                      SpanSampler sampler)
focal_class.identifier: startTraceListener
focal_class.modifiers: protected
focal_class.parameters: (final String strPort,
                                      ReportableEntityHandlerFactory handlerFactory,
                                      SpanSampler sampler)
focal_class.return: void
focal_class.signature: void startTraceListener(final String strPort,
                                      ReportableEntityHandlerFactory handlerFactory,
                                      SpanSampler sampler)
focal_class.class_method_signature: PushAgent.startCustomTracingListener(final String strPort,
                                              ReportableEntityHandlerFactory handlerFactory,
                                              @Nullable WavefrontSender wfSender,
                                              SpanSampler sampler)
focal_class.full_signature: @VisibleForTesting protected void startCustomTracingListener(final String strPort,
                                              ReportableEntityHandlerFactory handlerFactory,
                                              @Nullable WavefrontSender wfSender,
                                              SpanSampler sampler)
focal_class.identifier: startCustomTracingListener
focal_class.modifiers: @VisibleForTesting protected
focal_class.parameters: (final String strPort,
                                              ReportableEntityHandlerFactory handlerFactory,
                                              @Nullable WavefrontSender wfSender,
                                              SpanSampler sampler)
focal_class.return: void
focal_class.signature: void startCustomTracingListener(final String strPort,
                                              ReportableEntityHandlerFactory handlerFactory,
                                              @Nullable WavefrontSender wfSender,
                                              SpanSampler sampler)
focal_class.class_method_signature: PushAgent.startTraceJaegerListener(String strPort,
                                            ReportableEntityHandlerFactory handlerFactory,
                                            @Nullable WavefrontSender wfSender,
                                            SpanSampler sampler)
focal_class.full_signature: protected void startTraceJaegerListener(String strPort,
                                            ReportableEntityHandlerFactory handlerFactory,
                                            @Nullable WavefrontSender wfSender,
                                            SpanSampler sampler)
focal_class.identifier: startTraceJaegerListener
focal_class.modifiers: protected
focal_class.parameters: (String strPort,
                                            ReportableEntityHandlerFactory handlerFactory,
                                            @Nullable WavefrontSender wfSender,
                                            SpanSampler sampler)
focal_class.return: void
focal_class.signature: void startTraceJaegerListener(String strPort,
                                            ReportableEntityHandlerFactory handlerFactory,
                                            @Nullable WavefrontSender wfSender,
                                            SpanSampler sampler)
focal_class.class_method_signature: PushAgent.startTraceJaegerHttpListener(final String strPort,
                                                ReportableEntityHandlerFactory handlerFactory,
                                                @Nullable WavefrontSender wfSender,
                                                SpanSampler sampler)
focal_class.full_signature: protected void startTraceJaegerHttpListener(final String strPort,
                                                ReportableEntityHandlerFactory handlerFactory,
                                                @Nullable WavefrontSender wfSender,
                                                SpanSampler sampler)
focal_class.identifier: startTraceJaegerHttpListener
focal_class.modifiers: protected
focal_class.parameters: (final String strPort,
                                                ReportableEntityHandlerFactory handlerFactory,
                                                @Nullable WavefrontSender wfSender,
                                                SpanSampler sampler)
focal_class.return: void
focal_class.signature: void startTraceJaegerHttpListener(final String strPort,
                                                ReportableEntityHandlerFactory handlerFactory,
                                                @Nullable WavefrontSender wfSender,
                                                SpanSampler sampler)
focal_class.class_method_signature: PushAgent.startTraceJaegerGrpcListener(final String strPort,
                                                ReportableEntityHandlerFactory handlerFactory,
                                                @Nullable WavefrontSender wfSender,
                                                SpanSampler sampler)
focal_class.full_signature: protected void startTraceJaegerGrpcListener(final String strPort,
                                                ReportableEntityHandlerFactory handlerFactory,
                                                @Nullable WavefrontSender wfSender,
                                                SpanSampler sampler)
focal_class.identifier: startTraceJaegerGrpcListener
focal_class.modifiers: protected
focal_class.parameters: (final String strPort,
                                                ReportableEntityHandlerFactory handlerFactory,
                                                @Nullable WavefrontSender wfSender,
                                                SpanSampler sampler)
focal_class.return: void
focal_class.signature: void startTraceJaegerGrpcListener(final String strPort,
                                                ReportableEntityHandlerFactory handlerFactory,
                                                @Nullable WavefrontSender wfSender,
                                                SpanSampler sampler)
focal_class.class_method_signature: PushAgent.startTraceZipkinListener(String strPort,
                                            ReportableEntityHandlerFactory handlerFactory,
                                            @Nullable WavefrontSender wfSender,
                                            SpanSampler sampler)
focal_class.full_signature: protected void startTraceZipkinListener(String strPort,
                                            ReportableEntityHandlerFactory handlerFactory,
                                            @Nullable WavefrontSender wfSender,
                                            SpanSampler sampler)
focal_class.identifier: startTraceZipkinListener
focal_class.modifiers: protected
focal_class.parameters: (String strPort,
                                            ReportableEntityHandlerFactory handlerFactory,
                                            @Nullable WavefrontSender wfSender,
                                            SpanSampler sampler)
focal_class.return: void
focal_class.signature: void startTraceZipkinListener(String strPort,
                                            ReportableEntityHandlerFactory handlerFactory,
                                            @Nullable WavefrontSender wfSender,
                                            SpanSampler sampler)
focal_class.class_method_signature: PushAgent.startGraphiteListener(String strPort,
                                         ReportableEntityHandlerFactory handlerFactory,
                                         SharedGraphiteHostAnnotator hostAnnotator,
                                         SpanSampler sampler)
focal_class.full_signature: @VisibleForTesting protected void startGraphiteListener(String strPort,
                                         ReportableEntityHandlerFactory handlerFactory,
                                         SharedGraphiteHostAnnotator hostAnnotator,
                                         SpanSampler sampler)
focal_class.identifier: startGraphiteListener
focal_class.modifiers: @VisibleForTesting protected
focal_class.parameters: (String strPort,
                                         ReportableEntityHandlerFactory handlerFactory,
                                         SharedGraphiteHostAnnotator hostAnnotator,
                                         SpanSampler sampler)
focal_class.return: void
focal_class.signature: void startGraphiteListener(String strPort,
                                         ReportableEntityHandlerFactory handlerFactory,
                                         SharedGraphiteHostAnnotator hostAnnotator,
                                         SpanSampler sampler)
focal_class.class_method_signature: PushAgent.startDeltaCounterListener(String strPort,
                                             SharedGraphiteHostAnnotator hostAnnotator,
                                             SenderTaskFactory senderTaskFactory,
                                             SpanSampler sampler)
focal_class.full_signature: @VisibleForTesting protected void startDeltaCounterListener(String strPort,
                                             SharedGraphiteHostAnnotator hostAnnotator,
                                             SenderTaskFactory senderTaskFactory,
                                             SpanSampler sampler)
focal_class.identifier: startDeltaCounterListener
focal_class.modifiers: @VisibleForTesting protected
focal_class.parameters: (String strPort,
                                             SharedGraphiteHostAnnotator hostAnnotator,
                                             SenderTaskFactory senderTaskFactory,
                                             SpanSampler sampler)
focal_class.return: void
focal_class.signature: void startDeltaCounterListener(String strPort,
                                             SharedGraphiteHostAnnotator hostAnnotator,
                                             SenderTaskFactory senderTaskFactory,
                                             SpanSampler sampler)
focal_class.class_method_signature: PushAgent.startRelayListener(String strPort,
                                      ReportableEntityHandlerFactory handlerFactory,
                                      SharedGraphiteHostAnnotator hostAnnotator)
focal_class.full_signature: @VisibleForTesting protected void startRelayListener(String strPort,
                                      ReportableEntityHandlerFactory handlerFactory,
                                      SharedGraphiteHostAnnotator hostAnnotator)
focal_class.identifier: startRelayListener
focal_class.modifiers: @VisibleForTesting protected
focal_class.parameters: (String strPort,
                                      ReportableEntityHandlerFactory handlerFactory,
                                      SharedGraphiteHostAnnotator hostAnnotator)
focal_class.return: void
focal_class.signature: void startRelayListener(String strPort,
                                      ReportableEntityHandlerFactory handlerFactory,
                                      SharedGraphiteHostAnnotator hostAnnotator)
focal_class.class_method_signature: PushAgent.startLogsIngestionListener(int port, LogsIngester logsIngester)
focal_class.full_signature: protected void startLogsIngestionListener(int port, LogsIngester logsIngester)
focal_class.identifier: startLogsIngestionListener
focal_class.modifiers: protected
focal_class.parameters: (int port, LogsIngester logsIngester)
focal_class.return: void
focal_class.signature: void startLogsIngestionListener(int port, LogsIngester logsIngester)
focal_class.class_method_signature: PushAgent.startRawLogsIngestionListener(int port, LogsIngester logsIngester)
focal_class.full_signature: @VisibleForTesting protected void startRawLogsIngestionListener(int port, LogsIngester logsIngester)
focal_class.identifier: startRawLogsIngestionListener
focal_class.modifiers: @VisibleForTesting protected
focal_class.parameters: (int port, LogsIngester logsIngester)
focal_class.return: void
focal_class.signature: void startRawLogsIngestionListener(int port, LogsIngester logsIngester)
focal_class.class_method_signature: PushAgent.startAdminListener(int port)
focal_class.full_signature: @VisibleForTesting protected void startAdminListener(int port)
focal_class.identifier: startAdminListener
focal_class.modifiers: @VisibleForTesting protected
focal_class.parameters: (int port)
focal_class.return: void
focal_class.signature: void startAdminListener(int port)
focal_class.class_method_signature: PushAgent.startHealthCheckListener(int port)
focal_class.full_signature: @VisibleForTesting protected void startHealthCheckListener(int port)
focal_class.identifier: startHealthCheckListener
focal_class.modifiers: @VisibleForTesting protected
focal_class.parameters: (int port)
focal_class.return: void
focal_class.signature: void startHealthCheckListener(int port)
focal_class.class_method_signature: PushAgent.startHistogramListeners(List<String> ports,
                                           ReportableEntityHandler<ReportPoint, String> pointHandler,
                                           SharedGraphiteHostAnnotator hostAnnotator,
                                           @Nullable Granularity granularity,
                                           int flushSecs, boolean memoryCacheEnabled,
                                           File baseDirectory, Long accumulatorSize, int avgKeyBytes,
                                           int avgDigestBytes, short compression, boolean persist,
                                           SpanSampler sampler)
focal_class.full_signature: protected void startHistogramListeners(List<String> ports,
                                           ReportableEntityHandler<ReportPoint, String> pointHandler,
                                           SharedGraphiteHostAnnotator hostAnnotator,
                                           @Nullable Granularity granularity,
                                           int flushSecs, boolean memoryCacheEnabled,
                                           File baseDirectory, Long accumulatorSize, int avgKeyBytes,
                                           int avgDigestBytes, short compression, boolean persist,
                                           SpanSampler sampler)
focal_class.identifier: startHistogramListeners
focal_class.modifiers: protected
focal_class.parameters: (List<String> ports,
                                           ReportableEntityHandler<ReportPoint, String> pointHandler,
                                           SharedGraphiteHostAnnotator hostAnnotator,
                                           @Nullable Granularity granularity,
                                           int flushSecs, boolean memoryCacheEnabled,
                                           File baseDirectory, Long accumulatorSize, int avgKeyBytes,
                                           int avgDigestBytes, short compression, boolean persist,
                                           SpanSampler sampler)
focal_class.return: void
focal_class.signature: void startHistogramListeners(List<String> ports,
                                           ReportableEntityHandler<ReportPoint, String> pointHandler,
                                           SharedGraphiteHostAnnotator hostAnnotator,
                                           @Nullable Granularity granularity,
                                           int flushSecs, boolean memoryCacheEnabled,
                                           File baseDirectory, Long accumulatorSize, int avgKeyBytes,
                                           int avgDigestBytes, short compression, boolean persist,
                                           SpanSampler sampler)
focal_class.class_method_signature: PushAgent.registerTimestampFilter(String strPort)
focal_class.full_signature: private void registerTimestampFilter(String strPort)
focal_class.identifier: registerTimestampFilter
focal_class.modifiers: private
focal_class.parameters: (String strPort)
focal_class.return: void
focal_class.signature: void registerTimestampFilter(String strPort)
focal_class.class_method_signature: PushAgent.registerPrefixFilter(String strPort)
focal_class.full_signature: private void registerPrefixFilter(String strPort)
focal_class.identifier: registerPrefixFilter
focal_class.modifiers: private
focal_class.parameters: (String strPort)
focal_class.return: void
focal_class.signature: void registerPrefixFilter(String strPort)
focal_class.class_method_signature: PushAgent.processConfiguration(AgentConfiguration config)
focal_class.full_signature: @Override protected void processConfiguration(AgentConfiguration config)
focal_class.identifier: processConfiguration
focal_class.modifiers: @Override protected
focal_class.parameters: (AgentConfiguration config)
focal_class.return: void
focal_class.signature: void processConfiguration(AgentConfiguration config)
focal_class.class_method_signature: PushAgent.updateRateLimiter(ReportableEntityType entityType,
                                   @Nullable Boolean collectorSetsRateLimit,
                                   @Nullable Number collectorRateLimit,
                                   @Nullable Number globalRateLimit)
focal_class.full_signature: private void updateRateLimiter(ReportableEntityType entityType,
                                   @Nullable Boolean collectorSetsRateLimit,
                                   @Nullable Number collectorRateLimit,
                                   @Nullable Number globalRateLimit)
focal_class.identifier: updateRateLimiter
focal_class.modifiers: private
focal_class.parameters: (ReportableEntityType entityType,
                                   @Nullable Boolean collectorSetsRateLimit,
                                   @Nullable Number collectorRateLimit,
                                   @Nullable Number globalRateLimit)
focal_class.return: void
focal_class.signature: void updateRateLimiter(ReportableEntityType entityType,
                                   @Nullable Boolean collectorSetsRateLimit,
                                   @Nullable Number collectorRateLimit,
                                   @Nullable Number globalRateLimit)
focal_class.class_method_signature: PushAgent.configureTokenAuthenticator()
focal_class.full_signature: protected TokenAuthenticator configureTokenAuthenticator()
focal_class.identifier: configureTokenAuthenticator
focal_class.modifiers: protected
focal_class.parameters: ()
focal_class.return: TokenAuthenticator
focal_class.signature: TokenAuthenticator configureTokenAuthenticator()
focal_class.class_method_signature: PushAgent.startAsManagedThread(int port, Runnable target, @Nullable String threadName)
focal_class.full_signature: protected void startAsManagedThread(int port, Runnable target, @Nullable String threadName)
focal_class.identifier: startAsManagedThread
focal_class.modifiers: protected
focal_class.parameters: (int port, Runnable target, @Nullable String threadName)
focal_class.return: void
focal_class.signature: void startAsManagedThread(int port, Runnable target, @Nullable String threadName)
focal_class.class_method_signature: PushAgent.stopListeners()
focal_class.full_signature: @Override public void stopListeners()
focal_class.identifier: stopListeners
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void stopListeners()
focal_class.class_method_signature: PushAgent.stopListener(int port)
focal_class.full_signature: @Override protected void stopListener(int port)
focal_class.identifier: stopListener
focal_class.modifiers: @Override protected
focal_class.parameters: (int port)
focal_class.return: void
focal_class.signature: void stopListener(int port)
focal_class.superclass: extends AbstractAgent
focal_method.body: @VisibleForTesting
    protected void startGraphiteListener(String strPort,
                                         ReportableEntityHandlerFactory handlerFactory,
                                         SharedGraphiteHostAnnotator hostAnnotator,
                                         SpanSampler sampler) {
      final int port = Integer.parseInt(strPort);
      registerPrefixFilter(strPort);
      registerTimestampFilter(strPort);
      if (proxyConfig.isHttpHealthCheckAllPorts()) healthCheckManager.enableHealthcheck(port);
  
      WavefrontPortUnificationHandler wavefrontPortUnificationHandler =
          new WavefrontPortUnificationHandler(strPort, tokenAuthenticator, healthCheckManager,
              decoderSupplier.get(), handlerFactory, hostAnnotator, preprocessors.get(strPort),
              () -> entityProps.get(ReportableEntityType.HISTOGRAM).isFeatureDisabled(),
              () -> entityProps.get(ReportableEntityType.TRACE).isFeatureDisabled(),
              () -> entityProps.get(ReportableEntityType.TRACE_SPAN_LOGS).isFeatureDisabled(),
              sampler);
  
      startAsManagedThread(port,
          new TcpIngester(createInitializer(wavefrontPortUnificationHandler, port,
              proxyConfig.getPushListenerMaxReceivedLength(),
              proxyConfig.getPushListenerHttpBufferSize(),
              proxyConfig.getListenerIdleConnectionTimeout(), getSslContext(strPort),
              getCorsConfig(strPort)), port).
              withChildChannelOptions(childChannelOptions), "listener-graphite-" + port);
    }
focal_method.class_method_signature: PushAgent.startGraphiteListener(String strPort,
                                         ReportableEntityHandlerFactory handlerFactory,
                                         SharedGraphiteHostAnnotator hostAnnotator,
                                         SpanSampler sampler)
focal_method.full_signature: @VisibleForTesting protected void startGraphiteListener(String strPort,
                                         ReportableEntityHandlerFactory handlerFactory,
                                         SharedGraphiteHostAnnotator hostAnnotator,
                                         SpanSampler sampler)
focal_method.identifier: startGraphiteListener
focal_method.invocations: parseInt registerPrefixFilter registerTimestampFilter isHttpHealthCheckAllPorts enableHealthcheck get get isFeatureDisabled get isFeatureDisabled get isFeatureDisabled get startAsManagedThread withChildChannelOptions createInitializer getPushListenerMaxReceivedLength getPushListenerHttpBufferSize getListenerIdleConnectionTimeout getSslContext getCorsConfig
focal_method.modifiers: @VisibleForTesting protected
focal_method.parameters: (String strPort,
                                         ReportableEntityHandlerFactory handlerFactory,
                                         SharedGraphiteHostAnnotator hostAnnotator,
                                         SpanSampler sampler)
focal_method.return: void
focal_method.signature: void startGraphiteListener(String strPort,
                                         ReportableEntityHandlerFactory handlerFactory,
                                         SharedGraphiteHostAnnotator hostAnnotator,
                                         SpanSampler sampler)