git commit: Schedule fat client schema pull on join

2014-10-07 Thread aleksey 
Repository: cassandra
Updated Branches:
  refs/heads/cassandra-2.0 e70f4f81a - 87cbcc0fc


Schedule fat client schema pull on join

patch by Oleg Anastasyev; reviewed by Aleksey Yeschenko for
CASSANDRA-7993


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/87cbcc0f
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/87cbcc0f
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/87cbcc0f

Branch: refs/heads/cassandra-2.0
Commit: 87cbcc0fc1d0fc0375332d77b252f4e0d7b95f80
Parents: e70f4f8
Author: Oleg Anastasyev olega...@gmail.com
Authored: Wed Oct 8 01:20:44 2014 +0300
Committer: Aleksey Yeschenko alek...@apache.org
Committed: Wed Oct 8 01:20:44 2014 +0300

--
 CHANGES.txt   | 1 +
 src/java/org/apache/cassandra/service/StorageService.java | 3 ++-
 2 files changed, 3 insertions(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/cassandra/blob/87cbcc0f/CHANGES.txt
--
diff --git a/CHANGES.txt b/CHANGES.txt
index 188f951..1bef399 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
 2.0.11:
+ * Schedule fat client schema pull on join (CASSANDRA-7993)
  * Don't reset nodes' versions when closing IncomingTcpConnections
(CASSANDRA-7734)
  * Record the real messaging version in all cases in OutboundTcpConnection

http://git-wip-us.apache.org/repos/asf/cassandra/blob/87cbcc0f/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 43bc198..0cd4be5 100644
--- a/src/java/org/apache/cassandra/service/StorageService.java
+++ b/src/java/org/apache/cassandra/service/StorageService.java
@@ -1970,6 +1970,8 @@ public class StorageService extends 
NotificationBroadcasterSupport implements IE
 
 public void onAlive(InetAddress endpoint, EndpointState state)
 {
+MigrationManager.instance.scheduleSchemaPull(endpoint, state);
+
 if (isClientMode)
 return;
 
@@ -1984,7 +1986,6 @@ public class StorageService extends 
NotificationBroadcasterSupport implements IE
 for (IEndpointLifecycleSubscriber subscriber : 
lifecycleSubscribers)
 subscriber.onJoinCluster(endpoint);
 }
-MigrationManager.instance.scheduleSchemaPull(endpoint, state);
 }
 
 public void onRemove(InetAddress endpoint)

[1/2] git commit: Schedule fat client schema pull on join

2014-10-07 Thread aleksey 
Repository: cassandra
Updated Branches:
  refs/heads/cassandra-2.1 ba50db429 - ed1681a47


Schedule fat client schema pull on join

patch by Oleg Anastasyev; reviewed by Aleksey Yeschenko for
CASSANDRA-7993


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/87cbcc0f
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/87cbcc0f
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/87cbcc0f

Branch: refs/heads/cassandra-2.1
Commit: 87cbcc0fc1d0fc0375332d77b252f4e0d7b95f80
Parents: e70f4f8
Author: Oleg Anastasyev olega...@gmail.com
Authored: Wed Oct 8 01:20:44 2014 +0300
Committer: Aleksey Yeschenko alek...@apache.org
Committed: Wed Oct 8 01:20:44 2014 +0300

--
 CHANGES.txt   | 1 +
 src/java/org/apache/cassandra/service/StorageService.java | 3 ++-
 2 files changed, 3 insertions(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/cassandra/blob/87cbcc0f/CHANGES.txt
--
diff --git a/CHANGES.txt b/CHANGES.txt
index 188f951..1bef399 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
 2.0.11:
+ * Schedule fat client schema pull on join (CASSANDRA-7993)
  * Don't reset nodes' versions when closing IncomingTcpConnections
(CASSANDRA-7734)
  * Record the real messaging version in all cases in OutboundTcpConnection

http://git-wip-us.apache.org/repos/asf/cassandra/blob/87cbcc0f/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 43bc198..0cd4be5 100644
--- a/src/java/org/apache/cassandra/service/StorageService.java
+++ b/src/java/org/apache/cassandra/service/StorageService.java
@@ -1970,6 +1970,8 @@ public class StorageService extends 
NotificationBroadcasterSupport implements IE
 
 public void onAlive(InetAddress endpoint, EndpointState state)
 {
+MigrationManager.instance.scheduleSchemaPull(endpoint, state);
+
 if (isClientMode)
 return;
 
@@ -1984,7 +1986,6 @@ public class StorageService extends 
NotificationBroadcasterSupport implements IE
 for (IEndpointLifecycleSubscriber subscriber : 
lifecycleSubscribers)
 subscriber.onJoinCluster(endpoint);
 }
-MigrationManager.instance.scheduleSchemaPull(endpoint, state);
 }
 
 public void onRemove(InetAddress endpoint)

[1/3] git commit: Schedule fat client schema pull on join

2014-10-07 Thread aleksey 
Repository: cassandra
Updated Branches:
  refs/heads/trunk 36edbda64 - 2e8ba0364


Schedule fat client schema pull on join

patch by Oleg Anastasyev; reviewed by Aleksey Yeschenko for
CASSANDRA-7993


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/87cbcc0f
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/87cbcc0f
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/87cbcc0f

Branch: refs/heads/trunk
Commit: 87cbcc0fc1d0fc0375332d77b252f4e0d7b95f80
Parents: e70f4f8
Author: Oleg Anastasyev olega...@gmail.com
Authored: Wed Oct 8 01:20:44 2014 +0300
Committer: Aleksey Yeschenko alek...@apache.org
Committed: Wed Oct 8 01:20:44 2014 +0300

--
 CHANGES.txt   | 1 +
 src/java/org/apache/cassandra/service/StorageService.java | 3 ++-
 2 files changed, 3 insertions(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/cassandra/blob/87cbcc0f/CHANGES.txt
--
diff --git a/CHANGES.txt b/CHANGES.txt
index 188f951..1bef399 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
 2.0.11:
+ * Schedule fat client schema pull on join (CASSANDRA-7993)
  * Don't reset nodes' versions when closing IncomingTcpConnections
(CASSANDRA-7734)
  * Record the real messaging version in all cases in OutboundTcpConnection

http://git-wip-us.apache.org/repos/asf/cassandra/blob/87cbcc0f/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 43bc198..0cd4be5 100644
--- a/src/java/org/apache/cassandra/service/StorageService.java
+++ b/src/java/org/apache/cassandra/service/StorageService.java
@@ -1970,6 +1970,8 @@ public class StorageService extends 
NotificationBroadcasterSupport implements IE
 
 public void onAlive(InetAddress endpoint, EndpointState state)
 {
+MigrationManager.instance.scheduleSchemaPull(endpoint, state);
+
 if (isClientMode)
 return;
 
@@ -1984,7 +1986,6 @@ public class StorageService extends 
NotificationBroadcasterSupport implements IE
 for (IEndpointLifecycleSubscriber subscriber : 
lifecycleSubscribers)
 subscriber.onJoinCluster(endpoint);
 }
-MigrationManager.instance.scheduleSchemaPull(endpoint, state);
 }
 
 public void onRemove(InetAddress endpoint)