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 2009/05/13 18:47:18 UTC
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
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];
}
}