From a2f3d55af04afa4b97f139a6b7b2a3b067a07ecc Mon Sep 17 00:00:00 2001 From: Alexandros Filios Date: Wed, 13 Nov 2024 13:15:32 +0100 Subject: [PATCH] fixup! Deliver reads blocks instead of filtered blocks Signed-off-by: Alexandros Filios --- platform/fabric/core/generic/channelprovider.go | 5 ++++- platform/fabric/sdk/dig/generic/providers.go | 1 + 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/platform/fabric/core/generic/channelprovider.go b/platform/fabric/core/generic/channelprovider.go index 3c43a3bff..24b1b42d0 100644 --- a/platform/fabric/core/generic/channelprovider.go +++ b/platform/fabric/core/generic/channelprovider.go @@ -82,6 +82,7 @@ type provider struct { newLedger LedgerConstructor newRWSetLoader RWSetLoaderConstructor newCommitter CommitterConstructor + useFilteredDelivery bool } func NewChannelProvider( @@ -98,6 +99,7 @@ func NewChannelProvider( newLedger LedgerConstructor, newRWSetLoader RWSetLoaderConstructor, newCommitter CommitterConstructor, + useFilteredDelivery bool, ) *provider { return &provider{ kvss: kvss, @@ -113,6 +115,7 @@ func NewChannelProvider( newLedger: newLedger, newRWSetLoader: newRWSetLoader, newCommitter: newCommitter, + useFilteredDelivery: useFilteredDelivery, } } @@ -147,7 +150,7 @@ func (p *provider) NewChannel(nw driver.FabricNetworkService, channelName string nw.LocalMembership().DefaultSigningIdentity(), p.hasher, channelConfig.FinalityWaitTimeout(), - true, + p.useFilteredDelivery, ) if err != nil { return nil, err diff --git a/platform/fabric/sdk/dig/generic/providers.go b/platform/fabric/sdk/dig/generic/providers.go index 90af6f13d..6e76888cd 100644 --- a/platform/fabric/sdk/dig/generic/providers.go +++ b/platform/fabric/sdk/dig/generic/providers.go @@ -109,5 +109,6 @@ func NewChannelProvider(in struct { ledger.New, rwset.NewLoader, committer.New, + true, ) }