From: Christopher <chris@entropealabs.com>
Date: Thu, 16 Apr 2020 15:20:20 +0000 (-0500)
Subject: more logging
X-Git-Url: http://git.entropealabs.com/?a=commitdiff_plain;h=e7cc2f8b7f4e564ccbc1d0fb913c3240a5576f78;p=cluster_kv.git

more logging
---

diff --git a/lib/cluster_kv/db.ex b/lib/cluster_kv/db.ex
index 468235e..9b0cd01 100644
--- a/lib/cluster_kv/db.ex
+++ b/lib/cluster_kv/db.ex
@@ -143,7 +143,7 @@ defmodule ClusterKV.DB do
     batch
     |> Enum.slice(last_batch, chunk)
     |> Enum.each(fn {_k, _v} = v ->
-      :ets.insert(db, v)
+      :ets.insert_new(db, v)
       # do_upsert(db, k, v, fun)
     end)
 
diff --git a/lib/cluster_kv/ring.ex b/lib/cluster_kv/ring.ex
index df75eb0..e51787a 100644
--- a/lib/cluster_kv/ring.ex
+++ b/lib/cluster_kv/ring.ex
@@ -338,6 +338,7 @@ defmodule ClusterKV.Ring do
   end
 
   def handle_info({:get_key, key, ref, node}, _, %SL{data: %Ring{name: n, db: db, node: me}} = sl) do
+    Logger.info("Getting value for #{inspect(key)} with ref #{inspect(ref)}")
     send({n, node}, {:reply, get_key(db, key), ref, me})
     {:ok, sl, []}
   end
@@ -380,6 +381,7 @@ defmodule ClusterKV.Ring do
   end
 
   def handle_info({:reply, val, ref, from}, _, %SL{data: %Ring{requests: reqs} = data} = sl) do
+    Logger.info("Got #{inspect(val)} with ref #{inspect(ref)}")
     {requests, actions} = maybe_reply(ref, reqs, val, from)
     {:ok, %SL{sl | data: %Ring{data | requests: requests}}, actions}
   end