Skip to content

Commit e780159

Browse files
committed
rename
1 parent e49d923 commit e780159

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinatorLock.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ public class PipeTaskCoordinatorLock {
3737

3838
private final BlockingDeque<Long> deque = new LinkedBlockingDeque<>(1);
3939
private final AtomicLong idGenerator = new AtomicLong(0);
40-
private final AtomicLong acquireLockIdGenerator = new AtomicLong(0);
40+
private final AtomicLong lockSeqIdGenerator = new AtomicLong(0);
4141

4242
public long lock() {
4343
try {
@@ -51,7 +51,7 @@ public long lock() {
5151
"PipeTaskCoordinator lock (id: {}) acquired by thread {}",
5252
id,
5353
Thread.currentThread().getName());
54-
return acquireLockIdGenerator.incrementAndGet();
54+
return lockSeqIdGenerator.incrementAndGet();
5555
} catch (InterruptedException e) {
5656
Thread.currentThread().interrupt();
5757
LOGGER.error(
@@ -73,7 +73,7 @@ public long tryLock() {
7373
"PipeTaskCoordinator lock (id: {}) acquired by thread {}",
7474
id,
7575
Thread.currentThread().getName());
76-
return acquireLockIdGenerator.incrementAndGet();
76+
return lockSeqIdGenerator.incrementAndGet();
7777
} else {
7878
LOGGER.info(
7979
"PipeTaskCoordinator lock (id: {}) failed to acquire by thread {} because of timeout",

0 commit comments

Comments
 (0)