cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

townhall: Send nonces

Browse Source
This commit is contained in:
Łukasz Magiera 2019-11-14 17:37:02 +01:00
parent 483f4aed44
commit dbdf120746
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
chain/metrics/consensus.go
View File

@ -71,6 +71,7 @@ type message struct {
Height uint64 Height uint64
Weight types.BigInt Weight types.BigInt
Time uint64 Time uint64
Nonce uint64
// Meta // Meta
@ -86,6 +87,9 @@ func sendHeadNotifs(ctx context.Context, ps *pubsub.PubSub, topic string, chain
return err return err
} }
// using unix nano time makes very sure we pick a nonce higher than previous restart
nonce := uint64(time.Now().UnixNano())
for { for {
select { select {
case notif := <-notifs: case notif := <-notifs:
@ -103,6 +107,7 @@ func sendHeadNotifs(ctx context.Context, ps *pubsub.PubSub, topic string, chain
Weight: w, Weight: w,
NodeName: nickname, NodeName: nickname,
Time: uint64(time.Now().UnixNano() / 1000_000), Time: uint64(time.Now().UnixNano() / 1000_000),
Nonce: nonce,
} }
b, err := json.Marshal(m) b, err := json.Marshal(m)
@ -116,5 +121,7 @@ func sendHeadNotifs(ctx context.Context, ps *pubsub.PubSub, topic string, chain
case <-ctx.Done(): case <-ctx.Done():
return nil return nil
} }
nonce++
} }
} }