Author: jbellis Date: Mon Jul 5 20:54:51 2010 New Revision: 960694 URL: http://svn.apache.org/viewvc?rev=960694&view=rev Log: r/m unused code. patch by jbellis
Modified: cassandra/trunk/src/java/org/apache/cassandra/db/Table.java cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java Modified: cassandra/trunk/src/java/org/apache/cassandra/db/Table.java URL: http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/db/Table.java?rev=960694&r1=960693&r2=960694&view=diff ============================================================================== --- cassandra/trunk/src/java/org/apache/cassandra/db/Table.java (original) +++ cassandra/trunk/src/java/org/apache/cassandra/db/Table.java Mon Jul 5 20:54:51 2010 @@ -58,7 +58,6 @@ public class Table static final ReentrantReadWriteLock flusherLock = new ReentrantReadWriteLock(true); private static Timer flushTimer = new Timer("FLUSH-TIMER"); - private final boolean waitForCommitLog; // This is a result of pushing down the point in time when storage directories get created. It used to happen in // CassandraDaemon, but it is possible to call Table.open without a running daemon, so it made sense to ensure @@ -216,7 +215,6 @@ public class Table private Table(String table) { name = table; - waitForCommitLog = DatabaseDescriptor.getCommitLogSync() == Config.CommitLogSync.batch; // create data directories. for (String dataDir : DatabaseDescriptor.getAllDataFileLocations()) { Modified: cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java URL: http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java?rev=960694&r1=960693&r2=960694&view=diff ============================================================================== --- cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java (original) +++ cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java Mon Jul 5 20:54:51 2010 @@ -1687,7 +1687,6 @@ public class StorageService implements I return old; } - @Override public void truncate(String keyspace, String columnFamily) throws UnavailableException, TimeoutException, IOException { StorageProxy.truncateBlocking(keyspace, columnFamily);