Function fifo_ordering

nodedb-crdt/src/deferred.rs:333–363

()

    #[test]
    fn fifo_ordering() {
        let mut queue = DeferredQueue::new(10);
        let now = 1000;

        // Enqueue three entries with same retry time
        for i in 0..3 {
            queue.enqueue(
                40 + i,
                0,
                0,
                format!("delta{}", i).into_bytes(),
                "posts".to_string(),
                "posts_author_fk".to_string(),
                0,
                3,
                now,
                500,
                60,
            );
        }

        assert_eq!(queue.len(), 3);

        let ready = queue.poll_ready(now + 500);
        assert_eq!(ready.len(), 3);

        // Verify FIFO order by peer_id
        assert_eq!(ready[0].peer_id, 40);
        assert_eq!(ready[1].peer_id, 41);
        assert_eq!(ready[2].peer_id, 42);
    }

    #[test]
    fn capacity_limit() {