logos-messaging/go-libp2p-pubsub
1
0
Fork 0
mirror of https://github.com/logos-messaging/go-libp2p-pubsub.git synced 2026-01-09 16:23:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

use atomic counter for message seqnos; timestamp is insufficient

Browse Source
This commit is contained in:
vyzo 2018-01-03 11:25:20 +02:00
parent 54413c29cc
commit 8a31b41b4c
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
floodsub.go
View File

@ -4,6 +4,7 @@ import (
"context"
"encoding/binary"
"fmt"
"sync/atomic"
"time"
pb "github.com/libp2p/go-floodsub/pb"
@ -57,6 +58,9 @@ type PubSub struct {
seenMessages *timecache.TimeCache
ctx context.Context
// atomic counter for seqnos
counter uint64
}
type Message struct {
@ -414,8 +418,10 @@ func (p *PubSub) GetTopics() []string {
// Publish publishes data under the given topic
func (p *PubSub) Publish(topic string, data []byte) error {
seqno := make([]byte, 8)
binary.BigEndian.PutUint64(seqno, uint64(time.Now().UnixNano()))
seqno := make([]byte, 16)
counter := atomic.AddUint64(&p.counter, 1)
binary.BigEndian.PutUint64(seqno[:8], uint64(time.Now().UnixNano()))
binary.BigEndian.PutUint64(seqno[8:], counter)
p.publish <- &Message{
&pb.Message{