Commit c6419ebe authored by Florian Fittkau's avatar Florian Fittkau

WiP

parent b25581f7
......@@ -19,13 +19,13 @@ public class FilterConfiguration {
final SinglePipeConnector<IRecord> traceReductionConnector = new SinglePipeConnector<IRecord>(
Constants.TRACE_RECONSTRUCTION_DISRUPTOR_SIZE);
new TracesSummarizationFilter(traceReductionConnector, TimeUnit.SECONDS.toNanos(3), sink)
.start();
new TracesSummarizationFilter(traceReductionConnector, TimeUnit.SECONDS.toNanos(2), sink)
.start();
final PipesMerger<IRecord> traceReconstructionMerger = new PipesMerger<IRecord>(
Constants.TCP_READER_DISRUPTOR_SIZE);
new TraceReconstructionFilter(traceReconstructionMerger, TimeUnit.SECONDS.toNanos(3),
new TraceReconstructionFilter(traceReconstructionMerger, TimeUnit.SECONDS.toNanos(2),
traceReductionConnector.registerProducer()).start();
new TCPReader(configuration.getIntProperty(ConfigurationFactory.READER_LISTENING_PORT,
......
......@@ -41,7 +41,7 @@ class TCPReaderOneClient extends Thread {
private HostApplicationMetaDataRecord hostApplicationMetadata;
private final StringRegistry stringRegistry = new StringRegistry(null);
private final List<byte[]> waitingForStringMessages = new ArrayList<byte[]>(128);
private final List<byte[]> waitingForStringMessages = new ArrayList<byte[]>(32);
private final SocketChannel socketChannel;
......@@ -65,7 +65,7 @@ class TCPReaderOneClient extends Thread {
LOG.info("Client " + remoteAddress + " connected.");
}
RemoteConfigurationServlet.getConnectedChildren().add(remoteAddress);
// RemoteConfigurationServlet.getConnectedChildren().add(remoteAddress);
// sendAdaptiveMonitoringList();
......@@ -74,7 +74,7 @@ class TCPReaderOneClient extends Thread {
messagesfromByteArray(buffer);
}
} catch (final IOException ex) {
RemoteConfigurationServlet.getConnectedChildren().remove(remoteAddress);
// RemoteConfigurationServlet.getConnectedChildren().remove(remoteAddress);
LOG.info("Error in read() " + ex.getMessage());
} finally {
LOG.info("Client " + remoteAddress + " disconnected.");
......@@ -955,7 +955,7 @@ class TCPReaderOneClient extends Thread {
}
}
public final void putInQueue(final IRecord message) {
private final void putInQueue(final IRecord message) {
while (!queue.offer(message)) {
try {
Thread.sleep(1);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment