Skip to content

adds jcstress for requester and responder operators - #999

Merged
OlegDokuka merged 2 commits into
masterfrom
enhancement/jcstresstests
Jun 7, 2021
Merged

adds jcstress for requester and responder operators#999
OlegDokuka merged 2 commits into
masterfrom
enhancement/jcstresstests

Conversation

@OlegDokuka

Copy link
Copy Markdown
Member

Adds JCStressTests Support

Motivation:

JCStress is a proven tool for making sure correctness of concurrency model used in various places

Modifications:

Adds list of JCStress tests

Result:

Better verification of concurrency related issues

Signed-off-by: Oleh Dokuka oleh.dokuka@icloud.com

@OlegDokuka
OlegDokukaforce-pushed the enhancement/jcstresstests branch from 18c96b4 to de54cfdCompareMarch 27, 2021 22:08
@OlegDokukaOlegDokuka added this to the 1.1.1 milestone Mar 27, 2021
Operators.onErrorDropped(t, Context.empty());
return;
}

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Also update the copy in loadbalance?

Copy link
Copy Markdown
MemberAuthor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

done

import reactor.core.publisher.Operators;
import reactor.util.context.Context;

public class StressSubscriber<T> implements CoreSubscriber<T> {

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

StressTestSubscriber perhaps?

import reactor.core.CoreSubscriber;
import reactor.core.publisher.Operators;

public class StressSubscription<T> implements Subscription {

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Likewise StressTestSubscription

Comment on lines +61 to +82
public volatile boolean concurrentOnNext;

public volatile boolean concurrentOnError;

public volatile boolean concurrentOnComplete;

public volatile boolean concurrentOnSubscribe;

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

These are set but not used. Am I missing something? There are others that are not used as well like droppedErrors, onNextDiscarded, and error.

Copy link
Copy Markdown
MemberAuthor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

it is ported from reactor-core and should be used in the upcoming updates

@OlegDokuka
OlegDokukaforce-pushed the enhancement/jcstresstests branch 7 times, most recently from 893b7ea to 3296d72CompareMay 20, 2021 09:30
@OlegDokuka
OlegDokuka marked this pull request as ready for review May 24, 2021 09:12
@OlegDokuka
OlegDokukaforce-pushed the enhancement/jcstresstests branch 4 times, most recently from 20ad9dc to c81c408CompareMay 24, 2021 13:46
@OlegDokukaOlegDokuka changed the title adds jcstress supportadds jcstress for requester and responder operatorsMay 24, 2021
@OlegDokukaOlegDokuka linked an issue May 24, 2021 that may be closed by this pull request
8 tasks
@OlegDokuka
OlegDokuka changed the base branch from master to 1.0.xMay 24, 2021 13:52
@OlegDokuka
OlegDokuka changed the base branch from 1.0.x to masterMay 24, 2021 13:52
Signed-off-by: Oleh Dokuka <oleh.dokuka@icloud.com>
Signed-off-by: Oleh Dokuka <oleh.dokuka@icloud.com>
@OlegDokuka
OlegDokukaforce-pushed the enhancement/jcstresstests branch from c81c408 to 61cf1cfCompareJune 7, 2021 13:01
@OlegDokuka
OlegDokuka merged commit de60762 into masterJun 7, 2021
@OlegDokuka
OlegDokuka deleted the enhancement/jcstresstests branch June 7, 2021 13:57
Sign up for freeto join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Add JCStress for requester and responder Operators

2 participants

@OlegDokuka@rstoyanchev