1 Star 0 Fork 0

13683679291/fabric

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
克隆/下载
ab_deliver_client.go 14.89 KB
一键复制 编辑 原始数据 按行查看 历史
Jason Yellick 提交于 2019-09-09 11:07 . FAB-7559 Reimplement blocksprovider
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587
// Code generated by counterfeiter. DO NOT EDIT.
package fake
import (
"context"
"sync"
"github.com/hyperledger/fabric-protos-go/common"
"github.com/hyperledger/fabric-protos-go/orderer"
"google.golang.org/grpc/metadata"
)
type DeliverClient struct {
CloseSendStub func() error
closeSendMutex sync.RWMutex
closeSendArgsForCall []struct {
}
closeSendReturns struct {
result1 error
}
closeSendReturnsOnCall map[int]struct {
result1 error
}
ContextStub func() context.Context
contextMutex sync.RWMutex
contextArgsForCall []struct {
}
contextReturns struct {
result1 context.Context
}
contextReturnsOnCall map[int]struct {
result1 context.Context
}
HeaderStub func() (metadata.MD, error)
headerMutex sync.RWMutex
headerArgsForCall []struct {
}
headerReturns struct {
result1 metadata.MD
result2 error
}
headerReturnsOnCall map[int]struct {
result1 metadata.MD
result2 error
}
RecvStub func() (*orderer.DeliverResponse, error)
recvMutex sync.RWMutex
recvArgsForCall []struct {
}
recvReturns struct {
result1 *orderer.DeliverResponse
result2 error
}
recvReturnsOnCall map[int]struct {
result1 *orderer.DeliverResponse
result2 error
}
RecvMsgStub func(interface{}) error
recvMsgMutex sync.RWMutex
recvMsgArgsForCall []struct {
arg1 interface{}
}
recvMsgReturns struct {
result1 error
}
recvMsgReturnsOnCall map[int]struct {
result1 error
}
SendStub func(*common.Envelope) error
sendMutex sync.RWMutex
sendArgsForCall []struct {
arg1 *common.Envelope
}
sendReturns struct {
result1 error
}
sendReturnsOnCall map[int]struct {
result1 error
}
SendMsgStub func(interface{}) error
sendMsgMutex sync.RWMutex
sendMsgArgsForCall []struct {
arg1 interface{}
}
sendMsgReturns struct {
result1 error
}
sendMsgReturnsOnCall map[int]struct {
result1 error
}
TrailerStub func() metadata.MD
trailerMutex sync.RWMutex
trailerArgsForCall []struct {
}
trailerReturns struct {
result1 metadata.MD
}
trailerReturnsOnCall map[int]struct {
result1 metadata.MD
}
invocations map[string][][]interface{}
invocationsMutex sync.RWMutex
}
func (fake *DeliverClient) CloseSend() error {
fake.closeSendMutex.Lock()
ret, specificReturn := fake.closeSendReturnsOnCall[len(fake.closeSendArgsForCall)]
fake.closeSendArgsForCall = append(fake.closeSendArgsForCall, struct {
}{})
fake.recordInvocation("CloseSend", []interface{}{})
fake.closeSendMutex.Unlock()
if fake.CloseSendStub != nil {
return fake.CloseSendStub()
}
if specificReturn {
return ret.result1
}
fakeReturns := fake.closeSendReturns
return fakeReturns.result1
}
func (fake *DeliverClient) CloseSendCallCount() int {
fake.closeSendMutex.RLock()
defer fake.closeSendMutex.RUnlock()
return len(fake.closeSendArgsForCall)
}
func (fake *DeliverClient) CloseSendCalls(stub func() error) {
fake.closeSendMutex.Lock()
defer fake.closeSendMutex.Unlock()
fake.CloseSendStub = stub
}
func (fake *DeliverClient) CloseSendReturns(result1 error) {
fake.closeSendMutex.Lock()
defer fake.closeSendMutex.Unlock()
fake.CloseSendStub = nil
fake.closeSendReturns = struct {
result1 error
}{result1}
}
func (fake *DeliverClient) CloseSendReturnsOnCall(i int, result1 error) {
fake.closeSendMutex.Lock()
defer fake.closeSendMutex.Unlock()
fake.CloseSendStub = nil
if fake.closeSendReturnsOnCall == nil {
fake.closeSendReturnsOnCall = make(map[int]struct {
result1 error
})
}
fake.closeSendReturnsOnCall[i] = struct {
result1 error
}{result1}
}
func (fake *DeliverClient) Context() context.Context {
fake.contextMutex.Lock()
ret, specificReturn := fake.contextReturnsOnCall[len(fake.contextArgsForCall)]
fake.contextArgsForCall = append(fake.contextArgsForCall, struct {
}{})
fake.recordInvocation("Context", []interface{}{})
fake.contextMutex.Unlock()
if fake.ContextStub != nil {
return fake.ContextStub()
}
if specificReturn {
return ret.result1
}
fakeReturns := fake.contextReturns
return fakeReturns.result1
}
func (fake *DeliverClient) ContextCallCount() int {
fake.contextMutex.RLock()
defer fake.contextMutex.RUnlock()
return len(fake.contextArgsForCall)
}
func (fake *DeliverClient) ContextCalls(stub func() context.Context) {
fake.contextMutex.Lock()
defer fake.contextMutex.Unlock()
fake.ContextStub = stub
}
func (fake *DeliverClient) ContextReturns(result1 context.Context) {
fake.contextMutex.Lock()
defer fake.contextMutex.Unlock()
fake.ContextStub = nil
fake.contextReturns = struct {
result1 context.Context
}{result1}
}
func (fake *DeliverClient) ContextReturnsOnCall(i int, result1 context.Context) {
fake.contextMutex.Lock()
defer fake.contextMutex.Unlock()
fake.ContextStub = nil
if fake.contextReturnsOnCall == nil {
fake.contextReturnsOnCall = make(map[int]struct {
result1 context.Context
})
}
fake.contextReturnsOnCall[i] = struct {
result1 context.Context
}{result1}
}
func (fake *DeliverClient) Header() (metadata.MD, error) {
fake.headerMutex.Lock()
ret, specificReturn := fake.headerReturnsOnCall[len(fake.headerArgsForCall)]
fake.headerArgsForCall = append(fake.headerArgsForCall, struct {
}{})
fake.recordInvocation("Header", []interface{}{})
fake.headerMutex.Unlock()
if fake.HeaderStub != nil {
return fake.HeaderStub()
}
if specificReturn {
return ret.result1, ret.result2
}
fakeReturns := fake.headerReturns
return fakeReturns.result1, fakeReturns.result2
}
func (fake *DeliverClient) HeaderCallCount() int {
fake.headerMutex.RLock()
defer fake.headerMutex.RUnlock()
return len(fake.headerArgsForCall)
}
func (fake *DeliverClient) HeaderCalls(stub func() (metadata.MD, error)) {
fake.headerMutex.Lock()
defer fake.headerMutex.Unlock()
fake.HeaderStub = stub
}
func (fake *DeliverClient) HeaderReturns(result1 metadata.MD, result2 error) {
fake.headerMutex.Lock()
defer fake.headerMutex.Unlock()
fake.HeaderStub = nil
fake.headerReturns = struct {
result1 metadata.MD
result2 error
}{result1, result2}
}
func (fake *DeliverClient) HeaderReturnsOnCall(i int, result1 metadata.MD, result2 error) {
fake.headerMutex.Lock()
defer fake.headerMutex.Unlock()
fake.HeaderStub = nil
if fake.headerReturnsOnCall == nil {
fake.headerReturnsOnCall = make(map[int]struct {
result1 metadata.MD
result2 error
})
}
fake.headerReturnsOnCall[i] = struct {
result1 metadata.MD
result2 error
}{result1, result2}
}
func (fake *DeliverClient) Recv() (*orderer.DeliverResponse, error) {
fake.recvMutex.Lock()
ret, specificReturn := fake.recvReturnsOnCall[len(fake.recvArgsForCall)]
fake.recvArgsForCall = append(fake.recvArgsForCall, struct {
}{})
fake.recordInvocation("Recv", []interface{}{})
fake.recvMutex.Unlock()
if fake.RecvStub != nil {
return fake.RecvStub()
}
if specificReturn {
return ret.result1, ret.result2
}
fakeReturns := fake.recvReturns
return fakeReturns.result1, fakeReturns.result2
}
func (fake *DeliverClient) RecvCallCount() int {
fake.recvMutex.RLock()
defer fake.recvMutex.RUnlock()
return len(fake.recvArgsForCall)
}
func (fake *DeliverClient) RecvCalls(stub func() (*orderer.DeliverResponse, error)) {
fake.recvMutex.Lock()
defer fake.recvMutex.Unlock()
fake.RecvStub = stub
}
func (fake *DeliverClient) RecvReturns(result1 *orderer.DeliverResponse, result2 error) {
fake.recvMutex.Lock()
defer fake.recvMutex.Unlock()
fake.RecvStub = nil
fake.recvReturns = struct {
result1 *orderer.DeliverResponse
result2 error
}{result1, result2}
}
func (fake *DeliverClient) RecvReturnsOnCall(i int, result1 *orderer.DeliverResponse, result2 error) {
fake.recvMutex.Lock()
defer fake.recvMutex.Unlock()
fake.RecvStub = nil
if fake.recvReturnsOnCall == nil {
fake.recvReturnsOnCall = make(map[int]struct {
result1 *orderer.DeliverResponse
result2 error
})
}
fake.recvReturnsOnCall[i] = struct {
result1 *orderer.DeliverResponse
result2 error
}{result1, result2}
}
func (fake *DeliverClient) RecvMsg(arg1 interface{}) error {
fake.recvMsgMutex.Lock()
ret, specificReturn := fake.recvMsgReturnsOnCall[len(fake.recvMsgArgsForCall)]
fake.recvMsgArgsForCall = append(fake.recvMsgArgsForCall, struct {
arg1 interface{}
}{arg1})
fake.recordInvocation("RecvMsg", []interface{}{arg1})
fake.recvMsgMutex.Unlock()
if fake.RecvMsgStub != nil {
return fake.RecvMsgStub(arg1)
}
if specificReturn {
return ret.result1
}
fakeReturns := fake.recvMsgReturns
return fakeReturns.result1
}
func (fake *DeliverClient) RecvMsgCallCount() int {
fake.recvMsgMutex.RLock()
defer fake.recvMsgMutex.RUnlock()
return len(fake.recvMsgArgsForCall)
}
func (fake *DeliverClient) RecvMsgCalls(stub func(interface{}) error) {
fake.recvMsgMutex.Lock()
defer fake.recvMsgMutex.Unlock()
fake.RecvMsgStub = stub
}
func (fake *DeliverClient) RecvMsgArgsForCall(i int) interface{} {
fake.recvMsgMutex.RLock()
defer fake.recvMsgMutex.RUnlock()
argsForCall := fake.recvMsgArgsForCall[i]
return argsForCall.arg1
}
func (fake *DeliverClient) RecvMsgReturns(result1 error) {
fake.recvMsgMutex.Lock()
defer fake.recvMsgMutex.Unlock()
fake.RecvMsgStub = nil
fake.recvMsgReturns = struct {
result1 error
}{result1}
}
func (fake *DeliverClient) RecvMsgReturnsOnCall(i int, result1 error) {
fake.recvMsgMutex.Lock()
defer fake.recvMsgMutex.Unlock()
fake.RecvMsgStub = nil
if fake.recvMsgReturnsOnCall == nil {
fake.recvMsgReturnsOnCall = make(map[int]struct {
result1 error
})
}
fake.recvMsgReturnsOnCall[i] = struct {
result1 error
}{result1}
}
func (fake *DeliverClient) Send(arg1 *common.Envelope) error {
fake.sendMutex.Lock()
ret, specificReturn := fake.sendReturnsOnCall[len(fake.sendArgsForCall)]
fake.sendArgsForCall = append(fake.sendArgsForCall, struct {
arg1 *common.Envelope
}{arg1})
fake.recordInvocation("Send", []interface{}{arg1})
fake.sendMutex.Unlock()
if fake.SendStub != nil {
return fake.SendStub(arg1)
}
if specificReturn {
return ret.result1
}
fakeReturns := fake.sendReturns
return fakeReturns.result1
}
func (fake *DeliverClient) SendCallCount() int {
fake.sendMutex.RLock()
defer fake.sendMutex.RUnlock()
return len(fake.sendArgsForCall)
}
func (fake *DeliverClient) SendCalls(stub func(*common.Envelope) error) {
fake.sendMutex.Lock()
defer fake.sendMutex.Unlock()
fake.SendStub = stub
}
func (fake *DeliverClient) SendArgsForCall(i int) *common.Envelope {
fake.sendMutex.RLock()
defer fake.sendMutex.RUnlock()
argsForCall := fake.sendArgsForCall[i]
return argsForCall.arg1
}
func (fake *DeliverClient) SendReturns(result1 error) {
fake.sendMutex.Lock()
defer fake.sendMutex.Unlock()
fake.SendStub = nil
fake.sendReturns = struct {
result1 error
}{result1}
}
func (fake *DeliverClient) SendReturnsOnCall(i int, result1 error) {
fake.sendMutex.Lock()
defer fake.sendMutex.Unlock()
fake.SendStub = nil
if fake.sendReturnsOnCall == nil {
fake.sendReturnsOnCall = make(map[int]struct {
result1 error
})
}
fake.sendReturnsOnCall[i] = struct {
result1 error
}{result1}
}
func (fake *DeliverClient) SendMsg(arg1 interface{}) error {
fake.sendMsgMutex.Lock()
ret, specificReturn := fake.sendMsgReturnsOnCall[len(fake.sendMsgArgsForCall)]
fake.sendMsgArgsForCall = append(fake.sendMsgArgsForCall, struct {
arg1 interface{}
}{arg1})
fake.recordInvocation("SendMsg", []interface{}{arg1})
fake.sendMsgMutex.Unlock()
if fake.SendMsgStub != nil {
return fake.SendMsgStub(arg1)
}
if specificReturn {
return ret.result1
}
fakeReturns := fake.sendMsgReturns
return fakeReturns.result1
}
func (fake *DeliverClient) SendMsgCallCount() int {
fake.sendMsgMutex.RLock()
defer fake.sendMsgMutex.RUnlock()
return len(fake.sendMsgArgsForCall)
}
func (fake *DeliverClient) SendMsgCalls(stub func(interface{}) error) {
fake.sendMsgMutex.Lock()
defer fake.sendMsgMutex.Unlock()
fake.SendMsgStub = stub
}
func (fake *DeliverClient) SendMsgArgsForCall(i int) interface{} {
fake.sendMsgMutex.RLock()
defer fake.sendMsgMutex.RUnlock()
argsForCall := fake.sendMsgArgsForCall[i]
return argsForCall.arg1
}
func (fake *DeliverClient) SendMsgReturns(result1 error) {
fake.sendMsgMutex.Lock()
defer fake.sendMsgMutex.Unlock()
fake.SendMsgStub = nil
fake.sendMsgReturns = struct {
result1 error
}{result1}
}
func (fake *DeliverClient) SendMsgReturnsOnCall(i int, result1 error) {
fake.sendMsgMutex.Lock()
defer fake.sendMsgMutex.Unlock()
fake.SendMsgStub = nil
if fake.sendMsgReturnsOnCall == nil {
fake.sendMsgReturnsOnCall = make(map[int]struct {
result1 error
})
}
fake.sendMsgReturnsOnCall[i] = struct {
result1 error
}{result1}
}
func (fake *DeliverClient) Trailer() metadata.MD {
fake.trailerMutex.Lock()
ret, specificReturn := fake.trailerReturnsOnCall[len(fake.trailerArgsForCall)]
fake.trailerArgsForCall = append(fake.trailerArgsForCall, struct {
}{})
fake.recordInvocation("Trailer", []interface{}{})
fake.trailerMutex.Unlock()
if fake.TrailerStub != nil {
return fake.TrailerStub()
}
if specificReturn {
return ret.result1
}
fakeReturns := fake.trailerReturns
return fakeReturns.result1
}
func (fake *DeliverClient) TrailerCallCount() int {
fake.trailerMutex.RLock()
defer fake.trailerMutex.RUnlock()
return len(fake.trailerArgsForCall)
}
func (fake *DeliverClient) TrailerCalls(stub func() metadata.MD) {
fake.trailerMutex.Lock()
defer fake.trailerMutex.Unlock()
fake.TrailerStub = stub
}
func (fake *DeliverClient) TrailerReturns(result1 metadata.MD) {
fake.trailerMutex.Lock()
defer fake.trailerMutex.Unlock()
fake.TrailerStub = nil
fake.trailerReturns = struct {
result1 metadata.MD
}{result1}
}
func (fake *DeliverClient) TrailerReturnsOnCall(i int, result1 metadata.MD) {
fake.trailerMutex.Lock()
defer fake.trailerMutex.Unlock()
fake.TrailerStub = nil
if fake.trailerReturnsOnCall == nil {
fake.trailerReturnsOnCall = make(map[int]struct {
result1 metadata.MD
})
}
fake.trailerReturnsOnCall[i] = struct {
result1 metadata.MD
}{result1}
}
func (fake *DeliverClient) Invocations() map[string][][]interface{} {
fake.invocationsMutex.RLock()
defer fake.invocationsMutex.RUnlock()
fake.closeSendMutex.RLock()
defer fake.closeSendMutex.RUnlock()
fake.contextMutex.RLock()
defer fake.contextMutex.RUnlock()
fake.headerMutex.RLock()
defer fake.headerMutex.RUnlock()
fake.recvMutex.RLock()
defer fake.recvMutex.RUnlock()
fake.recvMsgMutex.RLock()
defer fake.recvMsgMutex.RUnlock()
fake.sendMutex.RLock()
defer fake.sendMutex.RUnlock()
fake.sendMsgMutex.RLock()
defer fake.sendMsgMutex.RUnlock()
fake.trailerMutex.RLock()
defer fake.trailerMutex.RUnlock()
copiedInvocations := map[string][][]interface{}{}
for key, value := range fake.invocations {
copiedInvocations[key] = value
}
return copiedInvocations
}
func (fake *DeliverClient) 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)
}
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/mmcro/fabric.git
git@gitee.com:mmcro/fabric.git
mmcro
fabric
fabric
v2.1.1

搜索帮助