fix consistent hash bug

fuhp · Jun 26, 2017 · 2593ec1 · 2593ec1
1 parent 25bb40e
commit 2593ec1
Showing 1 changed file with 4 additions and 7 deletions.
diff --git a/cpp/servant/libservant/EndpointManager.cpp b/cpp/servant/libservant/EndpointManager.cpp
@@ -1241,11 +1241,8 @@ void EndpointManager::updateConHashProxyWeighted(bool bStatic, vector<AdapterPro
         return ;
     }
 
-    if(bStatic)
-    {
-        vLastConHashProxys = _vRegProxys;
-        conHash.clear();
-    }
+    vLastConHashProxys = _vRegProxys;
+    conHash.clear();
 
     for(size_t i = 0; i < _vRegProxys.size(); ++i)
     {
@@ -1257,7 +1254,7 @@ void EndpointManager::updateConHashProxyWeighted(bool bStatic, vector<AdapterPro
             {
                 iWeight = 1;
             }
-            conHash.addNode(_vRegProxys[i]->endpoint().desc(), i, _vRegProxys[i]->getWeight());
+            conHash.addNode(_vRegProxys[i]->endpoint().desc(), i, iWeight);
         }
     }
 
@@ -1362,7 +1359,7 @@ AdapterProxy* EndpointManager::getConHashProxyForNormal(int64_t hashCode)
     {
         int64_t iBegin = TNOWMS;
 
-        updateConHashProxyWeighted(true, _lastConHashProxys, _consistentHash);
+        updateConHashProxyWeighted(false, _lastConHashProxys, _consistentHash);
 
         int64_t iEnd = TNOWMS;