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();