File tree Expand file tree Collapse file tree 2 files changed +6
-1
lines changed
pkg/mcs/resourcemanager/server Expand file tree Collapse file tree 2 files changed +6
-1
lines changed Original file line number Diff line number Diff line change @@ -131,7 +131,7 @@ func (m *Manager) GetKeyspaceServiceLimiter(keyspaceID uint32) *serviceLimiter {
131131// SetKeyspaceServiceLimit sets the service limit of the keyspace.
132132func (m * Manager ) SetKeyspaceServiceLimit (keyspaceID uint32 , serviceLimit float64 ) {
133133 // If the keyspace is not found, create a new keyspace resource group manager.
134- m .getOrCreateKeyspaceResourceGroupManager (keyspaceID ).setServiceLimiter (serviceLimit )
134+ m .getOrCreateKeyspaceResourceGroupManager (keyspaceID , true ).setServiceLimiter (serviceLimit )
135135}
136136
137137func (m * Manager ) getOrCreateKeyspaceResourceGroupManager (keyspaceID uint32 , initDefault bool ) * keyspaceResourceGroupManager {
Original file line number Diff line number Diff line change @@ -317,6 +317,11 @@ func TestKeyspaceServiceLimit(t *testing.T) {
317317 limiter = m .GetKeyspaceServiceLimiter (2 )
318318 re .Equal (100.0 , limiter .ServiceLimit )
319319 re .Equal (0.0 , limiter .AvailableTokens )
320+ // Ensure the keyspace resource group manager is initialized correctly.
321+ krgm := m .getKeyspaceResourceGroupManager (2 )
322+ re .NotNil (krgm )
323+ re .Equal (uint32 (2 ), krgm .keyspaceID )
324+ re .Equal (DefaultResourceGroupName , krgm .getMutableResourceGroup (DefaultResourceGroupName ).Name )
320325}
321326
322327func TestKeyspaceNameLookup (t * testing.T ) {
You can’t perform that action at this time.
0 commit comments