Method try_enqueue

nodedb-bridge/src/wfq.rs:107–120

Attempt to enqueue `item` for `database_id`. Returns `Err(item)` if the total queue has reached capacity.

(&mut self, database_id: u64, item: T)

    /// Attempt to enqueue `item` for `database_id`. Returns `Err(item)` if the
    /// total queue has reached capacity.
    pub fn try_enqueue(&mut self, database_id: u64, item: T) -> Result<(), T> {
        if self.total >= self.capacity {
            return Err(item);
        }
        if let std::collections::hash_map::Entry::Vacant(e) = self.queues.entry(database_id) {
            e.insert(VirtualQueue::new());
            self.db_order.push_back(database_id);
        }
        // Safe: we just ensured the key exists.
        let vq = self.queues.get_mut(&database_id).expect("just inserted");
        vq.items.push_back(item);
        self.total += 1;
        Ok(())
    }

    /// Set (or update) the priority class for a database. Applied on the next
    /// `pop_next` call after this update.