private void reportFailedCheckpoint ( FailedCheckpointStats failed ) { statsReadWriteLock . lock ( ) ; try { counts . incrementFailedCheckpoints ( ) ; history . replacePendingCheckpointById ( failed ) ; dirty = true ; } finally { statsReadWriteLock . unlock ( ) ; } }
Callback when a checkpoint fails .