fn process_fs_queue<F: FileSystem + Sync>(
    queue: &mut Queue,
    server: &Arc<Server<F>>,
    tube: &Arc<Mutex<Tube>>,
    slot: u32
) -> Result<()>