1 Star 0 Fork 0

peter/fabric

加入 Gitee
与超过 1400万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
gossip.go 24.94 KB
一键复制 编辑 原始数据 按行查看 历史
yacovm 提交于 2017-12-25 06:54 +08:00 . [FAB-7551] Peer support for discovery service
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804
// Code generated by counterfeiter. DO NOT EDIT.
package mocks
import (
"sync"
"github.com/hyperledger/fabric/gossip/api"
"github.com/hyperledger/fabric/gossip/comm"
"github.com/hyperledger/fabric/gossip/common"
"github.com/hyperledger/fabric/gossip/discovery"
"github.com/hyperledger/fabric/gossip/filter"
"github.com/hyperledger/fabric/gossip/gossip"
proto "github.com/hyperledger/fabric/protos/gossip"
)
type Gossip struct {
SelfMembershipInfoStub func() discovery.NetworkMember
selfMembershipInfoMutex sync.RWMutex
selfMembershipInfoArgsForCall []struct{}
selfMembershipInfoReturns struct {
result1 discovery.NetworkMember
}
selfMembershipInfoReturnsOnCall map[int]struct {
result1 discovery.NetworkMember
}
SelfChannelInfoStub func(common.ChainID) *proto.SignedGossipMessage
selfChannelInfoMutex sync.RWMutex
selfChannelInfoArgsForCall []struct {
arg1 common.ChainID
}
selfChannelInfoReturns struct {
result1 *proto.SignedGossipMessage
}
selfChannelInfoReturnsOnCall map[int]struct {
result1 *proto.SignedGossipMessage
}
SendStub func(msg *proto.GossipMessage, peers ...*comm.RemotePeer)
sendMutex sync.RWMutex
sendArgsForCall []struct {
msg *proto.GossipMessage
peers []*comm.RemotePeer
}
SendByCriteriaStub func(*proto.SignedGossipMessage, gossip.SendCriteria) error
sendByCriteriaMutex sync.RWMutex
sendByCriteriaArgsForCall []struct {
arg1 *proto.SignedGossipMessage
arg2 gossip.SendCriteria
}
sendByCriteriaReturns struct {
result1 error
}
sendByCriteriaReturnsOnCall map[int]struct {
result1 error
}
PeersStub func() []discovery.NetworkMember
peersMutex sync.RWMutex
peersArgsForCall []struct{}
peersReturns struct {
result1 []discovery.NetworkMember
}
peersReturnsOnCall map[int]struct {
result1 []discovery.NetworkMember
}
PeersOfChannelStub func(common.ChainID) []discovery.NetworkMember
peersOfChannelMutex sync.RWMutex
peersOfChannelArgsForCall []struct {
arg1 common.ChainID
}
peersOfChannelReturns struct {
result1 []discovery.NetworkMember
}
peersOfChannelReturnsOnCall map[int]struct {
result1 []discovery.NetworkMember
}
UpdateMetadataStub func(metadata []byte)
updateMetadataMutex sync.RWMutex
updateMetadataArgsForCall []struct {
metadata []byte
}
UpdateLedgerHeightStub func(height uint64, chainID common.ChainID)
updateLedgerHeightMutex sync.RWMutex
updateLedgerHeightArgsForCall []struct {
height uint64
chainID common.ChainID
}
UpdateChaincodesStub func(chaincode []*proto.Chaincode, chainID common.ChainID)
updateChaincodesMutex sync.RWMutex
updateChaincodesArgsForCall []struct {
chaincode []*proto.Chaincode
chainID common.ChainID
}
GossipStub func(msg *proto.GossipMessage)
gossipMutex sync.RWMutex
gossipArgsForCall []struct {
msg *proto.GossipMessage
}
PeerFilterStub func(channel common.ChainID, messagePredicate api.SubChannelSelectionCriteria) (filter.RoutingFilter, error)
peerFilterMutex sync.RWMutex
peerFilterArgsForCall []struct {
channel common.ChainID
messagePredicate api.SubChannelSelectionCriteria
}
peerFilterReturns struct {
result1 filter.RoutingFilter
result2 error
}
peerFilterReturnsOnCall map[int]struct {
result1 filter.RoutingFilter
result2 error
}
AcceptStub func(acceptor common.MessageAcceptor, passThrough bool) (<-chan *proto.GossipMessage, <-chan proto.ReceivedMessage)
acceptMutex sync.RWMutex
acceptArgsForCall []struct {
acceptor common.MessageAcceptor
passThrough bool
}
acceptReturns struct {
result1 <-chan *proto.GossipMessage
result2 <-chan proto.ReceivedMessage
}
acceptReturnsOnCall map[int]struct {
result1 <-chan *proto.GossipMessage
result2 <-chan proto.ReceivedMessage
}
JoinChanStub func(joinMsg api.JoinChannelMessage, chainID common.ChainID)
joinChanMutex sync.RWMutex
joinChanArgsForCall []struct {
joinMsg api.JoinChannelMessage
chainID common.ChainID
}
LeaveChanStub func(chainID common.ChainID)
leaveChanMutex sync.RWMutex
leaveChanArgsForCall []struct {
chainID common.ChainID
}
SuspectPeersStub func(s api.PeerSuspector)
suspectPeersMutex sync.RWMutex
suspectPeersArgsForCall []struct {
s api.PeerSuspector
}
IdentityInfoStub func() api.PeerIdentitySet
identityInfoMutex sync.RWMutex
identityInfoArgsForCall []struct{}
identityInfoReturns struct {
result1 api.PeerIdentitySet
}
identityInfoReturnsOnCall map[int]struct {
result1 api.PeerIdentitySet
}
StopStub func()
stopMutex sync.RWMutex
stopArgsForCall []struct{}
invocations map[string][][]interface{}
invocationsMutex sync.RWMutex
}
func (fake *Gossip) SelfMembershipInfo() discovery.NetworkMember {
fake.selfMembershipInfoMutex.Lock()
ret, specificReturn := fake.selfMembershipInfoReturnsOnCall[len(fake.selfMembershipInfoArgsForCall)]
fake.selfMembershipInfoArgsForCall = append(fake.selfMembershipInfoArgsForCall, struct{}{})
fake.recordInvocation("SelfMembershipInfo", []interface{}{})
fake.selfMembershipInfoMutex.Unlock()
if fake.SelfMembershipInfoStub != nil {
return fake.SelfMembershipInfoStub()
}
if specificReturn {
return ret.result1
}
return fake.selfMembershipInfoReturns.result1
}
func (fake *Gossip) SelfMembershipInfoCallCount() int {
fake.selfMembershipInfoMutex.RLock()
defer fake.selfMembershipInfoMutex.RUnlock()
return len(fake.selfMembershipInfoArgsForCall)
}
func (fake *Gossip) SelfMembershipInfoReturns(result1 discovery.NetworkMember) {
fake.SelfMembershipInfoStub = nil
fake.selfMembershipInfoReturns = struct {
result1 discovery.NetworkMember
}{result1}
}
func (fake *Gossip) SelfMembershipInfoReturnsOnCall(i int, result1 discovery.NetworkMember) {
fake.SelfMembershipInfoStub = nil
if fake.selfMembershipInfoReturnsOnCall == nil {
fake.selfMembershipInfoReturnsOnCall = make(map[int]struct {
result1 discovery.NetworkMember
})
}
fake.selfMembershipInfoReturnsOnCall[i] = struct {
result1 discovery.NetworkMember
}{result1}
}
func (fake *Gossip) SelfChannelInfo(arg1 common.ChainID) *proto.SignedGossipMessage {
fake.selfChannelInfoMutex.Lock()
ret, specificReturn := fake.selfChannelInfoReturnsOnCall[len(fake.selfChannelInfoArgsForCall)]
fake.selfChannelInfoArgsForCall = append(fake.selfChannelInfoArgsForCall, struct {
arg1 common.ChainID
}{arg1})
fake.recordInvocation("SelfChannelInfo", []interface{}{arg1})
fake.selfChannelInfoMutex.Unlock()
if fake.SelfChannelInfoStub != nil {
return fake.SelfChannelInfoStub(arg1)
}
if specificReturn {
return ret.result1
}
return fake.selfChannelInfoReturns.result1
}
func (fake *Gossip) SelfChannelInfoCallCount() int {
fake.selfChannelInfoMutex.RLock()
defer fake.selfChannelInfoMutex.RUnlock()
return len(fake.selfChannelInfoArgsForCall)
}
func (fake *Gossip) SelfChannelInfoArgsForCall(i int) common.ChainID {
fake.selfChannelInfoMutex.RLock()
defer fake.selfChannelInfoMutex.RUnlock()
return fake.selfChannelInfoArgsForCall[i].arg1
}
func (fake *Gossip) SelfChannelInfoReturns(result1 *proto.SignedGossipMessage) {
fake.SelfChannelInfoStub = nil
fake.selfChannelInfoReturns = struct {
result1 *proto.SignedGossipMessage
}{result1}
}
func (fake *Gossip) SelfChannelInfoReturnsOnCall(i int, result1 *proto.SignedGossipMessage) {
fake.SelfChannelInfoStub = nil
if fake.selfChannelInfoReturnsOnCall == nil {
fake.selfChannelInfoReturnsOnCall = make(map[int]struct {
result1 *proto.SignedGossipMessage
})
}
fake.selfChannelInfoReturnsOnCall[i] = struct {
result1 *proto.SignedGossipMessage
}{result1}
}
func (fake *Gossip) Send(msg *proto.GossipMessage, peers ...*comm.RemotePeer) {
fake.sendMutex.Lock()
fake.sendArgsForCall = append(fake.sendArgsForCall, struct {
msg *proto.GossipMessage
peers []*comm.RemotePeer
}{msg, peers})
fake.recordInvocation("Send", []interface{}{msg, peers})
fake.sendMutex.Unlock()
if fake.SendStub != nil {
fake.SendStub(msg, peers...)
}
}
func (fake *Gossip) SendCallCount() int {
fake.sendMutex.RLock()
defer fake.sendMutex.RUnlock()
return len(fake.sendArgsForCall)
}
func (fake *Gossip) SendArgsForCall(i int) (*proto.GossipMessage, []*comm.RemotePeer) {
fake.sendMutex.RLock()
defer fake.sendMutex.RUnlock()
return fake.sendArgsForCall[i].msg, fake.sendArgsForCall[i].peers
}
func (fake *Gossip) SendByCriteria(arg1 *proto.SignedGossipMessage, arg2 gossip.SendCriteria) error {
fake.sendByCriteriaMutex.Lock()
ret, specificReturn := fake.sendByCriteriaReturnsOnCall[len(fake.sendByCriteriaArgsForCall)]
fake.sendByCriteriaArgsForCall = append(fake.sendByCriteriaArgsForCall, struct {
arg1 *proto.SignedGossipMessage
arg2 gossip.SendCriteria
}{arg1, arg2})
fake.recordInvocation("SendByCriteria", []interface{}{arg1, arg2})
fake.sendByCriteriaMutex.Unlock()
if fake.SendByCriteriaStub != nil {
return fake.SendByCriteriaStub(arg1, arg2)
}
if specificReturn {
return ret.result1
}
return fake.sendByCriteriaReturns.result1
}
func (fake *Gossip) SendByCriteriaCallCount() int {
fake.sendByCriteriaMutex.RLock()
defer fake.sendByCriteriaMutex.RUnlock()
return len(fake.sendByCriteriaArgsForCall)
}
func (fake *Gossip) SendByCriteriaArgsForCall(i int) (*proto.SignedGossipMessage, gossip.SendCriteria) {
fake.sendByCriteriaMutex.RLock()
defer fake.sendByCriteriaMutex.RUnlock()
return fake.sendByCriteriaArgsForCall[i].arg1, fake.sendByCriteriaArgsForCall[i].arg2
}
func (fake *Gossip) SendByCriteriaReturns(result1 error) {
fake.SendByCriteriaStub = nil
fake.sendByCriteriaReturns = struct {
result1 error
}{result1}
}
func (fake *Gossip) SendByCriteriaReturnsOnCall(i int, result1 error) {
fake.SendByCriteriaStub = nil
if fake.sendByCriteriaReturnsOnCall == nil {
fake.sendByCriteriaReturnsOnCall = make(map[int]struct {
result1 error
})
}
fake.sendByCriteriaReturnsOnCall[i] = struct {
result1 error
}{result1}
}
func (fake *Gossip) Peers() []discovery.NetworkMember {
fake.peersMutex.Lock()
ret, specificReturn := fake.peersReturnsOnCall[len(fake.peersArgsForCall)]
fake.peersArgsForCall = append(fake.peersArgsForCall, struct{}{})
fake.recordInvocation("Peers", []interface{}{})
fake.peersMutex.Unlock()
if fake.PeersStub != nil {
return fake.PeersStub()
}
if specificReturn {
return ret.result1
}
return fake.peersReturns.result1
}
func (fake *Gossip) PeersCallCount() int {
fake.peersMutex.RLock()
defer fake.peersMutex.RUnlock()
return len(fake.peersArgsForCall)
}
func (fake *Gossip) PeersReturns(result1 []discovery.NetworkMember) {
fake.PeersStub = nil
fake.peersReturns = struct {
result1 []discovery.NetworkMember
}{result1}
}
func (fake *Gossip) PeersReturnsOnCall(i int, result1 []discovery.NetworkMember) {
fake.PeersStub = nil
if fake.peersReturnsOnCall == nil {
fake.peersReturnsOnCall = make(map[int]struct {
result1 []discovery.NetworkMember
})
}
fake.peersReturnsOnCall[i] = struct {
result1 []discovery.NetworkMember
}{result1}
}
func (fake *Gossip) PeersOfChannel(arg1 common.ChainID) []discovery.NetworkMember {
fake.peersOfChannelMutex.Lock()
ret, specificReturn := fake.peersOfChannelReturnsOnCall[len(fake.peersOfChannelArgsForCall)]
fake.peersOfChannelArgsForCall = append(fake.peersOfChannelArgsForCall, struct {
arg1 common.ChainID
}{arg1})
fake.recordInvocation("PeersOfChannel", []interface{}{arg1})
fake.peersOfChannelMutex.Unlock()
if fake.PeersOfChannelStub != nil {
return fake.PeersOfChannelStub(arg1)
}
if specificReturn {
return ret.result1
}
return fake.peersOfChannelReturns.result1
}
func (fake *Gossip) PeersOfChannelCallCount() int {
fake.peersOfChannelMutex.RLock()
defer fake.peersOfChannelMutex.RUnlock()
return len(fake.peersOfChannelArgsForCall)
}
func (fake *Gossip) PeersOfChannelArgsForCall(i int) common.ChainID {
fake.peersOfChannelMutex.RLock()
defer fake.peersOfChannelMutex.RUnlock()
return fake.peersOfChannelArgsForCall[i].arg1
}
func (fake *Gossip) PeersOfChannelReturns(result1 []discovery.NetworkMember) {
fake.PeersOfChannelStub = nil
fake.peersOfChannelReturns = struct {
result1 []discovery.NetworkMember
}{result1}
}
func (fake *Gossip) PeersOfChannelReturnsOnCall(i int, result1 []discovery.NetworkMember) {
fake.PeersOfChannelStub = nil
if fake.peersOfChannelReturnsOnCall == nil {
fake.peersOfChannelReturnsOnCall = make(map[int]struct {
result1 []discovery.NetworkMember
})
}
fake.peersOfChannelReturnsOnCall[i] = struct {
result1 []discovery.NetworkMember
}{result1}
}
func (fake *Gossip) UpdateMetadata(metadata []byte) {
var metadataCopy []byte
if metadata != nil {
metadataCopy = make([]byte, len(metadata))
copy(metadataCopy, metadata)
}
fake.updateMetadataMutex.Lock()
fake.updateMetadataArgsForCall = append(fake.updateMetadataArgsForCall, struct {
metadata []byte
}{metadataCopy})
fake.recordInvocation("UpdateMetadata", []interface{}{metadataCopy})
fake.updateMetadataMutex.Unlock()
if fake.UpdateMetadataStub != nil {
fake.UpdateMetadataStub(metadata)
}
}
func (fake *Gossip) UpdateMetadataCallCount() int {
fake.updateMetadataMutex.RLock()
defer fake.updateMetadataMutex.RUnlock()
return len(fake.updateMetadataArgsForCall)
}
func (fake *Gossip) UpdateMetadataArgsForCall(i int) []byte {
fake.updateMetadataMutex.RLock()
defer fake.updateMetadataMutex.RUnlock()
return fake.updateMetadataArgsForCall[i].metadata
}
func (fake *Gossip) UpdateLedgerHeight(height uint64, chainID common.ChainID) {
fake.updateLedgerHeightMutex.Lock()
fake.updateLedgerHeightArgsForCall = append(fake.updateLedgerHeightArgsForCall, struct {
height uint64
chainID common.ChainID
}{height, chainID})
fake.recordInvocation("UpdateLedgerHeight", []interface{}{height, chainID})
fake.updateLedgerHeightMutex.Unlock()
if fake.UpdateLedgerHeightStub != nil {
fake.UpdateLedgerHeightStub(height, chainID)
}
}
func (fake *Gossip) UpdateLedgerHeightCallCount() int {
fake.updateLedgerHeightMutex.RLock()
defer fake.updateLedgerHeightMutex.RUnlock()
return len(fake.updateLedgerHeightArgsForCall)
}
func (fake *Gossip) UpdateLedgerHeightArgsForCall(i int) (uint64, common.ChainID) {
fake.updateLedgerHeightMutex.RLock()
defer fake.updateLedgerHeightMutex.RUnlock()
return fake.updateLedgerHeightArgsForCall[i].height, fake.updateLedgerHeightArgsForCall[i].chainID
}
func (fake *Gossip) UpdateChaincodes(chaincode []*proto.Chaincode, chainID common.ChainID) {
var chaincodeCopy []*proto.Chaincode
if chaincode != nil {
chaincodeCopy = make([]*proto.Chaincode, len(chaincode))
copy(chaincodeCopy, chaincode)
}
fake.updateChaincodesMutex.Lock()
fake.updateChaincodesArgsForCall = append(fake.updateChaincodesArgsForCall, struct {
chaincode []*proto.Chaincode
chainID common.ChainID
}{chaincodeCopy, chainID})
fake.recordInvocation("UpdateChaincodes", []interface{}{chaincodeCopy, chainID})
fake.updateChaincodesMutex.Unlock()
if fake.UpdateChaincodesStub != nil {
fake.UpdateChaincodesStub(chaincode, chainID)
}
}
func (fake *Gossip) UpdateChaincodesCallCount() int {
fake.updateChaincodesMutex.RLock()
defer fake.updateChaincodesMutex.RUnlock()
return len(fake.updateChaincodesArgsForCall)
}
func (fake *Gossip) UpdateChaincodesArgsForCall(i int) ([]*proto.Chaincode, common.ChainID) {
fake.updateChaincodesMutex.RLock()
defer fake.updateChaincodesMutex.RUnlock()
return fake.updateChaincodesArgsForCall[i].chaincode, fake.updateChaincodesArgsForCall[i].chainID
}
func (fake *Gossip) Gossip(msg *proto.GossipMessage) {
fake.gossipMutex.Lock()
fake.gossipArgsForCall = append(fake.gossipArgsForCall, struct {
msg *proto.GossipMessage
}{msg})
fake.recordInvocation("Gossip", []interface{}{msg})
fake.gossipMutex.Unlock()
if fake.GossipStub != nil {
fake.GossipStub(msg)
}
}
func (fake *Gossip) GossipCallCount() int {
fake.gossipMutex.RLock()
defer fake.gossipMutex.RUnlock()
return len(fake.gossipArgsForCall)
}
func (fake *Gossip) GossipArgsForCall(i int) *proto.GossipMessage {
fake.gossipMutex.RLock()
defer fake.gossipMutex.RUnlock()
return fake.gossipArgsForCall[i].msg
}
func (fake *Gossip) PeerFilter(channel common.ChainID, messagePredicate api.SubChannelSelectionCriteria) (filter.RoutingFilter, error) {
fake.peerFilterMutex.Lock()
ret, specificReturn := fake.peerFilterReturnsOnCall[len(fake.peerFilterArgsForCall)]
fake.peerFilterArgsForCall = append(fake.peerFilterArgsForCall, struct {
channel common.ChainID
messagePredicate api.SubChannelSelectionCriteria
}{channel, messagePredicate})
fake.recordInvocation("PeerFilter", []interface{}{channel, messagePredicate})
fake.peerFilterMutex.Unlock()
if fake.PeerFilterStub != nil {
return fake.PeerFilterStub(channel, messagePredicate)
}
if specificReturn {
return ret.result1, ret.result2
}
return fake.peerFilterReturns.result1, fake.peerFilterReturns.result2
}
func (fake *Gossip) PeerFilterCallCount() int {
fake.peerFilterMutex.RLock()
defer fake.peerFilterMutex.RUnlock()
return len(fake.peerFilterArgsForCall)
}
func (fake *Gossip) PeerFilterArgsForCall(i int) (common.ChainID, api.SubChannelSelectionCriteria) {
fake.peerFilterMutex.RLock()
defer fake.peerFilterMutex.RUnlock()
return fake.peerFilterArgsForCall[i].channel, fake.peerFilterArgsForCall[i].messagePredicate
}
func (fake *Gossip) PeerFilterReturns(result1 filter.RoutingFilter, result2 error) {
fake.PeerFilterStub = nil
fake.peerFilterReturns = struct {
result1 filter.RoutingFilter
result2 error
}{result1, result2}
}
func (fake *Gossip) PeerFilterReturnsOnCall(i int, result1 filter.RoutingFilter, result2 error) {
fake.PeerFilterStub = nil
if fake.peerFilterReturnsOnCall == nil {
fake.peerFilterReturnsOnCall = make(map[int]struct {
result1 filter.RoutingFilter
result2 error
})
}
fake.peerFilterReturnsOnCall[i] = struct {
result1 filter.RoutingFilter
result2 error
}{result1, result2}
}
func (fake *Gossip) Accept(acceptor common.MessageAcceptor, passThrough bool) (<-chan *proto.GossipMessage, <-chan proto.ReceivedMessage) {
fake.acceptMutex.Lock()
ret, specificReturn := fake.acceptReturnsOnCall[len(fake.acceptArgsForCall)]
fake.acceptArgsForCall = append(fake.acceptArgsForCall, struct {
acceptor common.MessageAcceptor
passThrough bool
}{acceptor, passThrough})
fake.recordInvocation("Accept", []interface{}{acceptor, passThrough})
fake.acceptMutex.Unlock()
if fake.AcceptStub != nil {
return fake.AcceptStub(acceptor, passThrough)
}
if specificReturn {
return ret.result1, ret.result2
}
return fake.acceptReturns.result1, fake.acceptReturns.result2
}
func (fake *Gossip) AcceptCallCount() int {
fake.acceptMutex.RLock()
defer fake.acceptMutex.RUnlock()
return len(fake.acceptArgsForCall)
}
func (fake *Gossip) AcceptArgsForCall(i int) (common.MessageAcceptor, bool) {
fake.acceptMutex.RLock()
defer fake.acceptMutex.RUnlock()
return fake.acceptArgsForCall[i].acceptor, fake.acceptArgsForCall[i].passThrough
}
func (fake *Gossip) AcceptReturns(result1 <-chan *proto.GossipMessage, result2 <-chan proto.ReceivedMessage) {
fake.AcceptStub = nil
fake.acceptReturns = struct {
result1 <-chan *proto.GossipMessage
result2 <-chan proto.ReceivedMessage
}{result1, result2}
}
func (fake *Gossip) AcceptReturnsOnCall(i int, result1 <-chan *proto.GossipMessage, result2 <-chan proto.ReceivedMessage) {
fake.AcceptStub = nil
if fake.acceptReturnsOnCall == nil {
fake.acceptReturnsOnCall = make(map[int]struct {
result1 <-chan *proto.GossipMessage
result2 <-chan proto.ReceivedMessage
})
}
fake.acceptReturnsOnCall[i] = struct {
result1 <-chan *proto.GossipMessage
result2 <-chan proto.ReceivedMessage
}{result1, result2}
}
func (fake *Gossip) JoinChan(joinMsg api.JoinChannelMessage, chainID common.ChainID) {
fake.joinChanMutex.Lock()
fake.joinChanArgsForCall = append(fake.joinChanArgsForCall, struct {
joinMsg api.JoinChannelMessage
chainID common.ChainID
}{joinMsg, chainID})
fake.recordInvocation("JoinChan", []interface{}{joinMsg, chainID})
fake.joinChanMutex.Unlock()
if fake.JoinChanStub != nil {
fake.JoinChanStub(joinMsg, chainID)
}
}
func (fake *Gossip) JoinChanCallCount() int {
fake.joinChanMutex.RLock()
defer fake.joinChanMutex.RUnlock()
return len(fake.joinChanArgsForCall)
}
func (fake *Gossip) JoinChanArgsForCall(i int) (api.JoinChannelMessage, common.ChainID) {
fake.joinChanMutex.RLock()
defer fake.joinChanMutex.RUnlock()
return fake.joinChanArgsForCall[i].joinMsg, fake.joinChanArgsForCall[i].chainID
}
func (fake *Gossip) LeaveChan(chainID common.ChainID) {
fake.leaveChanMutex.Lock()
fake.leaveChanArgsForCall = append(fake.leaveChanArgsForCall, struct {
chainID common.ChainID
}{chainID})
fake.recordInvocation("LeaveChan", []interface{}{chainID})
fake.leaveChanMutex.Unlock()
if fake.LeaveChanStub != nil {
fake.LeaveChanStub(chainID)
}
}
func (fake *Gossip) LeaveChanCallCount() int {
fake.leaveChanMutex.RLock()
defer fake.leaveChanMutex.RUnlock()
return len(fake.leaveChanArgsForCall)
}
func (fake *Gossip) LeaveChanArgsForCall(i int) common.ChainID {
fake.leaveChanMutex.RLock()
defer fake.leaveChanMutex.RUnlock()
return fake.leaveChanArgsForCall[i].chainID
}
func (fake *Gossip) SuspectPeers(s api.PeerSuspector) {
fake.suspectPeersMutex.Lock()
fake.suspectPeersArgsForCall = append(fake.suspectPeersArgsForCall, struct {
s api.PeerSuspector
}{s})
fake.recordInvocation("SuspectPeers", []interface{}{s})
fake.suspectPeersMutex.Unlock()
if fake.SuspectPeersStub != nil {
fake.SuspectPeersStub(s)
}
}
func (fake *Gossip) SuspectPeersCallCount() int {
fake.suspectPeersMutex.RLock()
defer fake.suspectPeersMutex.RUnlock()
return len(fake.suspectPeersArgsForCall)
}
func (fake *Gossip) SuspectPeersArgsForCall(i int) api.PeerSuspector {
fake.suspectPeersMutex.RLock()
defer fake.suspectPeersMutex.RUnlock()
return fake.suspectPeersArgsForCall[i].s
}
func (fake *Gossip) IdentityInfo() api.PeerIdentitySet {
fake.identityInfoMutex.Lock()
ret, specificReturn := fake.identityInfoReturnsOnCall[len(fake.identityInfoArgsForCall)]
fake.identityInfoArgsForCall = append(fake.identityInfoArgsForCall, struct{}{})
fake.recordInvocation("IdentityInfo", []interface{}{})
fake.identityInfoMutex.Unlock()
if fake.IdentityInfoStub != nil {
return fake.IdentityInfoStub()
}
if specificReturn {
return ret.result1
}
return fake.identityInfoReturns.result1
}
func (fake *Gossip) IdentityInfoCallCount() int {
fake.identityInfoMutex.RLock()
defer fake.identityInfoMutex.RUnlock()
return len(fake.identityInfoArgsForCall)
}
func (fake *Gossip) IdentityInfoReturns(result1 api.PeerIdentitySet) {
fake.IdentityInfoStub = nil
fake.identityInfoReturns = struct {
result1 api.PeerIdentitySet
}{result1}
}
func (fake *Gossip) IdentityInfoReturnsOnCall(i int, result1 api.PeerIdentitySet) {
fake.IdentityInfoStub = nil
if fake.identityInfoReturnsOnCall == nil {
fake.identityInfoReturnsOnCall = make(map[int]struct {
result1 api.PeerIdentitySet
})
}
fake.identityInfoReturnsOnCall[i] = struct {
result1 api.PeerIdentitySet
}{result1}
}
func (fake *Gossip) Stop() {
fake.stopMutex.Lock()
fake.stopArgsForCall = append(fake.stopArgsForCall, struct{}{})
fake.recordInvocation("Stop", []interface{}{})
fake.stopMutex.Unlock()
if fake.StopStub != nil {
fake.StopStub()
}
}
func (fake *Gossip) StopCallCount() int {
fake.stopMutex.RLock()
defer fake.stopMutex.RUnlock()
return len(fake.stopArgsForCall)
}
func (fake *Gossip) Invocations() map[string][][]interface{} {
fake.invocationsMutex.RLock()
defer fake.invocationsMutex.RUnlock()
fake.selfMembershipInfoMutex.RLock()
defer fake.selfMembershipInfoMutex.RUnlock()
fake.selfChannelInfoMutex.RLock()
defer fake.selfChannelInfoMutex.RUnlock()
fake.sendMutex.RLock()
defer fake.sendMutex.RUnlock()
fake.sendByCriteriaMutex.RLock()
defer fake.sendByCriteriaMutex.RUnlock()
fake.peersMutex.RLock()
defer fake.peersMutex.RUnlock()
fake.peersOfChannelMutex.RLock()
defer fake.peersOfChannelMutex.RUnlock()
fake.updateMetadataMutex.RLock()
defer fake.updateMetadataMutex.RUnlock()
fake.updateLedgerHeightMutex.RLock()
defer fake.updateLedgerHeightMutex.RUnlock()
fake.updateChaincodesMutex.RLock()
defer fake.updateChaincodesMutex.RUnlock()
fake.gossipMutex.RLock()
defer fake.gossipMutex.RUnlock()
fake.peerFilterMutex.RLock()
defer fake.peerFilterMutex.RUnlock()
fake.acceptMutex.RLock()
defer fake.acceptMutex.RUnlock()
fake.joinChanMutex.RLock()
defer fake.joinChanMutex.RUnlock()
fake.leaveChanMutex.RLock()
defer fake.leaveChanMutex.RUnlock()
fake.suspectPeersMutex.RLock()
defer fake.suspectPeersMutex.RUnlock()
fake.identityInfoMutex.RLock()
defer fake.identityInfoMutex.RUnlock()
fake.stopMutex.RLock()
defer fake.stopMutex.RUnlock()
copiedInvocations := map[string][][]interface{}{}
for key, value := range fake.invocations {
copiedInvocations[key] = value
}
return copiedInvocations
}
func (fake *Gossip) recordInvocation(key string, args []interface{}) {
fake.invocationsMutex.Lock()
defer fake.invocationsMutex.Unlock()
if fake.invocations == nil {
fake.invocations = map[string][][]interface{}{}
}
if fake.invocations[key] == nil {
fake.invocations[key] = [][]interface{}{}
}
fake.invocations[key] = append(fake.invocations[key], args)
}
var _ gossip.Gossip = new(Gossip)
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/peter_code_git/fabric.git
git@gitee.com:peter_code_git/fabric.git
peter_code_git
fabric
fabric
v1.2.1

搜索帮助