import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-abstract class AbstractDropTest implements Listener<PacketReceived>, AutoCloseable {
+abstract class AbstractDropTest implements Listener<PacketReceived>, AutoCloseable, DropTest {
private static final Logger LOG = LoggerFactory.getLogger(AbstractDropTest.class);
protected static final Uint16 PRIORITY = Uint16.valueOf(4);
.newUpdater(AbstractDropTest.class, "runablesRejected");
protected volatile int runablesRejected;
+ @Override
public final DropTestStats getStats() {
return new DropTestStats(sent, rcvd, excs, ftrFailed, ftrSuccess, runablesExecuted, runablesRejected);
}
executorService = threadPool;
}
+ @Override
public final void clearStats() {
sent = 0;
rcvd = 0;