cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r895716 - in /incubator/cassandra/branches/cassandra-0.5: CHANGES.txt src/java/org/apache/cassandra/service/CassandraServer.java src/java/org/apache/cassandra/service/StorageProxy.java
Date Mon, 04 Jan 2010 17:30:31 GMT
Author: jbellis
Date: Mon Jan  4 17:30:28 2010
New Revision: 895716

URL: http://svn.apache.org/viewvc?rev=895716&view=rev
Log:
revert 894192, leaving CASSANDRA-600 only in trunk.  patch by jbellis

Modified:
    incubator/cassandra/branches/cassandra-0.5/CHANGES.txt
    incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/service/CassandraServer.java
    incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/service/StorageProxy.java

Modified: incubator/cassandra/branches/cassandra-0.5/CHANGES.txt
URL: http://svn.apache.org/viewvc/incubator/cassandra/branches/cassandra-0.5/CHANGES.txt?rev=895716&r1=895715&r2=895716&view=diff
==============================================================================
--- incubator/cassandra/branches/cassandra-0.5/CHANGES.txt (original)
+++ incubator/cassandra/branches/cassandra-0.5/CHANGES.txt Mon Jan  4 17:30:28 2010
@@ -1,11 +1,9 @@
 0.5.0 RC2
  * fix bugs in converting get_slice_range results to Thrift 
    (CASSANDRA-647, CASSANDRA-649)
- * expose java.util.concurrent.TimeoutException in StorageProxy methods
-   (CASSANDRA-600)
  * TcpConnectionManager was holding on to disconnected connections, 
    giving the false indication they were being used. (CASSANDRA-651)
- * Remove duplicated write. (CASSANDRA-662)
+ * Avoid redundant write of the same mutation. (CASSANDRA-662)
 
 
 0.5.0 RC1

Modified: incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/service/CassandraServer.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/service/CassandraServer.java?rev=895716&r1=895715&r2=895716&view=diff
==============================================================================
--- incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/service/CassandraServer.java
(original)
+++ incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/service/CassandraServer.java
Mon Jan  4 17:30:28 2010
@@ -22,7 +22,6 @@
 import java.io.FileInputStream;
 import java.io.IOException;
 import java.util.*;
-import java.util.concurrent.TimeoutException;
 
 import org.apache.log4j.Logger;
 
@@ -93,10 +92,6 @@
         {
             rows = StorageProxy.readProtocol(commands, consistency_level);
         }
-        catch (TimeoutException e) 
-        {
-        	throw new TimedOutException();
-        }
         catch (IOException e)
         {
             throw new RuntimeException(e);
@@ -468,14 +463,7 @@
     {
         if (consistency_level != ConsistencyLevel.ZERO)
         {
-            try
-            {
-                StorageProxy.insertBlocking(rm, consistency_level);
-            }
-            catch (TimeoutException e)
-            {
-                throw new TimedOutException();
-            }
+            StorageProxy.insertBlocking(rm, consistency_level);
         }
         else
         {
@@ -585,10 +573,6 @@
             rows = StorageProxy.getRangeSlice(new RangeSliceCommand(keyspace, column_parent,
predicate, startKey, finishKey, maxRows), consistency_level);
             assert rows != null;
         }
-        catch (TimeoutException e)
-        {
-        	throw new TimedOutException();
-        }
         catch (IOException e)
         {
             throw new RuntimeException(e);
@@ -624,10 +608,6 @@
         {
             return StorageProxy.getKeyRange(new RangeCommand(tablename, columnFamily, startWith,
stopAt, maxResults));
         }
-        catch (TimeoutException e)
-        {
-        	throw new TimedOutException();
-        }
         catch (IOException e)
         {
             throw new RuntimeException(e);

Modified: incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/service/StorageProxy.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/service/StorageProxy.java?rev=895716&r1=895715&r2=895716&view=diff
==============================================================================
--- incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/service/StorageProxy.java
(original)
+++ incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/service/StorageProxy.java
Mon Jan  4 17:30:28 2010
@@ -160,7 +160,7 @@
         }
     }
     
-    public static void insertBlocking(final RowMutation rm, int consistency_level) throws
UnavailableException, TimeoutException
+    public static void insertBlocking(final RowMutation rm, int consistency_level) throws
UnavailableException, TimedOutException
     {
         long startTime = System.currentTimeMillis();
         try
@@ -240,6 +240,10 @@
             // wait for writes.  throws timeoutexception if necessary
             responseHandler.get();
         }
+        catch (TimeoutException e)
+        {
+            throw new TimedOutException();
+        }
         catch (IOException e)
         {
             throw new RuntimeException("error writing key " + rm.key(), e);
@@ -288,7 +292,7 @@
      * @return the row associated with command.key
      * @throws Exception
      */
-    private static List<Row> weakReadRemote(List<ReadCommand> commands) throws
IOException, UnavailableException, TimeoutException
+    private static List<Row> weakReadRemote(List<ReadCommand> commands) throws
IOException, UnavailableException, TimedOutException
     {
         if (logger.isDebugEnabled())
             logger.debug("weakreadremote reading " + StringUtils.join(commands, ", "));
@@ -310,7 +314,14 @@
         for (IAsyncResult iar: iars)
         {
             byte[] body;
-            body = iar.get(DatabaseDescriptor.getRpcTimeout(), TimeUnit.MILLISECONDS);
+            try
+            {
+                body = iar.get(DatabaseDescriptor.getRpcTimeout(), TimeUnit.MILLISECONDS);
+            }
+            catch (TimeoutException e)
+            {
+                throw new TimedOutException();
+            }
             DataInputBuffer bufIn = new DataInputBuffer();
             bufIn.reset(body, body.length);
             ReadResponse response = ReadResponse.serializer().deserialize(bufIn);
@@ -325,7 +336,7 @@
      * a specific set of column names from a given column family.
      */
     public static List<Row> readProtocol(List<ReadCommand> commands, int consistency_level)
-            throws IOException, UnavailableException, TimeoutException
+            throws IOException, UnavailableException, TimedOutException
     {
         long startTime = System.currentTimeMillis();
 
@@ -379,7 +390,7 @@
          * 7. else carry out read repair by getting data from all the nodes.
         // 5. return success
      */
-    private static List<Row> strongRead(List<ReadCommand> commands, int consistency_level)
throws IOException, UnavailableException, TimeoutException
+    private static List<Row> strongRead(List<ReadCommand> commands, int consistency_level)
throws IOException, UnavailableException, TimedOutException
     {
         List<QuorumResponseHandler<Row>> quorumResponseHandlers = new ArrayList<QuorumResponseHandler<Row>>();
         List<InetAddress[]> commandEndPoints = new ArrayList<InetAddress[]>();
@@ -434,6 +445,10 @@
                 if (logger.isDebugEnabled())
                     logger.debug("quorumResponseHandler: " + (System.currentTimeMillis()
- startTime2) + " ms.");
             }
+            catch (TimeoutException e)
+            {
+                throw new TimedOutException();
+            }
             catch (DigestMismatchException ex)
             {
                 if (DatabaseDescriptor.getConsistencyCheck())
@@ -451,6 +466,10 @@
                         if (row != null)
                             rows.add(row);
                     }
+                    catch (TimeoutException e)
+                    {
+                        throw new TimedOutException();
+                    }
                     catch (DigestMismatchException e)
                     {
                         // TODO should this be a thrift exception?
@@ -493,7 +512,7 @@
         return rows;
     }
 
-    static List<Pair<String, ColumnFamily>> getRangeSlice(RangeSliceCommand command,
int consistency_level) throws IOException, UnavailableException, TimeoutException
+    static List<Pair<String, ColumnFamily>> getRangeSlice(RangeSliceCommand command,
int consistency_level) throws IOException, UnavailableException, TimedOutException
     {
         long startTime = System.currentTimeMillis();
         TokenMetadata tokenMetadata = StorageService.instance().getTokenMetadata();
@@ -543,6 +562,10 @@
             {
                 rows.putAll(handler.get());
             }
+            catch (TimeoutException e)
+            {
+                throw new TimedOutException();
+            }
             catch (DigestMismatchException e)
             {
                 throw new AssertionError(e); // no digests in range slices yet
@@ -571,7 +594,7 @@
         return results;
     }
 
-    static List<String> getKeyRange(RangeCommand command) throws IOException, UnavailableException,
TimeoutException
+    static List<String> getKeyRange(RangeCommand command) throws IOException, UnavailableException,
TimedOutException
     {
         long startTime = System.currentTimeMillis();
         TokenMetadata tokenMetadata = StorageService.instance().getTokenMetadata();
@@ -589,8 +612,14 @@
 
             // read response
             byte[] responseBody;
-            responseBody = iar.get(DatabaseDescriptor.getRpcTimeout(), TimeUnit.MILLISECONDS);
-           
+            try
+            {
+                responseBody = iar.get(DatabaseDescriptor.getRpcTimeout(), TimeUnit.MILLISECONDS);
+            }
+            catch (TimeoutException e)
+            {
+                throw new TimedOutException();
+            }
             RangeReply rangeReply = RangeReply.read(responseBody);
             uniqueKeys.addAll(rangeReply.keys);
 



Mime
View raw message