sync

Documentation

Index

• type BlockListener
  • func NewBlockListener(net service.Service, sync *Syncer, concurrency int, logger log.Log) *BlockListener
  • func (bl *BlockListener) Close()
  • func (ms BlockListener) GetExit() chan struct{}
  • func (ms BlockListener) GetTimeout() time.Duration
  • func (bl *BlockListener) Start()
• type Configuration
• type Syncer
  • func NewSync(srv service.Service, layers *mesh.Mesh, txpool txMemPool, atxDB atxDB, ...) *Syncer
  • func NewSyncWithMocks(atxdbStore *database.LDBDatabase, mshdb *mesh.DB, txpool *state.TxMempool, ...) *Syncer
  • func (s *Syncer) Await() chan struct{}
  • func (s *Syncer) Close()
  • func (s *Syncer) FetchAtxReferences(atx *types.ActivationTx) error
  • func (s *Syncer) FetchPoetProof(poetProofRef []byte) error
  • func (s *Syncer) ForceSync()
  • func (ms Syncer) GetExit() chan struct{}
  • func (ms Syncer) GetTimeout() time.Duration
  • func (s *Syncer) IsSynced() bool
  • func (s *Syncer) ListenToGossip() bool
  • func (s *Syncer) Start()

Types

type BlockListener

type BlockListener struct {
	*Syncer

	log.Log
	// contains filtered or unexported fields
}

BlockListener Listens to blocks propagated in gossip

func NewBlockListener

func NewBlockListener(net service.Service, sync *Syncer, concurrency int, logger log.Log) *BlockListener

NewBlockListener creates a new instance of BlockListener

func (*BlockListener) Close

func (bl *BlockListener) Close()

Close closes all running goroutines

func (BlockListener) GetExit

func (ms BlockListener) GetExit() chan struct{}

func (BlockListener) GetTimeout

func (ms BlockListener) GetTimeout() time.Duration

func (*BlockListener) Start

func (bl *BlockListener) Start()

Start starts the main listening goroutine

type Configuration

type Configuration struct {
	LayersPerEpoch  uint16
	Concurrency     int // number of workers for sync method
	LayerSize       int
	RequestTimeout  time.Duration
	SyncInterval    time.Duration
	ValidationDelta time.Duration
	AtxsLimit       int
	Hdist           int
	AlwaysListen    bool
}

Configuration represents all config params needed by syncer

type Syncer

type Syncer struct {
	log.Log
	Configuration
	*mesh.Mesh
	// contains filtered or unexported fields
}

Syncer is used to sync the node with the network periodically the Syncer will check if the node is synced with the rest of the network and will follow the sync protocol in order to fetch all missing data and become synced again

func NewSync

func NewSync(srv service.Service, layers *mesh.Mesh, txpool txMemPool, atxDB atxDB, bv blockEligibilityValidator, poetdb poetDb, conf Configuration, clock ticker, logger log.Log) *Syncer

NewSync fires a sync every sm.SyncInterval or on force space from outside

func NewSyncWithMocks

func NewSyncWithMocks(atxdbStore *database.LDBDatabase, mshdb *mesh.DB, txpool *state.TxMempool, atxpool *activation.AtxMemDB, swarm service.Service, poetDb *activation.PoetDb, conf Configuration, expectedLayers types.LayerID) *Syncer

NewSyncWithMocks returns a syncer instance that is backed by mocks of other modules for use in testing

func (*Syncer) Await

func (s *Syncer) Await() chan struct{}

Await returns a channel that blocks until the node is synced

func (*Syncer) Close

func (s *Syncer) Close()

Close closes all running goroutines

func (*Syncer) FetchAtxReferences

func (s *Syncer) FetchAtxReferences(atx *types.ActivationTx) error

FetchAtxReferences fetches positioning and prev atxs from peers if they are not found in db

func (*Syncer) FetchPoetProof

func (s *Syncer) FetchPoetProof(poetProofRef []byte) error

FetchPoetProof fetches a poet proof from network peers

func (*Syncer) ForceSync

func (s *Syncer) ForceSync()

ForceSync signals syncer to run the synchronise flow

func (Syncer) GetExit

func (ms Syncer) GetExit() chan struct{}

func (Syncer) GetTimeout

func (ms Syncer) GetTimeout() time.Duration

func (*Syncer) IsSynced

func (s *Syncer) IsSynced() bool

IsSynced returns true if the node is synced false otherwise

func (*Syncer) ListenToGossip

func (s *Syncer) ListenToGossip() bool

ListenToGossip enables other modules to check if they should listen to gossip

func (*Syncer) Start

func (s *Syncer) Start()

Start starts the main pooling routine that checks the sync status every set interval and calls synchronise if the node is out of sync