magmaus3/continuwuity
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

remove the db pool queue full warning

Browse source 
Signed-off-by: Jason Volk <jason@zemos.net>
This commit is contained in:
Jason Volk 2025-04-04 02:56:54 +00:00
parent d036394ec7
commit 00f7745ec4
1 changed files with 1 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

9
src/database/pool.rs
View file

@ -12,7 +12,7 @@ use std::{
use async_channel::{QueueStrategy, Receiver, RecvError, Sender}; use async_channel::{QueueStrategy, Receiver, RecvError, Sender};
use conduwuit::{ use conduwuit::{
Error, Result, Server, debug, debug_warn, err, error, implement, Error, Result, Server, debug, err, error, implement,
result::DebugInspect, result::DebugInspect,
smallvec::SmallVec, smallvec::SmallVec,
trace, trace,
@ -245,13 +245,6 @@ async fn execute(&self, queue: &Sender<Cmd>, cmd: Cmd) -> Result {
self.queued_max.fetch_max(queue.len(), Ordering::Relaxed); self.queued_max.fetch_max(queue.len(), Ordering::Relaxed);
} }
if queue.is_full() {
debug_warn!(
capacity = ?queue.capacity(),
"pool queue is full"
);
}
queue queue
.send(cmd) .send(cmd)
.await .await