private void quiesceIngest() throws IOException {
    InjectionHandler.processEvent(InjectionEvent.STANDBY_QUIESCE_INGEST);
    synchronized (ingestStateLock) {
      assertState(StandbyIngestState.INGESTING_EDITS,
          StandbyIngestState.NOT_INGESTING);
      ingest.quiesce();
    }
    try {
      ingestThread.join();
      currentIngestState = StandbyIngestState.NOT_INGESTING;
      LOG.info("Standby: Quiesce - Ingest thread for segment: "
          + ingest.toString() + " exited.");
    } catch (InterruptedException e) {
      LOG.info("Standby: Quiesce - Ingest thread interrupted.");
      throw new IOException(e.getMessage());
    }
  }
private void quiesceIngest ( ) throws IOException { InjectionHandler . processEvent ( InjectionEvent . STANDBY_QUIESCE_INGEST ) ; synchronized ( ingestStateLock ) { assertState ( StandbyIngestState . INGESTING_EDITS , StandbyIngestState . NOT_INGESTING ) ; ingest . quiesce ( ) ; } try { ingestThread . join ( ) ; currentIngestState = StandbyIngestState . NOT_INGESTING ; LOG . info ( "Standby: Quiesce - Ingest thread for segment: " + ingest . toString ( ) + " exited." ) ; } catch ( InterruptedException e ) { LOG . info ( "Standby: Quiesce - Ingest thread interrupted." ) ; throw new IOException ( e . getMessage ( ) ) ; } }
Quiesces the currently running ingest