debug: bool,
) -> tokio::sync::mpsc::Receiver<Result<tokio_openssl::SslStream<tokio::net::TcpStream>, Error>> {
- let (sender, receiver) = tokio::sync::mpsc::channel(1024);
+ const MAX_PENDING_ACCEPTS: usize = 1024;
- let accept_counter = Arc::new(());
+ let (sender, receiver) = tokio::sync::mpsc::channel(MAX_PENDING_ACCEPTS);
- const MAX_PENDING_ACCEPTS: usize = 1024;
+ let accept_counter = Arc::new(());
tokio::spawn(async move {
loop {
let mut sender = sender.clone();
if Arc::strong_count(&accept_counter) > MAX_PENDING_ACCEPTS {
- if debug {
- eprintln!("connection rejected - to many open connections");
- }
+ eprintln!("connection rejected - to many open connections");
continue;
}