{: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},
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