You are viewing a plain text version of this content. The canonical link for it is here.
Posted to solr-commits@lucene.apache.org by yo...@apache.org on 2010/02/09 18:21:18 UTC
svn commit: r908123 -
/lucene/solr/branches/cloud/src/solrj/org/apache/solr/client/solrj/impl/CloudSolrServer.java
Author: yonik
Date: Tue Feb 9 17:21:18 2010
New Revision: 908123
URL: http://svn.apache.org/viewvc?rev=908123&view=rev
Log:
don't publish the zk controller until it's ready
Modified:
lucene/solr/branches/cloud/src/solrj/org/apache/solr/client/solrj/impl/CloudSolrServer.java
Modified: lucene/solr/branches/cloud/src/solrj/org/apache/solr/client/solrj/impl/CloudSolrServer.java
URL: http://svn.apache.org/viewvc/lucene/solr/branches/cloud/src/solrj/org/apache/solr/client/solrj/impl/CloudSolrServer.java?rev=908123&r1=908122&r2=908123&view=diff
==============================================================================
--- lucene/solr/branches/cloud/src/solrj/org/apache/solr/client/solrj/impl/CloudSolrServer.java (original)
+++ lucene/solr/branches/cloud/src/solrj/org/apache/solr/client/solrj/impl/CloudSolrServer.java Tue Feb 9 17:21:18 2010
@@ -65,9 +65,10 @@
synchronized(this) {
if (zkController != null) return;
try {
- zkController = new ZkController(zkHost, zkConnectTimeout, zkClientTimeout, null, null, null);
- zkController.addShardZkNodeWatches();
- zkController.updateCloudState(true);
+ ZkController zk = new ZkController(zkHost, zkConnectTimeout, zkClientTimeout, null, null, null);
+ zk.addShardZkNodeWatches();
+ zk.updateCloudState(true);
+ zkController = zk;
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
throw new ZooKeeperException(SolrException.ErrorCode.SERVER_ERROR, "", e);