distr: fix superfluous requestpull due to bothed origin skip
This commit is contained in:
parent
8ecdfa6701
commit
163979612d
2 changed files with 1 additions and 6 deletions
|
@ -71,8 +71,7 @@ defmodule Floof.Distributor do
|
|||
send(trg, {:fwdxfer, {dcdhash, dcd2}})
|
||||
end
|
||||
|
||||
oset = MapSet.put(MapSet.new(), origin)
|
||||
Floof.SessionManager.set_for_all(dcdhash, dcd2, oset)
|
||||
Floof.SessionManager.set_for_all(dcdhash, dcd2, origin)
|
||||
end)
|
||||
|
||||
Floof.DistributorSeen.mark_seen(dcdhash)
|
||||
|
|
|
@ -65,10 +65,6 @@ defmodule Floof.SessionManager do
|
|||
for {key, {sub, m}} <- state, into: %{} do
|
||||
m2 =
|
||||
if origin != sub do
|
||||
Logger.debug(
|
||||
"set_for_all origin!=sub #{inspect(key: key, origin: origin, sub: sub, subkey: subkey)}"
|
||||
)
|
||||
|
||||
if sub != nil do
|
||||
send(sub, {:SessionPushed, key})
|
||||
end
|
||||
|
|
Loading…
Reference in a new issue