rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-05-24 00:20:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Terminate subscription if channel is full.

Browse Source 
Might help as a hotfix, but need to understand root better.
This commit is contained in:
Arseny Sher
2022-12-15 12:36:57 +04:00
parent bf3ac2be2d
commit 9fd9a15305
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
storage_broker/src/bin/storage_broker.rs
View File

@@ -369,7 +369,9 @@ impl BrokerService for Broker {
Err(RecvError::Lagged(skipped_msg)) => {
missed_msgs += skipped_msg;
if let Poll::Ready(_) = futures::poll!(Box::pin(warn_interval.tick())) {
warn!("dropped {} messages, channel is full", missed_msgs);
warn!("subscription id={}, key={:?}, addr={:?} dropped {} messages, channel is full",
subscriber.id, subscriber.key, subscriber.remote_addr, missed_msgs);
Err(Status::new(Code::Internal, "full channel"))?;
missed_msgs = 0;
}
}