Documentation ¶
Index ¶
- func Contains(s []*btss.PartyID, e *btss.PartyID) bool
- func GetMsgRound(msg []byte, partyID *btss.PartyID, isBroadcast bool) (blame.RoundInfo, error)
- func InitLog(level string, pretty bool, serviceValue string)
- func MsgToHashInt(msg []byte) (*big.Int, error)
- func MsgToHashString(msg []byte) (string, error)
- type BulkWireMsg
- type LocalCacheItem
- type PartyInfo
- type Status
- type TssCommon
- func (t *TssCommon) GetBlameMgr() *blame.Manager
- func (t *TssCommon) GetConf() TssConfig
- func (t *TssCommon) GetLocalPeerID() string
- func (t *TssCommon) GetTaskDone() chan struct{}
- func (t *TssCommon) NotifyTaskDone() error
- func (t *TssCommon) ProcessInboundMessages(finishChan chan struct{}, wg *sync.WaitGroup)
- func (t *TssCommon) ProcessOneMessage(wrappedMsg *messages.WrappedMessage, peerID string) error
- func (t *TssCommon) ProcessOutCh(msg btss.Message, msgType messages.THORChainTSSMessageType) error
- func (t *TssCommon) SetLocalPeerID(peerID string)
- func (t *TssCommon) SetPartyInfo(partyInfo *PartyInfo)
- func (t *TssCommon) TryGetAllLocalCached() []*LocalCacheItem
- func (t *TssCommon) TryGetLocalCacheItem(key string) *LocalCacheItem
- type TssConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetMsgRound ¶
func MsgToHashString ¶
Types ¶
type BulkWireMsg ¶
type BulkWireMsg struct { WiredBulkMsgs []byte MsgIdentifier string Routing *btss.MessageRouting }
func NewBulkWireMsg ¶
func NewBulkWireMsg(msg []byte, id string, r *btss.MessageRouting) BulkWireMsg
type LocalCacheItem ¶
type LocalCacheItem struct { Msg *messages.WireMessage Hash string ConfirmedList map[string]string // contains filtered or unexported fields }
LocalCacheItem used to cache the unconfirmed broadcast message
func NewLocalCacheItem ¶
func NewLocalCacheItem(msg *messages.WireMessage, hash string) *LocalCacheItem
func (*LocalCacheItem) GetPeers ¶
func (l *LocalCacheItem) GetPeers() []string
func (*LocalCacheItem) TotalConfirmParty ¶
func (l *LocalCacheItem) TotalConfirmParty() int
TotalConfirmParty number of parties that already confirmed their hash
func (*LocalCacheItem) UpdateConfirmList ¶
func (l *LocalCacheItem) UpdateConfirmList(P2PID, hash string)
UpdateConfirmList add the given party's hash into the confirm list
type TssCommon ¶
type TssCommon struct { PartyIDtoP2PID map[string]peer.ID TssMsg chan *p2p.Message P2PPeersLock *sync.RWMutex P2PPeers []peer.ID // most of tss message are broadcast, we store the peers ID to avoid iterating // contains filtered or unexported fields }
func NewTssCommon ¶
func (*TssCommon) GetBlameMgr ¶
func (*TssCommon) GetLocalPeerID ¶
func (*TssCommon) GetTaskDone ¶
func (t *TssCommon) GetTaskDone() chan struct{}
func (*TssCommon) NotifyTaskDone ¶
func (*TssCommon) ProcessInboundMessages ¶
func (*TssCommon) ProcessOneMessage ¶
func (t *TssCommon) ProcessOneMessage(wrappedMsg *messages.WrappedMessage, peerID string) error
func (*TssCommon) ProcessOutCh ¶
func (*TssCommon) SetLocalPeerID ¶
func (*TssCommon) SetPartyInfo ¶
func (*TssCommon) TryGetAllLocalCached ¶
func (t *TssCommon) TryGetAllLocalCached() []*LocalCacheItem
func (*TssCommon) TryGetLocalCacheItem ¶
func (t *TssCommon) TryGetLocalCacheItem(key string) *LocalCacheItem
type TssConfig ¶
type TssConfig struct { // Party Timeout defines how long do we wait for the party to form PartyTimeout time.Duration // KeyGenTimeoutSeconds defines how long do we wait the keygen parties to pass messages along KeyGenTimeout time.Duration // KeySignTimeoutSeconds defines how long do we wait keysign KeySignTimeout time.Duration // Pre-parameter define the pre-parameter generations timeout PreParamTimeout time.Duration // enable the tss monitor EnableMonitor bool }
Click to show internal directories.
Click to hide internal directories.