Skip to content

Commit

Permalink
Remove resetting all values from a map.
Browse files Browse the repository at this point in the history
Signed-off-by: Antonio Navarro Perez <[email protected]>
  • Loading branch information
ajnavarro committed Oct 11, 2022
1 parent ed5473f commit 03b564e
Showing 1 changed file with 0 additions and 32 deletions.
32 changes: 0 additions & 32 deletions core/node/libp2p/rcmgr.go
Original file line number Diff line number Diff line change
Expand Up @@ -391,16 +391,6 @@ func NetResetLimit(mgr network.ResourceManager, repo repo.Repo, scope string) (r
case strings.HasPrefix(scope, config.ResourceMgrServiceScopePrefix):
svc := strings.TrimPrefix(scope, config.ResourceMgrServiceScopePrefix)

if svc == "" {
// reset defaults
err = mgr.ViewSystem(func(s network.ResourceScope) error { return setLimit(s, &defaults.ServiceDefault) })
setConfigFunc = func() rcmgr.BaseLimit {
configLimits.ServiceDefault = defaults.ServiceDefault
return defaults.ServiceDefault
}
break
}

err = mgr.ViewService(svc, func(s network.ServiceScope) error { return setLimit(s, &defaults.ServiceDefault) })
setConfigFunc = func() rcmgr.BaseLimit {
if configLimits.Service == nil {
Expand All @@ -412,17 +402,6 @@ func NetResetLimit(mgr network.ResourceManager, repo repo.Repo, scope string) (r
case strings.HasPrefix(scope, config.ResourceMgrProtocolScopePrefix):
proto := strings.TrimPrefix(scope, config.ResourceMgrProtocolScopePrefix)

if proto == "" {
// reset defaults
err = mgr.ViewSystem(func(s network.ResourceScope) error { return setLimit(s, &defaults.ProtocolDefault) })
setConfigFunc = func() rcmgr.BaseLimit {
configLimits.ProtocolDefault = defaults.ProtocolDefault

return defaults.ProtocolDefault
}
break
}

err = mgr.ViewProtocol(protocol.ID(proto), func(s network.ProtocolScope) error { return setLimit(s, &defaults.ProtocolDefault) })
setConfigFunc = func() rcmgr.BaseLimit {
if configLimits.Protocol == nil {
Expand All @@ -435,17 +414,6 @@ func NetResetLimit(mgr network.ResourceManager, repo repo.Repo, scope string) (r
case strings.HasPrefix(scope, config.ResourceMgrPeerScopePrefix):
p := strings.TrimPrefix(scope, config.ResourceMgrPeerScopePrefix)

if p == "" {
// reset defaults
err = mgr.ViewSystem(func(s network.ResourceScope) error { return setLimit(s, &defaults.PeerDefault) })
setConfigFunc = func() rcmgr.BaseLimit {
configLimits.PeerDefault = defaults.PeerDefault

return defaults.PeerDefault
}
break
}

var pid peer.ID
pid, err = peer.Decode(p)
if err != nil {
Expand Down

0 comments on commit 03b564e

Please sign in to comment.