cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r768586 - /incubator/cassandra/trunk/src/org/apache/cassandra/db/ReadVerbHandler.java
Date Sat, 25 Apr 2009 19:13:28 GMT
Author: jbellis
Date: Sat Apr 25 19:13:27 2009
New Revision: 768586

URL: http://svn.apache.org/viewvc?rev=768586&view=rev
Log:
DO_REPAIR header is not always present now that DatabaseDescriptor.getConsistencyCheck is
optional.
patch by Per Mellqvist; reviewed by jbellis for #109

Modified:
    incubator/cassandra/trunk/src/org/apache/cassandra/db/ReadVerbHandler.java

Modified: incubator/cassandra/trunk/src/org/apache/cassandra/db/ReadVerbHandler.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/org/apache/cassandra/db/ReadVerbHandler.java?rev=768586&r1=768585&r2=768586&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/org/apache/cassandra/db/ReadVerbHandler.java (original)
+++ incubator/cassandra/trunk/src/org/apache/cassandra/db/ReadVerbHandler.java Sat Apr 25
19:13:27 2009
@@ -106,9 +106,10 @@
             logger_.info("ReadVerbHandler  TIME 2: " + (System.currentTimeMillis() - start)
+ " ms.");
             
             /* Do read repair if header of the message says so */
-            String repair = new String( message.getHeader(ReadCommand.DO_REPAIR) );
-            if ( repair.equals( ReadCommand.DO_REPAIR) )
+            if (message.getHeader(ReadCommand.DO_REPAIR) != null)
+            {
                 doReadRepair(row, readCommand);
+            }
         }
         catch ( IOException ex)
         {



Mime
View raw message