You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zh...@apache.org on 2016/07/04 12:41:41 UTC
hbase git commit: HBASE-16135 addendum format comments
Repository: hbase
Updated Branches:
refs/heads/branch-1 721c5b712 -> 480783630
HBASE-16135 addendum format comments
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/48078363
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/48078363
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/48078363
Branch: refs/heads/branch-1
Commit: 4807836304ab75a2c9bedcc4afb30d2332cebb7b
Parents: 721c5b7
Author: zhangduo <zh...@apache.org>
Authored: Mon Jul 4 20:41:06 2016 +0800
Committer: zhangduo <zh...@apache.org>
Committed: Mon Jul 4 20:41:06 2016 +0800
----------------------------------------------------------------------
.../hbase/replication/regionserver/ReplicationSourceManager.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/48078363/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.java
index b41fe2b..9f4985d 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.java
@@ -389,8 +389,8 @@ public class ReplicationSourceManager implements ReplicationListener {
String logName = logPath.getName();
String logPrefix = DefaultWALProvider.getWALPrefixFromWALName(logName);
// update replication queues on ZK
- synchronized (replicationPeers) {// synchronize on replicationPeers to avoid adding source for
- // the to-be-removed peer
+ // synchronize on replicationPeers to avoid adding source for the to-be-removed peer
+ synchronized (replicationPeers) {
for (String id : replicationPeers.getPeerIds()) {
try {
this.replicationQueues.addLog(id, logName);