cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r774424 - in /incubator/cassandra/trunk/src/java/org/apache/cassandra: db/RowMutationVerbHandler.java net/ResponseVerbHandler.java service/ConsistencyManager.java service/QuorumResponseHandler.java service/StorageService.java
Date Wed, 13 May 2009 16:47:18 GMT
Author: jbellis
Date: Wed May 13 16:47:14 2009
New Revision: 774424

URL: http://svn.apache.org/viewvc?rev=774424&view=rev
Log:
more log cleanup.  patch by jbellis

Modified:
    incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutationVerbHandler.java
    incubator/cassandra/trunk/src/java/org/apache/cassandra/net/ResponseVerbHandler.java
    incubator/cassandra/trunk/src/java/org/apache/cassandra/service/ConsistencyManager.java
    incubator/cassandra/trunk/src/java/org/apache/cassandra/service/QuorumResponseHandler.java
    incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java

Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutationVerbHandler.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutationVerbHandler.java?rev=774424&r1=774423&r2=774424&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutationVerbHandler.java
(original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/db/RowMutationVerbHandler.java
Wed May 13 16:47:14 2009
@@ -81,17 +81,13 @@
                 hintedMutation.apply();
             }
 
-            long start = System.currentTimeMillis();
-
             rowMutationCtx.row_.clear();
             rowMutationCtx.row_.key(rm.key());
             rm.apply(rowMutationCtx.row_);
 
-            long end = System.currentTimeMillis();
-
             WriteResponse response = new WriteResponse(rm.table(), rm.key(), true);
             Message responseMessage = WriteResponse.makeWriteResponseMessage(message, response);
-            logger_.debug("Mutation applied in " + (end - start) + "ms.  Sending response
to " + message.getMessageId() + "@" + message.getFrom());
+            logger_.debug(rm + " applied.  Sending response to " + message.getMessageId()
+ "@" + message.getFrom());
             MessagingService.getMessagingInstance().sendOneWay(responseMessage, message.getFrom());
         }
         catch (IOException e)

Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/net/ResponseVerbHandler.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/net/ResponseVerbHandler.java?rev=774424&r1=774423&r2=774424&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/net/ResponseVerbHandler.java (original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/net/ResponseVerbHandler.java Wed
May 13 16:47:14 2009
@@ -34,7 +34,7 @@
         IAsyncCallback cb = MessagingService.getRegisteredCallback(messageId);
         if ( cb != null )
         {
-            logger_.info("Processing response on a callback from " + message.getMessageId()
+ "@" + message.getFrom());
+            logger_.debug("Processing response on a callback from " + message.getMessageId()
+ "@" + message.getFrom());
             cb.response(message);
         }
         else
@@ -42,7 +42,7 @@
             IAsyncResult ar = MessagingService.getAsyncResult(messageId);
             if ( ar != null )
             {
-                logger_.info("Processing response on an async result from " + message.getMessageId()
+ "@" + message.getFrom());
+                logger_.debug("Processing response on an async result from " + message.getMessageId()
+ "@" + message.getFrom());
                 ar.result(message);
             }
         }

Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/service/ConsistencyManager.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/service/ConsistencyManager.java?rev=774424&r1=774423&r2=774424&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/service/ConsistencyManager.java
(original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/service/ConsistencyManager.java
Wed May 13 16:47:14 2009
@@ -63,7 +63,6 @@
 		private void handleDigestResponses()
 		{
 			DataInputBuffer bufIn = new DataInputBuffer();
-			logger_.debug("Handle Digest reponses");
 			for( Message response : responses_ )
 			{
 				byte[] body = response.getMessageBody();            

Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/service/QuorumResponseHandler.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/service/QuorumResponseHandler.java?rev=774424&r1=774423&r2=774424&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/service/QuorumResponseHandler.java
(original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/service/QuorumResponseHandler.java
Wed May 13 16:47:14 2009
@@ -60,7 +60,6 @@
     
     public T get() throws TimeoutException, DigestMismatchException
     {
-        long startTime = System.currentTimeMillis();
     	lock_.lock();
         try
         {            
@@ -95,8 +94,6 @@
             	MessagingService.removeRegisteredCallback( response.getMessageId() );
             }
         }
-        logger_.info("QuorumResponseHandler: " + (System.currentTimeMillis() - startTime)
-                + " ms.");
 
     	return responseResolver_.resolve( responses_);
     }

Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java?rev=774424&r1=774423&r2=774424&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java (original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java Wed
May 13 16:47:14 2009
@@ -1065,7 +1065,7 @@
 
     /**
      * This function finds the most suitable endpoint given a key.
-     * It checks for loclity and alive test.
+     * It checks for locality and alive test.
      */
 	public EndPoint findSuitableEndPoint(String key) throws IOException
 	{
@@ -1082,7 +1082,6 @@
 		{
 			if ( StorageService.instance().isInSameDataCenter(endpoints[j]) && FailureDetector.instance().isAlive(endpoints[j])
)
 			{
-				logger_.debug("EndPoint " + endpoints[j] + " is in the same data center as local storage
endpoint.");
 				return endpoints[j];
 			}
 		}



Mime
View raw message