Skip to content

Commit 644cdbc

Browse files
authored
HBASE-29055 Remove the useless parameter from RootProcedureState (#6903)
Signed-off-by: Duo Zhang <[email protected]>
1 parent e28b449 commit 644cdbc

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1454,7 +1454,7 @@ private void executeProcedure(Procedure<TEnvironment> proc) {
14541454
}
14551455
do {
14561456
// Try to acquire the execution
1457-
if (!procStack.acquire(proc)) {
1457+
if (!procStack.acquire()) {
14581458
if (procStack.setRollback()) {
14591459
// we have the 'rollback-lock' we can start rollingback
14601460
switch (executeRollback(rootProcId, procStack)) {
@@ -1513,7 +1513,7 @@ private void executeProcedure(Procedure<TEnvironment> proc) {
15131513
default:
15141514
throw new UnsupportedOperationException();
15151515
}
1516-
procStack.release(proc);
1516+
procStack.release();
15171517

15181518
if (proc.isSuccess()) {
15191519
// update metrics on finishing the procedure

hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/RootProcedureState.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -135,7 +135,7 @@ protected synchronized RemoteProcedureException getException() {
135135
/**
136136
* Called by the ProcedureExecutor to mark the procedure step as running.
137137
*/
138-
protected synchronized boolean acquire(Procedure<TEnvironment> proc) {
138+
protected synchronized boolean acquire() {
139139
if (state != State.RUNNING) {
140140
return false;
141141
}
@@ -147,7 +147,7 @@ protected synchronized boolean acquire(Procedure<TEnvironment> proc) {
147147
/**
148148
* Called by the ProcedureExecutor to mark the procedure step as finished.
149149
*/
150-
protected synchronized void release(Procedure<TEnvironment> proc) {
150+
protected synchronized void release() {
151151
running--;
152152
}
153153

0 commit comments

Comments
 (0)