@@ -115,16 +115,9 @@ namespace NKikimr::NStorage {
115
115
116
116
// forget pending queries
117
117
if (fromController) {
118
- group.GetGroupRequestPending = false ;
119
118
group.ProposeRequestPending = false ;
120
- } else if (fromResolver) {
121
- group.GetGroupRequestPending = false ;
122
- }
123
-
124
- if (group.GroupResolver && !group.GetGroupRequestPending ) {
125
- TActivationContext::Send (new IEventHandle (TEvents::TSystem::Poison, 0 , group.GroupResolver , {}, nullptr , 0 ));
126
- group.GroupResolver = {};
127
119
}
120
+ group.GetGroupRequestPending = false ;
128
121
129
122
// update group content and encryption stuff
130
123
bool groupChanged = false ; // did the 'Group' field change somehow?
@@ -260,6 +253,11 @@ namespace NKikimr::NStorage {
260
253
GroupPendingQueue.erase (it);
261
254
}
262
255
}
256
+
257
+ if (group.GroupResolver && group.Info ) {
258
+ TActivationContext::Send (new IEventHandle (TEvents::TSystem::Poison, 0 , group.GroupResolver , {}, nullptr , 0 ));
259
+ group.GroupResolver = {};
260
+ }
263
261
}
264
262
265
263
void TNodeWarden::RequestGroupConfig (ui32 groupId, TGroupRecord& group) {
@@ -273,6 +271,7 @@ namespace NKikimr::NStorage {
273
271
SendToController (std::make_unique<TEvBlobStorage::TEvControllerGetGroup>(LocalNodeId, &groupId, &groupId + 1 ));
274
272
group.GroupResolver = RegisterWithSameMailbox (CreateGroupResolverActor (groupId));
275
273
group.GetGroupRequestPending = true ;
274
+ Send (SelfId (), new TEvNodeWardenQueryCache (Sprintf (" G%08" PRIx32, groupId), true ));
276
275
}
277
276
}
278
277
0 commit comments