Method update

crates/firewheel-graph/src/context.rs:813–923

Update the firewheel context. This must be called regularly (i.e. once every frame).

(&mut self)

    /// Retrieve the latest performance profiling data.
    pub fn profiling_data(&mut self) -> &ProfilingData {
        self.profiler_rx.fetch_info()
    }

    /// Update the firewheel context.
    ///
    /// This must be called regularly (i.e. once every frame).
    pub fn update(&mut self) -> Result<(), UpdateError> {
        self.logger_rx.flush(
            |msg| {
                #[cfg(feature = "tracing")]
                tracing::error!("{}", msg);

                #[cfg(all(feature = "log", not(feature = "tracing")))]
                log::error!("{}", msg);

                let _ = msg;
            },
            |msg| {
                #[cfg(feature = "tracing")]
                tracing::debug!("{}", msg);

                #[cfg(all(feature = "log", not(feature = "tracing")))]
                log::debug!("{}", msg);

                let _ = msg;
            },
        );

        firewheel_core::collector::GlobalRtGc::collect();

        for msg in self.from_processor_rx.pop_iter() {
            match msg {
                ProcessorToContextMsg::DropEventGroup(mut event_group) => {
                    event_group.clear();
                    self.event_group_pool.push(event_group);
                }
                ProcessorToContextMsg::DropSchedule(schedule_data) => {
                    self.graph.drop_old_schedule_data(schedule_data);
                }
                #[cfg(feature = "musical_transport")]
                ProcessorToContextMsg::DropTransportState(transport_state) => {
                    if self.transport_state_alloc_reuse.is_none() {
                        self.transport_state_alloc_reuse = Some(transport_state);
                    }
                }
                #[cfg(feature = "scheduled_events")]
                ProcessorToContextMsg::DropClearScheduledEvents(msgs) => {
                    let _ = msgs;
                }
            }
        }

        self.graph
            .update(self.stream_info.as_ref(), &mut self.event_group);

        if self.is_active() {
            if self.graph.needs_compile() {
                let schedule_data = self.graph.compile(self.stream_info.as_ref().unwrap())?;