udt-java-commits

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

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

Revision: 27
          http://udt-java.svn.sourceforge.net/udt-java/?rev=27&view=rev
Author:   bschuller
Date:     2010-04-26 06:36:47 +0000 (Mon, 26 Apr 2010)

Log Message:
-----------


Modified Paths:
--------------
    udt-java/trunk/src/main/java/udt/UDTCongestionControl.java

Modified: udt-java/trunk/src/main/java/udt/UDTCongestionControl.java
===================================================================
--- udt-java/trunk/src/main/java/udt/UDTCongestionControl.java	2010-04-25 21:32:53 UTC (rev 26)
+++ udt-java/trunk/src/main/java/udt/UDTCongestionControl.java	2010-04-26 06:36:47 UTC (rev 27)
@@ -126,7 +126,6 @@
 			lastAckSeqNumber = ackSeqno;
 			//but not beyond a maximum size
 			if(congestionWindowSize>session.getFlowWindowSize()){
-				System.out.println("slow start ends on ACK");
 				slowStartPhase=false;
 				if(packetArrivalRate>0){
 					packetSendingPeriod=1000000.0/packetArrivalRate;


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

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

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

Revision: 37
          http://udt-java.svn.sourceforge.net/udt-java/?rev=37&view=rev
Author:   bschuller
Date:     2010-05-24 19:45:19 +0000 (Mon, 24 May 2010)

Log Message:
-----------
experiment with ack interval

Modified Paths:
--------------
    udt-java/trunk/src/main/java/udt/UDTCongestionControl.java

Modified: udt-java/trunk/src/main/java/udt/UDTCongestionControl.java
===================================================================
--- udt-java/trunk/src/main/java/udt/UDTCongestionControl.java	2010-05-24 19:15:33 UTC (rev 36)
+++ udt-java/trunk/src/main/java/udt/UDTCongestionControl.java	2010-05-24 19:45:19 UTC (rev 37)
@@ -71,7 +71,8 @@
 	/* (non-Javadoc)
 	 * @see udt.CongestionControl#init()
 	 */
-	public void init() {	
+	public void init() {
+		setAckInterval(10);
 	}
 
 	/* (non-Javadoc)
@@ -112,7 +113,7 @@
 	}
 	public void setAckInterval(long ackInterval){
 		this.ackInterval=ackInterval;
-		if(session.getSocket().getReceiver()!=null){
+		if(session.getSocket()!=null && session.getSocket().getReceiver()!=null){
 			session.getSocket().getReceiver().setAckInterval(ackInterval);
 		}
 	}


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