MCPcopy Index your code
hub / github.com/OpenTSDB/asynchbase / run

Method run

src/HBaseClient.java:1791–1806  ·  view source on GitHub ↗
(final Timeout timeout)

Source from the content-addressed store, hash-verified

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.

Callers

nothing calls this directly

Calls 2

newTimeoutMethod · 0.45

Tested by

no test coverage detected