From: Christopher <chris@entropealabs.com>
Date: Sat, 7 Mar 2020 18:13:06 +0000 (-0600)
Subject: only get frmo one node
X-Git-Url: http://git.entropealabs.com/?a=commitdiff_plain;h=dccc4c2191b6b670bcb6095a4eb13ef38fced3a8;p=cluster_kv.git

only get frmo one node
---

diff --git a/lib/cluster_kv/ring.ex b/lib/cluster_kv/ring.ex
index 104e5e9..57893af 100644
--- a/lib/cluster_kv/ring.ex
+++ b/lib/cluster_kv/ring.ex
@@ -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