diff --git a/Start Master (testing only).launch b/Start Master (testing only).launch index 92ef4480469f95b69dddcabcc9929f542185459e..803bd3b4486e8ea4853f474e0ca60b1012026170 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 83a9afc5991de17ac595be173ac7fc3a6743cfe2..f32bf19d0690da5f0f74961005df450584afb42c 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 05d0336854a6159eccba4ff77d789f5f2d765d3d..13bbca69ba33fe55346fb4b82bf22f6df9fadbcf 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) {