Hi,
Thank you for the pointers. I only have one CubDB process.
I removed all Logger references, including require Logger calls, and the problem is still there.
What is strange is that there is this error about sys.beam, but why the BEAM would load this file once again, since the module is loaded at the VM boot …
All the calls to CubDB are made by 4 processes, all using get_multi and get_and_update_multi either to load data or to write data.
Reading:
CubDB.get_multi(cub, keys, :NOT_FOUND)
When writing we give no key:
CubDB.get_and_update_multi(cub, [], fn %{} ->
{events, puts, delete_keys}
end)
edit
I have found that the error happens because I’ve set auto_compact: true. If I set it to false, everything works well. So maybe it is an expected behaviour ?
Everything seem to work well, as I changed your code to add IO.puts calls and have the following logs:
IO.puts("compaction_completed")
send(caller, {:compaction_completed, btree, compacted_btree})
defp can_compact?(%State{compactor: compactor}) do
case compactor do
nil ->
IO.puts("compaction will run")
true
_ ->
IO.puts("compaction is pending")
{false, :pending_compaction}
end
end
compaction is pending
compaction_completed
compaction is pending
compaction is pending
compaction is pending
compaction is pending
compaction is pending
compaction is pending
compaction is pending
compaction is pending
compaction is pending
compaction is pending
compaction is pending
compaction is pending
compaction is pending
compaction is pending
compaction is pending
compaction will run
compaction is pending
compaction is pending
compaction is pending
compaction_completed
compaction is pending
compaction is pending
compaction is pending
compaction is pending
compaction is pending
compaction is pending
compaction is pending
compaction is pending
