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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
