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];
}
}
