channel.send(new Message(local_addr, null, new Integer(i)));
if(i % 100 == 0)
System.out.println("-- sent " + i);
}
num_msgs_sent_after = getNumMessagesSentViaNetwork(channel) ;
<BUG>Assert.assertEquals(num_msgs_sent_before, num_msgs_sent_after, "Messages are (incorrectly) being sent via network") ;
try {
Boolean result = p.getResultWithTimeout(TIMEOUT) ;
}</BUG>
catch(TimeoutException te) {

channel.send(new Message(local_addr, null, new Integer(i)));
if(i % 100 == 0)
System.out.println("-- sent " + i);
}
num_msgs_sent_after = getNumMessagesSentViaNetwork(channel) ;
System.out.println("num msgs before: " + num_msgs_sent_before + ", num msgs after: " + num_msgs_sent_after);
assert num_msgs_sent_before <= num_msgs_sent_after;
assert num_msgs_sent_after < NUM/10;
try {
p.getResultWithTimeout(TIMEOUT) ;
}
catch(TimeoutException te) {
