(final Timeout timeout)
| 1789 | // Start periodic buffered increment flushes. |
| 1790 | final class FlushBufferedIncrementsTimer implements TimerTask { |
| 1791 | public void run(final Timeout timeout) { |
| 1792 | try { |
| 1793 | flushBufferedIncrements(increment_buffer); |
| 1794 | } finally { |
| 1795 | final short interval = flush_interval; // Volatile-read. |
| 1796 | // Even if we paused or disabled the client side buffer by calling |
| 1797 | // setFlushInterval(0), we will continue to schedule this timer |
| 1798 | // forever instead of pausing it. Pausing it is troublesome because |
| 1799 | // we don't keep a reference to this timer, so we can't cancel it or |
| 1800 | // tell if it's running or not. So let's just KISS and assume that |
| 1801 | // if we need the timer once, we'll need it forever. If it's truly |
| 1802 | // not needed anymore, we'll just cause a bit of extra work to the |
| 1803 | // timer thread every 100ms, no big deal. |
| 1804 | newTimeout(this, interval > 0 ? interval : 100); |
| 1805 | } |
| 1806 | } |
| 1807 | } |
| 1808 | |
| 1809 | final short interval = flush_interval; // Volatile-read. |
nothing calls this directly
no test coverage detected