p2p

Nov 9, 2022

Changes in this version

+ func SendEnvelopeShim(p Peer, e Envelope, lg log.Logger) bool

+ func TrySendEnvelopeShim(p Peer, e Envelope, lg log.Logger) bool

type BaseReactor

+ func (*BaseReactor) ReceiveEnvelope(e Envelope)

+ type Envelope struct

+ ChannelID byte

+ Message proto.Message

+ Src Peer

+ type EnvelopeReceiver interface

+ ReceiveEnvelope func(Envelope)

+ type EnvelopeSender interface

+ SendEnvelope func(Envelope) bool

+ TrySendEnvelope func(Envelope) bool

type Metrics

+ MessageReceiveBytesTotal metrics.Counter

+ MessageSendBytesTotal metrics.Counter

type Switch

+ func (sw *Switch) BroadcastEnvelope(e Envelope) chan bool

+ type Unwrapper interface

+ Unwrap func() (proto.Message, error)

+ type Wrapper interface

+ Wrap func() proto.Message

Oct 18, 2022

Changes in this version

+ type ErrPeerRemoval struct

+ func (e ErrPeerRemoval) Error() string

type Peer

+ GetRemovalFailed func() bool

+ SetRemovalFailed func()

Apr 14, 2021

Changes in this version

type DefaultNodeInfo

+ func (info DefaultNodeInfo) HasChannel(chID byte) bool

type MultiplexTransport

+ func (mt *MultiplexTransport) AddChannel(chID byte)

Jan 12, 2021 GO-2022-1052

  GO-2022-1052: Uncontrolled resource consumption during consensus in github.com/tendermint/tendermint

Jan 6, 2021 GO-2022-1052

  GO-2022-1052: Uncontrolled resource consumption during consensus in github.com/tendermint/tendermint

Dec 23, 2020 GO-2022-1052

  GO-2022-1052: Uncontrolled resource consumption during consensus in github.com/tendermint/tendermint

Dec 10, 2020 GO-2022-1052

  GO-2022-1052: Uncontrolled resource consumption during consensus in github.com/tendermint/tendermint

Nov 19, 2020 GO-2022-1052

  GO-2022-1052: Uncontrolled resource consumption during consensus in github.com/tendermint/tendermint

Changes in this version

+ const EmptyNetAddress

+ func NetAddressesToProto(nas []*NetAddress) []tmp2p.NetAddress

type AddrBook

+ AddPrivateIDs func([]string)

+ type AddrBookMock struct

+ Addrs map[string]struct{}

+ OurAddrs map[string]struct{}

+ PrivateAddrs map[string]struct{}

+ func (book *AddrBookMock) AddAddress(addr *NetAddress, src *NetAddress) error

+ func (book *AddrBookMock) AddOurAddress(addr *NetAddress)

+ func (book *AddrBookMock) AddPrivateIDs(addrs []string)

+ func (book *AddrBookMock) HasAddress(addr *NetAddress) bool

+ func (book *AddrBookMock) MarkGood(ID)

+ func (book *AddrBookMock) OurAddress(addr *NetAddress) bool

+ func (book *AddrBookMock) RemoveAddress(addr *NetAddress)

+ func (book *AddrBookMock) Save()

type DefaultNodeInfo

+ func DefaultNodeInfoFromToProto(pb *tmp2p.DefaultNodeInfo) (DefaultNodeInfo, error)

+ func (info DefaultNodeInfo) ToProto() *tmp2p.DefaultNodeInfo

type NetAddress

+ func NetAddressFromProto(pb tmp2p.NetAddress) (*NetAddress, error)

+ func NetAddressesFromProto(pbs []tmp2p.NetAddress) ([]*NetAddress, error)

+ func (na *NetAddress) ToProto() tmp2p.NetAddress

type NodeKey

+ func (nodeKey *NodeKey) SaveAs(filePath string) error

type Switch

+ func (sw *Switch) AddPrivatePeerIDs(ids []string) error

Jun 24, 2020 GO-2021-0090

  GO-2021-0090: Denial of service in github.com/tendermint/tendermint

Nov 16, 2020 GO-2021-0090

  GO-2021-0090: Denial of service in github.com/tendermint/tendermint

Aug 11, 2020 GO-2021-0090

  GO-2021-0090: Denial of service in github.com/tendermint/tendermint

Aug 4, 2020 GO-2021-0090

  GO-2021-0090: Denial of service in github.com/tendermint/tendermint

Jul 2, 2020 GO-2021-0090

  GO-2021-0090: Denial of service in github.com/tendermint/tendermint

May 28, 2020 GO-2021-0090

  GO-2021-0090: Denial of service in github.com/tendermint/tendermint

Apr 21, 2020 GO-2021-0090

  GO-2021-0090: Denial of service in github.com/tendermint/tendermint

Apr 9, 2020 GO-2021-0090

  GO-2021-0090: Denial of service in github.com/tendermint/tendermint

Mar 11, 2020 GO-2021-0090

  GO-2021-0090: Denial of service in github.com/tendermint/tendermint

Feb 14, 2020 GO-2021-0090

  GO-2021-0090: Denial of service in github.com/tendermint/tendermint

Mar 9, 2020 GO-2021-0090

  GO-2021-0090: Denial of service in github.com/tendermint/tendermint

Feb 27, 2020 GO-2021-0090

  GO-2021-0090: Denial of service in github.com/tendermint/tendermint

Feb 26, 2020 GO-2021-0090

  GO-2021-0090: Denial of service in github.com/tendermint/tendermint

Feb 7, 2020 GO-2021-0090

  GO-2021-0090: Denial of service in github.com/tendermint/tendermint

Jan 15, 2020 GO-2021-0090

  GO-2021-0090: Denial of service in github.com/tendermint/tendermint

Changes in this version

+ const TestHost

type DefaultNodeInfo

+ DefaultNodeID ID

type Switch

+ func (sw *Switch) AddUnconditionalPeerIDs(ids []string) error

+ func (sw *Switch) IsPeerPersistent(na *NetAddress) bool

+ func (sw *Switch) IsPeerUnconditional(id ID) bool

May 19, 2020

Changes in this version

type NetAddress

+ func (na *NetAddress) OnionCatTor() bool

Aug 1, 2019

Changes in this version

type Switch

+ func (sw *Switch) RemoveReactor(name string, reactor Reactor)

Apr 9, 2020

Changes in this version

type MultiplexTransportOption

+ func MultiplexTransportMaxIncomingConnections(n int) MultiplexTransportOption

May 30, 2019

Changes in this version

+ const PeerBehaviourBadMessage

+ const PeerBehaviourBlockPart

+ const PeerBehaviourMessageOutOfOrder

+ const PeerBehaviourVote

+ func AddPeerToSwitchPeerSet(sw *Switch, peer Peer)

type BaseReactor

+ func (*BaseReactor) InitPeer(peer Peer) Peer

+ type MockPeerBehaviourReporter struct

+ func NewMockPeerBehaviourReporter() *MockPeerBehaviourReporter

+ func (mpbr *MockPeerBehaviourReporter) GetBehaviours(peerID ID) []PeerBehaviour

+ func (mpbr *MockPeerBehaviourReporter) Report(peerID ID, behaviour PeerBehaviour)

+ type PeerBehaviour int

+ type PeerBehaviourReporter interface

+ Report func(peerID ID, behaviour PeerBehaviour) error

type Reactor

+ InitPeer func(peer Peer) Peer

type Switch

+ func (sw *Switch) AddPersistentPeers(addrs []string) error

+ type SwitchPeerBehaviourReporter struct

+ func NewSwitchPeerBehaviourReporter(sw *Switch) *SwitchPeerBehaviourReporter

+ func (spbr *SwitchPeerBehaviourReporter) Report(peerID ID, behaviour PeerBehaviour) error

Apr 12, 2019

Changes in this version

+ type ErrCurrentlyDialingOrExistingAddress struct

+ Addr string

+ func (e ErrCurrentlyDialingOrExistingAddress) Error() string

Mar 19, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Mar 14, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Apr 3, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Feb 28, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Apr 16, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Apr 2, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Changes in this version

type MultiplexTransport

+ func (mt *MultiplexTransport) NetAddress() NetAddress

type Peer

+ SocketAddr func() *NetAddress

type Switch

+ func (sw *Switch) NetAddress() *NetAddress

type Transport

+ NetAddress func() NetAddress

Mar 11, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Feb 20, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Feb 9, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Feb 8, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Feb 8, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Feb 8, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Feb 8, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Feb 8, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jan 24, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jan 24, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jan 22, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jan 22, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jan 19, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jan 18, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jan 18, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jan 16, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jan 10, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jan 13, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jan 13, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Dec 21, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Dec 16, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Dec 16, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Dec 16, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Dec 5, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Dec 5, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Dec 5, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Nov 29, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Nov 28, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Nov 27, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Nov 17, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Nov 15, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Nov 15, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Nov 12, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Nov 10, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Nov 9, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Nov 7, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Nov 6, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Nov 3, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Changes in this version

type DefaultNodeInfo

+ func (info DefaultNodeInfo) ValidateBasic() error

Nov 1, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Oct 29, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Oct 15, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Oct 18, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Sep 23, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Changes in this version

+ type NodeInfoOther struct

+ AminoVersion string

+ ConsensusVersion string

+ P2PVersion string

+ RPCAddress string

+ RPCVersion string

+ TxIndex string

+ func (o NodeInfoOther) String() string

Sep 7, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Sep 5, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Aug 31, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Aug 22, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Aug 5, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jul 27, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jul 27, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jul 27, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jul 26, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jul 25, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jul 25, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jul 24, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jul 14, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jul 14, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jul 10, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jul 10, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jul 10, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jul 10, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jul 2, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Changes in this version

type DefaultListener

+ func (l *DefaultListener) ExternalAddressHost() string

type Listener

+ ExternalAddressHost func() string

Jul 2, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jul 1, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jul 1, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jul 4, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jun 27, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jun 22, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jun 21, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jun 15, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jun 19, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jun 7, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jun 3, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jun 2, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jun 1, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

May 31, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jun 6, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jun 6, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jun 4, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

May 31, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

May 31, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

May 29, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

May 29, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

May 25, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

May 24, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

May 21, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

May 20, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

May 20, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

May 17, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

May 15, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

May 14, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Apr 30, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Changes in this version

+ const DefaultMinNumOutboundPeers

type PeerConfig

+ DialFail bool

Apr 30, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Apr 28, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Apr 17, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Apr 9, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Apr 9, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Apr 6, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Apr 5, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Apr 6, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Mar 27, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Mar 27, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Changes in this version

type Switch

+ func (sw *Switch) FilterConnByID(id ID) error

+ func (sw *Switch) SetIDFilter(f func(ID) error)

Feb 21, 2018 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Changes in this version

type NodeInfo

+ Channels []byte

+ func (info NodeInfo) ID() ID

+ func (info NodeInfo) NetAddress() *NetAddress

+ func (info NodeInfo) Validate(pubKey crypto.PubKey) error

Dec 29, 2017 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Changes in this version

type Channel

+ Logger log.Logger

+ func (ch *Channel) SetLogger(l log.Logger)

type MConnection

+ func (c *MConnection) SetLogger(l log.Logger)

Dec 12, 2017 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Dec 6, 2017 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Nov 28, 2017 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Oct 28, 2017 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Oct 10, 2017 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Sep 22, 2017 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Nov 1, 2017 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Sep 5, 2017 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Aug 10, 2017 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jul 10, 2017 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jun 28, 2017 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Jun 3, 2017 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Changes in this version

+ const FuzzModeDelay

+ const FuzzModeDrop

+ const PexChannel

+ const Version

+ var ErrSwitchDuplicatePeer = errors.New("Duplicate peer")

+ var PanicOnAddPeerErr = false

+ func AddToIPRangeCounts(counts map[string]int, ip string) map[string]int

+ func CheckIPRangeCounts(counts map[string]int, limits []int) bool

type AddrBook

+ func NewAddrBook(filePath string, routabilityStrict bool) *AddrBook

+ func (a *AddrBook) GetSelection() []*NetAddress

+ func (a *AddrBook) MarkAttempt(addr *NetAddress)

+ func (a *AddrBook) MarkBad(addr *NetAddress)

+ func (a *AddrBook) NeedMoreAddrs() bool

+ func (a *AddrBook) OnStart() error

+ func (a *AddrBook) OnStop()

+ func (a *AddrBook) OurAddresses() []*NetAddress

+ func (a *AddrBook) PickAddress(newBias int) *NetAddress

+ func (a *AddrBook) Size() int

+ func (a *AddrBook) Wait()

+ type Channel struct

type ChannelDescriptor

+ ID byte

+ Priority int

+ RecvBufferCapacity int

+ RecvMessageCapacity int

+ SendQueueCapacity int

+ func (chDesc *ChannelDescriptor) FillDefaults()

+ type ChannelStatus struct

+ ID byte

+ Priority int

+ RecentlySent int64

+ SendQueueCapacity int

+ SendQueueSize int

type ConnectionStatus

+ Channels []ChannelStatus

+ RecvMonitor flow.Status

+ SendMonitor flow.Status

+ type DefaultListener struct

+ func (l *DefaultListener) Connections() <-chan net.Conn

+ func (l *DefaultListener) ExternalAddress() *NetAddress

+ func (l *DefaultListener) InternalAddress() *NetAddress

+ func (l *DefaultListener) NetListener() net.Listener

+ func (l *DefaultListener) OnStart() error

+ func (l *DefaultListener) OnStop()

+ func (l *DefaultListener) String() string

+ type FuzzConnConfig struct

+ MaxDelay time.Duration

+ Mode int

+ ProbDropConn float64

+ ProbDropRW float64

+ ProbSleep float64

+ func DefaultFuzzConnConfig() *FuzzConnConfig

+ type Listener interface

+ Connections func() <-chan net.Conn

+ ExternalAddress func() *NetAddress

+ InternalAddress func() *NetAddress

+ Stop func() bool

+ String func() string

+ func NewDefaultListener(protocol string, lAddr string, skipUPNP bool, logger log.Logger) Listener

type MConnConfig

+ RecvRate int64

+ SendRate int64

+ func DefaultMConnConfig() *MConnConfig

+ type MConnection struct

+ LocalAddress *NetAddress

+ RemoteAddress *NetAddress

+ func NewMConnection(conn net.Conn, chDescs []*ChannelDescriptor, onReceive receiveCbFunc, ...) *MConnection

+ func NewMConnectionWithConfig(conn net.Conn, chDescs []*ChannelDescriptor, onReceive receiveCbFunc, ...) *MConnection

+ func (c *MConnection) CanSend(chID byte) bool

+ func (c *MConnection) OnStart() error

+ func (c *MConnection) OnStop()

+ func (c *MConnection) Send(chID byte, msg interface{}) bool

+ func (c *MConnection) Status() ConnectionStatus

+ func (c *MConnection) String() string

+ func (c *MConnection) TrySend(chID byte, msg interface{}) bool

type NetAddress

+ func (na *NetAddress) Less(other interface{}) bool

type NodeInfo

+ ListenAddr string

+ Moniker string

+ Network string

+ Other []string

+ PubKey crypto.PubKeyEd25519

+ RemoteAddr string

+ Version string

+ func (info *NodeInfo) CompatibleWith(other *NodeInfo) error

+ func (info *NodeInfo) ListenHost() string

+ func (info *NodeInfo) ListenPort() int

+ func (info NodeInfo) String() string

+ type PEXReactor struct

+ func NewPEXReactor(b *AddrBook) *PEXReactor

+ func (r *PEXReactor) AddPeer(p *Peer)

+ func (r *PEXReactor) GetChannels() []*ChannelDescriptor

+ func (r *PEXReactor) IncrementMsgCountForPeer(addr string)

+ func (r *PEXReactor) OnStart() error

+ func (r *PEXReactor) OnStop()

+ func (r *PEXReactor) ReachedMaxMsgCountForPeer(addr string) bool

+ func (r *PEXReactor) Receive(chID byte, src *Peer, msgBytes []byte)

+ func (r *PEXReactor) RemovePeer(p *Peer, reason interface{})

+ func (r *PEXReactor) RequestPEX(p *Peer)

+ func (r *PEXReactor) SendAddrs(p *Peer, addrs []*NetAddress)

+ func (r *PEXReactor) SetEnsurePeersPeriod(d time.Duration)

+ func (r *PEXReactor) SetMaxMsgCountByPeer(v uint16)

type Peer

+ Data *cmn.CMap

+ Key string

+ func (p *Peer) Addr() net.Addr

+ func (p *Peer) CanSend(chID byte) bool

+ func (p *Peer) Connection() *MConnection

+ func (p *Peer) Equals(other *Peer) bool

+ func (p *Peer) HandshakeTimeout(ourNodeInfo *NodeInfo, timeout time.Duration) error

+ func (p *Peer) OnStart() error

+ func (p *Peer) OnStop()

+ func (p *Peer) PubKey() crypto.PubKeyEd25519

+ func (p *Peer) String() string

+ func (p *Peer) WriteTo(w io.Writer) (n int64, err error)

+ type PeerConfig struct

+ AuthEnc bool

+ DialTimeout time.Duration

+ Fuzz bool

+ FuzzConfig *FuzzConnConfig

+ HandshakeTimeout time.Duration

+ MConfig *MConnConfig

+ func DefaultPeerConfig() *PeerConfig

+ type PexMessage interface

+ func DecodeMessage(bz []byte) (msgType byte, msg PexMessage, err error)

+ type SecretConnection struct

+ func MakeSecretConnection(conn io.ReadWriteCloser, locPrivKey crypto.PrivKeyEd25519) (*SecretConnection, error)

+ func (sc *SecretConnection) Close() error

+ func (sc *SecretConnection) LocalAddr() net.Addr

+ func (sc *SecretConnection) Read(data []byte) (n int, err error)

+ func (sc *SecretConnection) RemoteAddr() net.Addr

+ func (sc *SecretConnection) RemotePubKey() crypto.PubKeyEd25519

+ func (sc *SecretConnection) SetDeadline(t time.Time) error

+ func (sc *SecretConnection) SetReadDeadline(t time.Time) error

+ func (sc *SecretConnection) SetWriteDeadline(t time.Time) error

+ func (sc *SecretConnection) Write(data []byte) (n int, err error)

type Switch

+ func (sw *Switch) AddListener(l Listener)

+ func (sw *Switch) AddPeer(peer *Peer) error

+ func (sw *Switch) DialSeeds(addrBook *AddrBook, seeds []string) error

+ func (sw *Switch) FilterConnByAddr(addr net.Addr) error

+ func (sw *Switch) FilterConnByPubKey(pubkey crypto.PubKeyEd25519) error

+ func (sw *Switch) IsDialing(addr *NetAddress) bool

+ func (sw *Switch) IsListening() bool

+ func (sw *Switch) Listeners() []Listener

+ func (sw *Switch) SetAddrFilter(f func(net.Addr) error)

+ func (sw *Switch) SetNodePrivKey(nodePrivKey crypto.PrivKeyEd25519)

+ func (sw *Switch) SetPubKeyFilter(f func(crypto.PubKeyEd25519) error)

+ type SwitchEventDonePeer struct

+ Error interface{}

+ Peer *Peer

+ type SwitchEventNewPeer struct

+ Peer *Peer

May 29, 2017 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

May 18, 2017 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Mar 19, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Mar 19, 2019 GO-2020-0037

  GO-2020-0037: Uncontrolled resource consumption in github.com/tendermint/tendermint

Changes in this version

+ const IDByteLength

+ const MetricsSubsystem

+ const TEST_HOST

+ func AddPeerToSwitch(sw *Switch, peer Peer)

+ func Connect2Switches(switches []*Switch, i, j int)

+ func CreateRandomPeer(outbound bool) *peer

+ func FuzzConn(conn net.Conn) net.Conn

+ func FuzzConnAfter(conn net.Conn, d time.Duration) net.Conn

+ func FuzzConnAfterFromConfig(conn net.Conn, d time.Duration, config *config.FuzzConnConfig) net.Conn

+ func FuzzConnFromConfig(conn net.Conn, config *config.FuzzConnConfig) net.Conn

+ func IDAddressString(id ID, protocolHostPort string) string

+ func MConnConfig(cfg *config.P2PConfig) conn.MConnConfig

+ func MakePoWTarget(difficulty, targetBits uint) []byte

+ func MaxNodeInfoSize() int

+ func NewConnSet() *connSet

+ func StartSwitches(switches []*Switch) error

+ type AddrBook interface

+ AddAddress func(addr *NetAddress, src *NetAddress) error

+ AddOurAddress func(*NetAddress)

+ HasAddress func(*NetAddress) bool

+ MarkGood func(*NetAddress)

+ OurAddress func(*NetAddress) bool

+ RemoveAddress func(*NetAddress)

+ Save func()

+ type BaseReactor struct

+ Switch *Switch

+ func NewBaseReactor(name string, impl Reactor) *BaseReactor

+ func (*BaseReactor) AddPeer(peer Peer)

+ func (*BaseReactor) GetChannels() []*conn.ChannelDescriptor

+ func (*BaseReactor) Receive(chID byte, peer Peer, msgBytes []byte)

+ func (*BaseReactor) RemovePeer(peer Peer, reason interface{})

+ func (br *BaseReactor) SetSwitch(sw *Switch)

+ type ChannelDescriptor = conn.ChannelDescriptor

+ type ConnFilterFunc func(ConnSet, net.Conn, []net.IP) error

+ func ConnDuplicateIPFilter() ConnFilterFunc

+ type ConnSet interface

+ Has func(net.Conn) bool

+ HasIP func(net.IP) bool

+ Remove func(net.Conn)

+ RemoveAddr func(net.Addr)

+ Set func(net.Conn, []net.IP)

+ type ConnectionStatus = conn.ConnectionStatus

+ type DefaultNodeInfo struct

+ Channels cmn.HexBytes

+ ID_ ID

+ ListenAddr string

+ Moniker string

+ Network string

+ Other DefaultNodeInfoOther

+ ProtocolVersion ProtocolVersion

+ Version string

+ func (info *DefaultNodeInfo) Marshal() ([]byte, error)

+ func (info *DefaultNodeInfo) MarshalTo(data []byte) (int, error)

+ func (info *DefaultNodeInfo) Size() int

+ func (info *DefaultNodeInfo) Unmarshal(bs []byte) error

+ func (info DefaultNodeInfo) CompatibleWith(other_ NodeInfo) error

+ func (info DefaultNodeInfo) ID() ID

+ func (info DefaultNodeInfo) NetAddress() *NetAddress

+ func (info DefaultNodeInfo) Validate() error

+ type DefaultNodeInfoOther struct

+ RPCAddress string

+ TxIndex string

+ type ErrFilterTimeout struct

+ func (e ErrFilterTimeout) Error() string

+ type ErrNetAddressInvalid struct

+ Addr string

+ Err error

+ func (e ErrNetAddressInvalid) Error() string

+ type ErrNetAddressLookup struct

+ Addr string

+ Err error

+ func (e ErrNetAddressLookup) Error() string

+ type ErrNetAddressNoID struct

+ Addr string

+ func (e ErrNetAddressNoID) Error() string

+ type ErrRejected struct

+ func (e ErrRejected) Addr() NetAddress

+ func (e ErrRejected) Error() string

+ func (e ErrRejected) IsAuthFailure() bool

+ func (e ErrRejected) IsDuplicate() bool

+ func (e ErrRejected) IsFiltered() bool

+ func (e ErrRejected) IsIncompatible() bool

+ func (e ErrRejected) IsNodeInfoInvalid() bool

+ func (e ErrRejected) IsSelf() bool

+ type ErrSwitchAuthenticationFailure struct

+ Dialed *NetAddress

+ Got ID

+ func (e ErrSwitchAuthenticationFailure) Error() string

+ type ErrSwitchConnectToSelf struct

+ Addr *NetAddress

+ func (e ErrSwitchConnectToSelf) Error() string

+ type ErrSwitchDuplicatePeerID struct

+ ID ID

+ func (e ErrSwitchDuplicatePeerID) Error() string

+ type ErrSwitchDuplicatePeerIP struct

+ IP net.IP

+ func (e ErrSwitchDuplicatePeerIP) Error() string

+ type ErrTransportClosed struct

+ func (e ErrTransportClosed) Error() string

+ type FuzzedConnection struct

+ func (fc *FuzzedConnection) Close() error

+ func (fc *FuzzedConnection) Config() *config.FuzzConnConfig

+ func (fc *FuzzedConnection) LocalAddr() net.Addr

+ func (fc *FuzzedConnection) Read(data []byte) (n int, err error)

+ func (fc *FuzzedConnection) RemoteAddr() net.Addr

+ func (fc *FuzzedConnection) SetDeadline(t time.Time) error

+ func (fc *FuzzedConnection) SetReadDeadline(t time.Time) error

+ func (fc *FuzzedConnection) SetWriteDeadline(t time.Time) error

+ func (fc *FuzzedConnection) Write(data []byte) (n int, err error)

+ type ID string

+ func PubKeyToID(pubKey crypto.PubKey) ID

+ type IPResolver interface

+ LookupIPAddr func(context.Context, string) ([]net.IPAddr, error)

+ type IPeerSet interface

+ Get func(key ID) Peer

+ Has func(key ID) bool

+ HasIP func(ip net.IP) bool

+ List func() []Peer

+ Size func() int

+ type Metrics struct

+ NumTxs metrics.Gauge

+ PeerPendingSendBytes metrics.Gauge

+ PeerReceiveBytesTotal metrics.Counter

+ PeerSendBytesTotal metrics.Counter

+ Peers metrics.Gauge

+ func NopMetrics() *Metrics

+ func PrometheusMetrics(namespace string, labelsAndValues ...string) *Metrics

+ type MultiplexTransport struct

+ func NewMultiplexTransport(nodeInfo NodeInfo, nodeKey NodeKey, mConfig conn.MConnConfig) *MultiplexTransport

+ func (mt *MultiplexTransport) Accept(cfg peerConfig) (Peer, error)

+ func (mt *MultiplexTransport) Cleanup(p Peer)

+ func (mt *MultiplexTransport) Close() error

+ func (mt *MultiplexTransport) Dial(addr NetAddress, cfg peerConfig) (Peer, error)

+ func (mt *MultiplexTransport) Listen(addr NetAddress) error

+ type MultiplexTransportOption func(*MultiplexTransport)

+ func MultiplexTransportConnFilters(filters ...ConnFilterFunc) MultiplexTransportOption

+ func MultiplexTransportFilterTimeout(timeout time.Duration) MultiplexTransportOption

+ func MultiplexTransportResolver(resolver IPResolver) MultiplexTransportOption

+ type NetAddress struct

+ ID ID

+ IP net.IP

+ Port uint16

+ func CreateRoutableAddr() (addr string, netAddr *NetAddress)

+ func NewNetAddress(id ID, addr net.Addr) *NetAddress

+ func NewNetAddressIPPort(ip net.IP, port uint16) *NetAddress

+ func NewNetAddressString(addr string) (*NetAddress, error)

+ func NewNetAddressStringWithOptionalID(addr string) (*NetAddress, error)

+ func NewNetAddressStrings(addrs []string) ([]*NetAddress, []error)

+ func (na *NetAddress) Dial() (net.Conn, error)

+ func (na *NetAddress) DialString() string

+ func (na *NetAddress) DialTimeout(timeout time.Duration) (net.Conn, error)

+ func (na *NetAddress) Equals(other interface{}) bool

+ func (na *NetAddress) HasID() bool

+ func (na *NetAddress) Local() bool

+ func (na *NetAddress) RFC1918() bool

+ func (na *NetAddress) RFC3849() bool

+ func (na *NetAddress) RFC3927() bool

+ func (na *NetAddress) RFC3964() bool

+ func (na *NetAddress) RFC4193() bool

+ func (na *NetAddress) RFC4380() bool

+ func (na *NetAddress) RFC4843() bool

+ func (na *NetAddress) RFC4862() bool

+ func (na *NetAddress) RFC6052() bool

+ func (na *NetAddress) RFC6145() bool

+ func (na *NetAddress) ReachabilityTo(o *NetAddress) int

+ func (na *NetAddress) Routable() bool

+ func (na *NetAddress) Same(other interface{}) bool

+ func (na *NetAddress) String() string

+ func (na *NetAddress) Valid() bool

+ type NodeInfo interface

+ type NodeKey struct

+ PrivKey crypto.PrivKey

+ func LoadNodeKey(filePath string) (*NodeKey, error)

+ func LoadOrGenNodeKey(filePath string) (*NodeKey, error)

+ func (nodeKey *NodeKey) ID() ID

+ func (nodeKey *NodeKey) PubKey() crypto.PubKey

+ type Peer interface

+ CloseConn func() error

+ FlushStop func()

+ Get func(string) interface{}

+ ID func() ID

+ IsOutbound func() bool

+ IsPersistent func() bool

+ NodeInfo func() NodeInfo

+ OriginalAddr func() *NetAddress

+ RemoteAddr func() net.Addr

+ RemoteIP func() net.IP

+ Send func(byte, []byte) bool

+ Set func(string, interface{})

+ Status func() tmconn.ConnectionStatus

+ TrySend func(byte, []byte) bool

+ type PeerFilterFunc func(IPeerSet, Peer) error

+ type PeerOption func(*peer)

+ func PeerMetrics(metrics *Metrics) PeerOption

+ type PeerSet struct

+ func NewPeerSet() *PeerSet

+ func (ps *PeerSet) Add(peer Peer) error

+ func (ps *PeerSet) Get(peerKey ID) Peer

+ func (ps *PeerSet) Has(peerKey ID) bool

+ func (ps *PeerSet) HasIP(peerIP net.IP) bool

+ func (ps *PeerSet) List() []Peer

+ func (ps *PeerSet) Remove(peer Peer) bool

+ func (ps *PeerSet) Size() int

+ type ProtocolVersion struct

+ App version.Protocol

+ Block version.Protocol

+ P2P version.Protocol

+ func NewProtocolVersion(p2p, block, app version.Protocol) ProtocolVersion

+ type Reactor interface

+ AddPeer func(peer Peer)

+ GetChannels func() []*conn.ChannelDescriptor

+ Receive func(chID byte, peer Peer, msgBytes []byte)

+ RemovePeer func(peer Peer, reason interface{})

+ SetSwitch func(*Switch)

+ type Switch struct

+ func MakeConnectedSwitches(cfg *config.P2PConfig, n int, initSwitch func(int, *Switch) *Switch, ...) []*Switch

+ func MakeSwitch(cfg *config.P2PConfig, i int, network, version string, ...) *Switch

+ func NewSwitch(cfg *config.P2PConfig, transport Transport, options ...SwitchOption) *Switch

+ func (sw *Switch) AddReactor(name string, reactor Reactor) Reactor

+ func (sw *Switch) Broadcast(chID byte, msgBytes []byte) chan bool

+ func (sw *Switch) DialPeerWithAddress(addr *NetAddress, persistent bool) error

+ func (sw *Switch) DialPeersAsync(addrBook AddrBook, peers []string, persistent bool) error

+ func (sw *Switch) IsDialingOrExistingAddress(addr *NetAddress) bool

+ func (sw *Switch) MarkPeerAsGood(peer Peer)

+ func (sw *Switch) MaxNumOutboundPeers() int

+ func (sw *Switch) NodeInfo() NodeInfo

+ func (sw *Switch) NumPeers() (outbound, inbound, dialing int)

+ func (sw *Switch) OnStart() error

+ func (sw *Switch) OnStop()

+ func (sw *Switch) Peers() IPeerSet

+ func (sw *Switch) Reactor(name string) Reactor

+ func (sw *Switch) Reactors() map[string]Reactor

+ func (sw *Switch) SetAddrBook(addrBook AddrBook)

+ func (sw *Switch) SetNodeInfo(nodeInfo NodeInfo)

+ func (sw *Switch) SetNodeKey(nodeKey *NodeKey)

+ func (sw *Switch) StopPeerForError(peer Peer, reason interface{})

+ func (sw *Switch) StopPeerGracefully(peer Peer)

+ type SwitchOption func(*Switch)

+ func SwitchFilterTimeout(timeout time.Duration) SwitchOption

+ func SwitchPeerFilters(filters ...PeerFilterFunc) SwitchOption

+ func WithMetrics(metrics *Metrics) SwitchOption

+ type Transport interface

+ Accept func(peerConfig) (Peer, error)

+ Cleanup func(Peer)

+ Dial func(NetAddress, peerConfig) (Peer, error)