-
Notifications
You must be signed in to change notification settings - Fork 745
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
Revert #1409 partially #1603
Revert #1409 partially #1603
Conversation
|
||
if delayed_messages_count > 0 { | ||
// Here we wait for all the delayed messages to be sent. | ||
let _timer = metrics.time_delayed_rx_events(); // Dropped after `await` is completed |
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.
This metric is useful, why not keep it ?
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.
This PR just reverts the "bad things", so I've decided to leave it as simple and quick as possible. I'm working on a better version in the meantime on top of this one.
bot merge |
@vstakhov |
Futures channels that are used by default has a side effect of
Sender::Clone
that efficiently increases the capacity of the bounded channel by one. This PR fixes the undesired backpressure removal that was caused by the #1409. This issue has been discovered by @sandreim during Versi testing and needs to be treated as critical that should not be included in any release without this reversion.This PR reverts the original behaviour that can be slightly improved without cloning the sender.