-
-
Notifications
You must be signed in to change notification settings - Fork 114
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 leaking of pool.Message #381
Conversation
fb674c0
to
016aee1
Compare
c101f5b
to
4d45d54
Compare
Codecov Report
@@ Coverage Diff @@
## v3 #381 +/- ##
==========================================
- Coverage 70.39% 70.17% -0.22%
==========================================
Files 68 67 -1
Lines 5174 5089 -85
==========================================
- Hits 3642 3571 -71
+ Misses 1149 1136 -13
+ Partials 383 382 -1
Help us with your feedback. Take ten seconds to tell us how you rate us. Have a feature suggestion? Share it here. |
4d45d54
to
71b285c
Compare
@@ -462,8 +430,8 @@ func (b *BlockWise[C]) Handle(w *responsewriter.ResponseWriter[C], r *pool.Messa | |||
b.errors(fmt.Errorf("continueSendingMessage(%v): %w", r, err)) | |||
return | |||
} | |||
if b.autoCleanUpResponseCache && !more { | |||
b.RemoveFromResponseCache(token) | |||
if !more && sendingMessageCached.Data().Code() > codes.DELETE { |
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.
Are codes >
than codes.DELETE
invalid or why are only those codes deleted from cache?
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.
For codes GET,POST,PUT,DELETE, we want them to wait for pairing response and then delete them when the full response comes in or when timeout occurs.
71b285c
to
317fb99
Compare
No description provided.