From 04876162d59983eb06d234d3a1dc0e7f575b4d3e Mon Sep 17 00:00:00 2001 From: Florian Fittkau <ffi@informatik.uni-kiel.de> Date: Tue, 10 Feb 2015 21:54:43 +0100 Subject: [PATCH] started trace debugging --- Start Master (testing only).launch | 2 +- Start Worker.launch | 2 +- src/explorviz/live_trace_processing/connector/TCPConnector.java | 2 ++ 3 files changed, 4 insertions(+), 2 deletions(-) diff --git a/Start Master (testing only).launch b/Start Master (testing only).launch index 92ef448..803bd3b 100644 --- a/Start Master (testing only).launch +++ b/Start Master (testing only).launch @@ -11,5 +11,5 @@ </listAttribute> <stringAttribute key="org.eclipse.jdt.launching.MAIN_TYPE" value="explorviz.live_trace_processing.main.WorkerStarter"/> <stringAttribute key="org.eclipse.jdt.launching.PROJECT_ATTR" value="worker"/> -<stringAttribute key="org.eclipse.jdt.launching.VM_ARGUMENTS" value="-Xmx4G -Dexplorviz.live_trace_processing.worker_enabled=false -Dexplorviz.live_trace_processing.reader_listening_port=10133"/> +<stringAttribute key="org.eclipse.jdt.launching.VM_ARGUMENTS" value="-Xmx4G -Dexplorviz.live_trace_processing.worker_enabled=false -Dexplorviz.live_trace_processing.reader_listening_port=10134"/> </launchConfiguration> diff --git a/Start Worker.launch b/Start Worker.launch index 83a9afc..f32bf19 100644 --- a/Start Worker.launch +++ b/Start Worker.launch @@ -11,5 +11,5 @@ </listAttribute> <stringAttribute key="org.eclipse.jdt.launching.MAIN_TYPE" value="explorviz.live_trace_processing.main.WorkerStarter"/> <stringAttribute key="org.eclipse.jdt.launching.PROJECT_ATTR" value="worker"/> -<stringAttribute key="org.eclipse.jdt.launching.VM_ARGUMENTS" value="-Xmx4G -Dexplorviz.live_trace_processing.worker_enabled=true -Dexplorviz.live_trace_processing.reader_listening_port=10133"/> +<stringAttribute key="org.eclipse.jdt.launching.VM_ARGUMENTS" value="-Xmx4G -Dexplorviz.live_trace_processing.worker_enabled=true -Dexplorviz.live_trace_processing.reader_listening_port=10133 -Dexplorviz.live_trace_processing.writer_target_port=10134"/> </launchConfiguration> diff --git a/src/explorviz/live_trace_processing/connector/TCPConnector.java b/src/explorviz/live_trace_processing/connector/TCPConnector.java index 05d0336..13bbca6 100644 --- a/src/explorviz/live_trace_processing/connector/TCPConnector.java +++ b/src/explorviz/live_trace_processing/connector/TCPConnector.java @@ -76,6 +76,8 @@ public class TCPConnector extends AbstractSink implements IWriter, IStringRecord final ISerializableRecord serializableRecord = (ISerializableRecord) record; if (buffer.remaining() < serializableRecord.getRecordSizeInBytes()) { send(buffer); + System.out.println("required: " + serializableRecord.getRecordSizeInBytes() + + " and capacity is " + buffer.capacity()); } serializableRecord.putIntoByteBuffer(buffer, stringRegistry); } else if (record instanceof TimedPeriodRecord) { -- GitLab