]> Entropealabs - cluster_kv.git/commitdiff
send correct node for response
authorChristopher <chris@entropealabs.com>
Sat, 7 Mar 2020 05:59:51 +0000 (23:59 -0600)
committerChristopher <chris@entropealabs.com>
Sat, 7 Mar 2020 05:59:51 +0000 (23:59 -0600)
lib/cluster_kv/ring.ex

index dce336316c6c66d2c204fc4a75e3d215146a2b07..1b014ebfbebd3bb485e7af2e6e1a1ef4fc8e0b03 100644 (file)
@@ -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