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/01/28 19:25:13 UTC
svn commit: r1064808 - in
/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db:
HintedHandOffManager.java Memtable.java
Author: jbellis
Date: Fri Jan 28 18:25:13 2011
New Revision: 1064808
URL: http://svn.apache.org/viewvc?rev=1064808&view=rev
Log:
replace ExecutorService.submit with .execute where a Future is not required
patch by jbellis
Modified:
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/HintedHandOffManager.java
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/Memtable.java
Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/HintedHandOffManager.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/HintedHandOffManager.java?rev=1064808&r1=1064807&r2=1064808&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/HintedHandOffManager.java (original)
+++ cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/HintedHandOffManager.java Fri Jan 28 18:25:13 2011
@@ -298,7 +298,7 @@ public class HintedHandOffManager
deliverHintsToEndpoint(to);
}
};
- executor_.submit(r);
+ executor_.execute(r);
}
public void deliverHints(String to) throws UnknownHostException
Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/Memtable.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/Memtable.java?rev=1064808&r1=1064807&r2=1064808&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/Memtable.java (original)
+++ cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/Memtable.java Fri Jan 28 18:25:13 2011
@@ -167,7 +167,7 @@ public class Memtable implements Compara
public void flushAndSignal(final CountDownLatch latch, ExecutorService sorter, final ExecutorService writer)
{
cfs.getMemtablesPendingFlush().add(this); // it's ok for the MT to briefly be both active and pendingFlush
- writer.submit(new WrappedRunnable()
+ writer.execute(new WrappedRunnable()
{
public void runMayThrow() throws IOException
{