diff --git a/go-libp2p-blossomsub/bitmask.go b/go-libp2p-blossomsub/bitmask.go index 1e976f9..d37cc1e 100644 --- a/go-libp2p-blossomsub/bitmask.go +++ b/go-libp2p-blossomsub/bitmask.go @@ -161,7 +161,7 @@ func (t *Bitmask) Subscribe(opts ...SubOpt) (*Subscription, error) { if sub.ch == nil { // apply the default size - sub.ch = make(chan *Message, 32) + sub.ch = make(chan *Message, 1000) } out := make(chan *Subscription, 1) diff --git a/go-libp2p-blossomsub/pubsub.go b/go-libp2p-blossomsub/pubsub.go index bde0de7..78d5449 100644 --- a/go-libp2p-blossomsub/pubsub.go +++ b/go-libp2p-blossomsub/pubsub.go @@ -260,11 +260,11 @@ func NewPubSub(ctx context.Context, h host.Host, rt PubSubRouter, opts ...Option peerFilter: DefaultPeerFilter, disc: &discover{}, maxMessageSize: DefaultMaxMessageSize, - peerOutboundQueueSize: 32, + peerOutboundQueueSize: 1000, signID: h.ID(), signKey: nil, signPolicy: StrictSign, - incoming: make(chan *RPC, 32), + incoming: make(chan *RPC, 1000), newPeers: make(chan struct{}, 1), newPeersPend: make(map[peer.ID]struct{}), newPeerStream: make(chan network.Stream), @@ -280,7 +280,7 @@ func NewPubSub(ctx context.Context, h host.Host, rt PubSubRouter, opts ...Option addBitmask: make(chan *addBitmaskReq), rmBitmask: make(chan *rmBitmaskReq), getBitmasks: make(chan *bitmaskReq), - sendMsg: make(chan *Message, 32), + sendMsg: make(chan *Message, 1000), addVal: make(chan *addValReq), rmVal: make(chan *rmValReq), eval: make(chan func()), @@ -1308,7 +1308,7 @@ func (p *PubSub) Subscribe(bitmask []byte, opts ...SubOpt) (*Subscription, error } // WithBufferSize is a Subscribe option to customize the size of the subscribe output buffer. -// The default length is 32 but it can be configured to avoid dropping messages if the consumer is not reading fast +// The default length is 1000 but it can be configured to avoid dropping messages if the consumer is not reading fast // enough. func WithBufferSize(size int) SubOpt { return func(sub *Subscription) error { diff --git a/node/app/db_console.go b/node/app/db_console.go index 718eb72..9bf7dc0 100644 --- a/node/app/db_console.go +++ b/node/app/db_console.go @@ -887,11 +887,11 @@ func logoVersion(width int) string { out += " ''---.. ...---'' ##\n" out += " ''----------''\n" out += " \n" - out += " Quilibrium Node - v1.4.1 – Sunset\n" + out += " Quilibrium Node - v1.4.2 – Sunset\n" out += " \n" out += " DB Console\n" } else { - out = "Quilibrium Node - v1.4.1 – Sunset - DB Console\n" + out = "Quilibrium Node - v1.4.2 – Sunset - DB Console\n" } return out } diff --git a/node/consensus/consensus_engine.go b/node/consensus/consensus_engine.go index 9541380..2f1c10c 100644 --- a/node/consensus/consensus_engine.go +++ b/node/consensus/consensus_engine.go @@ -59,5 +59,5 @@ func GetMinimumVersion() []byte { } func GetVersion() []byte { - return []byte{0x01, 0x04, 0x01} + return []byte{0x01, 0x04, 0x02} } diff --git a/node/consensus/master/broadcast_messaging.go b/node/consensus/master/broadcast_messaging.go index f030f80..5325c65 100644 --- a/node/consensus/master/broadcast_messaging.go +++ b/node/consensus/master/broadcast_messaging.go @@ -103,6 +103,15 @@ func (e *MasterClockConsensusEngine) handleClockFrameData( return errors.Wrap(err, "handle clock frame data") } + head, err := e.masterTimeReel.Head() + if err != nil { + panic(err) + } + + if frame.FrameNumber < head.FrameNumber { + return nil + } + if e.difficulty != frame.Difficulty { e.logger.Debug( "frame difficulty mismatched", diff --git a/node/main.go b/node/main.go index 214d7f3..4a6ae3a 100644 --- a/node/main.go +++ b/node/main.go @@ -495,5 +495,5 @@ func printLogo() { func printVersion() { fmt.Println(" ") - fmt.Println(" Quilibrium Node - v1.4.1 – Sunset") + fmt.Println(" Quilibrium Node - v1.4.2 – Sunset") }