Skip to content

Commit 93ada79

Browse files
committed
broadcast tip changes quicker
1 parent e95fd72 commit 93ada79

3 files changed

Lines changed: 10 additions & 1 deletion

File tree

ex/lib/api/api_chain.ex

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ defmodule API.Chain do
9090

9191
def stat_txs_sec() do
9292
height = Fabric.rooted_tip_height()
93-
last_100 = Enum.sum_by(height..(height-100), fn(height)->
93+
last_100 = Enum.sum_by((height-100)..height, fn(height)->
9494
length(Fabric.entries_by_height(height) |> List.first() |> Map.get(:txs))
9595
end)
9696
last_100/50

ex/lib/consensus/fabric_gen.ex

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -269,6 +269,7 @@ defmodule FabricGen do
269269
#TODO: fix this in a better way later
270270
peers = Application.fetch_env!(:ama, :seedanrs_as_peers)
271271
send(NodeGen.get_socket_gen(), {:send_to, peers, msg})
272+
send(NodeGen, :signal_tips_change)
272273

273274
next_entry
274275
end

ex/lib/node/node_gen.ex

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -121,6 +121,14 @@ defmodule NodeGen do
121121
innerstate = NodeState.handle(op, innerstate, args)
122122
Map.put(state, :ns, innerstate)
123123

124+
:signal_tips_change ->
125+
:erlang.spawn(fn()->
126+
msg = NodeProto.event_tip()
127+
{vals, peers} = NodeANR.handshaked_and_online()
128+
send(get_socket_gen(), {:send_to, vals ++ Enum.take(peers, 10), msg})
129+
end)
130+
state
131+
124132
end
125133
{:noreply, state}
126134
end

0 commit comments

Comments
 (0)