blocksync

package
v0.5.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 29, 2020 License: Apache-2.0, MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Headers = 1 << iota
	Messages
)

Request options. When fetching the chain segment we can fetch either block headers, messages, or both.

View Source
const (
	Ok status = 0
	// We could not fetch all blocks requested (but at least we returned
	// the `Head` requested). Not considered an error.
	Partial = 101

	// Errors
	NotFound      = 201
	GoAway        = 202
	InternalError = 203
	BadRequest    = 204
)
View Source
const BlockSyncProtocolID = "/fil/sync/blk/0.0.1"
View Source
const READ_RES_DEADLINE = WRITE_REQ_DEADLINE
View Source
const READ_RES_MIN_SPEED = 50 << 10
View Source
const SHUFFLE_PEERS_PREFIX = 5
View Source
const SUCCESS_PEER_TAG_VALUE = 25

Extracted constants from the code. FIXME: Should be reviewed and confirmed.

View Source
const WRITE_REQ_DEADLINE = 5 * time.Second
View Source
const WRITE_RES_DEADLINE = 60 * time.Second

Variables

View Source
var MaxRequestLength = uint64(build.ForkLengthThreshold)

FIXME: Bumped from original 800 to this to accommodate `syncFork()`

use of `GetBlocks()`. It seems the expectation of that API is to
fetch any amount of blocks leaving it to the internal logic here
to partition and reassemble the requests if they go above the maximum.
(Also as a consequence of this temporarily removing the `const`
 qualifier to avoid "const initializer [...] is not a constant" error.)

Functions

This section is empty.

Types

type BSTipSet

type BSTipSet struct {
	Blocks   []*types.BlockHeader
	Messages *CompactedMessages
}

FIXME: Rename.

func (*BSTipSet) MarshalCBOR

func (t *BSTipSet) MarshalCBOR(w io.Writer) error

func (*BSTipSet) UnmarshalCBOR

func (t *BSTipSet) UnmarshalCBOR(r io.Reader) error

type BlockSync

type BlockSync struct {
	// contains filtered or unexported fields
}

Protocol client. FIXME: Rename to just `Client`. Not done at the moment to avoid

disrupting too much of the consumer code, should be done along
https://github.com/filecoin-project/lotus/issues/2612.

func NewClient added in v0.5.0

func NewClient(
	host host.Host,
	pmgr peermgr.MaybePeerMgr,
) *BlockSync

func (*BlockSync) AddPeer

func (client *BlockSync) AddPeer(p peer.ID)

func (*BlockSync) GetBlocks

func (client *BlockSync) GetBlocks(
	ctx context.Context,
	tsk types.TipSetKey,
	count int,
) ([]*types.TipSet, error)

GetBlocks fetches count blocks from the network, from the provided tipset *backwards*, returning as many tipsets as count.

{hint/usage}: This is used by the Syncer during normal chain syncing and when resolving forks.

func (*BlockSync) GetChainMessages

func (client *BlockSync) GetChainMessages(
	ctx context.Context,
	head *types.TipSet,
	length uint64,
) ([]*CompactedMessages, error)

func (*BlockSync) GetFullTipSet

func (client *BlockSync) GetFullTipSet(
	ctx context.Context,
	peer peer.ID,
	tsk types.TipSetKey,
) (*store.FullTipSet, error)

func (*BlockSync) RemovePeer

func (client *BlockSync) RemovePeer(p peer.ID)

type BlockSyncService

type BlockSyncService struct {
	// contains filtered or unexported fields
}

BlockSyncService is the component that services BlockSync requests from peers.

BlockSync is the basic chain synchronization protocol of Filecoin. BlockSync is an RPC-oriented protocol, with a single operation to request blocks.

A request contains a start anchor block (referred to with a CID), and a amount of blocks requested beyond the anchor (including the anchor itself).

A client can also pass options, encoded as a 64-bit bitfield. Lotus supports two options at the moment:

  • include block contents
  • include block messages

The response will include a status code, an optional message, and the response payload in case of success. The payload is a slice of serialized tipsets. FIXME: Rename to just `Server` (will be done later, see note on `BlockSync`).

func NewBlockSyncService

func NewBlockSyncService(cs *store.ChainStore) *BlockSyncService

func (*BlockSyncService) HandleStream

func (server *BlockSyncService) HandleStream(stream inet.Stream)

Entry point of the service, handles `Request`s.

type CompactedMessages added in v0.5.0

type CompactedMessages struct {
	Bls         []*types.Message
	BlsIncludes [][]uint64

	Secpk         []*types.SignedMessage
	SecpkIncludes [][]uint64
}

All messages of a single tipset compacted together instead of grouped by block to save space, since there are normally many repeated messages per tipset in different blocks.

`BlsIncludes`/`SecpkIncludes` matches `Bls`/`Secpk` messages to blocks in the tipsets with the format: `BlsIncludes[BI][MI]`

  • BI: block index in the tipset.
  • MI: message index in `Bls` list

FIXME: The logic to decompress this structure should belong

to itself, not to the consumer.

func (*CompactedMessages) MarshalCBOR added in v0.5.0

func (t *CompactedMessages) MarshalCBOR(w io.Writer) error

func (*CompactedMessages) UnmarshalCBOR added in v0.5.0

func (t *CompactedMessages) UnmarshalCBOR(r io.Reader) error

type Request added in v0.5.0

type Request struct {
	// List of ordered CIDs comprising a `TipSetKey` from where to start
	// fetching backwards.
	// FIXME: Consider using `TipSetKey` now (introduced after the creation
	//  of this protocol) instead of converting back and forth.
	Head []cid.Cid
	// Number of block sets to fetch from `Head` (inclusive, should always
	// be in the range `[1, MaxRequestLength]`).
	Length uint64
	// Request options, see `Options` type for more details. Compressed
	// in a single `uint64` to save space.
	Options uint64
}

FIXME: Rename. Make private.

func (*Request) MarshalCBOR added in v0.5.0

func (t *Request) MarshalCBOR(w io.Writer) error

func (*Request) UnmarshalCBOR added in v0.5.0

func (t *Request) UnmarshalCBOR(r io.Reader) error

type Response added in v0.5.0

type Response struct {
	Status status
	// String that complements the error status when converting to an
	// internal error (see `statusToError()`).
	ErrorMessage string

	Chain []*BSTipSet
}

FIXME: Rename. Make private.

func (*Response) MarshalCBOR added in v0.5.0

func (t *Response) MarshalCBOR(w io.Writer) error

func (*Response) UnmarshalCBOR added in v0.5.0

func (t *Response) UnmarshalCBOR(r io.Reader) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL