fn handle_pending_applies(&mut self) {
        fail_point!("apply_pending_snapshot", |_| {});
        while !self.pending_applies.is_empty() {
            // should not handle too many applies than the number of files that can be ingested.
            // check level 0 every time because we can not make sure how does the number of level 0 files change.
            if self.ctx.ingest_maybe_stall() {
                break;
            }
            if let Some(Task::Apply { region_id, status }) = self.pending_applies.pop_front() {
                self.ctx.handle_apply(region_id, status);
            }
        }
    }
/// Tries to apply pending tasks if there is some.
Tries to apply pending tasks if there is some.
Tries to apply pending tasks if there is some .
fn handle_pending_applies(&mut self) {
        fail_point!("apply_pending_snapshot", |_| {});
        while !self.pending_applies.is_empty() {
            // should not handle too many applies than the number of files that can be ingested.
            // check level 0 every time because we can not make sure how does the number of level 0 files change.
            if self.ctx.ingest_maybe_stall() {
                break;
            }
            if let Some(Task::Apply { region_id, status }) = self.pending_applies.pop_front() {
                self.ctx.handle_apply(region_id, status);
            }
        }
    }
fn handle_pending_applies ( & mut self ) { fail_point ! ( " " { } ) ; while ! self . pending_applies . is_empty ( ) { // should not handle too many applies than the number of files that can be ingested. // check level 0 every time because we can not make sure how does the number of level 0 files change. if self . ctx . ingest_maybe_stall ( ) { break ; } if let Some ( Task :: Apply { region_id , status } ) = self . pending_applies . pop_front ( ) { self . ctx . handle_apply ( region_id , status ) ; } } }
Tries to apply pending tasks if there is some.
Tries to apply pending tasks if there is some .
&mut self