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 <[email protected]> Authored: Tue May 6 16:12:58 2014 -0500 Committer: Brandon Williams <[email protected]> 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; } }
