You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tubemq.apache.org by go...@apache.org on 2020/01/13 02:04:51 UTC
[incubator-tubemq] branch master updated: [TUBEMQ-18] Correct
TMaster#idGenerater to TMaster#idGenerator (#9)
This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git
The following commit(s) were added to refs/heads/master by this push:
new f8beb7b [TUBEMQ-18] Correct TMaster#idGenerater to TMaster#idGenerator (#9)
f8beb7b is described below
commit f8beb7b4c6852a967e812ac43507d4bbb248d3d5
Author: Tboy <gu...@immomo.com>
AuthorDate: Mon Jan 13 10:04:45 2020 +0800
[TUBEMQ-18] Correct TMaster#idGenerater to TMaster#idGenerator (#9)
Correct spelling, correct method naming and correct TMaster#idGenerater to TMaster#idGenerator
---
.../src/main/java/com/tencent/tubemq/server/master/TMaster.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/tubemq-server/src/main/java/com/tencent/tubemq/server/master/TMaster.java b/tubemq-server/src/main/java/com/tencent/tubemq/server/master/TMaster.java
index 931b585..cf204b5 100644
--- a/tubemq-server/src/main/java/com/tencent/tubemq/server/master/TMaster.java
+++ b/tubemq-server/src/main/java/com/tencent/tubemq/server/master/TMaster.java
@@ -140,7 +140,7 @@ public class TMaster extends HasThread implements MasterService, Stoppable {
private final BrokerConfManage defaultBrokerConfManage; //broker config manager
private final CertificateMasterHandler serverAuthHandler; //server auth handler
private AtomicBoolean shutdownHooked = new AtomicBoolean(false);
- private AtomicLong idGenerater = new AtomicLong(0); //id generator
+ private AtomicLong idGenerator = new AtomicLong(0); //id generator
private volatile boolean stopped = false; //stop flag
private Thread balancerChore; //balance chore
private Thread resetBalancerChore; //reset balance chore
@@ -1880,7 +1880,7 @@ public class TMaster extends HasThread implements MasterService, Stoppable {
private void balance() {
// #lizard forgives
final StringBuilder strBuffer = new StringBuilder(512);
- long rebalanceId = idGenerater.incrementAndGet();
+ long rebalanceId = idGenerator.incrementAndGet();
if (defaultBdbStoreService != null) {
logger.info(strBuffer.append("[Rebalance Start] ").append(rebalanceId)
.append(", isMaster=").append(defaultBdbStoreService.isMaster())
@@ -2027,7 +2027,7 @@ public class TMaster extends HasThread implements MasterService, Stoppable {
// #lizard forgives
//consumer need reset offset
final StringBuilder strBuffer = new StringBuilder(512);
- long rebalanceId = idGenerater.incrementAndGet();
+ long rebalanceId = idGenerator.incrementAndGet();
if (defaultBdbStoreService != null) {
logger.info(strBuffer.append("[ResetRebalance Start] ").append(rebalanceId)
.append(", isMaster=").append(defaultBdbStoreService.isMaster())