svn commit: r1206805 - /lucene/dev/branches/solrcloud/solr/core/src/java/org/apache/solr/update/processor/DistributedUpdateProcessor.java

[ma...@apache.org]

Author: markrmiller
Date: Sun Nov 27 18:53:47 2011
New Revision: 1206805

URL: http://svn.apache.org/viewvc?rev=1206805&view=rev
Log:
if not in zk mode, assume you are the leader

Modified:
    lucene/dev/branches/solrcloud/solr/core/src/java/org/apache/solr/update/processor/DistributedUpdateProcessor.java

Modified: lucene/dev/branches/solrcloud/solr/core/src/java/org/apache/solr/update/processor/DistributedUpdateProcessor.java
URL: http://svn.apache.org/viewvc/lucene/dev/branches/solrcloud/solr/core/src/java/org/apache/solr/update/processor/DistributedUpdateProcessor.java?rev=1206805&r1=1206804&r2=1206805&view=diff
==============================================================================
--- lucene/dev/branches/solrcloud/solr/core/src/java/org/apache/solr/update/processor/DistributedUpdateProcessor.java (original)
+++ lucene/dev/branches/solrcloud/solr/core/src/java/org/apache/solr/update/processor/DistributedUpdateProcessor.java Sun Nov 27 18:53:47 2011
@@ -75,7 +75,7 @@ public class DistributedUpdateProcessor 
   private NamedList addsResponse = null;
   private NamedList deleteResponse = null;
   private CharsRef scratch;
-  private boolean isLeader;
+  private boolean isLeader = true;
   private boolean forwardToLeader = false;
 
   private final SchemaField idField;
@@ -156,8 +156,8 @@ public class DistributedUpdateProcessor 
             // we got a version, just go local - set no shardStr
             
             // still mark if i am the leader though
-            if (shardZkNodeName.equals(leader)) {
-              isLeader = true;
+            if (!shardZkNodeName.equals(leader)) {
+              isLeader = false;
             }
           } else if (shardZkNodeName.equals(leader)) {
             isLeader = true;
@@ -172,7 +172,8 @@ public class DistributedUpdateProcessor 
             // I need to forward onto the leader...
             shards = new ArrayList<String>(1);
             shards.add(leaderUrl);
-            forwardToLeader  = true;
+            forwardToLeader = true;
+            isLeader = false;
           }
           req.setParams(params);
         }