Show progress of direct sent messages in network stress test

This commit is contained in:
Ivan Vilata-i-Balaguer 2016-05-12 09:13:48 +02:00
parent 7b0834e3b8
commit 3a9b2dd932

View file

@ -309,13 +309,13 @@ public class NetworkStressTest {
@Override @Override
public void onArrived() { public void onArrived() {
sentDelays.add(System.currentTimeMillis() - sendMillis); sentDelays.add(System.currentTimeMillis() - sendMillis);
sentDirectLatch.countDown(); countDownAndPrint(sentDirectLatch, 'd');
} }
@Override @Override
public void onFault() { public void onFault() {
sentDirectFailed.set(true); sentDirectFailed.set(true);
sentDirectLatch.countDown(); countDownAndPrint(sentDirectLatch, 'd');
} }
}); });
}, sendAfterMillis, TimeUnit.MILLISECONDS }, sendAfterMillis, TimeUnit.MILLISECONDS