diff --git a/src/java/org/apache/cassandra/db/RowMutationVerbHandler.java b/src/java/org/apache/cassandra/db/RowMutationVerbHandler.java index 673ddc9e7f..38a303571c 100644 --- a/src/java/org/apache/cassandra/db/RowMutationVerbHandler.java +++ b/src/java/org/apache/cassandra/db/RowMutationVerbHandler.java @@ -81,17 +81,13 @@ public class RowMutationVerbHandler implements IVerbHandler 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) diff --git a/src/java/org/apache/cassandra/net/ResponseVerbHandler.java b/src/java/org/apache/cassandra/net/ResponseVerbHandler.java index 4fef5161c9..f5e818b7e4 100644 --- a/src/java/org/apache/cassandra/net/ResponseVerbHandler.java +++ b/src/java/org/apache/cassandra/net/ResponseVerbHandler.java @@ -34,7 +34,7 @@ class ResponseVerbHandler implements IVerbHandler 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 @@ class ResponseVerbHandler implements IVerbHandler 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); } } diff --git a/src/java/org/apache/cassandra/service/ConsistencyManager.java b/src/java/org/apache/cassandra/service/ConsistencyManager.java index d98bc0afa1..6ad6deffe1 100644 --- a/src/java/org/apache/cassandra/service/ConsistencyManager.java +++ b/src/java/org/apache/cassandra/service/ConsistencyManager.java @@ -63,7 +63,6 @@ class ConsistencyManager implements Runnable private void handleDigestResponses() { DataInputBuffer bufIn = new DataInputBuffer(); - logger_.debug("Handle Digest reponses"); for( Message response : responses_ ) { byte[] body = response.getMessageBody(); diff --git a/src/java/org/apache/cassandra/service/QuorumResponseHandler.java b/src/java/org/apache/cassandra/service/QuorumResponseHandler.java index c0e4b85683..e5eb3f8616 100644 --- a/src/java/org/apache/cassandra/service/QuorumResponseHandler.java +++ b/src/java/org/apache/cassandra/service/QuorumResponseHandler.java @@ -60,7 +60,6 @@ public class QuorumResponseHandler implements IAsyncCallback public T get() throws TimeoutException, DigestMismatchException { - long startTime = System.currentTimeMillis(); lock_.lock(); try { @@ -95,8 +94,6 @@ public class QuorumResponseHandler implements IAsyncCallback MessagingService.removeRegisteredCallback( response.getMessageId() ); } } - logger_.info("QuorumResponseHandler: " + (System.currentTimeMillis() - startTime) - + " ms."); return responseResolver_.resolve( responses_); } diff --git a/src/java/org/apache/cassandra/service/StorageService.java b/src/java/org/apache/cassandra/service/StorageService.java index aa3d2295e9..5187a7ddc9 100644 --- a/src/java/org/apache/cassandra/service/StorageService.java +++ b/src/java/org/apache/cassandra/service/StorageService.java @@ -1065,7 +1065,7 @@ public final class StorageService implements IEndPointStateChangeSubscriber, Sto /** * 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 @@ public final class StorageService implements IEndPointStateChangeSubscriber, Sto { 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]; } }