You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2011/10/28 08:59:47 UTC
svn commit: r1190176 - in /hbase/trunk: ./
src/main/java/org/apache/hadoop/hbase/
src/main/java/org/apache/hadoop/hbase/master/
src/main/java/org/apache/hadoop/hbase/util/
src/test/java/org/apache/hadoop/hbase/
src/test/java/org/apache/hadoop/hbase/mas...
Author: stack
Date: Fri Oct 28 06:59:47 2011
New Revision: 1190176
URL: http://svn.apache.org/viewvc?rev=1190176&view=rev
Log:
HBASE-4692 HBASE-4300 broke the build
Modified:
hbase/trunk/CHANGES.txt
hbase/trunk/src/main/java/org/apache/hadoop/hbase/ServerName.java
hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/ActiveMasterManager.java
hbase/trunk/src/main/java/org/apache/hadoop/hbase/util/Addressing.java
hbase/trunk/src/test/java/org/apache/hadoop/hbase/TestServerName.java
hbase/trunk/src/test/java/org/apache/hadoop/hbase/master/TestActiveMasterManager.java
Modified: hbase/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hbase/trunk/CHANGES.txt?rev=1190176&r1=1190175&r2=1190176&view=diff
==============================================================================
--- hbase/trunk/CHANGES.txt (original)
+++ hbase/trunk/CHANGES.txt Fri Oct 28 06:59:47 2011
@@ -416,6 +416,7 @@ Release 0.92.0 - Unreleased
hanging around
HBASE-4679 Thrift null mutation error
HBASE-4304 requestsPerSecond counter stuck at 0 (Li Pi)
+ HBASE-4692 HBASE-4300 broke the build
TESTS
HBASE-4450 test for number of blocks read: to serve as baseline for expected
Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/ServerName.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/ServerName.java?rev=1190176&r1=1190175&r2=1190176&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/ServerName.java (original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/ServerName.java Fri Oct 28 06:59:47 2011
@@ -65,7 +65,7 @@ public class ServerName implements Compa
public static final String SERVERNAME_SEPARATOR = ",";
public static Pattern SERVERNAME_PATTERN =
- Pattern.compile(Addressing.VALID_HOSTNAME_REGEX_PREFIX +
+ Pattern.compile("[^" + SERVERNAME_SEPARATOR + "]+" +
SERVERNAME_SEPARATOR + Addressing.VALID_PORT_REGEX +
SERVERNAME_SEPARATOR + Addressing.VALID_PORT_REGEX + "$");
@@ -286,4 +286,4 @@ public class ServerName implements Compa
return SERVERNAME_PATTERN.matcher(str).matches()? new ServerName(str):
new ServerName(str, NON_STARTCODE);
}
-}
+}
\ No newline at end of file
Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/ActiveMasterManager.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/ActiveMasterManager.java?rev=1190176&r1=1190175&r2=1190176&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/ActiveMasterManager.java (original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/ActiveMasterManager.java Fri Oct 28 06:59:47 2011
@@ -42,7 +42,7 @@ import org.apache.zookeeper.KeeperExcept
* for the active master to fail.
*
* <p>This class is instantiated in the HMaster constructor and the method
- * {@link #blockUntilBecomingActiveMaster()} is called to wait until becoming
+ * #blockUntilBecomingActiveMaster() is called to wait until becoming
* the active master of the cluster.
*/
class ActiveMasterManager extends ZooKeeperListener {
@@ -128,10 +128,11 @@ class ActiveMasterManager extends ZooKee
boolean blockUntilBecomingActiveMaster(MonitoredTask startupStatus) {
startupStatus.setStatus("Trying to register in ZK as active master");
boolean cleanSetOfActiveMaster = true;
- // Try to become the active master, watch if there is another master
+ // Try to become the active master, watch if there is another master.
+ // Write out our ServerName as versioned bytes.
try {
if (ZKUtil.createEphemeralNodeAndWatch(this.watcher,
- this.watcher.masterAddressZNode, Bytes.toBytes(this.sn.toString()))) {
+ this.watcher.masterAddressZNode, sn.getVersionedBytes())) {
// We are the master, return
startupStatus.setStatus("Successfully registered as active master.");
this.clusterHasActiveMaster.set(true);
Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/util/Addressing.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/util/Addressing.java?rev=1190176&r1=1190175&r2=1190176&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/util/Addressing.java (original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/util/Addressing.java Fri Oct 28 06:59:47 2011
@@ -25,20 +25,6 @@ import java.net.InetSocketAddress;
* Utility for network addresses, resolving and naming.
*/
public class Addressing {
- /**
- * Regex for RFC952 hostname matching. Does not have a '$" on the end. Can
- * be used as prefix on a larger regex.
- * @see http://stackoverflow.com/questions/106179/regular-expression-to-match-hostname-or-ip-address
- */
- public static final String VALID_HOSTNAME_REGEX_PREFIX =
- "^(([a-zA-Z]|[a-zA-Z][a-zA-Z0-9\\-]*[a-zA-Z0-9])\\.)*([A-Za-z]|[A-Za-z][A-Za-z0-9\\-]*[A-Za-z0-9])";
- /**
- * Regex for RFC952 hostname matching.
- * @see http://stackoverflow.com/questions/106179/regular-expression-to-match-hostname-or-ip-address
- */
- public static final String VALID_HOSTNAME_REGEX =
- VALID_HOSTNAME_REGEX_PREFIX + "$";
-
public static final String VALID_PORT_REGEX = "[\\d]+";
public static final String HOSTNAME_PORT_SEPARATOR = ":";
Modified: hbase/trunk/src/test/java/org/apache/hadoop/hbase/TestServerName.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/test/java/org/apache/hadoop/hbase/TestServerName.java?rev=1190176&r1=1190175&r2=1190176&view=diff
==============================================================================
--- hbase/trunk/src/test/java/org/apache/hadoop/hbase/TestServerName.java (original)
+++ hbase/trunk/src/test/java/org/apache/hadoop/hbase/TestServerName.java Fri Oct 28 06:59:47 2011
@@ -33,10 +33,11 @@ public class TestServerName {
public void testRegexPatterns() {
assertTrue(Pattern.matches(Addressing.VALID_PORT_REGEX, "123"));
assertFalse(Pattern.matches(Addressing.VALID_PORT_REGEX, ""));
- assertTrue(Pattern.matches(Addressing.VALID_HOSTNAME_REGEX, "example.org"));
- assertTrue(Pattern.matches(Addressing.VALID_HOSTNAME_REGEX,
- "www1.example.org"));
assertTrue(ServerName.SERVERNAME_PATTERN.matcher("www1.example.org,1234,567").matches());
+ ServerName.parseServerName("a.b.c,58102,1319771740322");
+ ServerName.parseServerName("192.168.1.199,58102,1319771740322");
+ ServerName.parseServerName("a.b.c:58102");
+ ServerName.parseServerName("192.168.1.199:58102");
}
@Test public void testParseOfBytes() {
Modified: hbase/trunk/src/test/java/org/apache/hadoop/hbase/master/TestActiveMasterManager.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/test/java/org/apache/hadoop/hbase/master/TestActiveMasterManager.java?rev=1190176&r1=1190175&r2=1190176&view=diff
==============================================================================
--- hbase/trunk/src/test/java/org/apache/hadoop/hbase/master/TestActiveMasterManager.java (original)
+++ hbase/trunk/src/test/java/org/apache/hadoop/hbase/master/TestActiveMasterManager.java Fri Oct 28 06:59:47 2011
@@ -187,7 +187,7 @@ public class TestActiveMasterManager {
ServerName expectedAddress)
throws KeeperException {
ServerName readAddress =
- new ServerName(Bytes.toString(ZKUtil.getData(zk, zk.masterAddressZNode)));
+ ServerName.parseVersionedServerName(ZKUtil.getData(zk, zk.masterAddressZNode));
assertNotNull(readAddress);
assertTrue(expectedAddress.equals(readAddress));
}