Skip to content

Commit

Permalink
Remove references to reify
Browse files Browse the repository at this point in the history
  • Loading branch information
MarcoPolo committed Jan 31, 2023
1 parent 2f95f28 commit 15f6fa5
Show file tree
Hide file tree
Showing 5 changed files with 16 additions and 10 deletions.
2 changes: 1 addition & 1 deletion p2p/host/resource-manager/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ scalingLimits := rcmgr.DefaultLimits
// Add limits around included libp2p protocols
libp2p.SetDefaultServiceLimits(&scalingLimits)

// Turn the scaling limits into a reified set of limits using `.AutoScale`. This
// Turn the scaling limits into a concrete set of limits using `.AutoScale`. This
// scales the limits proportional to your system memory.
scaledDefaultLimits := scalingLimits.AutoScale()

Expand Down
8 changes: 4 additions & 4 deletions p2p/host/resource-manager/limit_config_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -111,16 +111,16 @@ func TestLimitConfigRoundTrip(t *testing.T) {
defaults := DefaultLimits
defaults.AddServiceLimit("C", DefaultLimits.ServiceBaseLimit, BaseLimitIncrease{})
defaults.AddProtocolPeerLimit("C", DefaultLimits.ServiceBaseLimit, BaseLimitIncrease{})
reifiedCfg, err := readLimiterConfigFromJSON(in, defaults.AutoScale())
concreteCfg, err := readLimiterConfigFromJSON(in, defaults.AutoScale())
require.NoError(t, err)

// Roundtrip
limitConfig := reifiedCfg.ToLimitConfig()
limitConfig := concreteCfg.ToLimitConfig()
// Using InfiniteLimits because it's different then the defaults used above.
// If anything was marked "default" in the round trip, it would show up as a
// difference here.
reifiedCfgRT := limitConfig.Build(InfiniteLimits)
require.Equal(t, reifiedCfg, reifiedCfgRT)
concreteCfgRT := limitConfig.Build(InfiniteLimits)
require.Equal(t, concreteCfg, concreteCfgRT)
}

func TestReadmeLimitConfigSerialization(t *testing.T) {
Expand Down
8 changes: 7 additions & 1 deletion p2p/host/resource-manager/limit_defaults.go
Original file line number Diff line number Diff line change
Expand Up @@ -148,6 +148,12 @@ func (l *LimitVal) UnmarshalJSON(b []byte) error {
if err := json.Unmarshal(b, &val); err != nil {
return err
}

if val == 0 {
// If there is an explicit 0 in the JSON we should interpret this as block all.
*l = BlockAllLimit
}

*l = LimitVal(val)
return nil
}
Expand Down Expand Up @@ -576,7 +582,7 @@ func resourceLimitsMapFromBaseLimitMap[K comparable](baseLimitMap map[K]BaseLimi
return out
}

// ToLimitConfig converts a ReifiedLimitConfig to a PartialLimitConfig. The returned
// ToLimitConfig converts a ConcreteLimitConfig to a PartialLimitConfig. The returned
// PartialLimitConfig will have no default values.
func (cfg ConcreteLimitConfig) ToLimitConfig() PartialLimitConfig {
return PartialLimitConfig{
Expand Down
6 changes: 3 additions & 3 deletions p2p/host/resource-manager/limit_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -203,11 +203,11 @@ func TestRoundTripFromConcreteAndBack(t *testing.T) {
},
}

reified := l.Build(InfiniteLimits)
concrete := l.Build(InfiniteLimits)

// Roundtrip
fromReified := reified.ToLimitConfigWithDefaults(InfiniteLimits)
require.Equal(t, l, fromReified)
fromConcrete := concrete.ToLimitConfigWithDefaults(InfiniteLimits)
require.Equal(t, l, fromConcrete)
}

func TestSerializeJSON(t *testing.T) {
Expand Down
2 changes: 1 addition & 1 deletion p2p/test/resource-manager/rcmgr_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -299,7 +299,7 @@ func TestReadmeExample(t *testing.T) {
// Add limits around included libp2p protocols
libp2p.SetDefaultServiceLimits(&scalingLimits)

// Turn the scaling limits into a reified set of limits using `.AutoScale`. This
// Turn the scaling limits into a concrete set of limits using `.AutoScale`. This
// scales the limits proportional to your system memory.
scaledDefaultLimits := scalingLimits.AutoScale()

Expand Down

0 comments on commit 15f6fa5

Please sign in to comment.