mirrors/lemmy
1
0
Fork 0
mirror of https://github.com/LemmyNet/lemmy.git synced 2024-11-26 19:31:05 +00:00
Code Issues Projects Releases Wiki Activity

add assert

Browse source
This commit is contained in:
Felix Ableitner 2024-05-23 13:12:30 +02:00
parent d4f26da00e
commit b7cc908cb2
1 changed files with 8 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
crates/federate/src/lib.rs
View file

@ -46,6 +46,7 @@ impl SendManager {
pub fn new(opts: Opts, context: FederationConfig<LemmyContext>) -> Self { pub fn new(opts: Opts, context: FederationConfig<LemmyContext>) -> Self {
assert!(opts.process_count > 0); assert!(opts.process_count > 0);
assert!(opts.process_index > 0); assert!(opts.process_index > 0);
assert!(opts.process_index <= opts.process_count);
let (stats_sender, stats_receiver) = unbounded_channel(); let (stats_sender, stats_receiver) = unbounded_channel();
Self { Self {
@ -61,11 +62,10 @@ impl SendManager {
} }
pub fn run(mut self) -> CancellableTask { pub fn run(mut self) -> CancellableTask {
let cancel = CancellableTask::spawn(WORKER_EXIT_TIMEOUT, move |cancel| async move { CancellableTask::spawn(WORKER_EXIT_TIMEOUT, move |cancel| async move {
self.do_loop(cancel).await.unwrap(); self.do_loop(cancel).await.unwrap();
self.cancel().await.unwrap(); self.cancel().await.unwrap();
}); })
cancel
} }
async fn do_loop(&mut self, cancel: CancellationToken) -> LemmyResult<()> { async fn do_loop(&mut self, cancel: CancellationToken) -> LemmyResult<()> {
@ -243,21 +243,19 @@ mod test {
#[serial] #[serial]
async fn test_send_manager_processes() -> LemmyResult<()> { async fn test_send_manager_processes() -> LemmyResult<()> {
let active = Arc::new(Mutex::new(vec![])); let active = Arc::new(Mutex::new(vec![]));
let execute = |count, index, len, active: Arc<Mutex<Vec<InstanceId>>>| async move { let execute = |count, index, active: Arc<Mutex<Vec<InstanceId>>>| async move {
let mut data = TestData::init(count, index).await?; let mut data = TestData::init(count, index).await?;
data.run().await?; data.run().await?;
assert_eq!(len, data.send_manager.workers.len()); assert_eq!(1, data.send_manager.workers.len());
for k in data.send_manager.workers.keys() { for k in data.send_manager.workers.keys() {
active.lock().unwrap().push(*k); active.lock().unwrap().push(*k);
} }
data.cleanup().await?; data.cleanup().await?;
Ok::<(), LemmyError>(()) Ok::<(), LemmyError>(())
}; };
execute(3, 1, 1, active.clone()).await?; execute(3, 1, active.clone()).await?;
execute(3, 2, 1, active.clone()).await?; execute(3, 2, active.clone()).await?;
execute(3, 3, 1, active.clone()).await?; execute(3, 3, active.clone()).await?;
execute(3, 4, 0, active.clone()).await?;
execute(3, 6, 0, active.clone()).await?;
// Should run exactly three workers // Should run exactly three workers
assert_eq!(3, active.lock().unwrap().len()); assert_eq!(3, active.lock().unwrap().len());