end
def send_batch(name, batches) do
- Logger.debug("Sending batches: #{inspect(batches)}")
+ Logger.info("Sending batches to: #{inspect(Map.keys(batches))}")
Enum.each(batches, fn {node, batch} ->
send({name, node}, {:handle_batch, batch})
defp get_node(key, r, node, repls) do
nodes = HashRing.key_to_nodes(r, key, repls)
+ Logger.info("Possible Nodes: #{inspect(nodes)}")
- case node in nodes do
- true -> node
- false -> Enum.random(nodes)
- end
+ n =
+ case node in nodes do
+ true -> node
+ false -> Enum.random(nodes)
+ end
+
+ Logger.info("Chose #{inspect(n)}")
+ n
end
end