Please enable JavaScript.

Coggle requires JavaScript to display documents.

tokio_uring - Coggle Diagram

- - - - tokio::runtime::Runtime
        
        tokio::runtime::Builder::new_current_thread()
      - driver::Handle
        
        Rc<RefCell<Driver>>
        
        Driver
        
        Ops
        
        Slab<op::Lifecycle>
        
        enum Lifecycle
        
        5 more items...
        
        Slab<op::Completion>
        
        type Completion = SlabListEntry<CqeResult>
        
        1 more item...
        
        IoUring
        
        dyn FixedBuffers
      - functions
        
        start_uring_wakes_task()
        
        called in new()
        
        local.spawn_local(drive_uring_wakes(async_driver_handle));
        
        drive_uring_wakes
        
        async fn
        
        loop {
        let mut guard = driver.readable().await.unwrap();
        guard.get_inner().dispatch_completions();
        guard.clear_ready();
        }
        
        when to submit ops?
        
        block_on
        
        let res = self.tokio_rt.block_on(self.local.run_until(std::future::poll_fn(|cx| {future.as_mut().poll(cx)})));