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.
|
