New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
BounceMemberRule logging & fixes, smaller cluster in QueryBounceTest #10181
BounceMemberRule logging & fixes, smaller cluster in QueryBounceTest #10181
Conversation
0d5c2bf
to
8b18afd
Compare
Test PASSed. |
@@ -363,25 +388,33 @@ public void evaluate() throws Throwable { | |||
|
|||
// wait until all test tasks complete or one of them throws an exception | |||
private void waitForFutures(Future[] futures) { | |||
// do not wait more than 30 seconds | |||
long deadline = currentTimeMillis() + 30 * 1000; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I would make the timout a constant like TIMEOUT_SECONDS
and use TimeUnit.Seconds.toMillis(TIMEOUT_SECONDS)
here (and of course use the constant in the comment and warning log below as well).
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
thx, fixed
8b18afd
to
e50de90
Compare
|
Test PASSed. |
- Smaller cluster and test drivers size in QueryBounceTest to reduce probability of timeout - Added logging in BounceMemberRule for easier troubleshooting - Bounced members and test drivers with volatile read/write, as they are accessed by several threads - Bounce member thread is now a daemon thread
e50de90
to
5c4ca03
Compare
… QueryRunnable execution
5c4ca03
to
712443d
Compare
Test PASSed. |
run-lab-run |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
looks good 👍
Test PASSed. |
thanks @mdogan @Donnerbart |
@Test(timeout=...)
.AbstractHazelcastClassRunner
(eg when running within the IDE this is themain
thread)FailOnTimeoutStatement
that wraps every test to enforce the timeout spawns a separate thread that invokes the test method.BounceMemberRule.test*
will be invoked from this thread and will typically need to obtain at least a test driverHazelcastInstance
BounceMemberRule
that executes the member bouncing logic and updates the current cluster members inBounceMemberRule.members