| /dports/databases/hbase/hbase-1.2.1/hbase-common/src/main/java/org/apache/hadoop/hbase/ |
| H A D | ProcedureInfo.java | 40 public class ProcedureInfo implements Cloneable { class
55 public ProcedureInfo( in ProcedureInfo() method in ProcedureInfo
82 public ProcedureInfo clone() { in clone()
83 return new ProcedureInfo(procId, procName, procOwner, procState, parentId, nonceKey, in clone()
225 final ProcedureInfo procInfo) { in convertToProcedureProto()
259 public static ProcedureInfo convert(final ProcedureProtos.Procedure procProto) { in convert()
265 return new ProcedureInfo( in convert()
286 public static boolean isProcedureOwner(final ProcedureInfo procInfo, final User user) { in isProcedureOwner()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ |
| H A D | ProcedureExecutor.java | 43 import org.apache.hadoop.hbase.ProcedureInfo;
141 private final Map<Long, ProcedureInfo> completed;
147 final Map<Long, ProcedureInfo> completedMap, in CompletedProcedureCleaner()
224 new ConcurrentHashMap<Long, ProcedureInfo>();
597 public List<ProcedureInfo> listProcedures() { in listProcedures()
598 List<ProcedureInfo> procedureLists = in listProcedures()
685 public ProcedureInfo getResult(final long procId) { in getResult()
718 ProcedureInfo result = completed.get(procId); in removeResult()
776 ProcedureInfo procInfo = completed.get(procId); in isProcedureOwner()
785 public Map<Long, ProcedureInfo> getResults() { in getResults()
[all …]
|
| H A D | Procedure.java | 31 import org.apache.hadoop.hbase.ProcedureInfo;
655 public static ProcedureInfo createProcedureInfo(final Procedure proc, final NonceKey nonceKey) { in createProcedureInfo()
657 return new ProcedureInfo( in createProcedureInfo()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/ |
| H A D | ProcedureTestingUtility.java | 31 import org.apache.hadoop.hbase.ProcedureInfo;
172 ProcedureInfo result = procExecutor.getResult(procId); in assertProcNotFailed()
177 public static void assertProcNotFailed(final ProcedureInfo result) { in assertProcNotFailed()
183 public static void assertIsAbortException(final ProcedureInfo result) { in assertIsAbortException()
191 public static void assertIsTimeoutException(final ProcedureInfo result) { in assertIsTimeoutException()
198 public static void assertIsIllegalArgumentException(final ProcedureInfo result) { in assertIsIllegalArgumentException()
206 public static Throwable getExceptionCause(final ProcedureInfo procInfo) { in getExceptionCause()
|
| H A D | TestProcedureExecution.java | 30 import org.apache.hadoop.hbase.ProcedureInfo;
141 ProcedureInfo result = procExecutor.getResult(rootId); in testBadSubprocList()
162 ProcedureInfo result = procExecutor.getResult(rootId); in testSingleSequentialProc()
178 ProcedureInfo result = procExecutor.getResult(rootId); in testSingleSequentialProcRollback()
222 ProcedureInfo result = procExecutor.getResult(procId); in testRollbackRetriableFailure()
306 ProcedureInfo result = procExecutor.getResult(rootId); in testAbortTimeout()
321 ProcedureInfo result = procExecutor.getResult(rootId); in testAbortTimeoutWithChildren()
|
| H A D | TestProcedureRecovery.java | 33 import org.apache.hadoop.hbase.ProcedureInfo;
200 ProcedureInfo result = procExecutor.getResult(procId); in testSingleStepProcRecovery()
239 ProcedureInfo result = procExecutor.getResult(procId); in testMultiStepProcRecovery()
286 ProcedureInfo result = procExecutor.getResult(procId); in testMultiStepRollbackRecovery()
307 ProcedureInfo result = procExecutor.getResult(procId2); in testCompletedProcWithSameNonce()
454 ProcedureInfo result = procExecutor.getResult(procId); in testStateMachineRecovery()
508 ProcedureInfo result = procExecutor.getResult(procId); in testStateMachineRollbackRecovery()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/store/ |
| H A D | ProcedureStore.java | 25 import org.apache.hadoop.hbase.ProcedureInfo;
90 ProcedureInfo nextAsProcedureInfo(); in nextAsProcedureInfo()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/master/procedure/ |
| H A D | TestProcedureAdmin.java | 31 import org.apache.hadoop.hbase.ProcedureInfo;
198 List<ProcedureInfo> listProcedures = procExec.listProcedures(); in testListProcedure()
201 for (ProcedureInfo procInfo: listProcedures) { in testListProcedure()
216 for (ProcedureInfo procInfo: listProcedures) { in testListProcedure()
|
| H A D | TestTruncateTableProcedure.java | 28 import org.apache.hadoop.hbase.ProcedureInfo;
104 ProcedureInfo result = procExec.getResult(procId); in testTruncateNotExistentTable()
121 ProcedureInfo result = procExec.getResult(procId); in testTruncateNotDisabledTable()
|
| H A D | TestDeleteColumnFamilyProcedure.java | 31 import org.apache.hadoop.hbase.ProcedureInfo;
153 ProcedureInfo result = procExec.getResult(procId2); in testDeleteColumnFamilyTwice()
223 ProcedureInfo result = procExec.getResult(procId1); in testDeleteNonExistingColumnFamily()
|
| H A D | TestDisableTableProcedure.java | 29 import org.apache.hadoop.hbase.ProcedureInfo;
128 ProcedureInfo result = procExec.getResult(procId2); in testDisableTableMultipleTimes()
|
| H A D | TestEnableTableProcedure.java | 29 import org.apache.hadoop.hbase.ProcedureInfo;
143 ProcedureInfo result = procExec.getResult(procId1); in testEnableNonDisabledTable()
|
| H A D | TestDeleteTableProcedure.java | 28 import org.apache.hadoop.hbase.ProcedureInfo;
144 ProcedureInfo result = procExec.getResult(procId2); in testDeleteDeletedTable()
|
| H A D | TestModifyColumnFamilyProcedure.java | 31 import org.apache.hadoop.hbase.ProcedureInfo;
148 ProcedureInfo result = procExec.getResult(procId1); in testModifyNonExistingColumnFamily()
|
| H A D | TestAddColumnFamilyProcedure.java | 31 import org.apache.hadoop.hbase.ProcedureInfo;
155 ProcedureInfo result = procExec.getResult(procId2); in testAddSameColumnFamilyTwice()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/master/ |
| H A D | MasterServices.java | 29 import org.apache.hadoop.hbase.ProcedureInfo;
302 public List<ProcedureInfo> listProcedures() throws IOException; in listProcedures()
|
| H A D | MasterRpcServices.java | 38 import org.apache.hadoop.hbase.ProcedureInfo;
1032 Pair<ProcedureInfo, Procedure> v = master.getMasterProcedureExecutor() in getProcedureResult()
1035 ProcedureInfo result = v.getFirst(); in getProcedureResult()
1084 for(ProcedureInfo p: master.listProcedures()) { in listProcedures()
1085 response.addProcedure(ProcedureInfo.convertToProcedureProto(p)); in listProcedures()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/store/wal/ |
| H A D | ProcedureWALFormatReader.java | 28 import org.apache.hadoop.hbase.ProcedureInfo;
288 public ProcedureInfo convertToInfo() { in convertToInfo()
289 return ProcedureInfo.convert(proto); in convertToInfo()
337 public ProcedureInfo nextAsProcedureInfo() { in nextAsProcedureInfo()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/ |
| H A D | ProcedureSyncWait.java | 32 import org.apache.hadoop.hbase.ProcedureInfo;
81 ProcedureInfo result = procExec.getResult(procId); in waitForProcedureToComplete()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ |
| H A D | Admin.java | 35 import org.apache.hadoop.hbase.ProcedureInfo;
966 ProcedureInfo[] listProcedures() throws IOException; in listProcedures()
|
| H A D | HBaseAdmin.java | 55 import org.apache.hadoop.hbase.ProcedureInfo;
3051 public ProcedureInfo[] listProcedures() throws IOException {
3053 executeCallable(new MasterCallable<ProcedureInfo[]>(getConnection()) {
3055 public ProcedureInfo[] call(int callTimeout) throws Exception {
3060 ProcedureInfo[] procInfoList = new ProcedureInfo[procList.size()];
3062 procInfoList[i] = ProcedureInfo.convert(procList.get(i));
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/ |
| H A D | MasterObserver.java | 29 import org.apache.hadoop.hbase.ProcedureInfo;
494 List<ProcedureInfo> procInfoList) throws IOException; in postListProcedures()
|
| H A D | BaseMasterObserver.java | 25 import org.apache.hadoop.hbase.ProcedureInfo;
318 List<ProcedureInfo> procInfoList) throws IOException { in postListProcedures()
|
| H A D | BaseMasterAndRegionObserver.java | 25 import org.apache.hadoop.hbase.ProcedureInfo;
315 List<ProcedureInfo> procInfoList) throws IOException { in postListProcedures()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/client/ |
| H A D | TestAdmin2.java | 44 import org.apache.hadoop.hbase.ProcedureInfo;
790 ProcedureInfo[] procList = admin.listProcedures(); in testListProcedures()
|