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 2012/07/13 18:32:47 UTC
[3/4] git commit: formatting
formatting
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/2711548e
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/2711548e
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/2711548e
Branch: refs/heads/trunk
Commit: 2711548e00658c44ddf1807f73a872dfad5d709a
Parents: 200ba86
Author: Jonathan Ellis <jb...@apache.org>
Authored: Wed Jul 11 18:11:01 2012 -0500
Committer: Jonathan Ellis <jb...@apache.org>
Committed: Fri Jul 13 11:32:05 2012 -0500
----------------------------------------------------------------------
.../org/apache/cassandra/service/StorageProxy.java | 12 ++++++------
1 files changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/2711548e/src/java/org/apache/cassandra/service/StorageProxy.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/StorageProxy.java b/src/java/org/apache/cassandra/service/StorageProxy.java
index 7a79c06..58cc99d 100644
--- a/src/java/org/apache/cassandra/service/StorageProxy.java
+++ b/src/java/org/apache/cassandra/service/StorageProxy.java
@@ -283,10 +283,10 @@ public class StorageProxy implements StorageProxyMBean
* @throws TimeoutException if the hints cannot be written/enqueued
*/
public static void sendToHintedEndpoints(final RowMutation rm,
- Collection<InetAddress> targets,
- IWriteResponseHandler responseHandler,
- String localDataCenter,
- ConsistencyLevel consistency_level)
+ Collection<InetAddress> targets,
+ IWriteResponseHandler responseHandler,
+ String localDataCenter,
+ ConsistencyLevel consistency_level)
throws IOException, TimeoutException, UnavailableException
{
// Multimap that holds onto all the messages and addresses meant for a specific datacenter
@@ -321,8 +321,8 @@ public class StorageProxy implements StorageProxyMBean
Multimap<MessageOut, InetAddress> messages = dcMessages.get(dc);
if (messages == null)
{
- messages = HashMultimap.create();
- dcMessages.put(dc, messages);
+ messages = HashMultimap.create();
+ dcMessages.put(dc, messages);
}
messages.put(rm.createMessage(), destination);