From 394ff0adf08770de52b636d513af4bb94ddca9e7 Mon Sep 17 00:00:00 2001 From: Christopher Date: Fri, 6 Mar 2020 23:59:51 -0600 Subject: [PATCH] send correct node for response --- lib/cluster_kv/ring.ex | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) 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 -- 2.45.3