bytes: Cell<usize>,
    packets: Cell<usize>,

    out_packets: Cell<usize>,
    in_packets: Cell<usize>,

            bytes: Cell::new(0),
            packets: Cell::new(0),

            out_packets: Cell::new(0),
            in_packets: Cell::new(0),

        let msg = serde_json::to_string(&events).unwrap();

        let id = self.out_packets.get();
        let msg = serde_json::to_string(&(id, events)).unwrap();

        self.bytes.set(self.bytes.get() + msg.len() + 28);
        self.packets.set(self.packets.get() + 1);
        println!("message: {}", msg);
        println!("bytes: {} | packets: {}", self.bytes.get(), self.packets.get());

        println!("=> {}", msg);
        self.out_packets.set(self.out_packets.get() + 1);

                let msg = &buf[..len];
                match serde_json::from_slice(msg) {
                    Ok(events) => Some((events, addr)),
                    Err(e) => {
                        println!("{:?}: {}", e, String::from_utf8_lossy(msg));
                        None
                    },

                let msg = str::from_utf8(&buf[..len]).unwrap();
                let (id, events): (usize, Vec<io::Event>) = serde_json::from_str(msg).unwrap();
                // Debug
                println!("<= {}", msg);
                let expected_id = self.in_packets.get();
                if id < expected_id {
                    println!("^ old packet");
                    None
                } else {
                    if id > expected_id {
                        println!("^ lost {} packets", id - expected_id)
                    }
                    self.in_packets.set(id + 1);
                    Some((events, addr))

                    println!("{:?}", event);