temporary: log presented hashes

This commit is contained in:
Alain Zscheile 2022-11-27 23:58:21 +01:00
parent b10928e533
commit c0a210fa6e
2 changed files with 3 additions and 3 deletions

View file

@ -104,6 +104,7 @@ defmodule Floof do
[sesskey | _] = sesskeys
dcdids = Enum.map(MapSet.new(sesskeys), &MapSet.new(Floof.SessionManager.peek(&1)))
dcdids = Enum.reduce(dcdids, &MapSet.union(&1, &2))
Logger.debug("presenting session content #{inspect(dcdids)})")
:ok = send_summary(client, :requestpull, dcdids)
{backlog, sesskey}

View file

@ -102,13 +102,12 @@ defmodule Floof.SessionManager do
)
filter_keys = MapSet.delete(filter_keys, nil)
{:ok, all_keys} = all_session_keys(state)
# filter_keys contains all subscribed sessions
# all_keys contains all non-empty sessions
added_dets_ents =
for key <- MapSet.union(MapSet.new(all_keys), filter_keys), do: {key, subkey}
all_keys = MapSet.union(MapSet.new(all_keys), filter_keys)
added_dets_ents = for key <- all_keys, do: {key, subkey}
if not Enum.empty?(added_dets_ents) do
# only store packets when we have any sessions