Skip to content

Commit 4e6129a

Browse files
committed
[GH-#75] fixed peer removal
1 parent 0a2e2c1 commit 4e6129a

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

apps/aecore/lib/aecore/peers/worker.ex

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -99,8 +99,10 @@ defmodule Aecore.Peers.Worker do
9999
"""
100100
def handle_call(:check_peers, _from, peers) do
101101
filtered_peers = :maps.filter(fn(peer, _) ->
102-
{status, info} = Client.get_info(peer)
103-
:ok == status && info.genesis_block_hash == genesis_block_header_hash()
102+
case Client.get_info(peer) do
103+
{:ok, info} -> info.genesis_block_hash == genesis_block_header_hash()
104+
_ -> false
105+
end
104106
end, peers)
105107
updated_peers =
106108
for {peer, current_block_hash} <- filtered_peers, into: %{} do
@@ -132,9 +134,6 @@ defmodule Aecore.Peers.Worker do
132134
end
133135

134136
## Internal functions
135-
defp send_to_peers(uri, data, []) do
136-
Logger.warn("Empty peers list")
137-
end
138137
defp send_to_peers(uri, data, peers) do
139138
for peer <- peers do
140139
HttpClient.post(peer, data, uri)

0 commit comments

Comments
 (0)