@ Override protected void submitRedoPut ( final K key , final V value ) { if ( ! useRedo ) { return ; } createRedoThread ( ) ; final ByteBuffer buf = bufstack . pop ( ) ; buf . put ( ( byte ) 0x0A ) ; // PUT HEADER key . serialize ( buf ) ; value . serialize ( buf ) ; buf . put ( ( byte ) 0x0A ) ; // PUT FOOTER buf . flip ( ) ; if ( useRedoThread ) { try { redoQueue . put ( buf ) ; } catch ( InterruptedException e ) { log . error ( "InterruptedException in submitRedoPut(key, value)" , e ) ; } } else { redoStore . write ( buf ) ; bufstack . push ( buf ) ; } }
submit put to redo