Skip to content

Commit e211334

Browse files
committed
[FAB-14324] remove GetStableChannelConfig function
- peer instance method is used instead Change-Id: I4739f4f22395667e209154e42b3be98b4c1e078c Signed-off-by: Matthew Sykes <sykesmat@us.ibm.com>
1 parent 47ffaa7 commit e211334

File tree

2 files changed

+9
-10
lines changed

2 files changed

+9
-10
lines changed

core/peer/peer.go

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -646,9 +646,6 @@ func (p *Peer) GetChannelsInfo() []*pb.ChannelInfo {
646646

647647
// GetStableChannelConfig returns the stable channel configuration of the channel with channel ID.
648648
// Note that this call returns nil if channel cid has not been created.
649-
func GetStableChannelConfig(cid string) channelconfig.Resources {
650-
return Default.GetStableChannelConfig(cid)
651-
}
652649
func (p *Peer) GetStableChannelConfig(cid string) channelconfig.Resources {
653650
p.mutex.RLock()
654651
defer p.mutex.RUnlock()

internal/peer/node/start.go

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -145,12 +145,6 @@ func serve(args []string) error {
145145

146146
logger.Infof("Starting %s", version.GetInfo())
147147

148-
//startup aclmgmt with default ACL providers (resource based and default 1.0 policies based).
149-
//Users can pass in their own ACLProvider to RegisterACLProvider (currently unit tests do this)
150-
aclProvider := aclmgmt.NewACLProvider(
151-
aclmgmt.ResourceGetter(peer.GetStableChannelConfig),
152-
)
153-
154148
//obtain coreConfiguration
155149
coreConfig, err := peer.GlobalConfig()
156150
if err != nil {
@@ -238,6 +232,12 @@ func serve(args []string) error {
238232
}
239233
peer.Default = peerInstance
240234

235+
//startup aclmgmt with default ACL providers (resource based and default 1.0 policies based).
236+
//Users can pass in their own ACLProvider to RegisterACLProvider (currently unit tests do this)
237+
aclProvider := aclmgmt.NewACLProvider(
238+
aclmgmt.ResourceGetter(peerInstance.GetStableChannelConfig),
239+
)
240+
241241
// TODO, unfortunately, the lifecycle initialization is very unclean at the
242242
// moment. This is because ccprovider.SetChaincodePath only works after
243243
// ledgermgmt.Initialize, but ledgermgmt.Initialize requires a reference to
@@ -626,6 +626,7 @@ func serve(args []string) error {
626626
if coreConfig.DiscoveryEnabled {
627627
registerDiscoveryService(
628628
coreConfig,
629+
peerInstance,
629630
peerServer,
630631
policyMgr,
631632
lifecycle.NewMetadataProvider(
@@ -724,6 +725,7 @@ func createSelfSignedData() protoutil.SignedData {
724725

725726
func registerDiscoveryService(
726727
coreConfig *peer.Config,
728+
peerInstance *peer.Peer,
727729
peerServer *comm.GRPCServer,
728730
polMgr policies.ChannelPolicyManagerGetter,
729731
metadataProvider *lifecycle.MetadataProvider,
@@ -735,7 +737,7 @@ func registerDiscoveryService(
735737
localAccessPolicy = localPolicy(cauthdsl.SignedByAnyMember([]string{mspID}))
736738
}
737739
channelVerifier := discacl.NewChannelVerifier(policies.ChannelApplicationWriters, polMgr)
738-
acl := discacl.NewDiscoverySupport(channelVerifier, localAccessPolicy, discacl.ChannelConfigGetterFunc(peer.GetStableChannelConfig))
740+
acl := discacl.NewDiscoverySupport(channelVerifier, localAccessPolicy, discacl.ChannelConfigGetterFunc(peerInstance.GetStableChannelConfig))
739741
gSup := gossip.NewDiscoverySupport(gossipService)
740742
ccSup := ccsupport.NewDiscoverySupport(metadataProvider)
741743
ea := endorsement.NewEndorsementAnalyzer(gSup, ccSup, acl, metadataProvider)

0 commit comments

Comments
 (0)