You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2011/10/26 15:56:22 UTC
svn commit: r1189221 -
/cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/db/SystemTable.java
Author: jbellis
Date: Wed Oct 26 13:56:22 2011
New Revision: 1189221
URL: http://svn.apache.org/viewvc?rev=1189221&view=rev
Log:
add debug logging to purgeIncompatibleHints
patch by jbellis
Modified:
cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/db/SystemTable.java
Modified: cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/db/SystemTable.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/db/SystemTable.java?rev=1189221&r1=1189220&r2=1189221&view=diff
==============================================================================
--- cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/db/SystemTable.java (original)
+++ cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/db/SystemTable.java Wed Oct 26 13:56:22 2011
@@ -109,7 +109,10 @@ public class SystemTable
QueryFilter filter = QueryFilter.getNamesFilter(decorate(COOKIE_KEY), new QueryPath(STATUS_CF), upgradeMarker);
ColumnFamily cf = table.getColumnFamilyStore(STATUS_CF).getColumnFamily(filter);
if (cf != null)
+ {
+ logger.debug("Pre-1.0 hints already purged");
return;
+ }
// marker not found. Snapshot + remove hints and add the marker
ColumnFamilyStore hintsCfs = Table.open(Table.SYSTEM_TABLE).getColumnFamilyStore(HintedHandOffManager.HINTS_CF);
@@ -119,6 +122,7 @@ public class SystemTable
hintsCfs.snapshot("old-hints");
hintsCfs.removeAllSSTables();
}
+ logger.debug("Marking pre-1.0 hints purged");
RowMutation rm = new RowMutation(Table.SYSTEM_TABLE, COOKIE_KEY);
rm.add(new QueryPath(STATUS_CF, null, upgradeMarker), ByteBufferUtil.bytes("oh yes, they were purged"), System.currentTimeMillis());
rm.apply();