|  | 
| 53 | 53 | import org.apache.hadoop.hbase.filter.Filter; | 
| 54 | 54 | import org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker; | 
| 55 | 55 | import org.apache.hadoop.hbase.regionserver.MiniBatchOperationInProgress; | 
|  | 56 | +import org.apache.hadoop.hbase.regionserver.Store; | 
|  | 57 | +import org.apache.hadoop.hbase.regionserver.StoreFile; | 
|  | 58 | +import org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker; | 
| 56 | 59 | import org.apache.hadoop.hbase.util.Pair; | 
| 57 | 60 | import org.apache.hadoop.hbase.wal.WALEdit; | 
| 58 | 61 | import org.apache.yetus.audience.InterfaceAudience; | 
| @@ -81,6 +84,7 @@ private void internalReadOnlyGuard() throws IOException { | 
| 81 | 84 | 
 | 
| 82 | 85 |   @Override | 
| 83 | 86 |   public void start(CoprocessorEnvironment env) throws IOException { | 
|  | 87 | + | 
| 84 | 88 |     this.globalReadOnlyEnabled = | 
| 85 | 89 |       env.getConfiguration().getBoolean(HConstants.HBASE_GLOBAL_READONLY_ENABLED_KEY, | 
| 86 | 90 |         HConstants.HBASE_GLOBAL_READONLY_ENABLED_DEFAULT); | 
| @@ -131,6 +135,13 @@ public void preFlush(final ObserverContext<? extends RegionCoprocessorEnvironmen | 
| 131 | 135 |     internalReadOnlyGuard(); | 
| 132 | 136 |   } | 
| 133 | 137 | 
 | 
|  | 138 | +  @Override | 
|  | 139 | +  public void preCompactSelection(ObserverContext<? extends RegionCoprocessorEnvironment> c, | 
|  | 140 | +    Store store, List<? extends StoreFile> candidates, CompactionLifeCycleTracker tracker) | 
|  | 141 | +    throws IOException { | 
|  | 142 | +    internalReadOnlyGuard(); | 
|  | 143 | +  } | 
|  | 144 | + | 
| 134 | 145 |   @Override | 
| 135 | 146 |   public boolean preCheckAndPut(ObserverContext<? extends RegionCoprocessorEnvironment> c, | 
| 136 | 147 |     byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, | 
|  | 
0 commit comments