re_viewport 0.12.1

The central viewport panel of the Rerun viewer.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81

use std::collections::BTreeMap;

use ahash::HashMap;
use rayon::prelude::*;

use re_viewer_context::{
    SpaceViewClassIdentifier, SpaceViewId, SystemExecutionOutput, ViewQuery, ViewerContext,
};

use crate::{space_view_highlights::highlights_for_space_view, SpaceViewBlueprint};

pub fn create_and_run_space_view_systems(
    ctx: &ViewerContext<'_>,
    space_view_class: SpaceViewClassIdentifier,
    query: &ViewQuery<'_>,
) -> SystemExecutionOutput {
    re_tracing::profile_function!(space_view_class.as_str());

    let context_systems = {
        re_tracing::profile_wait!("ViewContextSystem::execute");
        let mut context_systems = ctx
            .space_view_class_registry
            .new_context_collection(space_view_class);
        context_systems
            .systems
            .par_iter_mut()
            .for_each(|(_name, system)| {
                re_tracing::profile_scope!("ViewContextSystem::execute", _name.as_str());
                system.execute(ctx, query);
            });
        context_systems
    };

    re_tracing::profile_wait!("VisualizerSystem::execute");
    let mut view_systems = ctx
        .space_view_class_registry
        .new_visualizer_collection(space_view_class);
    let draw_data = view_systems
        .systems
        .par_iter_mut()
        .map(|(name, part)| {
            re_tracing::profile_scope!("VisualizerSystem::execute", name.as_str());
            match part.execute(ctx, query, &context_systems) {
                Ok(part_draw_data) => part_draw_data,
                Err(err) => {
                    re_log::error_once!("Error executing visualizer {name:?}: {err}");
                    Vec::new()
                }
            }
        })
        .flatten()
        .collect();

    SystemExecutionOutput {
        view_systems,
        context_systems,
        draw_data,
    }
}

pub fn execute_systems_for_space_views<'a>(
    ctx: &'a ViewerContext<'a>,
    mut space_views_to_execute: Vec<SpaceViewId>,
    space_views: &'a BTreeMap<SpaceViewId, SpaceViewBlueprint>,
) -> HashMap<SpaceViewId, (ViewQuery<'a>, SystemExecutionOutput)> {
    let Some(time_int) = ctx.rec_cfg.time_ctrl.read().time_int() else {
        return HashMap::default();
    };

    re_tracing::profile_wait!("execute_systems");

    space_views_to_execute
        .par_drain(..)
        .filter_map(|space_view_id| {
            let space_view_blueprint = space_views.get(&space_view_id)?;
            let highlights = highlights_for_space_view(ctx, space_view_id);
            let output = space_view_blueprint.execute_systems(ctx, time_int, highlights);
            Some((space_view_id, output))
        })
        .collect::<HashMap<_, _>>()
}