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

use latest sccache, bump nix flake lock, cache everything in rust-cache

Browse source 
Signed-off-by: strawberry <strawberry@puppygock.gay>
This commit is contained in:
strawberry 2025-01-02 18:55:52 -05:00
parent 6c8a1b5e9b
commit 7a349fdc58
No known key found for this signature in database
5 changed files with 30 additions and 28 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/database/pool.rs
View file

@ -8,7 +8,7 @@ use std::{
},
};
use async_channel::{Receiver, RecvError, Sched, Sender};
use async_channel::{QueueStrategy, Receiver, RecvError, Sender};
use conduwuit::{
debug, debug_warn, defer, err, implement,
result::DebugInspect,
@ -71,13 +71,13 @@ const BATCH_INLINE: usize = 1;
#[implement(Pool)]
pub(crate) async fn new(server: &Arc<Server>) -> Result<Arc<Self>> {
const CHAN_SCHED: (Sched, Sched) = (Sched::Fifo, Sched::Lifo);
const CHAN_SCHED: (QueueStrategy, QueueStrategy) = (QueueStrategy::Fifo, QueueStrategy::Lifo);
let (total_workers, queue_sizes, topology) = configure(server);
let (senders, receivers) = queue_sizes
.into_iter()
.map(|cap| async_channel::bounded_with_sched(cap, CHAN_SCHED))
.map(|cap| async_channel::bounded_with_queue_strategy(cap, CHAN_SCHED))
.unzip();
let pool = Arc::new(Self {