-
Notifications
You must be signed in to change notification settings - Fork 3.8k
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
[#9264] Guarded ping only when stream is ready #9266
Conversation
@@ -91,6 +94,10 @@ public void run() { | |||
public StreamObserver<PPing> pingSession(final StreamObserver<PPing> responseObserver) { | |||
final StreamObserver<PPing> request = new StreamObserver<PPing>() { | |||
private final AtomicBoolean first = new AtomicBoolean(false); | |||
private final Runnable warnNotReady = new ThrottledRunnable(() -> { |
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.
ThrottledLogger would be simpler.
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 removed ThrottledRunnable :)
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
Codecov Report
@@ Coverage Diff @@
## master #9266 +/- ##
============================================
- Coverage 39.61% 39.60% -0.01%
- Complexity 11791 11829 +38
============================================
Files 3394 3407 +13
Lines 91358 91540 +182
Branches 10127 10159 +32
============================================
+ Hits 36188 36253 +65
- Misses 52084 52187 +103
- Partials 3086 3100 +14
Help us with your feedback. Take ten seconds to tell us how you rate us. Have a feature suggestion? Share it here. |
6c65648
to
8c04203
Compare
8c04203
to
324a543
Compare
resolves #9264