question: public void testStoreFailure ( ) throws Exception { delegate . setShouldFail ( true ) ; initStore ( 2 ) ; Set < Integer > exp ; try { exp = runPutGetRemoveMultithreaded ( 10 , 10 ) ; U . sleep ( FLUSH_FREQUENCY ) ; info ( ">>> There are " + store . getWriteBehindErrorRetryCount ( ) + " entries in RETRY state" ) ; delegate . setShouldFail ( false ) ; U . sleep ( 1000 ) ; } finally { shutdownStore ( ) ; } Map < Integer , String > map = delegate . getMap ( ) ; Collection < Integer > extra = new HashSet < > ( map . keySet ( ) ) ; extra . removeAll ( exp ) ; assertTrue ( "The underlying store contains extra keys: " + extra , extra . isEmpty ( ) ) ; Collection < Integer > missing = new HashSet < > ( exp ) ; missing . removeAll ( map . keySet ( ) ) ; assertTrue ( "Missing keys in the underlying store: " + missing , missing . isEmpty ( ) ) ; for ( Integer key : exp ) assertEquals ( "Invalid value for key " + key , "val" + key , map . get ( key ) ) ; }
target:  Tests that cache would keep values if underlying store fails.