From: Christopher Date: Sat, 7 Mar 2020 05:59:51 +0000 (-0600) Subject: send correct node for response X-Git-Url: http://git.entropealabs.com/?a=commitdiff_plain;h=394ff0adf08770de52b636d513af4bb94ddca9e7;p=cluster_kv.git send correct node for response --- diff --git a/lib/cluster_kv/ring.ex b/lib/cluster_kv/ring.ex index dce3363..1b014eb 100644 --- a/lib/cluster_kv/ring.ex +++ b/lib/cluster_kv/ring.ex @@ -100,13 +100,12 @@ defmodule ClusterKV.Ring do {:get, key}, from, @ready, - %SL{data: %Ring{name: n, node: node, requests: reqs, ring: r, replicas: repls} = data} = - sl + %SL{data: %Ring{name: n, node: me, requests: reqs, ring: r, replicas: repls} = data} = sl ) do - node = get_node(key, r, node, repls) + node = get_node(key, r, me, repls) ref = make_ref() - send({n, node}, {:get_key, key, ref, node}) + send({n, node}, {:get_key, key, ref, me}) {:ok, %SL{sl | data: %Ring{data | requests: [{ref, from, 1, []} | reqs]}}, []} end