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

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

Revision: 47
          http://udt-java.svn.sourceforge.net/udt-java/?rev=47&view=rev
Author:   bschuller
Date:     2010-09-01 13:58:45 +0000 (Wed, 01 Sep 2010)

Log Message:
-----------
fix unit test

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

Modified: udt-java/trunk/src/main/java/udt/UDTInputStream.java
===================================================================
--- udt-java/trunk/src/main/java/udt/UDTInputStream.java	2010-09-01 13:08:22 UTC (rev 46)
+++ udt-java/trunk/src/main/java/udt/UDTInputStream.java	2010-09-01 13:58:45 UTC (rev 47)
@@ -61,7 +61,7 @@
 
 	//the highest sequence number read by the application, initialised
 	//to the initial sequence number minus one
-	private volatile long highestSequenceNumber;
+	private volatile long highestSequenceNumber=0;
 
 	//set to 'false' by the receiver when it gets a shutdown signal from the peer
 	//see the noMoreData() method
@@ -82,7 +82,9 @@
 		this.statistics=statistics;
 		int capacity=socket!=null? 4*socket.getSession().getFlowWindowSize() : 64 ;
 		appData=new PriorityBlockingQueue<AppData>(capacity);
-		highestSequenceNumber=SequenceNumber.decrement(socket.getSession().getInitialSequenceNumber());
+		if(socket!=null){
+			highestSequenceNumber=SequenceNumber.decrement(socket.getSession().getInitialSequenceNumber());
+		}
 	}
 
 	/**


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