some improvements to default values

src/META-INF/explorviz.live_trace_processing.default.properties

@@ -36,13 +36,13 @@ explorviz.live_trace_processing.worker_enabled=true
 
 explorviz.live_trace_processing.reader_listening_port=10133
 
-explorviz.live_trace_processing.tcp_reader_output_buffer_size=8192
-explorviz.live_trace_processing.tcp_reader_disruptor_size=32
+explorviz.live_trace_processing.tcp_reader_output_buffer_size=16384
+explorviz.live_trace_processing.tcp_reader_disruptor_size=64
 
-explorviz.live_trace_processing.trace_reconstruction_output_buffer_size=64
-explorviz.live_trace_processing.trace_reconstruction_disruptor_size=16
+explorviz.live_trace_processing.trace_reconstruction_output_buffer_size=1024
+explorviz.live_trace_processing.trace_reconstruction_disruptor_size=64
 
 explorviz.live_trace_processing.trace_reconstruction_buffer_initial_size=1024
 
-explorviz.live_trace_processing.trace_summarization_output_buffer_size=64
-explorviz.live_trace_processing.trace_summarization_disruptor_size=16
+explorviz.live_trace_processing.trace_summarization_output_buffer_size=256
+explorviz.live_trace_processing.trace_summarization_disruptor_size=64

src/explorviz/live_trace_processing/reader/TCPReader.java

@@ -21,7 +21,6 @@ import explorviz.live_trace_processing.Constants;
 import explorviz.live_trace_processing.filter.RecordArrayEvent;
 import explorviz.live_trace_processing.filter.RecordArrayEventFactory;
 import explorviz.live_trace_processing.filter.reconstruction.ITraceReconstruction;
-import explorviz.live_trace_processing.record.IRecord;
 import explorviz.live_trace_processing.record.misc.TimedPeriodRecord;
 
 public final class TCPReader implements IPeriodicTimeSignalReceiver {
@@ -58,26 +57,24 @@ public final class TCPReader implements IPeriodicTimeSignalReceiver {
 	public void periodicTimeSignal(final long timestamp) {
 		final List<TCPReaderOneClient> toRemove = new ArrayList<TCPReaderOneClient>();
 
+		boolean alreadySent = false;
+
 		for (final TCPReaderOneClient thread : threads) {
 			if (!thread.isAlive()) {
 				toRemove.add(thread);
 			}
+
+			if (!alreadySent) {
+				thread.putInRingBuffer(new TimedPeriodRecord());
+				alreadySent = true;
+			}
+
 			thread.flushOutputBuffer();
 		}
 
 		for (final TCPReaderOneClient toRemoveThread : toRemove) {
 			threads.remove(toRemoveThread);
 		}
-
-		final long hiseq = ringBuffer.next();
-		final RecordArrayEvent valueEvent = ringBuffer.get(hiseq);
-		final IRecord[] buffer = valueEvent.getValues();
-		buffer[0] = new TimedPeriodRecord();
-
-		valueEvent.setValues(buffer);
-		valueEvent.setValueSize(1);
-
-		ringBuffer.publish(hiseq);
 	}
 
 	public final void read() {

src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java

@@ -700,7 +700,7 @@ class TCPReaderOneClient extends Thread {
 		}
 	}
 
-	private final void putInRingBuffer(final IRecord message) {
+	public final void putInRingBuffer(final IRecord message) {
 		synchronized (this) {
 			outputBuffer[outputBufferIndex++] = message;
 			if (outputBufferIndex == Constants.TCP_READER_OUTPUT_BUFFER_SIZE) {
@@ -709,7 +709,7 @@ class TCPReaderOneClient extends Thread {
 		}
 	}
 
-	public void flushOutputBuffer() {
+	public final void flushOutputBuffer() {
 		synchronized (this) {
 			if (outputBufferIndex > 0) {
 				final long hiseq = ringBuffer.next();