Skip to content

KAFKA-7288 - Make sure no bytes buffered when relying on idle timeout in channel close test#6390

Merged
rajinisivaram merged 1 commit intoapache:trunkfrom
rajinisivaram:KAFKA-7288-selector-test-v2
Mar 7, 2019
Merged

KAFKA-7288 - Make sure no bytes buffered when relying on idle timeout in channel close test#6390
rajinisivaram merged 1 commit intoapache:trunkfrom
rajinisivaram:KAFKA-7288-selector-test-v2

Conversation

@rajinisivaram
Copy link
Copy Markdown
Contributor

SelectorTest.testCloseConnectionInClosingState sends and receives messages to get the channel into a state with staged receives and then waits for idle timeout to close the channel. When run with SSL, the channel may have buffered bytes that prevent the channel from being closed. Updated the test to wait until there are no buffered bytes as well. I have left the number of retries to achieve this state at 100, since my local runs always succeed the first time.

I wasn't able to recreate the failure with or without the fix.

Committer Checklist (excluded from commit message)

  • Verify design and implementation
  • Verify test coverage and CI build status
  • Verify documentation (including upgrade notes)

Copy link
Copy Markdown
Member

@ijuma ijuma left a comment

Choose a reason for hiding this comment

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

LGTM

@rajinisivaram
Copy link
Copy Markdown
Contributor Author

@ijuma Thanks for the review, merging to trunk and 2.2.

@rajinisivaram rajinisivaram merged commit 644ff6e into apache:trunk Mar 7, 2019
rajinisivaram added a commit that referenced this pull request Mar 7, 2019
… in channel close test (#6390)

SelectorTest.testCloseConnectionInClosingState sends and receives messages to get the channel into a state with staged receives and then waits for idle timeout to close the channel. When run with SSL, the channel may have buffered bytes that prevent the channel from being closed. Updated the test to wait until there are no buffered bytes as well.

Reviewers: Ismael Juma <ismael@juma.me.uk>
jonlee2 pushed a commit to linkedin/kafka that referenced this pull request Mar 8, 2019
… in channel close test (apache#6390)

SelectorTest.testCloseConnectionInClosingState sends and receives messages to get the channel into a state with staged receives and then waits for idle timeout to close the channel. When run with SSL, the channel may have buffered bytes that prevent the channel from being closed. Updated the test to wait until there are no buffered bytes as well.

Reviewers: Ismael Juma <ismael@juma.me.uk>
pengxiaolong pushed a commit to pengxiaolong/kafka that referenced this pull request Jun 14, 2019
… in channel close test (apache#6390)

SelectorTest.testCloseConnectionInClosingState sends and receives messages to get the channel into a state with staged receives and then waits for idle timeout to close the channel. When run with SSL, the channel may have buffered bytes that prevent the channel from being closed. Updated the test to wait until there are no buffered bytes as well.

Reviewers: Ismael Juma <ismael@juma.me.uk>
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.

2 participants