Skip to content

Commit 4484bc1

Browse files
OlegDokukaOlegDokuka
committed
Merge 1.0.x into master
Signed-off-by: Oleh Dokuka <[email protected]> Signed-off-by: Oleh Dokuka <[email protected]>
2 parents 2911083 + 040278a commit 4484bc1

13 files changed

+196
-127
lines changed

‎rsocket-core/src/test/java/io/rsocket/RaceTestConstants.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
package io.rsocket;
2+
3+
public class RaceTestConstants {
4+
public static final int REPEATS =
5+
Integer.parseInt(System.getProperty("rsocket.test.race.repeats", "1000"));
6+
}

‎rsocket-core/src/test/java/io/rsocket/core/DefaultRSocketClientTests.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import io.netty.util.ReferenceCounted;
2727
import io.rsocket.Payload;
2828
import io.rsocket.RSocket;
29+
import io.rsocket.RaceTestConstants;
2930
import io.rsocket.frame.ErrorFrameCodec;
3031
import io.rsocket.frame.FrameHeaderCodec;
3132
import io.rsocket.frame.FrameType;
@@ -182,7 +183,7 @@ public void shouldHaveNoLeaksOnPayloadInCaseOfRacingOfOnNextAndCancel(
182183
throws Throwable {
183184
Assumptions.assumeThat(requestType).isNotEqualTo(FrameType.REQUEST_CHANNEL);
184185

185-
for (int i = 0; i < 10000; i++) {
186+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
186187
ClientSocketRule rule = new ClientSocketRule();
187188
rule.apply(
188189
new Statement() {
@@ -244,7 +245,7 @@ public void shouldHaveNoLeaksOnPayloadInCaseOfRacingOfRequestAndCancel(
244245
throws Throwable {
245246
Assumptions.assumeThat(requestType).isNotEqualTo(FrameType.REQUEST_CHANNEL);
246247

247-
for (int i = 0; i < 10000; i++) {
248+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
248249
ClientSocketRule rule = new ClientSocketRule();
249250
rule.apply(
250251
new Statement() {
@@ -481,7 +482,7 @@ public void shouldDisposeOriginalSource() {
481482

482483
@Test
483484
public void shouldDisposeOriginalSourceIfRacing() throws Throwable {
484-
for (int i = 0; i < 10000; i++) {
485+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
485486
ClientSocketRule rule = new ClientSocketRule();
486487
rule.apply(
487488
new Statement() {

‎rsocket-core/src/test/java/io/rsocket/core/RSocketRequesterTest.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,7 @@
5151
import io.rsocket.Payload;
5252
import io.rsocket.PayloadAssert;
5353
import io.rsocket.RSocket;
54+
import io.rsocket.RaceTestConstants;
5455
import io.rsocket.buffer.LeaksTrackingByteBufAllocator;
5556
import io.rsocket.exceptions.ApplicationErrorException;
5657
import io.rsocket.exceptions.CustomRSocketException;
@@ -429,7 +430,7 @@ static Stream<BiFunction<RSocket, Payload, Publisher<?>>> prepareCalls() {
429430
public void checkNoLeaksOnRacing(
430431
Function<ClientSocketRule, Publisher<Payload>> initiator,
431432
BiConsumer<AssertSubscriber<Payload>, ClientSocketRule> runner) {
432-
for (int i = 0; i < 10000; i++) {
433+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
433434
ClientSocketRule clientSocketRule = new ClientSocketRule();
434435
try {
435436
clientSocketRule
@@ -1076,7 +1077,7 @@ public void ensuresCorrectOrderOfStreamIdIssuingInCaseOfRacing(
10761077
FrameType interactionType2) {
10771078
Assumptions.assumeThat(interactionType1).isNotEqualTo(METADATA_PUSH);
10781079
Assumptions.assumeThat(interactionType2).isNotEqualTo(METADATA_PUSH);
1079-
for (int i = 1; i < 10000; i += 4) {
1080+
for (int i = 1; i < RaceTestConstants.REPEATS; i += 4) {
10801081
Payload payload = DefaultPayload.create("test", "test");
10811082
Publisher<?> publisher1 = interaction1.apply(rule, payload);
10821083
Publisher<?> publisher2 = interaction2.apply(rule, payload);
@@ -1161,7 +1162,7 @@ public void shouldTerminateAllStreamsIfThereRacingBetweenDisposeAndRequests(
11611162
BiFunction<ClientSocketRule, Payload, Publisher<?>> interaction2,
11621163
FrameType interactionType1,
11631164
FrameType interactionType2) {
1164-
for (int i = 1; i < 10000; i++) {
1165+
for (int i = 1; i < RaceTestConstants.REPEATS; i++) {
11651166
Payload payload1 = ByteBufPayload.create("test", "test");
11661167
Payload payload2 = ByteBufPayload.create("test", "test");
11671168
AssertSubscriber assertSubscriber1 = AssertSubscriber.create();

‎rsocket-core/src/test/java/io/rsocket/core/RSocketResponderTest.java

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,7 @@
4949
import io.rsocket.Payload;
5050
import io.rsocket.PayloadAssert;
5151
import io.rsocket.RSocket;
52+
import io.rsocket.RaceTestConstants;
5253
import io.rsocket.frame.CancelFrameCodec;
5354
import io.rsocket.frame.ErrorFrameCodec;
5455
import io.rsocket.frame.FrameHeaderCodec;
@@ -270,7 +271,7 @@ public void checkNoLeaksOnRacingCancelFromRequestChannelAndNextFromUpstream() {
270271
ByteBufAllocator allocator = rule.alloc();
271272
final TestRequestInterceptor testRequestInterceptor = new TestRequestInterceptor();
272273
rule.setRequestInterceptor(testRequestInterceptor);
273-
for (int i = 0; i < 10000; i++) {
274+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
274275
AssertSubscriber<Payload> assertSubscriber = AssertSubscriber.create();
275276
final Sinks.One<Payload> sink = Sinks.one();
276277

@@ -331,7 +332,7 @@ public void checkNoLeaksOnRacingBetweenDownstreamCancelAndOnNextFromRequestChann
331332
ByteBufAllocator allocator = rule.alloc();
332333
final TestRequestInterceptor testRequestInterceptor = new TestRequestInterceptor();
333334
rule.setRequestInterceptor(testRequestInterceptor);
334-
for (int i = 0; i < 10000; i++) {
335+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
335336
AssertSubscriber<Payload> assertSubscriber = AssertSubscriber.create();
336337

337338
FluxSink<Payload>[] sinks = new FluxSink[1];
@@ -374,7 +375,7 @@ public void checkNoLeaksOnRacingBetweenDownstreamCancelAndOnNextFromRequestChann
374375
ByteBufAllocator allocator = rule.alloc();
375376
final TestRequestInterceptor testRequestInterceptor = new TestRequestInterceptor();
376377
rule.setRequestInterceptor(testRequestInterceptor);
377-
for (int i = 0; i < 10000; i++) {
378+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
378379
AssertSubscriber<Payload> assertSubscriber = AssertSubscriber.create();
379380

380381
FluxSink<Payload>[] sinks = new FluxSink[1];
@@ -419,7 +420,7 @@ public Flux<Payload> requestChannel(Publisher<Payload> payloads) {
419420
ByteBufAllocator allocator = rule.alloc();
420421
final TestRequestInterceptor testRequestInterceptor = new TestRequestInterceptor();
421422
rule.setRequestInterceptor(testRequestInterceptor);
422-
for (int i = 0; i < 10000; i++) {
423+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
423424
FluxSink<Payload>[] sinks = new FluxSink[1];
424425
AssertSubscriber<Payload> assertSubscriber = AssertSubscriber.create();
425426
rule.setAcceptingSocket(
@@ -514,7 +515,7 @@ public void checkNoLeaksOnRacingBetweenDownstreamCancelAndOnNextFromRequestStrea
514515
ByteBufAllocator allocator = rule.alloc();
515516
final TestRequestInterceptor testRequestInterceptor = new TestRequestInterceptor();
516517
rule.setRequestInterceptor(testRequestInterceptor);
517-
for (int i = 0; i < 10000; i++) {
518+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
518519
FluxSink<Payload>[] sinks = new FluxSink[1];
519520

520521
rule.setAcceptingSocket(
@@ -553,7 +554,7 @@ public void checkNoLeaksOnRacingBetweenDownstreamCancelAndOnNextFromRequestRespo
553554
ByteBufAllocator allocator = rule.alloc();
554555
final TestRequestInterceptor testRequestInterceptor = new TestRequestInterceptor();
555556
rule.setRequestInterceptor(testRequestInterceptor);
556-
for (int i = 0; i < 10000; i++) {
557+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
557558
Operators.MonoSubscriber<Payload, Payload>[] sources = new Operators.MonoSubscriber[1];
558559

559560
rule.setAcceptingSocket(

‎rsocket-core/src/test/java/io/rsocket/core/ReconnectMonoTests.java

Lines changed: 20 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818

1919
import static org.junit.Assert.assertEquals;
2020

21+
import io.rsocket.RaceTestConstants;
2122
import io.rsocket.internal.subscriber.AssertSubscriber;
2223
import java.io.IOException;
2324
import java.time.Duration;
@@ -59,7 +60,7 @@ public class ReconnectMonoTests {
5960
public void shouldExpireValueOnRacingDisposeAndNext() {
6061
Hooks.onErrorDropped(t -> {});
6162
Hooks.onNextDropped(System.out::println);
62-
for (int i = 0; i < 10000; i++) {
63+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
6364
final int index = i;
6465
final CoreSubscriber<? super String>[] monoSubscribers = new CoreSubscriber[1];
6566
Subscription mockSubscription = Mockito.mock(Subscription.class);
@@ -108,7 +109,7 @@ public void subscribe(CoreSubscriber<? super String> actual) {
108109
@Test
109110
public void shouldNotifyAllTheSubscribersUnderRacingBetweenSubscribeAndComplete() {
110111
Hooks.onErrorDropped(t -> {});
111-
for (int i = 0; i < 10000; i++) {
112+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
112113
final TestPublisher<String> cold =
113114
TestPublisher.createNoncompliant(TestPublisher.Violation.REQUEST_OVERFLOW);
114115

@@ -151,7 +152,7 @@ public void shouldNotifyAllTheSubscribersUnderRacingBetweenSubscribeAndComplete(
151152
@Test
152153
public void shouldNotExpireNewlyResolvedValueIfSubscribeIsRacingWithInvalidate() {
153154
Hooks.onErrorDropped(t -> {});
154-
for (int i = 0; i < 10000; i++) {
155+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
155156
final int index = i;
156157
final TestPublisher<String> cold =
157158
TestPublisher.createNoncompliant(TestPublisher.Violation.REQUEST_OVERFLOW);
@@ -211,7 +212,7 @@ public void shouldNotExpireNewlyResolvedValueIfSubscribeIsRacingWithInvalidate()
211212
@Test
212213
public void shouldNotExpireNewlyResolvedValueIfSubscribeIsRacingWithInvalidates() {
213214
Hooks.onErrorDropped(t -> {});
214-
for (int i = 0; i < 10000; i++) {
215+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
215216
final int index = i;
216217
final TestPublisher<String> cold =
217218
TestPublisher.createNoncompliant(TestPublisher.Violation.REQUEST_OVERFLOW);
@@ -275,7 +276,7 @@ public void shouldNotExpireNewlyResolvedValueIfSubscribeIsRacingWithInvalidates(
275276
@Test
276277
public void shouldNotExpireNewlyResolvedValueIfBlockIsRacingWithInvalidate() {
277278
Hooks.onErrorDropped(t -> {});
278-
for (int i = 0; i < 10000; i++) {
279+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
279280
final int index = i;
280281
final Mono<String> source =
281282
Mono.fromSupplier(
@@ -341,7 +342,7 @@ public String get() {
341342

342343
@Test
343344
public void shouldEstablishValueOnceInCaseOfRacingBetweenSubscribers() {
344-
for (int i = 0; i < 10000; i++) {
345+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
345346
final TestPublisher<String> cold = TestPublisher.createCold();
346347
cold.next("value" + i);
347348

@@ -388,7 +389,7 @@ public void shouldEstablishValueOnceInCaseOfRacingBetweenSubscribers() {
388389
@Test
389390
public void shouldEstablishValueOnceInCaseOfRacingBetweenSubscribeAndBlock() {
390391
Duration timeout = Duration.ofMillis(100);
391-
for (int i = 0; i < 10000; i++) {
392+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
392393
final TestPublisher<String> cold = TestPublisher.createCold();
393394
cold.next("value" + i);
394395

@@ -436,7 +437,7 @@ public void shouldEstablishValueOnceInCaseOfRacingBetweenSubscribeAndBlock() {
436437
@Test
437438
public void shouldEstablishValueOnceInCaseOfRacingBetweenBlocks() {
438439
Duration timeout = Duration.ofMillis(100);
439-
for (int i = 0; i < 10000; i++) {
440+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
440441
final TestPublisher<String> cold = TestPublisher.createCold();
441442
cold.next("value" + i);
442443

@@ -481,7 +482,7 @@ public void shouldEstablishValueOnceInCaseOfRacingBetweenBlocks() {
481482
@Test
482483
public void shouldExpireValueOnRacingDisposeAndNoValueComplete() {
483484
Hooks.onErrorDropped(t -> {});
484-
for (int i = 0; i < 10000; i++) {
485+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
485486
final TestPublisher<String> cold =
486487
TestPublisher.createNoncompliant(TestPublisher.Violation.REQUEST_OVERFLOW);
487488

@@ -520,7 +521,7 @@ public void shouldExpireValueOnRacingDisposeAndNoValueComplete() {
520521
@Test
521522
public void shouldExpireValueOnRacingDisposeAndComplete() {
522523
Hooks.onErrorDropped(t -> {});
523-
for (int i = 0; i < 10000; i++) {
524+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
524525
final TestPublisher<String> cold =
525526
TestPublisher.createNoncompliant(TestPublisher.Violation.REQUEST_OVERFLOW);
526527

@@ -561,7 +562,7 @@ public void shouldExpireValueOnRacingDisposeAndComplete() {
561562
public void shouldExpireValueOnRacingDisposeAndError() {
562563
Hooks.onErrorDropped(t -> {});
563564
RuntimeException runtimeException = new RuntimeException("test");
564-
for (int i = 0; i < 10000; i++) {
565+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
565566
final TestPublisher<String> cold =
566567
TestPublisher.createNoncompliant(TestPublisher.Violation.REQUEST_OVERFLOW);
567568

@@ -607,7 +608,7 @@ public void shouldExpireValueOnRacingDisposeAndError() {
607608
public void shouldExpireValueOnRacingDisposeAndErrorWithNoBackoff() {
608609
Hooks.onErrorDropped(t -> {});
609610
RuntimeException runtimeException = new RuntimeException("test");
610-
for (int i = 0; i < 10000; i++) {
611+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
611612
final TestPublisher<String> cold =
612613
TestPublisher.createNoncompliant(TestPublisher.Violation.REQUEST_OVERFLOW);
613614

@@ -884,19 +885,21 @@ public void shouldNotifyAllTheSubscribers() {
884885

885886
final ArrayList<AssertSubscriber<String>> subscribers = new ArrayList<>(200);
886887

887-
for (int i = 0; i < 100; i++) {
888+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
888889
final AssertSubscriber<String> subA = new AssertSubscriber<>();
889890
final AssertSubscriber<String> subB = new AssertSubscriber<>();
890891
subscribers.add(subA);
891892
subscribers.add(subB);
892893
RaceTestUtils.race(() -> reconnectMono.subscribe(subA), () -> reconnectMono.subscribe(subB));
893894
}
894895

895-
Assertions.assertThat(reconnectMono.resolvingInner.subscribers).hasSize(204);
896+
Assertions.assertThat(reconnectMono.resolvingInner.subscribers)
897+
.hasSize(RaceTestConstants.REPEATS * 2 + 4);
896898

897899
sub1.cancel();
898900

899-
Assertions.assertThat(reconnectMono.resolvingInner.subscribers).hasSize(203);
901+
Assertions.assertThat(reconnectMono.resolvingInner.subscribers)
902+
.hasSize(RaceTestConstants.REPEATS * 2 + 3);
900903

901904
publisher.next("value");
902905

@@ -915,7 +918,7 @@ public void shouldNotifyAllTheSubscribers() {
915918

916919
@Test
917920
public void shouldExpireValueExactlyOnceOnRacingBetweenInvalidates() {
918-
for (int i = 0; i < 10000; i++) {
921+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
919922
final TestPublisher<String> cold = TestPublisher.createCold();
920923
cold.next("value");
921924
cold.complete();
@@ -963,7 +966,7 @@ public void shouldExpireValueExactlyOnceOnRacingBetweenInvalidates() {
963966

964967
@Test
965968
public void shouldExpireValueExactlyOnceOnRacingBetweenInvalidateAndDispose() {
966-
for (int i = 0; i < 10000; i++) {
969+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
967970
final TestPublisher<String> cold = TestPublisher.createCold();
968971
cold.next("value");
969972
final int timeout = 10000;

‎rsocket-core/src/test/java/io/rsocket/core/RequestChannelRequesterFluxTest.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
import io.rsocket.FrameAssert;
2525
import io.rsocket.Payload;
2626
import io.rsocket.PayloadAssert;
27+
import io.rsocket.RaceTestConstants;
2728
import io.rsocket.buffer.LeaksTrackingByteBufAllocator;
2829
import io.rsocket.exceptions.ApplicationErrorException;
2930
import io.rsocket.frame.FrameType;
@@ -545,7 +546,7 @@ public void shouldHaveEventsDeliveredSeriallyWhenOutboundErrorRacingWithInboundS
545546

546547
Hooks.onErrorDropped(droppedErrors::add);
547548
try {
548-
for (int i = 0; i < 10000; i++) {
549+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
549550
final TestRequesterResponderSupport activeStreams = TestRequesterResponderSupport.client();
550551
final LeaksTrackingByteBufAllocator allocator = activeStreams.getAllocator();
551552
final TestDuplexConnection sender = activeStreams.getDuplexConnection();
@@ -706,7 +707,7 @@ public void shouldHaveEventsDeliveredSeriallyWhenOutboundErrorRacingWithInboundS
706707
@ValueSource(strings = {"complete", "cancel"})
707708
public void shouldRemoveItselfFromActiveStreamsWhenInboundAndOutboundAreTerminated(
708709
String outboundTerminationMode) {
709-
for (int i = 0; i < 10000; i++) {
710+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
710711
final TestRequesterResponderSupport activeStreams = TestRequesterResponderSupport.client();
711712
final LeaksTrackingByteBufAllocator allocator = activeStreams.getAllocator();
712713
final TestDuplexConnection sender = activeStreams.getDuplexConnection();

‎rsocket-core/src/test/java/io/rsocket/core/RequestChannelResponderSubscriberTest.java

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@
2828
import io.rsocket.FrameAssert;
2929
import io.rsocket.Payload;
3030
import io.rsocket.PayloadAssert;
31+
import io.rsocket.RaceTestConstants;
3132
import io.rsocket.buffer.LeaksTrackingByteBufAllocator;
3233
import io.rsocket.exceptions.ApplicationErrorException;
3334
import io.rsocket.frame.FrameType;
@@ -270,7 +271,7 @@ public void requestNFrameShouldBeSentOnSubscriptionAndThenSeparately(String comp
270271

271272
@Test
272273
public void streamShouldWorkCorrectlyWhenRacingHandleCompleteWithSubscription() {
273-
for (int i = 0; i < 10000; i++) {
274+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
274275
final TestRequesterResponderSupport activeStreams = TestRequesterResponderSupport.client();
275276
final LeaksTrackingByteBufAllocator allocator = activeStreams.getAllocator();
276277
final TestDuplexConnection sender = activeStreams.getDuplexConnection();
@@ -331,7 +332,7 @@ public void streamShouldWorkCorrectlyWhenRacingHandleCompleteWithSubscription()
331332
public void streamShouldWorkCorrectlyWhenRacingHandleErrorWithSubscription() {
332333
ApplicationErrorException applicationErrorException = new ApplicationErrorException("test");
333334

334-
for (int i = 0; i < 10000; i++) {
335+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
335336
final TestRequesterResponderSupport activeStreams = TestRequesterResponderSupport.client();
336337
final LeaksTrackingByteBufAllocator allocator = activeStreams.getAllocator();
337338
final Payload firstPayload = TestRequesterResponderSupport.randomPayload(allocator);
@@ -377,7 +378,7 @@ public void streamShouldWorkCorrectlyWhenRacingHandleErrorWithSubscription() {
377378
public void streamShouldWorkCorrectlyWhenRacingOutboundErrorWithSubscription() {
378379
RuntimeException exception = new RuntimeException("test");
379380

380-
for (int i = 0; i < 10000; i++) {
381+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
381382
final TestRequesterResponderSupport activeStreams = TestRequesterResponderSupport.client();
382383
final LeaksTrackingByteBufAllocator allocator = activeStreams.getAllocator();
383384
final Payload firstPayload = TestRequesterResponderSupport.randomPayload(allocator);
@@ -425,7 +426,7 @@ public void streamShouldWorkCorrectlyWhenRacingOutboundErrorWithSubscription() {
425426

426427
@Test
427428
public void streamShouldWorkCorrectlyWhenRacingHandleCancelWithSubscription() {
428-
for (int i = 0; i < 10000; i++) {
429+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
429430
final TestRequesterResponderSupport activeStreams = TestRequesterResponderSupport.client();
430431
final LeaksTrackingByteBufAllocator allocator = activeStreams.getAllocator();
431432
final Payload firstPayload = TestRequesterResponderSupport.randomPayload(allocator);
@@ -493,7 +494,7 @@ public void shouldHaveEventsDeliveredSeriallyWhenOutboundErrorRacingWithInboundS
493494

494495
Hooks.onErrorDropped(droppedErrors::add);
495496
try {
496-
for (int i = 0; i < 10000; i++) {
497+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
497498
final TestRequesterResponderSupport activeStreams = TestRequesterResponderSupport.client();
498499
final LeaksTrackingByteBufAllocator allocator = activeStreams.getAllocator();
499500
final TestDuplexConnection sender = activeStreams.getDuplexConnection();
@@ -656,7 +657,7 @@ public void shouldHaveNoLeaksOnReassemblyAndCancelRacing(String terminationMode)
656657
final Payload oversizePayload =
657658
DefaultPayload.create(new byte[FRAME_LENGTH_MASK], new byte[FRAME_LENGTH_MASK]);
658659

659-
for (int i = 0; i < 10000; i++) {
660+
for (int i = 0; i < RaceTestConstants.REPEATS; i++) {
660661
final TestRequesterResponderSupport activeStreams = TestRequesterResponderSupport.client();
661662
final LeaksTrackingByteBufAllocator allocator = activeStreams.getAllocator();
662663
final TestDuplexConnection sender = activeStreams.getDuplexConnection();

0 commit comments

Comments
 (0)