natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

more log cleanup. patch by jbellis 

git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@774424 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jonathan Ellis 2009-05-13 16:47:14 +00:00
parent bd3c6acf33
commit 735008dafc
5 changed files with 4 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/java/org/apache/cassandra/db/RowMutationVerbHandler.java
View File

@ -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)

4
src/java/org/apache/cassandra/net/ResponseVerbHandler.java
View File

@ -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);
}
}

1
src/java/org/apache/cassandra/service/ConsistencyManager.java
View File

@ -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();

3
src/java/org/apache/cassandra/service/QuorumResponseHandler.java
View File

@ -60,7 +60,6 @@ public class QuorumResponseHandler<T> implements IAsyncCallback
public T get() throws TimeoutException, DigestMismatchException
{
long startTime = System.currentTimeMillis();
lock_.lock();
try
{
@ -95,8 +94,6 @@ public class QuorumResponseHandler<T> implements IAsyncCallback
MessagingService.removeRegisteredCallback( response.getMessageId() );
}
}
logger_.info("QuorumResponseHandler: " + (System.currentTimeMillis() - startTime)
+ " ms.");
return responseResolver_.resolve( responses_);
}

3
src/java/org/apache/cassandra/service/StorageService.java
View File

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