File tree 1 file changed +9
-6
lines changed
ydb/core/tx/limiter/grouped_memory/service
1 file changed +9
-6
lines changed Original file line number Diff line number Diff line change @@ -127,12 +127,15 @@ class TProcessMemoryScope {
127
127
}
128
128
129
129
void UnregisterGroup (const bool isPriorityProcess, const ui64 externalGroupId) {
130
- const ui64 internalGroupId = GroupIds.ExtractInternalIdVerified (externalGroupId);
131
- AFL_INFO (NKikimrServices::GROUPED_MEMORY_LIMITER)(" event" , " remove_group" )(" external_group_id" , externalGroupId)(
132
- " internal_group_id" , internalGroupId);
133
- UnregisterGroupImpl (internalGroupId);
134
- if (isPriorityProcess && (internalGroupId < GroupIds.GetMinInternalIdDef (internalGroupId))) {
135
- Y_UNUSED (TryAllocateWaiting (isPriorityProcess, 0 ));
130
+ if (auto internalGroupId = GroupIds.GetInternalIdOptional ()) {
131
+ AFL_INFO (NKikimrServices::GROUPED_MEMORY_LIMITER)(" event" , " remove_group" )(" external_group_id" , externalGroupId)(
132
+ " internal_group_id" , internalGroupId);
133
+ UnregisterGroupImpl (*internalGroupId);
134
+ if (isPriorityProcess && (*internalGroupId < GroupIds.GetMinInternalIdDef (*internalGroupId))) {
135
+ Y_UNUSED (TryAllocateWaiting (isPriorityProcess, 0 ));
136
+ }
137
+ } else {
138
+ AFL_WARN (NKikimrServices::GROUPED_MEMORY_LIMITER)(" event" , " remove_absent_group" )(" external_group_id" , externalGroupId);
136
139
}
137
140
}
138
141
You can’t perform that action at this time.
0 commit comments