Skip to content
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

Extra poll after receiving commit data #866

Merged
merged 4 commits into from
Aug 20, 2019
Merged

Conversation

ennru
Copy link
Member

@ennru ennru commented Aug 19, 2019

Purpose

Trigger a poll after receiving commit data so that the commit will be executed earlier than the scheduled poll, but still allowing more commits to arrive before the poll is made.

References

Follow-up on #862 as the "at-most-once" benchmarks showed very slow consumption when committing one message at a time.

* performance is much improved by collecting more requests/commits before performing the poll.
*/
private def requestExtraPoll(): Unit =
if (!delayedPollInFlight) {
Copy link
Contributor

Choose a reason for hiding this comment

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

I think the flag should match the method, so extraPollInFlight or requestDelayedPoll().

Copy link
Contributor

@2m 2m left a comment

Choose a reason for hiding this comment

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

LGTM with a name nitpick.

ennru added 3 commits August 20, 2019 10:11

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
@ennru ennru merged commit 685be43 into akka:master Aug 20, 2019
@ennru ennru deleted the trigger-poll branch August 20, 2019 15:41
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

2 participants