You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by br...@apache.org on 2014/05/06 23:17:17 UTC
[09/13] git commit: merge
merge
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/0a09edc8
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/0a09edc8
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/0a09edc8
Branch: refs/heads/trunk
Commit: 0a09edc8180d4b0dae8c56dd64a1b1c531d684f8
Parents: b17629c
Author: Brandon Williams <br...@apache.org>
Authored: Tue May 6 16:12:58 2014 -0500
Committer: Brandon Williams <br...@apache.org>
Committed: Tue May 6 16:12:58 2014 -0500
----------------------------------------------------------------------
.../org/apache/cassandra/service/StorageService.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/0a09edc8/src/java/org/apache/cassandra/service/StorageService.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/StorageService.java b/src/java/org/apache/cassandra/service/StorageService.java
index 38f1a99..0300f55 100644
--- a/src/java/org/apache/cassandra/service/StorageService.java
+++ b/src/java/org/apache/cassandra/service/StorageService.java
@@ -1433,22 +1433,22 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
switch (entry.getKey())
{
case RELEASE_VERSION:
- SystemTable.updatePeerInfo(endpoint, "release_version", quote(entry.getValue().value));
+ SystemKeyspace.updatePeerInfo(endpoint, "release_version", quote(entry.getValue().value));
break;
case DC:
- SystemTable.updatePeerInfo(endpoint, "data_center", quote(entry.getValue().value));
+ SystemKeyspace.updatePeerInfo(endpoint, "data_center", quote(entry.getValue().value));
break;
case RACK:
- SystemTable.updatePeerInfo(endpoint, "rack", quote(entry.getValue().value));
+ SystemKeyspace.updatePeerInfo(endpoint, "rack", quote(entry.getValue().value));
break;
case RPC_ADDRESS:
- SystemTable.updatePeerInfo(endpoint, "rpc_address", quote(entry.getValue().value));
+ SystemKeyspace.updatePeerInfo(endpoint, "rpc_address", quote(entry.getValue().value));
break;
case SCHEMA:
- SystemTable.updatePeerInfo(endpoint, "schema_version", entry.getValue().value);
+ SystemKeyspace.updatePeerInfo(endpoint, "schema_version", entry.getValue().value);
break;
case HOST_ID:
- SystemTable.updatePeerInfo(endpoint, "host_id", entry.getValue().value);
+ SystemKeyspace.updatePeerInfo(endpoint, "host_id", entry.getValue().value);
break;
}
}