protected void flushObjects ( ) { long now = System . currentTimeMillis ( ) ; for ( Iterator < IntMap . IntEntry < FlushRecord > > iter = _flushes . intEntrySet ( ) . iterator ( ) ; iter . hasNext ( ) ; ) { IntMap . IntEntry < FlushRecord > entry = iter . next ( ) ; // int oid = entry.getIntKey(); FlushRecord rec = entry . getValue ( ) ; if ( rec . expire <= now ) { iter . remove ( ) ; flushObject ( rec . object ) ; // Log.info("Flushed object " + oid + "."); } } }
Called periodically to flush any objects that have been lingering due to a previously enacted flush delay .