You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
45 lines
1.5 KiB
45 lines
1.5 KiB
package crosslinks
|
|
|
|
import (
|
|
"sync/atomic"
|
|
|
|
"github.com/woop-chain/woop/core/types"
|
|
)
|
|
|
|
// Crosslinks is helper for processing crosslinks. It has meaning only for shards.
|
|
type Crosslinks struct {
|
|
// This number stores value we have already sent.
|
|
// It can be ahead of CrosslinkHeartbeat.LatestContinuousBlockNum, because processing of crosslink takes some time.
|
|
latestSentCrosslinkBlockNumber uint64
|
|
// Latest received valid heartbeat signal.
|
|
lastKnownCrosslinkHeartbeatSignal atomic.Value
|
|
}
|
|
|
|
// New creates new Crosslinks.
|
|
func New() *Crosslinks {
|
|
return &Crosslinks{}
|
|
}
|
|
|
|
// LatestSentCrosslinkBlockNumber returns last set value for crosslink block number or zero if not.
|
|
func (a *Crosslinks) LatestSentCrosslinkBlockNumber() uint64 {
|
|
return atomic.LoadUint64(&a.latestSentCrosslinkBlockNumber)
|
|
}
|
|
|
|
// SetLatestSentCrosslinkBlockNumber sets last crosslink block number.
|
|
func (a *Crosslinks) SetLatestSentCrosslinkBlockNumber(number uint64) {
|
|
atomic.StoreUint64(&a.latestSentCrosslinkBlockNumber, number)
|
|
}
|
|
|
|
// LastKnownCrosslinkHeartbeatSignal returns last set value for heartbeat or nil if not.
|
|
func (a *Crosslinks) LastKnownCrosslinkHeartbeatSignal() *types.CrosslinkHeartbeat {
|
|
val := a.lastKnownCrosslinkHeartbeatSignal.Load()
|
|
if val == nil {
|
|
return nil
|
|
}
|
|
return val.(*types.CrosslinkHeartbeat)
|
|
}
|
|
|
|
// SetLastKnownCrosslinkHeartbeatSignal sets last known heartbeat.
|
|
func (a *Crosslinks) SetLastKnownCrosslinkHeartbeatSignal(signal *types.CrosslinkHeartbeat) {
|
|
a.lastKnownCrosslinkHeartbeatSignal.Store(signal)
|
|
}
|
|
|