fn start_tracking(&mut self, id: GlobalId) {
        let frontier = timely::progress::frontier::MutableAntichain::new_bottom(T::minimum());
        match self.uppers.entry(id) {
            Entry::Occupied(entry) => {
                // We're about to start tracking an already-bound ID. This means that the controller
                // needs to be informed about the `upper`.
                let mut change_batch = ChangeBatch::new_from(T::minimum(), -1);
                change_batch.extend(entry.get().frontier().iter().copied().map(|t| (t, 1)));
                self.responses
                    .push_back(ComputeResponse::FrontierUppers(vec![(id, change_batch)]));
            }
            Entry::Vacant(entry) => {
                entry.insert(frontier);
            }
        }
    }
/// Start tracking of a id within an instance.
///
/// If we're already tracking this ID, it means that the controller lost connection and
/// reconnected (or has a bug). We're updating the controller's upper to match the local state.
Start tracking of a id within an instance.
If we're already tracking this ID, it means that the controller lost connection and
reconnected (or has a bug). We're updating the controller's upper to match the local state.
Start tracking of a id within an instance . If we ' re already tracking this ID it means that the controller lost connection and reconnected ( or has a bug ) . We ' re updating the controller ' s upper to match the local state .
fn start_tracking(&mut self, id: GlobalId) {
        let frontier = timely::progress::frontier::MutableAntichain::new_bottom(T::minimum());
        match self.uppers.entry(id) {
            Entry::Occupied(entry) => {
                // We're about to start tracking an already-bound ID. This means that the controller
                // needs to be informed about the `upper`.
                let mut change_batch = ChangeBatch::new_from(T::minimum(), -1);
                change_batch.extend(entry.get().frontier().iter().copied().map(|t| (t, 1)));
                self.responses
                    .push_back(ComputeResponse::FrontierUppers(vec![(id, change_batch)]));
            }
            Entry::Vacant(entry) => {
                entry.insert(frontier);
            }
        }
    }
fn start_tracking ( & mut self , id : GlobalId ) { let frontier = timely :: progress :: frontier :: MutableAntichain :: new_bottom ( T :: minimum ( ) ) ; match self . uppers . entry ( id ) { Entry :: Occupied ( entry ) => { // We're about to start tracking an already-bound ID. This means that the controller // needs to be informed about the `upper`. let mut change_batch = ChangeBatch :: new_from ( T :: minimum ( ) , - 1 ) ; change_batch . extend ( entry . get ( ) . frontier ( ) . iter ( ) . copied ( ) . map ( | t | ( t , 1 ) ) ) ; self . responses . push_back ( ComputeResponse :: FrontierUppers ( vec ! [ ( id change_batch ) ] ) ) ; } Entry :: Vacant ( entry ) => { entry . insert ( frontier ) ; } } }
Start tracking of a id within an instance.
Start tracking of a id within an instance .
&mut self
id
GlobalId
&mut self
id
GlobalId