-
Notifications
You must be signed in to change notification settings - Fork 115
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
Fix the issue gRPC notify thread blocked #965
Conversation
…h configurable max buffer size Signed-off-by: Xin Li <[email protected]>
…istener, update test cases Signed-off-by: Xin Li <[email protected]>
Codecov Report
@@ Coverage Diff @@
## master #965 +/- ##
============================================
+ Coverage 86.81% 86.86% +0.04%
Complexity 210 210
============================================
Files 168 168
Lines 4233 4239 +6
Branches 466 466
============================================
+ Hits 3675 3682 +7
+ Misses 411 409 -2
- Partials 147 148 +1
Continue to review full report at Codecov.
|
…ected by the slow subscriber Signed-off-by: Xin Li <[email protected]>
hedera-mirror-grpc/src/test/java/com/hedera/mirror/grpc/listener/AbstractTopicListenerTest.java
Show resolved
Hide resolved
Signed-off-by: Xin Li <[email protected]>
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.
LGTM
hedera-mirror-grpc/src/main/java/com/hedera/mirror/grpc/controller/ConsensusController.java
Outdated
Show resolved
Hide resolved
...ra-mirror-grpc/src/test/java/com/hedera/mirror/grpc/listener/NotifyingTopicListenerTest.java
Outdated
Show resolved
Hide resolved
Signed-off-by: Xin Li <[email protected]>
Signed-off-by: Xin Li <[email protected]>
* Fix the issue gRPC notify thread blocked (hiero-ledger#965) Add backpressure buffer with ERROR strategy to notifying and shared polling topic listeners. When overflow happens, the controller will send a gRPC error after all buffered messages and disconnect the client. Signed-off-by: Xin Li <[email protected]> * Performance test HighTPS HCS publish improvements (hiero-ledger#970) * Performance updates to high tps module - Adds additional stats - Allow publish of stats interval to be configured - Does some reorganizing of code - Sets JMeter and java flags to allow for improved publish performance and prevent memory exhaustion Signed-off-by: Nana-EC <[email protected]> * Bump spring-boot-starter-parent from 2.2.7.RELEASE to 2.3.3.RELEASE (hiero-ledger#961) Bumps [spring-boot-starter-parent](https://github.com/spring-projects/spring-boot) from 2.2.7.RELEASE to 2.3.3.RELEASE. - [Release notes](https://github.com/spring-projects/spring-boot/releases) - [Commits](spring-projects/spring-boot@v2.2.7.RELEASE...v2.3.3.RELEASE) Signed-off-by: Nana-EC <[email protected]> Signed-off-by: dependabot[bot] <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Xin Li <[email protected]> Co-authored-by: Nana-EC <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Add backpressure buffer with ERROR strategy to notifying and shared polling topic listeners. When overflow happens, the controller will send a gRPC error after all buffered messages and disconnect the client. Signed-off-by: Xin Li <[email protected]>
Add backpressure buffer with ERROR strategy to notifying and shared polling topic listeners. When overflow happens, the controller will send a gRPC error after all buffered messages and disconnect the client. Signed-off-by: Xin Li <[email protected]> Signed-off-by: Nana-EC <[email protected]>
This reverts commit e301647.
This reverts commit e301647. Signed-off-by: Xin Li <[email protected]>
This reverts commit e301647. Signed-off-by: Xin Li <[email protected]>
Detailed description:
Add backpressure buffer with ERROR strategy to notifying and shared polling topic listeners. When overflow happens, the controller will send a gRPC error after all buffered messages and disconnect the client.
Which issue(s) this PR fixes:
Fixes #945
Special notes for your reviewer:
Checklist