relibc_ralloc/tests/mpsc.rs

extern crate ralloc;

use std::thread;
use std::sync::mpsc;

#[test]
fn test() {
    {
        {
            let (tx, rx) = mpsc::channel::<Box<u64>>();
            thread::spawn(move || {
                tx.send(Box::new(0xBABAFBABAF)).unwrap();
                tx.send(Box::new(0xDEADBEAF)).unwrap();
                tx.send(Box::new(0xDECEA5E)).unwrap();
                tx.send(Box::new(0xDEC1A551F1E5)).unwrap();
            });
            assert_eq!(*rx.recv().unwrap(), 0xBABAFBABAF);
            assert_eq!(*rx.recv().unwrap(), 0xDEADBEAF);
            assert_eq!(*rx.recv().unwrap(), 0xDECEA5E);
            assert_eq!(*rx.recv().unwrap(), 0xDEC1A551F1E5);
        }

        let (tx, rx) = mpsc::channel();
        for _ in 0..0xFFFF {
            let tx = tx.clone();
            thread::spawn(move || {
                tx.send(Box::new(0xFA11BAD)).unwrap();
            });
        }
        for _ in 0..0xFFFF {
            assert_eq!(*rx.recv().unwrap(), 0xFA11BAD);
        }
    }

    ralloc::lock().debug_assert_no_leak();
}