Method testThreshold

test/MaxPropRouterTest.java:103–137

()

	}
	
	public void testThreshold() {
		int msgSize = 90;
		
		Message m1 = new Message(h1,h5, msgId1, msgSize);
		h1.createNewMessage(m1);
		checkCreates(1);
		h1.connect(h2);
		
		/* thresholds should be zero before any transfers */
		assertEquals(0, r1.calcThreshold());
		assertEquals(0, r2.calcThreshold());
		
		/* simple delivery of msgId1 from h1 to h2 */
		updateAllNodes();
		checkTransferStart(h1, h2, msgId1);
		assertFalse(mc.next());
		clock.advance(5);
		updateAllNodes();
		assertFalse(mc.next()); // transfer should not be ready yet
		clock.advance(5); // now it should be done
		updateAllNodes();
		checkDelivered(h1, h2, msgId1, false);

		disconnect(h1);
		assertEquals(1, r1.calcThreshold());
		assertEquals(2, r2.calcThreshold());
		
		h2.connect(h3);
		deliverMessage(h2, h3, msgId1, msgSize, false);
		disconnect(h2);
		assertEquals(2, r2.calcThreshold());
		/* msg at h3 has traveled 2 hops and "bsize > avgTransferredBytes > 0"
		 * so threshold should be only msg's hopcount+1 */ 
		assertEquals(3, r3.calcThreshold());
	}
	
	public void testAckedMessageDeleting() {
		int msgSize = 10;