[Udt-java-commits] SF.net SVN: udt-java:[72] udt-java/trunk/src/main/java/udt

[<bsc...@us...>]

Revision: 72
          http://udt-java.svn.sourceforge.net/udt-java/?rev=72&view=rev
Author:   bschuller
Date:     2012-02-06 10:06:38 +0000 (Mon, 06 Feb 2012)
Log Message:
-----------
keep track of data array length

Modified Paths:
--------------
    udt-java/trunk/src/main/java/udt/UDTSender.java
    udt-java/trunk/src/main/java/udt/packets/DataPacket.java

Modified: udt-java/trunk/src/main/java/udt/UDTSender.java
===================================================================
--- udt-java/trunk/src/main/java/udt/UDTSender.java	2012-02-06 08:26:01 UTC (rev 71)
+++ udt-java/trunk/src/main/java/udt/UDTSender.java	2012-02-06 10:06:38 UTC (rev 72)
@@ -200,7 +200,11 @@
 				throughput.end();
 				throughput.begin();
 			}
-			sendBuffer.put(p.getPacketSequenceNumber(), p.getData());
+			//store data for potential retransmit
+			int l=p.getLength();
+			byte[]data=new byte[l];
+			System.arraycopy(p.getData(), 0, data, 0, l);
+			sendBuffer.put(p.getPacketSequenceNumber(), data);
 			unacknowledged.incrementAndGet();
 		}
 		statistics.incNumberOfSentDataPackets();

Modified: udt-java/trunk/src/main/java/udt/packets/DataPacket.java
===================================================================
--- udt-java/trunk/src/main/java/udt/packets/DataPacket.java	2012-02-06 08:26:01 UTC (rev 71)
+++ udt-java/trunk/src/main/java/udt/packets/DataPacket.java	2012-02-06 10:06:38 UTC (rev 72)
@@ -78,7 +78,7 @@
 		return this.data;
 	}
 
-	public double getLength(){
+	public int getLength(){
 		return dataLength;
 	}
 

This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.