]> Entropealabs - cluster_kv.git/commitdiff
only get frmo one node
authorChristopher <chris@entropealabs.com>
Sat, 7 Mar 2020 18:13:06 +0000 (12:13 -0600)
committerChristopher <chris@entropealabs.com>
Sat, 7 Mar 2020 18:13:06 +0000 (12:13 -0600)
lib/cluster_kv/ring.ex

index 104e5e9e6bd6116115c2b4fff1e0744e7c268749..57893af5bccaf9fccd20f7a6b9bbdf90f95a1e96 100644 (file)
@@ -145,7 +145,7 @@ defmodule ClusterKV.Ring do
     {:ok, %SL{sl | data: %Ring{data | requests: [{ref, from, length(itr) + 1, []} | reqs]}}, []}
   end
 
-  def handle_call({:prefix, _prefix}, from, _, sl), do: {:ok, sl, [{:reply, from, :no_quorum}]}
+  def handle_call({:prefix, _, _, _}, from, _, sl), do: {:ok, sl, [{:reply, from, :no_quorum}]}
 
   def handle_cast(
         {:put, key, value},
@@ -208,13 +208,13 @@ defmodule ClusterKV.Ring do
     send({n, node}, {:get_key, prefix, ref, me})
   end
 
-  defp get_node(key, r, node, repls) do
-    nodes = HashRing.key_to_nodes(r, key, repls)
+  defp get_node(key, r, _node, _repls) do
+    HashRing.key_to_node(r, key)
 
-    case node in nodes do
-      true -> node
-      false -> Enum.random(nodes)
-    end
+    case node in nodes do
+    #  true -> node
+    #  false -> Enum.random(nodes)
+    end
   end
 
   defp do_stream(db) do