Method Detail

• setMaxProcId

  void setMaxProcId(long maxProcId)

  Called by ProcedureStore.load() to notify about the maximum proc-id in the store.

  Parameters:

  maxProcId - the highest proc-id in the store

• load

  void load(ProcedureStore.ProcedureIterator procIter)
            throws IOException

  Called by the ProcedureStore.load() every time a set of procedures are ready to be executed. The ProcedureIterator passed to the method, has the procedure sorted in replay-order.

  Parameters:

  procIter - iterator over the procedures ready to be added to the executor.

  Throws:

  IOException

• handleCorrupted

  void handleCorrupted(ProcedureStore.ProcedureIterator procIter)
                       throws IOException

  Called by the ProcedureStore.load() in case we have procedures not-ready to be added to the executor, which probably means they are corrupted since some information/link is missing.

  Parameters:

  procIter - iterator over the procedures not ready to be added to the executor, corrupted

  Throws:

  IOException