cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r827742 - /incubator/cassandra/trunk/src/java/org/apache/cassandra/db/HintedHandOffManager.java
Date Tue, 20 Oct 2009 17:45:29 GMT
Author: jbellis
Date: Tue Oct 20 17:45:29 2009
New Revision: 827742

URL: http://svn.apache.org/viewvc?rev=827742&view=rev
Log:
Avoid using non-existent supercolumn timestamp in delete op.  Better conceptual integrity
to delete w/ correct system time anyway.
patch by jbellis; reviewed by junrao for CASSANDRA-491

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

Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/db/HintedHandOffManager.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/db/HintedHandOffManager.java?rev=827742&r1=827741&r2=827742&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/db/HintedHandOffManager.java (original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/db/HintedHandOffManager.java Tue
Oct 20 17:45:29 2009
@@ -164,7 +164,7 @@
                     String endpointStr = new String(endpoint.name(), "UTF-8");
                     if (sendMessage(endpointStr, tableName, keyStr))
                     {
-                        deleteEndPoint(endpoint.name(), tableName, keyColumn.name(), keyColumn.timestamp());
+                        deleteEndPoint(endpoint.name(), tableName, keyColumn.name(), System.currentTimeMillis());
                         deleted++;
                     }
                 }
@@ -214,7 +214,7 @@
                         }
                         else
                         {
-                            deleteEndPoint(hintEndPoint.name(), tableName, keyColumn.name(),
keyColumn.timestamp());
+                            deleteEndPoint(hintEndPoint.name(), tableName, keyColumn.name(),
System.currentTimeMillis());
                         }
                         break;
                     }



Mime
View raw message