http://git-wip-us.apache.org/repos/asf/hbase-site/blob/99c53df1/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegion.MutationBatch.html
----------------------------------------------------------------------
diff --git
a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegion.MutationBatch.html
b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegion.MutationBatch.html
index f6a717e..a701ece 100644
---
a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegion.MutationBatch.html
+++
b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegion.MutationBatch.html
@@ -7930,329 +7930,342 @@
<span class="sourceLineNo">7922</span> case DELETE:<a
name="line.7922"></a>
<span class="sourceLineNo">7923</span> case BATCH_MUTATE:<a
name="line.7923"></a>
<span class="sourceLineNo">7924</span> case COMPACT_REGION:<a
name="line.7924"></a>
-<span class="sourceLineNo">7925</span> // when a region is in
recovering state, no read, split or merge is allowed<a name="line.7925"></a>
-<span class="sourceLineNo">7926</span> if (isRecovering() &&
(this.disallowWritesInRecovering ||<a name="line.7926"></a>
-<span class="sourceLineNo">7927</span> (op != Operation.PUT
&& op != Operation.DELETE && op != Operation.BATCH_MUTATE)))
{<a name="line.7927"></a>
-<span class="sourceLineNo">7928</span> throw new
RegionInRecoveryException(getRegionInfo().getRegionNameAsString() +<a
name="line.7928"></a>
-<span class="sourceLineNo">7929</span> " is recovering; cannot take
reads");<a name="line.7929"></a>
-<span class="sourceLineNo">7930</span> }<a name="line.7930"></a>
-<span class="sourceLineNo">7931</span> break;<a name="line.7931"></a>
-<span class="sourceLineNo">7932</span> default:<a name="line.7932"></a>
-<span class="sourceLineNo">7933</span> break;<a name="line.7933"></a>
-<span class="sourceLineNo">7934</span> }<a name="line.7934"></a>
-<span class="sourceLineNo">7935</span> if (op == Operation.MERGE_REGION ||
op == Operation.SPLIT_REGION<a name="line.7935"></a>
-<span class="sourceLineNo">7936</span> || op ==
Operation.COMPACT_REGION) {<a name="line.7936"></a>
-<span class="sourceLineNo">7937</span> // split, merge or compact region
doesn't need to check the closing/closed state or lock the<a
name="line.7937"></a>
-<span class="sourceLineNo">7938</span> // region<a name="line.7938"></a>
-<span class="sourceLineNo">7939</span> return;<a name="line.7939"></a>
-<span class="sourceLineNo">7940</span> }<a name="line.7940"></a>
-<span class="sourceLineNo">7941</span> if (this.closing.get()) {<a
name="line.7941"></a>
-<span class="sourceLineNo">7942</span> throw new
NotServingRegionException(getRegionInfo().getRegionNameAsString() + " is
closing");<a name="line.7942"></a>
-<span class="sourceLineNo">7943</span> }<a name="line.7943"></a>
-<span class="sourceLineNo">7944</span> lock(lock.readLock());<a
name="line.7944"></a>
-<span class="sourceLineNo">7945</span> if (this.closed.get()) {<a
name="line.7945"></a>
-<span class="sourceLineNo">7946</span> lock.readLock().unlock();<a
name="line.7946"></a>
-<span class="sourceLineNo">7947</span> throw new
NotServingRegionException(getRegionInfo().getRegionNameAsString() + " is
closed");<a name="line.7947"></a>
-<span class="sourceLineNo">7948</span> }<a name="line.7948"></a>
-<span class="sourceLineNo">7949</span> try {<a name="line.7949"></a>
-<span class="sourceLineNo">7950</span> if (coprocessorHost != null) {<a
name="line.7950"></a>
-<span class="sourceLineNo">7951</span>
coprocessorHost.postStartRegionOperation(op);<a name="line.7951"></a>
-<span class="sourceLineNo">7952</span> }<a name="line.7952"></a>
-<span class="sourceLineNo">7953</span> } catch (Exception e) {<a
name="line.7953"></a>
-<span class="sourceLineNo">7954</span> lock.readLock().unlock();<a
name="line.7954"></a>
-<span class="sourceLineNo">7955</span> throw new IOException(e);<a
name="line.7955"></a>
-<span class="sourceLineNo">7956</span> }<a name="line.7956"></a>
-<span class="sourceLineNo">7957</span> }<a name="line.7957"></a>
-<span class="sourceLineNo">7958</span><a name="line.7958"></a>
-<span class="sourceLineNo">7959</span> @Override<a name="line.7959"></a>
-<span class="sourceLineNo">7960</span> public void closeRegionOperation()
throws IOException {<a name="line.7960"></a>
-<span class="sourceLineNo">7961</span>
closeRegionOperation(Operation.ANY);<a name="line.7961"></a>
-<span class="sourceLineNo">7962</span> }<a name="line.7962"></a>
-<span class="sourceLineNo">7963</span><a name="line.7963"></a>
-<span class="sourceLineNo">7964</span> /**<a name="line.7964"></a>
-<span class="sourceLineNo">7965</span> * Closes the lock. This needs to be
called in the finally block corresponding<a name="line.7965"></a>
-<span class="sourceLineNo">7966</span> * to the try block of {@link
#startRegionOperation(Operation)}<a name="line.7966"></a>
-<span class="sourceLineNo">7967</span> * @throws IOException<a
name="line.7967"></a>
-<span class="sourceLineNo">7968</span> */<a name="line.7968"></a>
-<span class="sourceLineNo">7969</span> public void
closeRegionOperation(Operation operation) throws IOException {<a
name="line.7969"></a>
-<span class="sourceLineNo">7970</span> lock.readLock().unlock();<a
name="line.7970"></a>
-<span class="sourceLineNo">7971</span> if (coprocessorHost != null) {<a
name="line.7971"></a>
-<span class="sourceLineNo">7972</span>
coprocessorHost.postCloseRegionOperation(operation);<a name="line.7972"></a>
-<span class="sourceLineNo">7973</span> }<a name="line.7973"></a>
-<span class="sourceLineNo">7974</span> }<a name="line.7974"></a>
-<span class="sourceLineNo">7975</span><a name="line.7975"></a>
-<span class="sourceLineNo">7976</span> /**<a name="line.7976"></a>
-<span class="sourceLineNo">7977</span> * This method needs to be called
before any public call that reads or<a name="line.7977"></a>
-<span class="sourceLineNo">7978</span> * modifies stores in bulk. It has to
be called just before a try.<a name="line.7978"></a>
-<span class="sourceLineNo">7979</span> * #closeBulkRegionOperation needs to
be called in the try's finally block<a name="line.7979"></a>
-<span class="sourceLineNo">7980</span> * Acquires a writelock and checks if
the region is closing or closed.<a name="line.7980"></a>
-<span class="sourceLineNo">7981</span> * @throws NotServingRegionException
when the region is closing or closed<a name="line.7981"></a>
-<span class="sourceLineNo">7982</span> * @throws RegionTooBusyException if
failed to get the lock in time<a name="line.7982"></a>
-<span class="sourceLineNo">7983</span> * @throws InterruptedIOException if
interrupted while waiting for a lock<a name="line.7983"></a>
-<span class="sourceLineNo">7984</span> */<a name="line.7984"></a>
-<span class="sourceLineNo">7985</span> private void
startBulkRegionOperation(boolean writeLockNeeded)<a name="line.7985"></a>
-<span class="sourceLineNo">7986</span> throws NotServingRegionException,
RegionTooBusyException, InterruptedIOException {<a name="line.7986"></a>
-<span class="sourceLineNo">7987</span> if (this.closing.get()) {<a
name="line.7987"></a>
-<span class="sourceLineNo">7988</span> throw new
NotServingRegionException(getRegionInfo().getRegionNameAsString() + " is
closing");<a name="line.7988"></a>
-<span class="sourceLineNo">7989</span> }<a name="line.7989"></a>
-<span class="sourceLineNo">7990</span> if (writeLockNeeded)
lock(lock.writeLock());<a name="line.7990"></a>
-<span class="sourceLineNo">7991</span> else lock(lock.readLock());<a
name="line.7991"></a>
-<span class="sourceLineNo">7992</span> if (this.closed.get()) {<a
name="line.7992"></a>
-<span class="sourceLineNo">7993</span> if (writeLockNeeded)
lock.writeLock().unlock();<a name="line.7993"></a>
-<span class="sourceLineNo">7994</span> else lock.readLock().unlock();<a
name="line.7994"></a>
-<span class="sourceLineNo">7995</span> throw new
NotServingRegionException(getRegionInfo().getRegionNameAsString() + " is
closed");<a name="line.7995"></a>
-<span class="sourceLineNo">7996</span> }<a name="line.7996"></a>
-<span class="sourceLineNo">7997</span> }<a name="line.7997"></a>
-<span class="sourceLineNo">7998</span><a name="line.7998"></a>
-<span class="sourceLineNo">7999</span> /**<a name="line.7999"></a>
-<span class="sourceLineNo">8000</span> * Closes the lock. This needs to be
called in the finally block corresponding<a name="line.8000"></a>
-<span class="sourceLineNo">8001</span> * to the try block of
#startRegionOperation<a name="line.8001"></a>
-<span class="sourceLineNo">8002</span> */<a name="line.8002"></a>
-<span class="sourceLineNo">8003</span> private void
closeBulkRegionOperation(){<a name="line.8003"></a>
-<span class="sourceLineNo">8004</span> if
(lock.writeLock().isHeldByCurrentThread()) lock.writeLock().unlock();<a
name="line.8004"></a>
-<span class="sourceLineNo">8005</span> else lock.readLock().unlock();<a
name="line.8005"></a>
-<span class="sourceLineNo">8006</span> }<a name="line.8006"></a>
-<span class="sourceLineNo">8007</span><a name="line.8007"></a>
-<span class="sourceLineNo">8008</span> /**<a name="line.8008"></a>
-<span class="sourceLineNo">8009</span> * Update LongAdders for number of
puts without wal and the size of possible data loss.<a name="line.8009"></a>
-<span class="sourceLineNo">8010</span> * These information are exposed by
the region server metrics.<a name="line.8010"></a>
-<span class="sourceLineNo">8011</span> */<a name="line.8011"></a>
-<span class="sourceLineNo">8012</span> private void
recordMutationWithoutWal(final Map<byte [], List<Cell>> familyMap)
{<a name="line.8012"></a>
-<span class="sourceLineNo">8013</span>
numMutationsWithoutWAL.increment();<a name="line.8013"></a>
-<span class="sourceLineNo">8014</span> if (numMutationsWithoutWAL.sum()
<= 1) {<a name="line.8014"></a>
-<span class="sourceLineNo">8015</span> LOG.info("writing data to region "
+ this +<a name="line.8015"></a>
-<span class="sourceLineNo">8016</span> " with WAL disabled. Data
may be lost in the event of a crash.");<a name="line.8016"></a>
-<span class="sourceLineNo">8017</span> }<a name="line.8017"></a>
-<span class="sourceLineNo">8018</span><a name="line.8018"></a>
-<span class="sourceLineNo">8019</span> long mutationSize = 0;<a
name="line.8019"></a>
-<span class="sourceLineNo">8020</span> for (List<Cell> cells:
familyMap.values()) {<a name="line.8020"></a>
-<span class="sourceLineNo">8021</span> assert cells instanceof
RandomAccess;<a name="line.8021"></a>
-<span class="sourceLineNo">8022</span> int listSize = cells.size();<a
name="line.8022"></a>
-<span class="sourceLineNo">8023</span> for (int i=0; i < listSize;
i++) {<a name="line.8023"></a>
-<span class="sourceLineNo">8024</span> Cell cell = cells.get(i);<a
name="line.8024"></a>
-<span class="sourceLineNo">8025</span> mutationSize +=
KeyValueUtil.length(cell);<a name="line.8025"></a>
-<span class="sourceLineNo">8026</span> }<a name="line.8026"></a>
-<span class="sourceLineNo">8027</span> }<a name="line.8027"></a>
-<span class="sourceLineNo">8028</span><a name="line.8028"></a>
-<span class="sourceLineNo">8029</span>
dataInMemoryWithoutWAL.add(mutationSize);<a name="line.8029"></a>
-<span class="sourceLineNo">8030</span> }<a name="line.8030"></a>
+<span class="sourceLineNo">7925</span> case SNAPSHOT:<a
name="line.7925"></a>
+<span class="sourceLineNo">7926</span> // when a region is in
recovering state, no read, split, merge or snapshot is allowed<a
name="line.7926"></a>
+<span class="sourceLineNo">7927</span> if (isRecovering() &&
(this.disallowWritesInRecovering ||<a name="line.7927"></a>
+<span class="sourceLineNo">7928</span> (op != Operation.PUT
&& op != Operation.DELETE && op != Operation.BATCH_MUTATE)))
{<a name="line.7928"></a>
+<span class="sourceLineNo">7929</span> throw new
RegionInRecoveryException(getRegionInfo().getRegionNameAsString() +<a
name="line.7929"></a>
+<span class="sourceLineNo">7930</span> " is recovering; cannot take
reads");<a name="line.7930"></a>
+<span class="sourceLineNo">7931</span> }<a name="line.7931"></a>
+<span class="sourceLineNo">7932</span> break;<a name="line.7932"></a>
+<span class="sourceLineNo">7933</span> default:<a name="line.7933"></a>
+<span class="sourceLineNo">7934</span> break;<a name="line.7934"></a>
+<span class="sourceLineNo">7935</span> }<a name="line.7935"></a>
+<span class="sourceLineNo">7936</span> if (op == Operation.MERGE_REGION ||
op == Operation.SPLIT_REGION<a name="line.7936"></a>
+<span class="sourceLineNo">7937</span> || op ==
Operation.COMPACT_REGION) {<a name="line.7937"></a>
+<span class="sourceLineNo">7938</span> // split, merge or compact region
doesn't need to check the closing/closed state or lock the<a
name="line.7938"></a>
+<span class="sourceLineNo">7939</span> // region<a name="line.7939"></a>
+<span class="sourceLineNo">7940</span> return;<a name="line.7940"></a>
+<span class="sourceLineNo">7941</span> }<a name="line.7941"></a>
+<span class="sourceLineNo">7942</span> if (this.closing.get()) {<a
name="line.7942"></a>
+<span class="sourceLineNo">7943</span> throw new
NotServingRegionException(getRegionInfo().getRegionNameAsString() + " is
closing");<a name="line.7943"></a>
+<span class="sourceLineNo">7944</span> }<a name="line.7944"></a>
+<span class="sourceLineNo">7945</span> lock(lock.readLock());<a
name="line.7945"></a>
+<span class="sourceLineNo">7946</span> if (this.closed.get()) {<a
name="line.7946"></a>
+<span class="sourceLineNo">7947</span> lock.readLock().unlock();<a
name="line.7947"></a>
+<span class="sourceLineNo">7948</span> throw new
NotServingRegionException(getRegionInfo().getRegionNameAsString() + " is
closed");<a name="line.7948"></a>
+<span class="sourceLineNo">7949</span> }<a name="line.7949"></a>
+<span class="sourceLineNo">7950</span> // The unit for snapshot is a
region. So, all stores for this region must be<a name="line.7950"></a>
+<span class="sourceLineNo">7951</span> // prepared for snapshot operation
before proceeding.<a name="line.7951"></a>
+<span class="sourceLineNo">7952</span> if (op == Operation.SNAPSHOT) {<a
name="line.7952"></a>
+<span class="sourceLineNo">7953</span> for (Store store :
stores.values()) {<a name="line.7953"></a>
+<span class="sourceLineNo">7954</span> if (store instanceof HStore) {<a
name="line.7954"></a>
+<span class="sourceLineNo">7955</span>
((HStore)store).preSnapshotOperation();<a name="line.7955"></a>
+<span class="sourceLineNo">7956</span> }<a name="line.7956"></a>
+<span class="sourceLineNo">7957</span> }<a name="line.7957"></a>
+<span class="sourceLineNo">7958</span> }<a name="line.7958"></a>
+<span class="sourceLineNo">7959</span> try {<a name="line.7959"></a>
+<span class="sourceLineNo">7960</span> if (coprocessorHost != null) {<a
name="line.7960"></a>
+<span class="sourceLineNo">7961</span>
coprocessorHost.postStartRegionOperation(op);<a name="line.7961"></a>
+<span class="sourceLineNo">7962</span> }<a name="line.7962"></a>
+<span class="sourceLineNo">7963</span> } catch (Exception e) {<a
name="line.7963"></a>
+<span class="sourceLineNo">7964</span> lock.readLock().unlock();<a
name="line.7964"></a>
+<span class="sourceLineNo">7965</span> throw new IOException(e);<a
name="line.7965"></a>
+<span class="sourceLineNo">7966</span> }<a name="line.7966"></a>
+<span class="sourceLineNo">7967</span> }<a name="line.7967"></a>
+<span class="sourceLineNo">7968</span><a name="line.7968"></a>
+<span class="sourceLineNo">7969</span> @Override<a name="line.7969"></a>
+<span class="sourceLineNo">7970</span> public void closeRegionOperation()
throws IOException {<a name="line.7970"></a>
+<span class="sourceLineNo">7971</span>
closeRegionOperation(Operation.ANY);<a name="line.7971"></a>
+<span class="sourceLineNo">7972</span> }<a name="line.7972"></a>
+<span class="sourceLineNo">7973</span><a name="line.7973"></a>
+<span class="sourceLineNo">7974</span> @Override<a name="line.7974"></a>
+<span class="sourceLineNo">7975</span> public void
closeRegionOperation(Operation operation) throws IOException {<a
name="line.7975"></a>
+<span class="sourceLineNo">7976</span> if (operation == Operation.SNAPSHOT)
{<a name="line.7976"></a>
+<span class="sourceLineNo">7977</span> for (Store store: stores.values())
{<a name="line.7977"></a>
+<span class="sourceLineNo">7978</span> if (store instanceof HStore) {<a
name="line.7978"></a>
+<span class="sourceLineNo">7979</span>
((HStore)store).postSnapshotOperation();<a name="line.7979"></a>
+<span class="sourceLineNo">7980</span> }<a name="line.7980"></a>
+<span class="sourceLineNo">7981</span> }<a name="line.7981"></a>
+<span class="sourceLineNo">7982</span> }<a name="line.7982"></a>
+<span class="sourceLineNo">7983</span> lock.readLock().unlock();<a
name="line.7983"></a>
+<span class="sourceLineNo">7984</span> if (coprocessorHost != null) {<a
name="line.7984"></a>
+<span class="sourceLineNo">7985</span>
coprocessorHost.postCloseRegionOperation(operation);<a name="line.7985"></a>
+<span class="sourceLineNo">7986</span> }<a name="line.7986"></a>
+<span class="sourceLineNo">7987</span> }<a name="line.7987"></a>
+<span class="sourceLineNo">7988</span><a name="line.7988"></a>
+<span class="sourceLineNo">7989</span> /**<a name="line.7989"></a>
+<span class="sourceLineNo">7990</span> * This method needs to be called
before any public call that reads or<a name="line.7990"></a>
+<span class="sourceLineNo">7991</span> * modifies stores in bulk. It has to
be called just before a try.<a name="line.7991"></a>
+<span class="sourceLineNo">7992</span> * #closeBulkRegionOperation needs to
be called in the try's finally block<a name="line.7992"></a>
+<span class="sourceLineNo">7993</span> * Acquires a writelock and checks if
the region is closing or closed.<a name="line.7993"></a>
+<span class="sourceLineNo">7994</span> * @throws NotServingRegionException
when the region is closing or closed<a name="line.7994"></a>
+<span class="sourceLineNo">7995</span> * @throws RegionTooBusyException if
failed to get the lock in time<a name="line.7995"></a>
+<span class="sourceLineNo">7996</span> * @throws InterruptedIOException if
interrupted while waiting for a lock<a name="line.7996"></a>
+<span class="sourceLineNo">7997</span> */<a name="line.7997"></a>
+<span class="sourceLineNo">7998</span> private void
startBulkRegionOperation(boolean writeLockNeeded)<a name="line.7998"></a>
+<span class="sourceLineNo">7999</span> throws NotServingRegionException,
RegionTooBusyException, InterruptedIOException {<a name="line.7999"></a>
+<span class="sourceLineNo">8000</span> if (this.closing.get()) {<a
name="line.8000"></a>
+<span class="sourceLineNo">8001</span> throw new
NotServingRegionException(getRegionInfo().getRegionNameAsString() + " is
closing");<a name="line.8001"></a>
+<span class="sourceLineNo">8002</span> }<a name="line.8002"></a>
+<span class="sourceLineNo">8003</span> if (writeLockNeeded)
lock(lock.writeLock());<a name="line.8003"></a>
+<span class="sourceLineNo">8004</span> else lock(lock.readLock());<a
name="line.8004"></a>
+<span class="sourceLineNo">8005</span> if (this.closed.get()) {<a
name="line.8005"></a>
+<span class="sourceLineNo">8006</span> if (writeLockNeeded)
lock.writeLock().unlock();<a name="line.8006"></a>
+<span class="sourceLineNo">8007</span> else lock.readLock().unlock();<a
name="line.8007"></a>
+<span class="sourceLineNo">8008</span> throw new
NotServingRegionException(getRegionInfo().getRegionNameAsString() + " is
closed");<a name="line.8008"></a>
+<span class="sourceLineNo">8009</span> }<a name="line.8009"></a>
+<span class="sourceLineNo">8010</span> }<a name="line.8010"></a>
+<span class="sourceLineNo">8011</span><a name="line.8011"></a>
+<span class="sourceLineNo">8012</span> /**<a name="line.8012"></a>
+<span class="sourceLineNo">8013</span> * Closes the lock. This needs to be
called in the finally block corresponding<a name="line.8013"></a>
+<span class="sourceLineNo">8014</span> * to the try block of
#startRegionOperation<a name="line.8014"></a>
+<span class="sourceLineNo">8015</span> */<a name="line.8015"></a>
+<span class="sourceLineNo">8016</span> private void
closeBulkRegionOperation(){<a name="line.8016"></a>
+<span class="sourceLineNo">8017</span> if
(lock.writeLock().isHeldByCurrentThread()) lock.writeLock().unlock();<a
name="line.8017"></a>
+<span class="sourceLineNo">8018</span> else lock.readLock().unlock();<a
name="line.8018"></a>
+<span class="sourceLineNo">8019</span> }<a name="line.8019"></a>
+<span class="sourceLineNo">8020</span><a name="line.8020"></a>
+<span class="sourceLineNo">8021</span> /**<a name="line.8021"></a>
+<span class="sourceLineNo">8022</span> * Update LongAdders for number of
puts without wal and the size of possible data loss.<a name="line.8022"></a>
+<span class="sourceLineNo">8023</span> * These information are exposed by
the region server metrics.<a name="line.8023"></a>
+<span class="sourceLineNo">8024</span> */<a name="line.8024"></a>
+<span class="sourceLineNo">8025</span> private void
recordMutationWithoutWal(final Map<byte [], List<Cell>> familyMap)
{<a name="line.8025"></a>
+<span class="sourceLineNo">8026</span>
numMutationsWithoutWAL.increment();<a name="line.8026"></a>
+<span class="sourceLineNo">8027</span> if (numMutationsWithoutWAL.sum()
<= 1) {<a name="line.8027"></a>
+<span class="sourceLineNo">8028</span> LOG.info("writing data to region "
+ this +<a name="line.8028"></a>
+<span class="sourceLineNo">8029</span> " with WAL disabled. Data
may be lost in the event of a crash.");<a name="line.8029"></a>
+<span class="sourceLineNo">8030</span> }<a name="line.8030"></a>
<span class="sourceLineNo">8031</span><a name="line.8031"></a>
-<span class="sourceLineNo">8032</span> private void lock(final Lock lock)<a
name="line.8032"></a>
-<span class="sourceLineNo">8033</span> throws RegionTooBusyException,
InterruptedIOException {<a name="line.8033"></a>
-<span class="sourceLineNo">8034</span> lock(lock, 1);<a
name="line.8034"></a>
-<span class="sourceLineNo">8035</span> }<a name="line.8035"></a>
-<span class="sourceLineNo">8036</span><a name="line.8036"></a>
-<span class="sourceLineNo">8037</span> /**<a name="line.8037"></a>
-<span class="sourceLineNo">8038</span> * Try to acquire a lock. Throw
RegionTooBusyException<a name="line.8038"></a>
-<span class="sourceLineNo">8039</span> * if failed to get the lock in time.
Throw InterruptedIOException<a name="line.8039"></a>
-<span class="sourceLineNo">8040</span> * if interrupted while waiting for
the lock.<a name="line.8040"></a>
-<span class="sourceLineNo">8041</span> */<a name="line.8041"></a>
-<span class="sourceLineNo">8042</span> private void lock(final Lock lock,
final int multiplier)<a name="line.8042"></a>
-<span class="sourceLineNo">8043</span> throws RegionTooBusyException,
InterruptedIOException {<a name="line.8043"></a>
-<span class="sourceLineNo">8044</span> try {<a name="line.8044"></a>
-<span class="sourceLineNo">8045</span> final long waitTime =
Math.min(maxBusyWaitDuration,<a name="line.8045"></a>
-<span class="sourceLineNo">8046</span> busyWaitDuration *
Math.min(multiplier, maxBusyWaitMultiplier));<a name="line.8046"></a>
-<span class="sourceLineNo">8047</span> if (!lock.tryLock(waitTime,
TimeUnit.MILLISECONDS)) {<a name="line.8047"></a>
-<span class="sourceLineNo">8048</span> throw new
RegionTooBusyException(<a name="line.8048"></a>
-<span class="sourceLineNo">8049</span> "failed to get a lock in " +
waitTime + " ms. " +<a name="line.8049"></a>
-<span class="sourceLineNo">8050</span> "regionName=" +
(this.getRegionInfo() == null ? "unknown" :<a name="line.8050"></a>
-<span class="sourceLineNo">8051</span>
this.getRegionInfo().getRegionNameAsString()) +<a name="line.8051"></a>
-<span class="sourceLineNo">8052</span> ", server=" +
(this.getRegionServerServices() == null ? "unknown" :<a name="line.8052"></a>
-<span class="sourceLineNo">8053</span>
this.getRegionServerServices().getServerName()));<a name="line.8053"></a>
-<span class="sourceLineNo">8054</span> }<a name="line.8054"></a>
-<span class="sourceLineNo">8055</span> } catch (InterruptedException ie)
{<a name="line.8055"></a>
-<span class="sourceLineNo">8056</span> LOG.info("Interrupted while
waiting for a lock");<a name="line.8056"></a>
-<span class="sourceLineNo">8057</span> InterruptedIOException iie = new
InterruptedIOException();<a name="line.8057"></a>
-<span class="sourceLineNo">8058</span> iie.initCause(ie);<a
name="line.8058"></a>
-<span class="sourceLineNo">8059</span> throw iie;<a name="line.8059"></a>
-<span class="sourceLineNo">8060</span> }<a name="line.8060"></a>
-<span class="sourceLineNo">8061</span> }<a name="line.8061"></a>
-<span class="sourceLineNo">8062</span><a name="line.8062"></a>
-<span class="sourceLineNo">8063</span> /**<a name="line.8063"></a>
-<span class="sourceLineNo">8064</span> * Calls sync with the given
transaction ID<a name="line.8064"></a>
-<span class="sourceLineNo">8065</span> * @param txid should sync up to which
transaction<a name="line.8065"></a>
-<span class="sourceLineNo">8066</span> * @throws IOException If anything
goes wrong with DFS<a name="line.8066"></a>
-<span class="sourceLineNo">8067</span> */<a name="line.8067"></a>
-<span class="sourceLineNo">8068</span> private void sync(long txid,
Durability durability) throws IOException {<a name="line.8068"></a>
-<span class="sourceLineNo">8069</span> if
(this.getRegionInfo().isMetaRegion()) {<a name="line.8069"></a>
-<span class="sourceLineNo">8070</span> this.wal.sync(txid);<a
name="line.8070"></a>
-<span class="sourceLineNo">8071</span> } else {<a name="line.8071"></a>
-<span class="sourceLineNo">8072</span> switch(durability) {<a
name="line.8072"></a>
-<span class="sourceLineNo">8073</span> case USE_DEFAULT:<a
name="line.8073"></a>
-<span class="sourceLineNo">8074</span> // do what table defaults to<a
name="line.8074"></a>
-<span class="sourceLineNo">8075</span> if (shouldSyncWAL()) {<a
name="line.8075"></a>
-<span class="sourceLineNo">8076</span> this.wal.sync(txid);<a
name="line.8076"></a>
-<span class="sourceLineNo">8077</span> }<a name="line.8077"></a>
-<span class="sourceLineNo">8078</span> break;<a name="line.8078"></a>
-<span class="sourceLineNo">8079</span> case SKIP_WAL:<a
name="line.8079"></a>
-<span class="sourceLineNo">8080</span> // nothing do to<a
name="line.8080"></a>
-<span class="sourceLineNo">8081</span> break;<a name="line.8081"></a>
-<span class="sourceLineNo">8082</span> case ASYNC_WAL:<a
name="line.8082"></a>
-<span class="sourceLineNo">8083</span> // nothing do to<a
name="line.8083"></a>
-<span class="sourceLineNo">8084</span> break;<a name="line.8084"></a>
-<span class="sourceLineNo">8085</span> case SYNC_WAL:<a
name="line.8085"></a>
-<span class="sourceLineNo">8086</span> case FSYNC_WAL:<a
name="line.8086"></a>
-<span class="sourceLineNo">8087</span> // sync the WAL edit (SYNC and
FSYNC treated the same for now)<a name="line.8087"></a>
-<span class="sourceLineNo">8088</span> this.wal.sync(txid);<a
name="line.8088"></a>
-<span class="sourceLineNo">8089</span> break;<a name="line.8089"></a>
-<span class="sourceLineNo">8090</span> default:<a name="line.8090"></a>
-<span class="sourceLineNo">8091</span> throw new
RuntimeException("Unknown durability " + durability);<a name="line.8091"></a>
-<span class="sourceLineNo">8092</span> }<a name="line.8092"></a>
-<span class="sourceLineNo">8093</span> }<a name="line.8093"></a>
-<span class="sourceLineNo">8094</span> }<a name="line.8094"></a>
-<span class="sourceLineNo">8095</span><a name="line.8095"></a>
-<span class="sourceLineNo">8096</span> /**<a name="line.8096"></a>
-<span class="sourceLineNo">8097</span> * Check whether we should sync the
wal from the table's durability settings<a name="line.8097"></a>
-<span class="sourceLineNo">8098</span> */<a name="line.8098"></a>
-<span class="sourceLineNo">8099</span> private boolean shouldSyncWAL() {<a
name="line.8099"></a>
-<span class="sourceLineNo">8100</span> return durability.ordinal() >
Durability.ASYNC_WAL.ordinal();<a name="line.8100"></a>
-<span class="sourceLineNo">8101</span> }<a name="line.8101"></a>
-<span class="sourceLineNo">8102</span><a name="line.8102"></a>
-<span class="sourceLineNo">8103</span> /**<a name="line.8103"></a>
-<span class="sourceLineNo">8104</span> * A mocked list implementation -
discards all updates.<a name="line.8104"></a>
-<span class="sourceLineNo">8105</span> */<a name="line.8105"></a>
-<span class="sourceLineNo">8106</span> private static final List<Cell>
MOCKED_LIST = new AbstractList<Cell>() {<a name="line.8106"></a>
-<span class="sourceLineNo">8107</span><a name="line.8107"></a>
-<span class="sourceLineNo">8108</span> @Override<a name="line.8108"></a>
-<span class="sourceLineNo">8109</span> public void add(int index, Cell
element) {<a name="line.8109"></a>
-<span class="sourceLineNo">8110</span> // do nothing<a
name="line.8110"></a>
-<span class="sourceLineNo">8111</span> }<a name="line.8111"></a>
-<span class="sourceLineNo">8112</span><a name="line.8112"></a>
-<span class="sourceLineNo">8113</span> @Override<a name="line.8113"></a>
-<span class="sourceLineNo">8114</span> public boolean addAll(int index,
Collection<? extends Cell> c) {<a name="line.8114"></a>
-<span class="sourceLineNo">8115</span> return false; // this list is
never changed as a result of an update<a name="line.8115"></a>
-<span class="sourceLineNo">8116</span> }<a name="line.8116"></a>
-<span class="sourceLineNo">8117</span><a name="line.8117"></a>
-<span class="sourceLineNo">8118</span> @Override<a name="line.8118"></a>
-<span class="sourceLineNo">8119</span> public KeyValue get(int index) {<a
name="line.8119"></a>
-<span class="sourceLineNo">8120</span> throw new
UnsupportedOperationException();<a name="line.8120"></a>
-<span class="sourceLineNo">8121</span> }<a name="line.8121"></a>
-<span class="sourceLineNo">8122</span><a name="line.8122"></a>
-<span class="sourceLineNo">8123</span> @Override<a name="line.8123"></a>
-<span class="sourceLineNo">8124</span> public int size() {<a
name="line.8124"></a>
-<span class="sourceLineNo">8125</span> return 0;<a name="line.8125"></a>
-<span class="sourceLineNo">8126</span> }<a name="line.8126"></a>
-<span class="sourceLineNo">8127</span> };<a name="line.8127"></a>
-<span class="sourceLineNo">8128</span><a name="line.8128"></a>
-<span class="sourceLineNo">8129</span> @Override<a name="line.8129"></a>
-<span class="sourceLineNo">8130</span> public long getOpenSeqNum() {<a
name="line.8130"></a>
-<span class="sourceLineNo">8131</span> return this.openSeqNum;<a
name="line.8131"></a>
-<span class="sourceLineNo">8132</span> }<a name="line.8132"></a>
-<span class="sourceLineNo">8133</span><a name="line.8133"></a>
-<span class="sourceLineNo">8134</span> @Override<a name="line.8134"></a>
-<span class="sourceLineNo">8135</span> public Map<byte[], Long>
getMaxStoreSeqId() {<a name="line.8135"></a>
-<span class="sourceLineNo">8136</span> return this.maxSeqIdInStores;<a
name="line.8136"></a>
-<span class="sourceLineNo">8137</span> }<a name="line.8137"></a>
-<span class="sourceLineNo">8138</span><a name="line.8138"></a>
-<span class="sourceLineNo">8139</span> @Override<a name="line.8139"></a>
-<span class="sourceLineNo">8140</span> public long
getOldestSeqIdOfStore(byte[] familyName) {<a name="line.8140"></a>
-<span class="sourceLineNo">8141</span> return
wal.getEarliestMemstoreSeqNum(getRegionInfo().getEncodedNameAsBytes(),
familyName);<a name="line.8141"></a>
-<span class="sourceLineNo">8142</span> }<a name="line.8142"></a>
-<span class="sourceLineNo">8143</span><a name="line.8143"></a>
-<span class="sourceLineNo">8144</span> @Override<a name="line.8144"></a>
-<span class="sourceLineNo">8145</span> public CompactionState
getCompactionState() {<a name="line.8145"></a>
-<span class="sourceLineNo">8146</span> boolean hasMajor =
majorInProgress.get() > 0, hasMinor = minorInProgress.get() > 0;<a
name="line.8146"></a>
-<span class="sourceLineNo">8147</span> return (hasMajor ? (hasMinor ?
CompactionState.MAJOR_AND_MINOR : CompactionState.MAJOR)<a name="line.8147"></a>
-<span class="sourceLineNo">8148</span> : (hasMinor ?
CompactionState.MINOR : CompactionState.NONE));<a name="line.8148"></a>
-<span class="sourceLineNo">8149</span> }<a name="line.8149"></a>
-<span class="sourceLineNo">8150</span><a name="line.8150"></a>
-<span class="sourceLineNo">8151</span> public void
reportCompactionRequestStart(boolean isMajor){<a name="line.8151"></a>
-<span class="sourceLineNo">8152</span> (isMajor ? majorInProgress :
minorInProgress).incrementAndGet();<a name="line.8152"></a>
-<span class="sourceLineNo">8153</span> }<a name="line.8153"></a>
-<span class="sourceLineNo">8154</span><a name="line.8154"></a>
-<span class="sourceLineNo">8155</span> public void
reportCompactionRequestEnd(boolean isMajor, int numFiles, long
filesSizeCompacted) {<a name="line.8155"></a>
-<span class="sourceLineNo">8156</span> int newValue = (isMajor ?
majorInProgress : minorInProgress).decrementAndGet();<a name="line.8156"></a>
-<span class="sourceLineNo">8157</span><a name="line.8157"></a>
-<span class="sourceLineNo">8158</span> // metrics<a name="line.8158"></a>
-<span class="sourceLineNo">8159</span>
compactionsFinished.incrementAndGet();<a name="line.8159"></a>
-<span class="sourceLineNo">8160</span>
compactionNumFilesCompacted.addAndGet(numFiles);<a name="line.8160"></a>
-<span class="sourceLineNo">8161</span>
compactionNumBytesCompacted.addAndGet(filesSizeCompacted);<a
name="line.8161"></a>
-<span class="sourceLineNo">8162</span><a name="line.8162"></a>
-<span class="sourceLineNo">8163</span> assert newValue >= 0;<a
name="line.8163"></a>
-<span class="sourceLineNo">8164</span> }<a name="line.8164"></a>
-<span class="sourceLineNo">8165</span><a name="line.8165"></a>
-<span class="sourceLineNo">8166</span> public void
reportCompactionRequestFailure() {<a name="line.8166"></a>
-<span class="sourceLineNo">8167</span>
compactionsFailed.incrementAndGet();<a name="line.8167"></a>
-<span class="sourceLineNo">8168</span> }<a name="line.8168"></a>
-<span class="sourceLineNo">8169</span><a name="line.8169"></a>
-<span class="sourceLineNo">8170</span> public void
incrementCompactionsQueuedCount() {<a name="line.8170"></a>
-<span class="sourceLineNo">8171</span>
compactionsQueued.incrementAndGet();<a name="line.8171"></a>
-<span class="sourceLineNo">8172</span> }<a name="line.8172"></a>
-<span class="sourceLineNo">8173</span><a name="line.8173"></a>
-<span class="sourceLineNo">8174</span> public void
decrementCompactionsQueuedCount() {<a name="line.8174"></a>
-<span class="sourceLineNo">8175</span>
compactionsQueued.decrementAndGet();<a name="line.8175"></a>
-<span class="sourceLineNo">8176</span> }<a name="line.8176"></a>
-<span class="sourceLineNo">8177</span><a name="line.8177"></a>
-<span class="sourceLineNo">8178</span> public void
incrementFlushesQueuedCount() {<a name="line.8178"></a>
-<span class="sourceLineNo">8179</span> flushesQueued.incrementAndGet();<a
name="line.8179"></a>
-<span class="sourceLineNo">8180</span> }<a name="line.8180"></a>
-<span class="sourceLineNo">8181</span><a name="line.8181"></a>
-<span class="sourceLineNo">8182</span> @VisibleForTesting<a
name="line.8182"></a>
-<span class="sourceLineNo">8183</span> public long getReadPoint() {<a
name="line.8183"></a>
-<span class="sourceLineNo">8184</span> return
getReadPoint(IsolationLevel.READ_COMMITTED);<a name="line.8184"></a>
+<span class="sourceLineNo">8032</span> long mutationSize = 0;<a
name="line.8032"></a>
+<span class="sourceLineNo">8033</span> for (List<Cell> cells:
familyMap.values()) {<a name="line.8033"></a>
+<span class="sourceLineNo">8034</span> assert cells instanceof
RandomAccess;<a name="line.8034"></a>
+<span class="sourceLineNo">8035</span> int listSize = cells.size();<a
name="line.8035"></a>
+<span class="sourceLineNo">8036</span> for (int i=0; i < listSize;
i++) {<a name="line.8036"></a>
+<span class="sourceLineNo">8037</span> Cell cell = cells.get(i);<a
name="line.8037"></a>
+<span class="sourceLineNo">8038</span> mutationSize +=
KeyValueUtil.length(cell);<a name="line.8038"></a>
+<span class="sourceLineNo">8039</span> }<a name="line.8039"></a>
+<span class="sourceLineNo">8040</span> }<a name="line.8040"></a>
+<span class="sourceLineNo">8041</span><a name="line.8041"></a>
+<span class="sourceLineNo">8042</span>
dataInMemoryWithoutWAL.add(mutationSize);<a name="line.8042"></a>
+<span class="sourceLineNo">8043</span> }<a name="line.8043"></a>
+<span class="sourceLineNo">8044</span><a name="line.8044"></a>
+<span class="sourceLineNo">8045</span> private void lock(final Lock lock)<a
name="line.8045"></a>
+<span class="sourceLineNo">8046</span> throws RegionTooBusyException,
InterruptedIOException {<a name="line.8046"></a>
+<span class="sourceLineNo">8047</span> lock(lock, 1);<a
name="line.8047"></a>
+<span class="sourceLineNo">8048</span> }<a name="line.8048"></a>
+<span class="sourceLineNo">8049</span><a name="line.8049"></a>
+<span class="sourceLineNo">8050</span> /**<a name="line.8050"></a>
+<span class="sourceLineNo">8051</span> * Try to acquire a lock. Throw
RegionTooBusyException<a name="line.8051"></a>
+<span class="sourceLineNo">8052</span> * if failed to get the lock in time.
Throw InterruptedIOException<a name="line.8052"></a>
+<span class="sourceLineNo">8053</span> * if interrupted while waiting for
the lock.<a name="line.8053"></a>
+<span class="sourceLineNo">8054</span> */<a name="line.8054"></a>
+<span class="sourceLineNo">8055</span> private void lock(final Lock lock,
final int multiplier)<a name="line.8055"></a>
+<span class="sourceLineNo">8056</span> throws RegionTooBusyException,
InterruptedIOException {<a name="line.8056"></a>
+<span class="sourceLineNo">8057</span> try {<a name="line.8057"></a>
+<span class="sourceLineNo">8058</span> final long waitTime =
Math.min(maxBusyWaitDuration,<a name="line.8058"></a>
+<span class="sourceLineNo">8059</span> busyWaitDuration *
Math.min(multiplier, maxBusyWaitMultiplier));<a name="line.8059"></a>
+<span class="sourceLineNo">8060</span> if (!lock.tryLock(waitTime,
TimeUnit.MILLISECONDS)) {<a name="line.8060"></a>
+<span class="sourceLineNo">8061</span> throw new
RegionTooBusyException(<a name="line.8061"></a>
+<span class="sourceLineNo">8062</span> "failed to get a lock in " +
waitTime + " ms. " +<a name="line.8062"></a>
+<span class="sourceLineNo">8063</span> "regionName=" +
(this.getRegionInfo() == null ? "unknown" :<a name="line.8063"></a>
+<span class="sourceLineNo">8064</span>
this.getRegionInfo().getRegionNameAsString()) +<a name="line.8064"></a>
+<span class="sourceLineNo">8065</span> ", server=" +
(this.getRegionServerServices() == null ? "unknown" :<a name="line.8065"></a>
+<span class="sourceLineNo">8066</span>
this.getRegionServerServices().getServerName()));<a name="line.8066"></a>
+<span class="sourceLineNo">8067</span> }<a name="line.8067"></a>
+<span class="sourceLineNo">8068</span> } catch (InterruptedException ie)
{<a name="line.8068"></a>
+<span class="sourceLineNo">8069</span> LOG.info("Interrupted while
waiting for a lock");<a name="line.8069"></a>
+<span class="sourceLineNo">8070</span> InterruptedIOException iie = new
InterruptedIOException();<a name="line.8070"></a>
+<span class="sourceLineNo">8071</span> iie.initCause(ie);<a
name="line.8071"></a>
+<span class="sourceLineNo">8072</span> throw iie;<a name="line.8072"></a>
+<span class="sourceLineNo">8073</span> }<a name="line.8073"></a>
+<span class="sourceLineNo">8074</span> }<a name="line.8074"></a>
+<span class="sourceLineNo">8075</span><a name="line.8075"></a>
+<span class="sourceLineNo">8076</span> /**<a name="line.8076"></a>
+<span class="sourceLineNo">8077</span> * Calls sync with the given
transaction ID<a name="line.8077"></a>
+<span class="sourceLineNo">8078</span> * @param txid should sync up to which
transaction<a name="line.8078"></a>
+<span class="sourceLineNo">8079</span> * @throws IOException If anything
goes wrong with DFS<a name="line.8079"></a>
+<span class="sourceLineNo">8080</span> */<a name="line.8080"></a>
+<span class="sourceLineNo">8081</span> private void sync(long txid,
Durability durability) throws IOException {<a name="line.8081"></a>
+<span class="sourceLineNo">8082</span> if
(this.getRegionInfo().isMetaRegion()) {<a name="line.8082"></a>
+<span class="sourceLineNo">8083</span> this.wal.sync(txid);<a
name="line.8083"></a>
+<span class="sourceLineNo">8084</span> } else {<a name="line.8084"></a>
+<span class="sourceLineNo">8085</span> switch(durability) {<a
name="line.8085"></a>
+<span class="sourceLineNo">8086</span> case USE_DEFAULT:<a
name="line.8086"></a>
+<span class="sourceLineNo">8087</span> // do what table defaults to<a
name="line.8087"></a>
+<span class="sourceLineNo">8088</span> if (shouldSyncWAL()) {<a
name="line.8088"></a>
+<span class="sourceLineNo">8089</span> this.wal.sync(txid);<a
name="line.8089"></a>
+<span class="sourceLineNo">8090</span> }<a name="line.8090"></a>
+<span class="sourceLineNo">8091</span> break;<a name="line.8091"></a>
+<span class="sourceLineNo">8092</span> case SKIP_WAL:<a
name="line.8092"></a>
+<span class="sourceLineNo">8093</span> // nothing do to<a
name="line.8093"></a>
+<span class="sourceLineNo">8094</span> break;<a name="line.8094"></a>
+<span class="sourceLineNo">8095</span> case ASYNC_WAL:<a
name="line.8095"></a>
+<span class="sourceLineNo">8096</span> // nothing do to<a
name="line.8096"></a>
+<span class="sourceLineNo">8097</span> break;<a name="line.8097"></a>
+<span class="sourceLineNo">8098</span> case SYNC_WAL:<a
name="line.8098"></a>
+<span class="sourceLineNo">8099</span> case FSYNC_WAL:<a
name="line.8099"></a>
+<span class="sourceLineNo">8100</span> // sync the WAL edit (SYNC and
FSYNC treated the same for now)<a name="line.8100"></a>
+<span class="sourceLineNo">8101</span> this.wal.sync(txid);<a
name="line.8101"></a>
+<span class="sourceLineNo">8102</span> break;<a name="line.8102"></a>
+<span class="sourceLineNo">8103</span> default:<a name="line.8103"></a>
+<span class="sourceLineNo">8104</span> throw new
RuntimeException("Unknown durability " + durability);<a name="line.8104"></a>
+<span class="sourceLineNo">8105</span> }<a name="line.8105"></a>
+<span class="sourceLineNo">8106</span> }<a name="line.8106"></a>
+<span class="sourceLineNo">8107</span> }<a name="line.8107"></a>
+<span class="sourceLineNo">8108</span><a name="line.8108"></a>
+<span class="sourceLineNo">8109</span> /**<a name="line.8109"></a>
+<span class="sourceLineNo">8110</span> * Check whether we should sync the
wal from the table's durability settings<a name="line.8110"></a>
+<span class="sourceLineNo">8111</span> */<a name="line.8111"></a>
+<span class="sourceLineNo">8112</span> private boolean shouldSyncWAL() {<a
name="line.8112"></a>
+<span class="sourceLineNo">8113</span> return durability.ordinal() >
Durability.ASYNC_WAL.ordinal();<a name="line.8113"></a>
+<span class="sourceLineNo">8114</span> }<a name="line.8114"></a>
+<span class="sourceLineNo">8115</span><a name="line.8115"></a>
+<span class="sourceLineNo">8116</span> /**<a name="line.8116"></a>
+<span class="sourceLineNo">8117</span> * A mocked list implementation -
discards all updates.<a name="line.8117"></a>
+<span class="sourceLineNo">8118</span> */<a name="line.8118"></a>
+<span class="sourceLineNo">8119</span> private static final List<Cell>
MOCKED_LIST = new AbstractList<Cell>() {<a name="line.8119"></a>
+<span class="sourceLineNo">8120</span><a name="line.8120"></a>
+<span class="sourceLineNo">8121</span> @Override<a name="line.8121"></a>
+<span class="sourceLineNo">8122</span> public void add(int index, Cell
element) {<a name="line.8122"></a>
+<span class="sourceLineNo">8123</span> // do nothing<a
name="line.8123"></a>
+<span class="sourceLineNo">8124</span> }<a name="line.8124"></a>
+<span class="sourceLineNo">8125</span><a name="line.8125"></a>
+<span class="sourceLineNo">8126</span> @Override<a name="line.8126"></a>
+<span class="sourceLineNo">8127</span> public boolean addAll(int index,
Collection<? extends Cell> c) {<a name="line.8127"></a>
+<span class="sourceLineNo">8128</span> return false; // this list is
never changed as a result of an update<a name="line.8128"></a>
+<span class="sourceLineNo">8129</span> }<a name="line.8129"></a>
+<span class="sourceLineNo">8130</span><a name="line.8130"></a>
+<span class="sourceLineNo">8131</span> @Override<a name="line.8131"></a>
+<span class="sourceLineNo">8132</span> public KeyValue get(int index) {<a
name="line.8132"></a>
+<span class="sourceLineNo">8133</span> throw new
UnsupportedOperationException();<a name="line.8133"></a>
+<span class="sourceLineNo">8134</span> }<a name="line.8134"></a>
+<span class="sourceLineNo">8135</span><a name="line.8135"></a>
+<span class="sourceLineNo">8136</span> @Override<a name="line.8136"></a>
+<span class="sourceLineNo">8137</span> public int size() {<a
name="line.8137"></a>
+<span class="sourceLineNo">8138</span> return 0;<a name="line.8138"></a>
+<span class="sourceLineNo">8139</span> }<a name="line.8139"></a>
+<span class="sourceLineNo">8140</span> };<a name="line.8140"></a>
+<span class="sourceLineNo">8141</span><a name="line.8141"></a>
+<span class="sourceLineNo">8142</span> @Override<a name="line.8142"></a>
+<span class="sourceLineNo">8143</span> public long getOpenSeqNum() {<a
name="line.8143"></a>
+<span class="sourceLineNo">8144</span> return this.openSeqNum;<a
name="line.8144"></a>
+<span class="sourceLineNo">8145</span> }<a name="line.8145"></a>
+<span class="sourceLineNo">8146</span><a name="line.8146"></a>
+<span class="sourceLineNo">8147</span> @Override<a name="line.8147"></a>
+<span class="sourceLineNo">8148</span> public Map<byte[], Long>
getMaxStoreSeqId() {<a name="line.8148"></a>
+<span class="sourceLineNo">8149</span> return this.maxSeqIdInStores;<a
name="line.8149"></a>
+<span class="sourceLineNo">8150</span> }<a name="line.8150"></a>
+<span class="sourceLineNo">8151</span><a name="line.8151"></a>
+<span class="sourceLineNo">8152</span> @Override<a name="line.8152"></a>
+<span class="sourceLineNo">8153</span> public long
getOldestSeqIdOfStore(byte[] familyName) {<a name="line.8153"></a>
+<span class="sourceLineNo">8154</span> return
wal.getEarliestMemstoreSeqNum(getRegionInfo().getEncodedNameAsBytes(),
familyName);<a name="line.8154"></a>
+<span class="sourceLineNo">8155</span> }<a name="line.8155"></a>
+<span class="sourceLineNo">8156</span><a name="line.8156"></a>
+<span class="sourceLineNo">8157</span> @Override<a name="line.8157"></a>
+<span class="sourceLineNo">8158</span> public CompactionState
getCompactionState() {<a name="line.8158"></a>
+<span class="sourceLineNo">8159</span> boolean hasMajor =
majorInProgress.get() > 0, hasMinor = minorInProgress.get() > 0;<a
name="line.8159"></a>
+<span class="sourceLineNo">8160</span> return (hasMajor ? (hasMinor ?
CompactionState.MAJOR_AND_MINOR : CompactionState.MAJOR)<a name="line.8160"></a>
+<span class="sourceLineNo">8161</span> : (hasMinor ?
CompactionState.MINOR : CompactionState.NONE));<a name="line.8161"></a>
+<span class="sourceLineNo">8162</span> }<a name="line.8162"></a>
+<span class="sourceLineNo">8163</span><a name="line.8163"></a>
+<span class="sourceLineNo">8164</span> public void
reportCompactionRequestStart(boolean isMajor){<a name="line.8164"></a>
+<span class="sourceLineNo">8165</span> (isMajor ? majorInProgress :
minorInProgress).incrementAndGet();<a name="line.8165"></a>
+<span class="sourceLineNo">8166</span> }<a name="line.8166"></a>
+<span class="sourceLineNo">8167</span><a name="line.8167"></a>
+<span class="sourceLineNo">8168</span> public void
reportCompactionRequestEnd(boolean isMajor, int numFiles, long
filesSizeCompacted) {<a name="line.8168"></a>
+<span class="sourceLineNo">8169</span> int newValue = (isMajor ?
majorInProgress : minorInProgress).decrementAndGet();<a name="line.8169"></a>
+<span class="sourceLineNo">8170</span><a name="line.8170"></a>
+<span class="sourceLineNo">8171</span> // metrics<a name="line.8171"></a>
+<span class="sourceLineNo">8172</span>
compactionsFinished.incrementAndGet();<a name="line.8172"></a>
+<span class="sourceLineNo">8173</span>
compactionNumFilesCompacted.addAndGet(numFiles);<a name="line.8173"></a>
+<span class="sourceLineNo">8174</span>
compactionNumBytesCompacted.addAndGet(filesSizeCompacted);<a
name="line.8174"></a>
+<span class="sourceLineNo">8175</span><a name="line.8175"></a>
+<span class="sourceLineNo">8176</span> assert newValue >= 0;<a
name="line.8176"></a>
+<span class="sourceLineNo">8177</span> }<a name="line.8177"></a>
+<span class="sourceLineNo">8178</span><a name="line.8178"></a>
+<span class="sourceLineNo">8179</span> public void
reportCompactionRequestFailure() {<a name="line.8179"></a>
+<span class="sourceLineNo">8180</span>
compactionsFailed.incrementAndGet();<a name="line.8180"></a>
+<span class="sourceLineNo">8181</span> }<a name="line.8181"></a>
+<span class="sourceLineNo">8182</span><a name="line.8182"></a>
+<span class="sourceLineNo">8183</span> public void
incrementCompactionsQueuedCount() {<a name="line.8183"></a>
+<span class="sourceLineNo">8184</span>
compactionsQueued.incrementAndGet();<a name="line.8184"></a>
<span class="sourceLineNo">8185</span> }<a name="line.8185"></a>
<span class="sourceLineNo">8186</span><a name="line.8186"></a>
-<span class="sourceLineNo">8187</span> /**<a name="line.8187"></a>
-<span class="sourceLineNo">8188</span> * {@inheritDoc}<a
name="line.8188"></a>
-<span class="sourceLineNo">8189</span> */<a name="line.8189"></a>
-<span class="sourceLineNo">8190</span> @Override<a name="line.8190"></a>
-<span class="sourceLineNo">8191</span> public void
onConfigurationChange(Configuration conf) {<a name="line.8191"></a>
-<span class="sourceLineNo">8192</span> // Do nothing for now.<a
name="line.8192"></a>
+<span class="sourceLineNo">8187</span> public void
decrementCompactionsQueuedCount() {<a name="line.8187"></a>
+<span class="sourceLineNo">8188</span>
compactionsQueued.decrementAndGet();<a name="line.8188"></a>
+<span class="sourceLineNo">8189</span> }<a name="line.8189"></a>
+<span class="sourceLineNo">8190</span><a name="line.8190"></a>
+<span class="sourceLineNo">8191</span> public void
incrementFlushesQueuedCount() {<a name="line.8191"></a>
+<span class="sourceLineNo">8192</span> flushesQueued.incrementAndGet();<a
name="line.8192"></a>
<span class="sourceLineNo">8193</span> }<a name="line.8193"></a>
<span class="sourceLineNo">8194</span><a name="line.8194"></a>
-<span class="sourceLineNo">8195</span> /**<a name="line.8195"></a>
-<span class="sourceLineNo">8196</span> * {@inheritDoc}<a
name="line.8196"></a>
-<span class="sourceLineNo">8197</span> */<a name="line.8197"></a>
-<span class="sourceLineNo">8198</span> @Override<a name="line.8198"></a>
-<span class="sourceLineNo">8199</span> public void
registerChildren(ConfigurationManager manager) {<a name="line.8199"></a>
-<span class="sourceLineNo">8200</span> configurationManager =
Optional.of(manager);<a name="line.8200"></a>
-<span class="sourceLineNo">8201</span> for (Store s : this.stores.values())
{<a name="line.8201"></a>
-<span class="sourceLineNo">8202</span>
configurationManager.get().registerObserver(s);<a name="line.8202"></a>
-<span class="sourceLineNo">8203</span> }<a name="line.8203"></a>
-<span class="sourceLineNo">8204</span> }<a name="line.8204"></a>
-<span class="sourceLineNo">8205</span><a name="line.8205"></a>
-<span class="sourceLineNo">8206</span> /**<a name="line.8206"></a>
-<span class="sourceLineNo">8207</span> * {@inheritDoc}<a
name="line.8207"></a>
-<span class="sourceLineNo">8208</span> */<a name="line.8208"></a>
-<span class="sourceLineNo">8209</span> @Override<a name="line.8209"></a>
-<span class="sourceLineNo">8210</span> public void
deregisterChildren(ConfigurationManager manager) {<a name="line.8210"></a>
-<span class="sourceLineNo">8211</span> for (Store s : this.stores.values())
{<a name="line.8211"></a>
-<span class="sourceLineNo">8212</span>
configurationManager.get().deregisterObserver(s);<a name="line.8212"></a>
-<span class="sourceLineNo">8213</span> }<a name="line.8213"></a>
-<span class="sourceLineNo">8214</span> }<a name="line.8214"></a>
-<span class="sourceLineNo">8215</span><a name="line.8215"></a>
-<span class="sourceLineNo">8216</span> @Override<a name="line.8216"></a>
-<span class="sourceLineNo">8217</span> public CellComparator
getCellComparator() {<a name="line.8217"></a>
-<span class="sourceLineNo">8218</span> return
this.getRegionInfo().isMetaRegion() ? CellComparator.META_COMPARATOR<a
name="line.8218"></a>
-<span class="sourceLineNo">8219</span> : CellComparator.COMPARATOR;<a
name="line.8219"></a>
-<span class="sourceLineNo">8220</span> }<a name="line.8220"></a>
-<span class="sourceLineNo">8221</span><a name="line.8221"></a>
-<span class="sourceLineNo">8222</span> public long getMemstoreFlushSize() {<a
name="line.8222"></a>
-<span class="sourceLineNo">8223</span> return this.memstoreFlushSize;<a
name="line.8223"></a>
-<span class="sourceLineNo">8224</span> }<a name="line.8224"></a>
-<span class="sourceLineNo">8225</span><a name="line.8225"></a>
-<span class="sourceLineNo">8226</span> //// method for debugging tests<a
name="line.8226"></a>
-<span class="sourceLineNo">8227</span> void throwException(String title,
String regionName) {<a name="line.8227"></a>
-<span class="sourceLineNo">8228</span> StringBuffer buf = new
StringBuffer();<a name="line.8228"></a>
-<span class="sourceLineNo">8229</span> buf.append(title + ", ");<a
name="line.8229"></a>
-<span class="sourceLineNo">8230</span>
buf.append(getRegionInfo().toString());<a name="line.8230"></a>
-<span class="sourceLineNo">8231</span>
buf.append(getRegionInfo().isMetaRegion() ? " meta region " : " ");<a
name="line.8231"></a>
-<span class="sourceLineNo">8232</span>
buf.append(getRegionInfo().isMetaTable() ? " meta table " : " ");<a
name="line.8232"></a>
-<span class="sourceLineNo">8233</span> buf.append("stores: ");<a
name="line.8233"></a>
-<span class="sourceLineNo">8234</span> for (Store s : getStores()) {<a
name="line.8234"></a>
-<span class="sourceLineNo">8235</span>
buf.append(s.getColumnFamilyDescriptor().getNameAsString());<a
name="line.8235"></a>
-<span class="sourceLineNo">8236</span> buf.append(" size: ");<a
name="line.8236"></a>
-<span class="sourceLineNo">8237</span>
buf.append(s.getSizeOfMemStore().getDataSize());<a name="line.8237"></a>
-<span class="sourceLineNo">8238</span> buf.append(" ");<a
name="line.8238"></a>
-<span class="sourceLineNo">8239</span> }<a name="line.8239"></a>
-<span class="sourceLineNo">8240</span> buf.append("end-of-stores");<a
name="line.8240"></a>
-<span class="sourceLineNo">8241</span> buf.append(", memstore size ");<a
name="line.8241"></a>
-<span class="sourceLineNo">8242</span> buf.append(getMemstoreSize());<a
name="line.8242"></a>
-<span class="sourceLineNo">8243</span> if
(getRegionInfo().getRegionNameAsString().startsWith(regionName)) {<a
name="line.8243"></a>
-<span class="sourceLineNo">8244</span> throw new
RuntimeException(buf.toString());<a name="line.8244"></a>
-<span class="sourceLineNo">8245</span> }<a name="line.8245"></a>
-<span class="sourceLineNo">8246</span> }<a name="line.8246"></a>
-<span class="sourceLineNo">8247</span>}<a name="line.8247"></a>
+<span class="sourceLineNo">8195</span> @VisibleForTesting<a
name="line.8195"></a>
+<span class="sourceLineNo">8196</span> public long getReadPoint() {<a
name="line.8196"></a>
+<span class="sourceLineNo">8197</span> return
getReadPoint(IsolationLevel.READ_COMMITTED);<a name="line.8197"></a>
+<span class="sourceLineNo">8198</span> }<a name="line.8198"></a>
+<span class="sourceLineNo">8199</span><a name="line.8199"></a>
+<span class="sourceLineNo">8200</span> /**<a name="line.8200"></a>
+<span class="sourceLineNo">8201</span> * {@inheritDoc}<a
name="line.8201"></a>
+<span class="sourceLineNo">8202</span> */<a name="line.8202"></a>
+<span class="sourceLineNo">8203</span> @Override<a name="line.8203"></a>
+<span class="sourceLineNo">8204</span> public void
onConfigurationChange(Configuration conf) {<a name="line.8204"></a>
+<span class="sourceLineNo">8205</span> // Do nothing for now.<a
name="line.8205"></a>
+<span class="sourceLineNo">8206</span> }<a name="line.8206"></a>
+<span class="sourceLineNo">8207</span><a name="line.8207"></a>
+<span class="sourceLineNo">8208</span> /**<a name="line.8208"></a>
+<span class="sourceLineNo">8209</span> * {@inheritDoc}<a
name="line.8209"></a>
+<span class="sourceLineNo">8210</span> */<a name="line.8210"></a>
+<span class="sourceLineNo">8211</span> @Override<a name="line.8211"></a>
+<span class="sourceLineNo">8212</span> public void
registerChildren(ConfigurationManager manager) {<a name="line.8212"></a>
+<span class="sourceLineNo">8213</span> configurationManager =
Optional.of(manager);<a name="line.8213"></a>
+<span class="sourceLineNo">8214</span> for (Store s : this.stores.values())
{<a name="line.8214"></a>
+<span class="sourceLineNo">8215</span>
configurationManager.get().registerObserver(s);<a name="line.8215"></a>
+<span class="sourceLineNo">8216</span> }<a name="line.8216"></a>
+<span class="sourceLineNo">8217</span> }<a name="line.8217"></a>
+<span class="sourceLineNo">8218</span><a name="line.8218"></a>
+<span class="sourceLineNo">8219</span> /**<a name="line.8219"></a>
+<span class="sourceLineNo">8220</span> * {@inheritDoc}<a
name="line.8220"></a>
+<span class="sourceLineNo">8221</span> */<a name="line.8221"></a>
+<span class="sourceLineNo">8222</span> @Override<a name="line.8222"></a>
+<span class="sourceLineNo">8223</span> public void
deregisterChildren(ConfigurationManager manager) {<a name="line.8223"></a>
+<span class="sourceLineNo">8224</span> for (Store s : this.stores.values())
{<a name="line.8224"></a>
+<span class="sourceLineNo">8225</span>
configurationManager.get().deregisterObserver(s);<a name="line.8225"></a>
+<span class="sourceLineNo">8226</span> }<a name="line.8226"></a>
+<span class="sourceLineNo">8227</span> }<a name="line.8227"></a>
+<span class="sourceLineNo">8228</span><a name="line.8228"></a>
+<span class="sourceLineNo">8229</span> @Override<a name="line.8229"></a>
+<span class="sourceLineNo">8230</span> public CellComparator
getCellComparator() {<a name="line.8230"></a>
+<span class="sourceLineNo">8231</span> return
this.getRegionInfo().isMetaRegion() ? CellComparator.META_COMPARATOR<a
name="line.8231"></a>
+<span class="sourceLineNo">8232</span> : CellComparator.COMPARATOR;<a
name="line.8232"></a>
+<span class="sourceLineNo">8233</span> }<a name="line.8233"></a>
+<span class="sourceLineNo">8234</span><a name="line.8234"></a>
+<span class="sourceLineNo">8235</span> public long getMemstoreFlushSize() {<a
name="line.8235"></a>
+<span class="sourceLineNo">8236</span> return this.memstoreFlushSize;<a
name="line.8236"></a>
+<span class="sourceLineNo">8237</span> }<a name="line.8237"></a>
+<span class="sourceLineNo">8238</span><a name="line.8238"></a>
+<span class="sourceLineNo">8239</span> //// method for debugging tests<a
name="line.8239"></a>
+<span class="sourceLineNo">8240</span> void throwException(String title,
String regionName) {<a name="line.8240"></a>
+<span class="sourceLineNo">8241</span> StringBuffer buf = new
StringBuffer();<a name="line.8241"></a>
+<span class="sourceLineNo">8242</span> buf.append(title + ", ");<a
name="line.8242"></a>
+<span class="sourceLineNo">8243</span>
buf.append(getRegionInfo().toString());<a name="line.8243"></a>
+<span class="sourceLineNo">8244</span>
buf.append(getRegionInfo().isMetaRegion() ? " meta region " : " ");<a
name="line.8244"></a>
+<span class="sourceLineNo">8245</span>
buf.append(getRegionInfo().isMetaTable() ? " meta table " : " ");<a
name="line.8245"></a>
+<span class="sourceLineNo">8246</span> buf.append("stores: ");<a
name="line.8246"></a>
+<span class="sourceLineNo">8247</span> for (Store s : getStores()) {<a
name="line.8247"></a>
+<span class="sourceLineNo">8248</span>
buf.append(s.getColumnFamilyDescriptor().getNameAsString());<a
name="line.8248"></a>
+<span class="sourceLineNo">8249</span> buf.append(" size: ");<a
name="line.8249"></a>
+<span class="sourceLineNo">8250</span>
buf.append(s.getSizeOfMemStore().getDataSize());<a name="line.8250"></a>
+<span class="sourceLineNo">8251</span> buf.append(" ");<a
name="line.8251"></a>
+<span class="sourceLineNo">8252</span> }<a name="line.8252"></a>
+<span class="sourceLineNo">8253</span> buf.append("end-of-stores");<a
name="line.8253"></a>
+<span class="sourceLineNo">8254</span> buf.append(", memstore size ");<a
name="line.8254"></a>
+<span class="sourceLineNo">8255</span> buf.append(getMemstoreSize());<a
name="line.8255"></a>
+<span class="sourceLineNo">8256</span> if
(getRegionInfo().getRegionNameAsString().startsWith(regionName)) {<a
name="line.8256"></a>
+<span class="sourceLineNo">8257</span> throw new
RuntimeException(buf.toString());<a name="line.8257"></a>
+<span class="sourceLineNo">8258</span> }<a name="line.8258"></a>
+<span class="sourceLineNo">8259</span> }<a name="line.8259"></a>
+<span class="sourceLineNo">8260</span>}<a name="line.8260"></a>
