slumberdb/slumberdb-service-model/src/main/java/org/boon/slumberdb/stores/mysql/MySQLDataStore.java
protected void flushReadsIfNeeded() throws InterruptedException {
        long now = timer.time();

        /* Every 250 ms flush the read queue. */
        if (now - lastReadFlushTime > flushQueueInterval && readList.size() > 0) {


            if (!loadQueue.offer(new ArrayList<>(readList))) {
                logger.warn("MySQL LOAD QUEUE IS FULL", loadQueue.size());
            } else {
                readList.clear();
            }
            lastReadFlushTime = now;


        }
    }
protected void flushReadsIfNeeded() throws InterruptedException {
        long now = timer.time();

        /* Every 250 ms flush the read queue. */
        if (now - lastReadFlushTime > flushQueueInterval && readList.size() > 0) {


            if (!loadQueue.offer(new ArrayList<>(readList))) {
                logger.warn("MySQL LOAD QUEUE IS FULL", loadQueue.size());
            } else {
                readList.clear();
            }
            lastReadFlushTime = now;


        }
    }
protected void flushReadsIfNeeded ( ) throws InterruptedException { long now = timer . time ( ) ; /* Every 250 ms flush the read queue. */ if ( now - lastReadFlushTime > flushQueueInterval && readList . size ( ) > 0 ) { if ( ! loadQueue . offer ( new ArrayList <> ( readList ) ) ) { logger . warn ( "MySQL LOAD QUEUE IS FULL" , loadQueue . size ( ) ) ; } else { readList . clear ( ) ; } lastReadFlushTime = now ; } }
Will flush to secondary storage if needed. This is used mostly by REMOTE_DB at the moment.
Will flush to secondary storage if needed . This is used mostly by REMOTE_DB at the moment .