This is an automated email from the ASF dual-hosted git repository. mck pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/cassandra.git
The following commit(s) were added to refs/heads/trunk by this push: new 3522b54 Make ConnectionBurnTest a proper unit test (fixes `ant test-burn`) 3522b54 is described below commit 3522b54f2d7f34c3dc8234c8981a4629ebcf9a50 Author: Mick Semb Wever <m...@apache.org> AuthorDate: Sat Oct 26 22:23:47 2019 +0200 Make ConnectionBurnTest a proper unit test (fixes `ant test-burn`) patch by Mick Semb Wever; reviewed by Benedict Elliott Smith https://the-asf.slack.com/archives/CK23JSY2K/p1572206490030800 --- test/burn/org/apache/cassandra/net/ConnectionBurnTest.java | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/test/burn/org/apache/cassandra/net/ConnectionBurnTest.java b/test/burn/org/apache/cassandra/net/ConnectionBurnTest.java index 81b6402..57eb726 100644 --- a/test/burn/org/apache/cassandra/net/ConnectionBurnTest.java +++ b/test/burn/org/apache/cassandra/net/ConnectionBurnTest.java @@ -622,7 +622,7 @@ public class ConnectionBurnTest } } - public static void test(GlobalInboundSettings inbound, OutboundConnectionSettings outbound) throws ExecutionException, InterruptedException, NoSuchFieldException, IllegalAccessException, TimeoutException + private void test(GlobalInboundSettings inbound, OutboundConnectionSettings outbound) throws ExecutionException, InterruptedException, NoSuchFieldException, IllegalAccessException, TimeoutException { MessageGenerator small = new UniformPayloadGenerator(0, 1, (1 << 15)); MessageGenerator large = new UniformPayloadGenerator(0, 1, (1 << 16) + (1 << 15)); @@ -635,12 +635,19 @@ public class ConnectionBurnTest .endpoints(4) .inbound(inbound) .outbound(outbound) - .time(2L, TimeUnit.DAYS) + // change the following for a longer burn + .time(2L, TimeUnit.MINUTES) .build().run(); } public static void main(String[] args) throws ExecutionException, InterruptedException, NoSuchFieldException, IllegalAccessException, TimeoutException { + new ConnectionBurnTest().test(); + } + + @org.junit.Test + public void test() throws ExecutionException, InterruptedException, NoSuchFieldException, IllegalAccessException, TimeoutException + { GlobalInboundSettings inboundSettings = new GlobalInboundSettings() .withQueueCapacity(1 << 18) .withEndpointReserveLimit(1 << 20) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org