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 2011/02/07 15:35:00 UTC
svn commit: r1067953 -
/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageProxy.java
Author: jbellis
Date: Mon Feb 7 14:34:59 2011
New Revision: 1067953
URL: http://svn.apache.org/viewvc?rev=1067953&view=rev
Log:
rename insertLocalMessage -> insertLocal
Modified:
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageProxy.java
Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageProxy.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageProxy.java?rev=1067953&r1=1067952&r2=1067953&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageProxy.java (original)
+++ cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageProxy.java Mon Feb 7 14:34:59 2011
@@ -144,7 +144,7 @@ public class StorageProxy implements Sto
// unhinted writes
if (destination.equals(FBUtilities.getLocalAddress()))
{
- insertLocalMessage(rm, responseHandler);
+ insertLocal(rm, responseHandler);
}
else
{
@@ -277,7 +277,7 @@ public class StorageProxy implements Sto
message.setHeader(RowMutation.HINT, bos.toByteArray());
}
- private static void insertLocalMessage(final RowMutation rm, final IWriteResponseHandler responseHandler)
+ private static void insertLocal(final RowMutation rm, final IWriteResponseHandler responseHandler)
{
if (logger.isDebugEnabled())
logger.debug("insert writing local " + rm.toString(true));