hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From st...@apache.org
Subject svn commit: r1437154 - /hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
Date Tue, 22 Jan 2013 20:45:40 GMT
Author: stack
Date: Tue Jan 22 20:45:40 2013
New Revision: 1437154

URL: http://svn.apache.org/viewvc?rev=1437154&view=rev
Log:
HBASE-7588 Fix two findbugs warning in MemStoreFlusher; REAPPLIED

Modified:
    hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java

Modified: hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java?rev=1437154&r1=1437153&r2=1437154&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
(original)
+++ hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
Tue Jan 22 20:45:40 2013
@@ -500,21 +500,21 @@ class MemStoreFlusher extends HasThread 
     return "flush_queue="
         + flushQueue.size();
   }
-  
+
   public String dumpQueue() {
     StringBuilder queueList = new StringBuilder();
     queueList.append("Flush Queue Queue dump:\n");
     queueList.append("  Flush Queue:\n");
     java.util.Iterator<FlushQueueEntry> it = flushQueue.iterator();
-    
+
     while(it.hasNext()){
       queueList.append("    "+it.next().toString());
       queueList.append("\n");
     }
-    
+
     return queueList.toString();
   }
-  
+
   interface FlushQueueEntry extends Delayed {}
 
   /**
@@ -530,6 +530,12 @@ class MemStoreFlusher extends HasThread 
     public int compareTo(Delayed o) {
       return -1;
     }
+
+    @Override
+    public boolean equals(Object obj) {
+      return (this == obj);
+    }
+
   }
 
   /**
@@ -597,5 +603,17 @@ class MemStoreFlusher extends HasThread 
     public String toString() {
       return "[flush region " + Bytes.toStringBinary(region.getRegionName()) + "]";
     }
+
+    @Override
+    public boolean equals(Object obj) {
+      if (this == obj) {
+        return true;
+      }
+      if (obj == null || getClass() != obj.getClass()) {
+        return false;
+      }
+      Delayed other = (Delayed) obj;
+      return compareTo(other) == 0;
+    }
   }
 }



Mime
View raw message