// Code generated by counterfeiter. DO NOT EDIT. package mock import ( "sync" "github.com/hyperledger/fabric-protos-go/common" "github.com/hyperledger/fabric/common/deliver" "github.com/hyperledger/fabric/protoutil" ) type ResponseSender struct { DataTypeStub func() string dataTypeMutex sync.RWMutex dataTypeArgsForCall []struct { } dataTypeReturns struct { result1 string } dataTypeReturnsOnCall map[int]struct { result1 string } SendBlockResponseStub func(*common.Block, string, deliver.Chain, *protoutil.SignedData) error sendBlockResponseMutex sync.RWMutex sendBlockResponseArgsForCall []struct { arg1 *common.Block arg2 string arg3 deliver.Chain arg4 *protoutil.SignedData } sendBlockResponseReturns struct { result1 error } sendBlockResponseReturnsOnCall map[int]struct { result1 error } SendStatusResponseStub func(common.Status) error sendStatusResponseMutex sync.RWMutex sendStatusResponseArgsForCall []struct { arg1 common.Status } sendStatusResponseReturns struct { result1 error } sendStatusResponseReturnsOnCall map[int]struct { result1 error } invocations map[string][][]interface{} invocationsMutex sync.RWMutex } func (fake *ResponseSender) DataType() string { fake.dataTypeMutex.Lock() ret, specificReturn := fake.dataTypeReturnsOnCall[len(fake.dataTypeArgsForCall)] fake.dataTypeArgsForCall = append(fake.dataTypeArgsForCall, struct { }{}) fake.recordInvocation("DataType", []interface{}{}) fake.dataTypeMutex.Unlock() if fake.DataTypeStub != nil { return fake.DataTypeStub() } if specificReturn { return ret.result1 } fakeReturns := fake.dataTypeReturns return fakeReturns.result1 } func (fake *ResponseSender) DataTypeCallCount() int { fake.dataTypeMutex.RLock() defer fake.dataTypeMutex.RUnlock() return len(fake.dataTypeArgsForCall) } func (fake *ResponseSender) DataTypeCalls(stub func() string) { fake.dataTypeMutex.Lock() defer fake.dataTypeMutex.Unlock() fake.DataTypeStub = stub } func (fake *ResponseSender) DataTypeReturns(result1 string) { fake.dataTypeMutex.Lock() defer fake.dataTypeMutex.Unlock() fake.DataTypeStub = nil fake.dataTypeReturns = struct { result1 string }{result1} } func (fake *ResponseSender) DataTypeReturnsOnCall(i int, result1 string) { fake.dataTypeMutex.Lock() defer fake.dataTypeMutex.Unlock() fake.DataTypeStub = nil if fake.dataTypeReturnsOnCall == nil { fake.dataTypeReturnsOnCall = make(map[int]struct { result1 string }) } fake.dataTypeReturnsOnCall[i] = struct { result1 string }{result1} } func (fake *ResponseSender) SendBlockResponse(arg1 *common.Block, arg2 string, arg3 deliver.Chain, arg4 *protoutil.SignedData) error { fake.sendBlockResponseMutex.Lock() ret, specificReturn := fake.sendBlockResponseReturnsOnCall[len(fake.sendBlockResponseArgsForCall)] fake.sendBlockResponseArgsForCall = append(fake.sendBlockResponseArgsForCall, struct { arg1 *common.Block arg2 string arg3 deliver.Chain arg4 *protoutil.SignedData }{arg1, arg2, arg3, arg4}) fake.recordInvocation("SendBlockResponse", []interface{}{arg1, arg2, arg3, arg4}) fake.sendBlockResponseMutex.Unlock() if fake.SendBlockResponseStub != nil { return fake.SendBlockResponseStub(arg1, arg2, arg3, arg4) } if specificReturn { return ret.result1 } fakeReturns := fake.sendBlockResponseReturns return fakeReturns.result1 } func (fake *ResponseSender) SendBlockResponseCallCount() int { fake.sendBlockResponseMutex.RLock() defer fake.sendBlockResponseMutex.RUnlock() return len(fake.sendBlockResponseArgsForCall) } func (fake *ResponseSender) SendBlockResponseCalls(stub func(*common.Block, string, deliver.Chain, *protoutil.SignedData) error) { fake.sendBlockResponseMutex.Lock() defer fake.sendBlockResponseMutex.Unlock() fake.SendBlockResponseStub = stub } func (fake *ResponseSender) SendBlockResponseArgsForCall(i int) (*common.Block, string, deliver.Chain, *protoutil.SignedData) { fake.sendBlockResponseMutex.RLock() defer fake.sendBlockResponseMutex.RUnlock() argsForCall := fake.sendBlockResponseArgsForCall[i] return argsForCall.arg1, argsForCall.arg2, argsForCall.arg3, argsForCall.arg4 } func (fake *ResponseSender) SendBlockResponseReturns(result1 error) { fake.sendBlockResponseMutex.Lock() defer fake.sendBlockResponseMutex.Unlock() fake.SendBlockResponseStub = nil fake.sendBlockResponseReturns = struct { result1 error }{result1} } func (fake *ResponseSender) SendBlockResponseReturnsOnCall(i int, result1 error) { fake.sendBlockResponseMutex.Lock() defer fake.sendBlockResponseMutex.Unlock() fake.SendBlockResponseStub = nil if fake.sendBlockResponseReturnsOnCall == nil { fake.sendBlockResponseReturnsOnCall = make(map[int]struct { result1 error }) } fake.sendBlockResponseReturnsOnCall[i] = struct { result1 error }{result1} } func (fake *ResponseSender) SendStatusResponse(arg1 common.Status) error { fake.sendStatusResponseMutex.Lock() ret, specificReturn := fake.sendStatusResponseReturnsOnCall[len(fake.sendStatusResponseArgsForCall)] fake.sendStatusResponseArgsForCall = append(fake.sendStatusResponseArgsForCall, struct { arg1 common.Status }{arg1}) fake.recordInvocation("SendStatusResponse", []interface{}{arg1}) fake.sendStatusResponseMutex.Unlock() if fake.SendStatusResponseStub != nil { return fake.SendStatusResponseStub(arg1) } if specificReturn { return ret.result1 } fakeReturns := fake.sendStatusResponseReturns return fakeReturns.result1 } func (fake *ResponseSender) SendStatusResponseCallCount() int { fake.sendStatusResponseMutex.RLock() defer fake.sendStatusResponseMutex.RUnlock() return len(fake.sendStatusResponseArgsForCall) } func (fake *ResponseSender) SendStatusResponseCalls(stub func(common.Status) error) { fake.sendStatusResponseMutex.Lock() defer fake.sendStatusResponseMutex.Unlock() fake.SendStatusResponseStub = stub } func (fake *ResponseSender) SendStatusResponseArgsForCall(i int) common.Status { fake.sendStatusResponseMutex.RLock() defer fake.sendStatusResponseMutex.RUnlock() argsForCall := fake.sendStatusResponseArgsForCall[i] return argsForCall.arg1 } func (fake *ResponseSender) SendStatusResponseReturns(result1 error) { fake.sendStatusResponseMutex.Lock() defer fake.sendStatusResponseMutex.Unlock() fake.SendStatusResponseStub = nil fake.sendStatusResponseReturns = struct { result1 error }{result1} } func (fake *ResponseSender) SendStatusResponseReturnsOnCall(i int, result1 error) { fake.sendStatusResponseMutex.Lock() defer fake.sendStatusResponseMutex.Unlock() fake.SendStatusResponseStub = nil if fake.sendStatusResponseReturnsOnCall == nil { fake.sendStatusResponseReturnsOnCall = make(map[int]struct { result1 error }) } fake.sendStatusResponseReturnsOnCall[i] = struct { result1 error }{result1} } func (fake *ResponseSender) Invocations() map[string][][]interface{} { fake.invocationsMutex.RLock() defer fake.invocationsMutex.RUnlock() fake.dataTypeMutex.RLock() defer fake.dataTypeMutex.RUnlock() fake.sendBlockResponseMutex.RLock() defer fake.sendBlockResponseMutex.RUnlock() fake.sendStatusResponseMutex.RLock() defer fake.sendStatusResponseMutex.RUnlock() copiedInvocations := map[string][][]interface{}{} for key, value := range fake.invocations { copiedInvocations[key] = value } return copiedInvocations } func (fake *ResponseSender) 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 _ deliver.ResponseSender = new(ResponseSender)