blame

Documentation

Index

• Constants
• Variables
• type Blame
  • func NewBlame(reason string, blameNodes []Node) Blame
  • func (b *Blame) AddBlameNodes(newBlameNodes ...Node)
  • func (b *Blame) AlreadyBlame() bool
  • func (b *Blame) IsEmpty() bool
  • func (b *Blame) SetBlame(reason string, nodes []Node, isUnicast bool)
  • func (b Blame) String() string
• type Manager
  • func NewBlameManager() *Manager
  • func (m *Manager) GetAcceptShares() *sync.Map
  • func (m *Manager) GetBlame() *Blame
  • func (m *Manager) GetBlamePubKeysLists(peer []string) ([]string, []string, error)
  • func (m *Manager) GetBroadcastBlame(lastMessageType string) ([]Node, error)
  • func (m *Manager) GetLastMsg() btss.Message
  • func (m *Manager) GetRoundMgr() *RoundMgr
  • func (m *Manager) GetShareMgr() *ShareMgr
  • func (m *Manager) GetUnicastBlame(lastMsgType string) ([]Node, error)
  • func (m *Manager) NodeSyncBlame(keys []string, onlinePeers []peer.ID) (Blame, error)
  • func (m *Manager) SetLastMsg(lastMsg btss.Message)
  • func (m *Manager) SetLastUnicastPeer(peerID peer.ID, roundInfo string)
  • func (m *Manager) SetPartyInfo(party btss.Party, partyIDMap map[string]*btss.PartyID)
  • func (m *Manager) TssMissingShareBlame(rounds int) ([]Node, bool, error)
  • func (m *Manager) TssWrongShareBlame(wiredMsg *messages.WireMessage) (string, error)
• type Node
  • func NewNode(pk string, blameData, blameSig []byte) Node
  • func (bn *Node) Equal(node Node) bool
• type PartyInfo
• type RoundInfo
• type RoundMgr
  • func NewTssRoundMgr() *RoundMgr
  • func (tr *RoundMgr) Get(key string) *messages.WireMessage
  • func (tr *RoundMgr) GetByRound(roundInfo string) []string
  • func (tr *RoundMgr) Set(key string, msg *messages.WireMessage)
• type ShareMgr
  • func NewTssShareMgr() *ShareMgr
  • func (sm *ShareMgr) QueryAndDelete(key string) bool
  • func (sm *ShareMgr) Set(key string)

Constants

const (
	HashCheckFail = "hash check failed"
	TssTimeout    = "Tss timeout"
	TssSyncFail   = "signers fail to sync before keygen/keysign"
	TssBrokenMsg  = "tss share verification failed"
	InternalError = "fail to start the join party "
)

Variables

var (
	ErrHashFromOwner     = errors.New(" hash sent from data owner")
	ErrNotEnoughPeer     = errors.New("not enough nodes to evaluate hash")
	ErrNotMajority       = errors.New("message we received does not match the majority")
	ErrTssTimeOut        = errors.New("error Tss Timeout")
	ErrHashCheck         = errors.New("error in processing hash check")
	ErrHashInconsistency = errors.New("fail to agree on the hash value")
)

Types

type Blame

type Blame struct {
	FailReason string `json:"fail_reason"`
	IsUnicast  bool   `json:"is_unicast"`
	BlameNodes []Node `json:"blame_peers,omitempty"`
}

Blame is used to store the blame nodes and the fail reason

func NewBlame

func NewBlame(reason string, blameNodes []Node) Blame

NewBlame create a new instance of Blame

func (*Blame) AddBlameNodes

func (b *Blame) AddBlameNodes(newBlameNodes ...Node)

AddBlameNodes add nodes to the blame list

func (*Blame) AlreadyBlame

func (b *Blame) AlreadyBlame() bool

func (*Blame) IsEmpty

func (b *Blame) IsEmpty() bool

IsEmpty check whether it is empty

func (*Blame) SetBlame

func (b *Blame) SetBlame(reason string, nodes []Node, isUnicast bool)

SetBlame update the field values of Blame

func (Blame) String

func (b Blame) String() string

String implement fmt.Stringer

type Manager

type Manager struct {
	PartyIDtoP2PID map[string]peer.ID
	// contains filtered or unexported fields
}

func NewBlameManager

func NewBlameManager() *Manager

func (*Manager) GetAcceptShares

func (m *Manager) GetAcceptShares() *sync.Map

func (*Manager) GetBlame

func (m *Manager) GetBlame() *Blame

func (*Manager) GetBlamePubKeysLists

func (m *Manager) GetBlamePubKeysLists(peer []string) ([]string, []string, error)

GetBlamePubKeysNotInList returns the nodes public key who are not in the peer list

func (*Manager) GetBroadcastBlame

func (m *Manager) GetBroadcastBlame(lastMessageType string) ([]Node, error)

this blame blames the node who cause the timeout in broadcast message

func (*Manager) GetLastMsg

func (m *Manager) GetLastMsg() btss.Message

func (*Manager) GetRoundMgr

func (m *Manager) GetRoundMgr() *RoundMgr

func (*Manager) GetShareMgr

func (m *Manager) GetShareMgr() *ShareMgr

func (*Manager) GetUnicastBlame

func (m *Manager) GetUnicastBlame(lastMsgType string) ([]Node, error)

this blame blames the node who cause the timeout in unicast message

func (*Manager) NodeSyncBlame

func (m *Manager) NodeSyncBlame(keys []string, onlinePeers []peer.ID) (Blame, error)

this blame blames the node who cause the timeout in node sync

func (*Manager) SetLastMsg

func (m *Manager) SetLastMsg(lastMsg btss.Message)

func (*Manager) SetLastUnicastPeer

func (m *Manager) SetLastUnicastPeer(peerID peer.ID, roundInfo string)

func (*Manager) SetPartyInfo

func (m *Manager) SetPartyInfo(party btss.Party, partyIDMap map[string]*btss.PartyID)

func (*Manager) TssMissingShareBlame

func (m *Manager) TssMissingShareBlame(rounds int) ([]Node, bool, error)

this blame blames the node fail to send the shares to the node

func (*Manager) TssWrongShareBlame

func (m *Manager) TssWrongShareBlame(wiredMsg *messages.WireMessage) (string, error)

this blame blames the node who provide the wrong share

type Node

type Node struct {
	Pubkey         string `json:"pubkey"`
	BlameData      []byte `json:"data"`
	BlameSignature []byte `json:"signature,omitempty"`
}

func NewNode

func NewNode(pk string, blameData, blameSig []byte) Node

func (*Node) Equal

func (bn *Node) Equal(node Node) bool

type PartyInfo

type PartyInfo struct {
	Party      btss.Party
	PartyIDMap map[string]*btss.PartyID
}

PartyInfo the information used by tss key gen and key sign

type RoundInfo

type RoundInfo struct {
	Index    int
	RoundMsg string
}

type RoundMgr

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

func NewTssRoundMgr

func NewTssRoundMgr() *RoundMgr

func (*RoundMgr) Get

func (tr *RoundMgr) Get(key string) *messages.WireMessage

func (*RoundMgr) GetByRound

func (tr *RoundMgr) GetByRound(roundInfo string) []string

func (*RoundMgr) Set

func (tr *RoundMgr) Set(key string, msg *messages.WireMessage)

type ShareMgr

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

func NewTssShareMgr

func NewTssShareMgr() *ShareMgr

func (*ShareMgr) QueryAndDelete

func (sm *ShareMgr) QueryAndDelete(key string) bool

func (*ShareMgr) Set

func (sm *ShareMgr) Set(key string)