cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r1064170 - in /cassandra/branches/cassandra-0.7: CHANGES.txt lib/jetty-6.1.21.jar lib/jetty-util-6.1.21.jar src/java/org/apache/cassandra/service/AbstractCassandraDaemon.java
Date Thu, 27 Jan 2011 16:06:13 GMT
Author: jbellis
Date: Thu Jan 27 16:06:12 2011
New Revision: 1064170

URL: http://svn.apache.org/viewvc?rev=1064170&view=rev
Log:
remove jetty dependency
patch by Nate McCall; reveiewed by stuhood for CASSANDRA-2050

Removed:
    cassandra/branches/cassandra-0.7/lib/jetty-6.1.21.jar
    cassandra/branches/cassandra-0.7/lib/jetty-util-6.1.21.jar
Modified:
    cassandra/branches/cassandra-0.7/CHANGES.txt
    cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/AbstractCassandraDaemon.java

Modified: cassandra/branches/cassandra-0.7/CHANGES.txt
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/CHANGES.txt?rev=1064170&r1=1064169&r2=1064170&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.7/CHANGES.txt (original)
+++ cassandra/branches/cassandra-0.7/CHANGES.txt Thu Jan 27 16:06:12 2011
@@ -3,6 +3,7 @@
  * add JVM shutdownhook to sync commitlog (CASSANDRA-1919)
  * allow nodes to be up without being part of  normal traffic (CASSANDRA-1951)
  * fix CLI "show keyspaces" with null options on NTS (CASSANDRA-2049)
+ * remove jetty dependency (CASSANDRA-2050)
 
 
 0.7.1

Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/AbstractCassandraDaemon.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/AbstractCassandraDaemon.java?rev=1064170&r1=1064169&r2=1064170&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/AbstractCassandraDaemon.java
(original)
+++ cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/AbstractCassandraDaemon.java
Thu Jan 27 16:06:12 2011
@@ -45,7 +45,6 @@ import org.apache.cassandra.db.migration
 import org.apache.cassandra.utils.CLibrary;
 import org.apache.cassandra.utils.FBUtilities;
 import org.apache.cassandra.utils.Mx4jTool;
-import org.mortbay.thread.ThreadPool;
 
 /**
  * The <code>CassandraDaemon</code> is an abstraction for a Cassandra daemon
@@ -349,7 +348,7 @@ public abstract class AbstractCassandraD
      * A subclass of Java's ThreadPoolExecutor which implements Jetty's ThreadPool
      * interface (for integration with Avro), and performs ClientState cleanup.
      */
-    public static class CleaningThreadPool extends ThreadPoolExecutor implements ThreadPool
+    public static class CleaningThreadPool extends ThreadPoolExecutor 
     {
         private ThreadLocal<ClientState> state;
         public CleaningThreadPool(ThreadLocal<ClientState> state, int minWorkerThread,
int maxWorkerThreads)
@@ -365,42 +364,6 @@ public abstract class AbstractCassandraD
             state.get().logout();
         }
 
-        /*********************************************************************/
-        /**   The following are cribbed from org.mortbay.thread.concurrent   */
-        /*********************************************************************/
-
-        public boolean dispatch(Runnable job)
-        {
-            try
-            {       
-                execute(job);
-                return true;
-            }
-            catch(RejectedExecutionException e)
-            {
-                logger.error("Failed to dispatch thread:", e);
-                return false;
-            }
-        }
 
-        public int getIdleThreads()
-        {
-            return getPoolSize()-getActiveCount();
-        }
-
-        public int getThreads()
-        {
-            return getPoolSize();
-        }
-
-        public boolean isLowOnThreads()
-        {
-            return getActiveCount()>=getMaximumPoolSize();
-        }
-
-        public void join() throws InterruptedException
-        {
-            this.awaitTermination(Long.MAX_VALUE,TimeUnit.MILLISECONDS);
-        }
     }
 }



Mime
View raw message