svn commit: r1179330 - /hbase/branches/0.92/src/test/java/org/apache/hadoop/hbase/regionserver/TestServerCustomProtocol.java

[st...@apache.org]

Author: stack
Date: Wed Oct  5 17:18:45 2011
New Revision: 1179330

URL: http://svn.apache.org/viewvc?rev=1179330&view=rev
Log:
Add debugging around failing TestServerCustomProtocol  testSingleMethod test

Modified:
    hbase/branches/0.92/src/test/java/org/apache/hadoop/hbase/regionserver/TestServerCustomProtocol.java

Modified: hbase/branches/0.92/src/test/java/org/apache/hadoop/hbase/regionserver/TestServerCustomProtocol.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.92/src/test/java/org/apache/hadoop/hbase/regionserver/TestServerCustomProtocol.java?rev=1179330&r1=1179329&r2=1179330&view=diff
==============================================================================
--- hbase/branches/0.92/src/test/java/org/apache/hadoop/hbase/regionserver/TestServerCustomProtocol.java (original)
+++ hbase/branches/0.92/src/test/java/org/apache/hadoop/hbase/regionserver/TestServerCustomProtocol.java Wed Oct  5 17:18:45 2011
@@ -25,6 +25,8 @@ import java.io.IOException;
 import java.util.List;
 import java.util.Map;
 
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.hbase.HBaseTestingUtility;
 import org.apache.hadoop.hbase.HConstants;
 import org.apache.hadoop.hbase.HRegionInfo;
@@ -46,6 +48,8 @@ import org.junit.Test;
 import com.google.common.collect.Lists;
 
 public class TestServerCustomProtocol {
+  private static final Log LOG = LogFactory.getLog(TestServerCustomProtocol.class);
+
   /* Test protocol */
   private static interface PingProtocol extends CoprocessorProtocol {
     public String ping();
@@ -325,6 +329,13 @@ public class TestServerCustomProtocol {
   throws Exception {
     HRegionLocation loc = table.getRegionLocation(row);
     byte[] region = loc.getRegionInfo().getRegionName();
+    StringBuffer resultsKeyStr = new StringBuffer();
+    for (Map.Entry<byte [], String> e: results.entrySet()) {
+      resultsKeyStr.append(Bytes.toString(e.getKey()));
+      resultsKeyStr.append(", ");
+    }
+    LOG.info("ResultsKeyStr=" + resultsKeyStr);
+    
     assertTrue("Results should contain region " +
         Bytes.toStringBinary(region)+" for row '"+Bytes.toStringBinary(row)+"'",
         results.containsKey(region));