Skip to content

Commit 5371a0b

Browse files
serbel324serbel324
committed
Wrap ctor arguments in structs (#7631)
1 parent c2e94d8 commit 5371a0b

18 files changed

+747
-531
lines changed

‎ydb/core/blobstorage/dsproxy/dsproxy.h

Lines changed: 194 additions & 106 deletions
Large diffs are not rendered by default.

‎ydb/core/blobstorage/dsproxy/dsproxy_assimilate.cpp

Lines changed: 8 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -264,17 +264,12 @@ class TBlobStorageGroupAssimilateRequest : public TBlobStorageGroupRequestActor<
264264
return mon->ActiveAssimilate;
265265
}
266266

267-
TBlobStorageGroupAssimilateRequest(const TIntrusivePtr<TBlobStorageGroupInfo>& info,
268-
const TIntrusivePtr<TGroupQueues>& state, const TActorId& source,
269-
const TIntrusivePtr<TBlobStorageGroupProxyMon>& mon, TEvBlobStorage::TEvAssimilate *ev, ui64 cookie,
270-
NWilson::TTraceId traceId, TInstant now, TIntrusivePtr<TStoragePoolCounters>& storagePoolCounters)
271-
: TBlobStorageGroupRequestActor(info, state, mon, source, cookie,
272-
NKikimrServices::BS_PROXY_ASSIMILATE, false, {}, now, storagePoolCounters, ev->RestartCounter,
273-
std::move(traceId), "DSProxy.Assimilate", ev, std::move(ev->ExecutionRelay))
274-
, SkipBlocksUpTo(ev->SkipBlocksUpTo)
275-
, SkipBarriersUpTo(ev->SkipBarriersUpTo)
276-
, SkipBlobsUpTo(ev->SkipBlobsUpTo)
277-
, PerVDiskInfo(info->GetTotalVDisksNum())
267+
TBlobStorageGroupAssimilateRequest(TBlobStorageGroupAssimilateParameters& params)
268+
: TBlobStorageGroupRequestActor(params)
269+
, SkipBlocksUpTo(params.Common.Event->SkipBlocksUpTo)
270+
, SkipBarriersUpTo(params.Common.Event->SkipBarriersUpTo)
271+
, SkipBlobsUpTo(params.Common.Event->SkipBlobsUpTo)
272+
, PerVDiskInfo(Info->GetTotalVDisksNum())
278273
, Result(new TEvBlobStorage::TEvAssimilateResult(NKikimrProto::OK, {}))
279274
{
280275
Heap.reserve(PerVDiskInfo.size());
@@ -464,11 +459,8 @@ class TBlobStorageGroupAssimilateRequest : public TBlobStorageGroupRequestActor<
464459
}
465460
};
466461

467-
IActor* CreateBlobStorageGroupAssimilateRequest(const TIntrusivePtr<TBlobStorageGroupInfo>& info,
468-
const TIntrusivePtr<TGroupQueues>& state, const TActorId& source,
469-
const TIntrusivePtr<TBlobStorageGroupProxyMon>& mon, TEvBlobStorage::TEvAssimilate *ev,
470-
ui64 cookie, NWilson::TTraceId traceId, TInstant now, TIntrusivePtr<TStoragePoolCounters>& storagePoolCounters) {
471-
return new TBlobStorageGroupAssimilateRequest(info, state, source, mon, ev, cookie, std::move(traceId), now, storagePoolCounters);
462+
IActor* CreateBlobStorageGroupAssimilateRequest(TBlobStorageGroupAssimilateParameters params) {
463+
return new TBlobStorageGroupAssimilateRequest(params);
472464
}
473465

474466
} // NKikimr

‎ydb/core/blobstorage/dsproxy/dsproxy_block.cpp

Lines changed: 9 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -132,19 +132,13 @@ class TBlobStorageGroupBlockRequest : public TBlobStorageGroupRequestActor<TBlob
132132
return mon->ActiveBlock;
133133
}
134134

135-
TBlobStorageGroupBlockRequest(const TIntrusivePtr<TBlobStorageGroupInfo> &info,
136-
const TIntrusivePtr<TGroupQueues> &state, const TActorId &source,
137-
const TIntrusivePtr<TBlobStorageGroupProxyMon> &mon, TEvBlobStorage::TEvBlock *ev,
138-
ui64 cookie, NWilson::TTraceId&& traceId, TInstant now,
139-
TIntrusivePtr<TStoragePoolCounters> &storagePoolCounters)
140-
: TBlobStorageGroupRequestActor(info, state, mon, source, cookie,
141-
NKikimrServices::BS_PROXY_BLOCK, false, {}, now, storagePoolCounters, ev->RestartCounter,
142-
std::move(traceId), "DSProxy.Block", ev, std::move(ev->ExecutionRelay))
143-
, TabletId(ev->TabletId)
144-
, Generation(ev->Generation)
145-
, Deadline(ev->Deadline)
146-
, IssuerGuid(ev->IssuerGuid)
147-
, StartTime(now)
135+
TBlobStorageGroupBlockRequest(TBlobStorageGroupBlockParameters& params)
136+
: TBlobStorageGroupRequestActor(params)
137+
, TabletId(params.Common.Event->TabletId)
138+
, Generation(params.Common.Event->Generation)
139+
, Deadline(params.Common.Event->Deadline)
140+
, IssuerGuid(params.Common.Event->IssuerGuid)
141+
, StartTime(params.Common.Now)
148142
, QuorumTracker(Info.Get())
149143
{}
150144

@@ -175,11 +169,8 @@ class TBlobStorageGroupBlockRequest : public TBlobStorageGroupRequestActor<TBlob
175169
}
176170
};
177171

178-
IActor* CreateBlobStorageGroupBlockRequest(const TIntrusivePtr<TBlobStorageGroupInfo> &info,
179-
const TIntrusivePtr<TGroupQueues> &state, const TActorId &source,
180-
const TIntrusivePtr<TBlobStorageGroupProxyMon> &mon, TEvBlobStorage::TEvBlock *ev,
181-
ui64 cookie, NWilson::TTraceId traceId, TInstant now, TIntrusivePtr<TStoragePoolCounters> &storagePoolCounters) {
182-
return new TBlobStorageGroupBlockRequest(info, state, source, mon, ev, cookie, std::move(traceId), now, storagePoolCounters);
172+
IActor* CreateBlobStorageGroupBlockRequest(TBlobStorageGroupBlockParameters params) {
173+
return new TBlobStorageGroupBlockRequest(params);
183174
}
184175

185176
} // NKikimr

‎ydb/core/blobstorage/dsproxy/dsproxy_collect.cpp

Lines changed: 17 additions & 26 deletions
Original file line numberDiff line numberDiff line change
@@ -141,27 +141,22 @@ class TBlobStorageGroupCollectGarbageRequest : public TBlobStorageGroupRequestAc
141141
return mon->ActiveCollectGarbage;
142142
}
143143

144-
TBlobStorageGroupCollectGarbageRequest(const TIntrusivePtr<TBlobStorageGroupInfo> &info,
145-
const TIntrusivePtr<TGroupQueues> &state, const TActorId &source,
146-
const TIntrusivePtr<TBlobStorageGroupProxyMon> &mon, TEvBlobStorage::TEvCollectGarbage *ev, ui64 cookie,
147-
NWilson::TTraceId traceId, TInstant now, TIntrusivePtr<TStoragePoolCounters> &storagePoolCounters)
148-
: TBlobStorageGroupRequestActor(info, state, mon, source, cookie,
149-
NKikimrServices::BS_PROXY_COLLECT, false, {}, now, storagePoolCounters, ev->RestartCounter,
150-
std::move(traceId), "DSProxy.CollectGarbage", ev, std::move(ev->ExecutionRelay))
151-
, TabletId(ev->TabletId)
152-
, RecordGeneration(ev->RecordGeneration)
153-
, PerGenerationCounter(ev->PerGenerationCounter)
154-
, Channel(ev->Channel)
155-
, Deadline(ev->Deadline)
156-
, Keep(ev->Keep.Release())
157-
, DoNotKeep(ev->DoNotKeep.Release())
158-
, CollectGeneration(ev->CollectGeneration)
159-
, CollectStep(ev->CollectStep)
160-
, Hard(ev->Hard)
161-
, Collect(ev->Collect)
162-
, Decommission(ev->Decommission)
144+
TBlobStorageGroupCollectGarbageRequest(TBlobStorageGroupCollectGarbageParameters& params)
145+
: TBlobStorageGroupRequestActor(params)
146+
, TabletId(params.Common.Event->TabletId)
147+
, RecordGeneration(params.Common.Event->RecordGeneration)
148+
, PerGenerationCounter(params.Common.Event->PerGenerationCounter)
149+
, Channel(params.Common.Event->Channel)
150+
, Deadline(params.Common.Event->Deadline)
151+
, Keep(params.Common.Event->Keep.Release())
152+
, DoNotKeep(params.Common.Event->DoNotKeep.Release())
153+
, CollectGeneration(params.Common.Event->CollectGeneration)
154+
, CollectStep(params.Common.Event->CollectStep)
155+
, Hard(params.Common.Event->Hard)
156+
, Collect(params.Common.Event->Collect)
157+
, Decommission(params.Common.Event->Decommission)
163158
, QuorumTracker(Info.Get())
164-
, StartTime(now)
159+
, StartTime(params.Common.Now)
165160
{}
166161

167162
void Bootstrap() {
@@ -205,12 +200,8 @@ class TBlobStorageGroupCollectGarbageRequest : public TBlobStorageGroupRequestAc
205200
}
206201
};
207202

208-
IActor* CreateBlobStorageGroupCollectGarbageRequest(const TIntrusivePtr<TBlobStorageGroupInfo> &info,
209-
const TIntrusivePtr<TGroupQueues> &state, const TActorId &source,
210-
const TIntrusivePtr<TBlobStorageGroupProxyMon> &mon, TEvBlobStorage::TEvCollectGarbage *ev,
211-
ui64 cookie, NWilson::TTraceId traceId, TInstant now, TIntrusivePtr<TStoragePoolCounters> &storagePoolCounters) {
212-
return new TBlobStorageGroupCollectGarbageRequest(info, state, source, mon, ev, cookie, std::move(traceId), now,
213-
storagePoolCounters);
203+
IActor* CreateBlobStorageGroupCollectGarbageRequest(TBlobStorageGroupCollectGarbageParameters params) {
204+
return new TBlobStorageGroupCollectGarbageRequest(params);
214205
}
215206

216207
} // NKikimr

‎ydb/core/blobstorage/dsproxy/dsproxy_discover.cpp

Lines changed: 12 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -877,24 +877,18 @@ class TBlobStorageGroupDiscoverRequest : public TBlobStorageGroupRequestActor<TB
877877
return ERequestType::Discover;
878878
}
879879

880-
TBlobStorageGroupDiscoverRequest(const TIntrusivePtr<TBlobStorageGroupInfo> &info,
881-
const TIntrusivePtr<TGroupQueues> &state, const TActorId &source,
882-
const TIntrusivePtr<TBlobStorageGroupProxyMon> mon, TEvBlobStorage::TEvDiscover *ev,
883-
ui64 cookie, NWilson::TTraceId traceId, TInstant now,
884-
TIntrusivePtr<TStoragePoolCounters> &storagePoolCounters)
885-
: TBlobStorageGroupRequestActor(info, state, mon, source, cookie,
886-
NKikimrServices::BS_PROXY_DISCOVER, true, {}, now, storagePoolCounters, ev->RestartCounter,
887-
std::move(traceId), "DSProxy.Discover", ev, std::move(ev->ExecutionRelay))
888-
, TabletId(ev->TabletId)
889-
, MinGeneration(ev->MinGeneration)
890-
, ReadBody(ev->ReadBody)
891-
, DiscoverBlockedGeneration(ev->DiscoverBlockedGeneration)
892-
, Deadline(ev->Deadline)
893-
, StartTime(now)
880+
TBlobStorageGroupDiscoverRequest(TBlobStorageGroupDiscoverParameters& params)
881+
: TBlobStorageGroupRequestActor(params)
882+
, TabletId(params.Common.Event->TabletId)
883+
, MinGeneration(params.Common.Event->MinGeneration)
884+
, ReadBody(params.Common.Event->ReadBody)
885+
, DiscoverBlockedGeneration(params.Common.Event->DiscoverBlockedGeneration)
886+
, Deadline(params.Common.Event->Deadline)
887+
, StartTime(params.Common.Now)
894888
, GroupResponseTracker(Info)
895889
, IsGetBlockDone(!DiscoverBlockedGeneration)
896-
, ForceBlockedGeneration(ev->ForceBlockedGeneration)
897-
, FromLeader(ev->FromLeader)
890+
, ForceBlockedGeneration(params.Common.Event->ForceBlockedGeneration)
891+
, FromLeader(params.Common.Event->FromLeader)
898892
{}
899893

900894
void Bootstrap() {
@@ -973,13 +967,8 @@ class TBlobStorageGroupDiscoverRequest : public TBlobStorageGroupRequestActor<TB
973967
}
974968
};
975969

976-
IActor* CreateBlobStorageGroupDiscoverRequest(const TIntrusivePtr<TBlobStorageGroupInfo> &info,
977-
const TIntrusivePtr<TGroupQueues> &state, const TActorId &source,
978-
const TIntrusivePtr<TBlobStorageGroupProxyMon> &mon, TEvBlobStorage::TEvDiscover *ev,
979-
ui64 cookie, NWilson::TTraceId traceId, TInstant now,
980-
TIntrusivePtr<TStoragePoolCounters> &storagePoolCounters) {
981-
return new TBlobStorageGroupDiscoverRequest(info, state, source, mon, ev, cookie, std::move(traceId), now,
982-
storagePoolCounters);
970+
IActor* CreateBlobStorageGroupDiscoverRequest(TBlobStorageGroupDiscoverParameters params) {
971+
return new TBlobStorageGroupDiscoverRequest(params);
983972
}
984973

985974
}//NKikimr

‎ydb/core/blobstorage/dsproxy/dsproxy_discover_m3dc.cpp

Lines changed: 12 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -457,22 +457,16 @@ class TBlobStorageGroupMirror3dcDiscoverRequest : public TBlobStorageGroupReques
457457
return ERequestType::Discover;
458458
}
459459

460-
TBlobStorageGroupMirror3dcDiscoverRequest(TIntrusivePtr<TBlobStorageGroupInfo> info,
461-
TIntrusivePtr<TGroupQueues> state, const TActorId& source,
462-
TIntrusivePtr<TBlobStorageGroupProxyMon> mon, TEvBlobStorage::TEvDiscover *ev,
463-
ui64 cookie, NWilson::TTraceId traceId, TInstant now,
464-
TIntrusivePtr<TStoragePoolCounters> &storagePoolCounters)
465-
: TBlobStorageGroupRequestActor(std::move(info), std::move(state), std::move(mon), source, cookie,
466-
NKikimrServices::BS_PROXY_DISCOVER, false, {}, now, storagePoolCounters, ev->RestartCounter,
467-
std::move(traceId), "DSProxy.Discover", ev, std::move(ev->ExecutionRelay))
468-
, TabletId(ev->TabletId)
469-
, MinGeneration(ev->MinGeneration)
470-
, StartTime(now)
471-
, Deadline(ev->Deadline)
472-
, ReadBody(ev->ReadBody)
473-
, DiscoverBlockedGeneration(ev->DiscoverBlockedGeneration)
474-
, ForceBlockedGeneration(ev->ForceBlockedGeneration)
475-
, FromLeader(ev->FromLeader)
460+
TBlobStorageGroupMirror3dcDiscoverRequest(TBlobStorageGroupDiscoverParameters& params)
461+
: TBlobStorageGroupRequestActor(params)
462+
, TabletId(params.Common.Event->TabletId)
463+
, MinGeneration(params.Common.Event->MinGeneration)
464+
, StartTime(params.Common.Now)
465+
, Deadline(params.Common.Event->Deadline)
466+
, ReadBody(params.Common.Event->ReadBody)
467+
, DiscoverBlockedGeneration(params.Common.Event->DiscoverBlockedGeneration)
468+
, ForceBlockedGeneration(params.Common.Event->ForceBlockedGeneration)
469+
, FromLeader(params.Common.Event->FromLeader)
476470
, GetBlockTracker(Info.Get())
477471
{}
478472

@@ -737,13 +731,8 @@ class TBlobStorageGroupMirror3dcDiscoverRequest : public TBlobStorageGroupReques
737731
}
738732
};
739733

740-
IActor* CreateBlobStorageGroupMirror3dcDiscoverRequest(const TIntrusivePtr<TBlobStorageGroupInfo> &info,
741-
const TIntrusivePtr<TGroupQueues> &state, const TActorId &source,
742-
const TIntrusivePtr<TBlobStorageGroupProxyMon> &mon, TEvBlobStorage::TEvDiscover *ev,
743-
ui64 cookie, NWilson::TTraceId traceId, TInstant now,
744-
TIntrusivePtr<TStoragePoolCounters> &storagePoolCounters) {
745-
return new TBlobStorageGroupMirror3dcDiscoverRequest(info, state, source, mon, ev, cookie, std::move(traceId), now,
746-
storagePoolCounters);
734+
IActor* CreateBlobStorageGroupMirror3dcDiscoverRequest(TBlobStorageGroupDiscoverParameters params) {
735+
return new TBlobStorageGroupMirror3dcDiscoverRequest(params);
747736
}
748737

749738
}//NKikimr

‎ydb/core/blobstorage/dsproxy/dsproxy_discover_m3of4.cpp

Lines changed: 12 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -29,22 +29,16 @@ class TBlobStorageGroupMirror3of4DiscoverRequest
2929
return ERequestType::Discover;
3030
}
3131

32-
TBlobStorageGroupMirror3of4DiscoverRequest(TIntrusivePtr<TBlobStorageGroupInfo> info,
33-
TIntrusivePtr<TGroupQueues> state, const TActorId& source,
34-
TIntrusivePtr<TBlobStorageGroupProxyMon> mon, TEvBlobStorage::TEvDiscover *ev,
35-
ui64 cookie, NWilson::TTraceId traceId, TInstant now,
36-
TIntrusivePtr<TStoragePoolCounters> &storagePoolCounters)
37-
: TBlobStorageGroupRequestActor(std::move(info), std::move(state), std::move(mon), source, cookie,
38-
NKikimrServices::BS_PROXY_DISCOVER, false, {}, now, storagePoolCounters, ev->RestartCounter,
39-
std::move(traceId), "DSProxy.Discover", ev, std::move(ev->ExecutionRelay))
40-
, TabletId(ev->TabletId)
41-
, MinGeneration(ev->MinGeneration)
42-
, StartTime(now)
43-
, Deadline(ev->Deadline)
44-
, ReadBody(ev->ReadBody)
45-
, DiscoverBlockedGeneration(ev->DiscoverBlockedGeneration)
46-
, ForceBlockedGeneration(ev->ForceBlockedGeneration)
47-
, FromLeader(ev->FromLeader)
32+
TBlobStorageGroupMirror3of4DiscoverRequest(TBlobStorageGroupDiscoverParameters& params)
33+
: TBlobStorageGroupRequestActor(params)
34+
, TabletId(params.Common.Event->TabletId)
35+
, MinGeneration(params.Common.Event->MinGeneration)
36+
, StartTime(params.Common.Now)
37+
, Deadline(params.Common.Event->Deadline)
38+
, ReadBody(params.Common.Event->ReadBody)
39+
, DiscoverBlockedGeneration(params.Common.Event->DiscoverBlockedGeneration)
40+
, ForceBlockedGeneration(params.Common.Event->ForceBlockedGeneration)
41+
, FromLeader(params.Common.Event->FromLeader)
4842
{
4943
for (size_t i = 0; i < DiskState.size(); ++i) {
5044
TDiskState& disk = DiskState[i];
@@ -360,13 +354,8 @@ class TBlobStorageGroupMirror3of4DiscoverRequest
360354
}
361355
};
362356

363-
IActor* CreateBlobStorageGroupMirror3of4DiscoverRequest(const TIntrusivePtr<TBlobStorageGroupInfo> &info,
364-
const TIntrusivePtr<TGroupQueues> &state, const TActorId &source,
365-
const TIntrusivePtr<TBlobStorageGroupProxyMon> &mon, TEvBlobStorage::TEvDiscover *ev,
366-
ui64 cookie, NWilson::TTraceId traceId, TInstant now,
367-
TIntrusivePtr<TStoragePoolCounters> &storagePoolCounters) {
368-
return new TBlobStorageGroupMirror3of4DiscoverRequest(info, state, source, mon, ev, cookie, std::move(traceId), now,
369-
storagePoolCounters);
357+
IActor* CreateBlobStorageGroupMirror3of4DiscoverRequest(TBlobStorageGroupDiscoverParameters params) {
358+
return new TBlobStorageGroupMirror3of4DiscoverRequest(params);
370359
}
371360

372361
}//NKikimr

‎ydb/core/blobstorage/dsproxy/dsproxy_get.cpp

Lines changed: 13 additions & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -388,32 +388,23 @@ class TBlobStorageGroupGetRequest : public TBlobStorageGroupRequestActor<TBlobSt
388388
return ERequestType::Get;
389389
}
390390

391-
static const auto& ActiveCounter(const TIntrusivePtr<TBlobStorageGroupProxyMon>& mon) {
392-
return mon->ActiveGet;
393-
}
394-
395-
TBlobStorageGroupGetRequest(const TIntrusivePtr<TBlobStorageGroupInfo> &info,
396-
const TIntrusivePtr<TGroupQueues> &state, const TActorId &source,
397-
const TIntrusivePtr<TBlobStorageGroupProxyMon> &mon, TEvBlobStorage::TEvGet *ev, ui64 cookie,
398-
NWilson::TTraceId&& traceId, TNodeLayoutInfoPtr&& nodeLayout, TMaybe<TGroupStat::EKind> latencyQueueKind,
399-
TInstant now, TIntrusivePtr<TStoragePoolCounters> &storagePoolCounters)
400-
: TBlobStorageGroupRequestActor(info, state, mon, source, cookie,
401-
NKikimrServices::BS_PROXY_GET, ev->IsVerboseNoDataEnabled || ev->CollectDebugInfo,
402-
latencyQueueKind, now, storagePoolCounters, ev->RestartCounter, std::move(traceId), "DSProxy.Get", ev,
403-
std::move(ev->ExecutionRelay))
404-
, GetImpl(info, state, ev, std::move(nodeLayout), LogCtx.RequestPrefix)
405-
, Orbit(std::move(ev->Orbit))
406-
, Deadline(ev->Deadline)
407-
, StartTime(now)
391+
TBlobStorageGroupGetRequest(TBlobStorageGroupGetParameters& params)
392+
: TBlobStorageGroupRequestActor(params)
393+
, GetImpl(Info, GroupQueues, params.Common.Event, std::move(params.NodeLayout),
394+
LogCtx.RequestPrefix)
395+
, Orbit(std::move(params.Common.Event->Orbit))
396+
, Deadline(params.Common.Event->Deadline)
397+
, StartTime(params.Common.Now)
408398
, StartTimePut(StartTime)
409-
, GroupSize(info->Type.BlobSubgroupSize())
399+
, GroupSize(Info->Type.BlobSubgroupSize())
410400
, ReportedBytes(0)
411401
{
412402
ReportBytes(sizeof(*this));
413-
MaxSaneRequests = ev->QuerySize * info->Type.TotalPartCount() * (1 + info->Type.Handoff()) * 3;
403+
MaxSaneRequests = params.Common.Event->QuerySize * Info->Type.TotalPartCount() *
404+
(1 + Info->Type.Handoff()) * 3;
414405

415406
RequestBytes = GetImpl.CountRequestBytes();
416-
RequestHandleClass = HandleClassToHandleClass(ev->GetHandleClass);
407+
RequestHandleClass = HandleClassToHandleClass(params.Common.Event->GetHandleClass);
417408
if (Orbit.HasShuttles()) {
418409
RootCauseTrack.IsOn = true;
419410
}
@@ -466,14 +457,8 @@ class TBlobStorageGroupGetRequest : public TBlobStorageGroupRequestActor<TBlobSt
466457
}
467458
};
468459

469-
IActor* CreateBlobStorageGroupGetRequest(const TIntrusivePtr<TBlobStorageGroupInfo> &info,
470-
const TIntrusivePtr<TGroupQueues> &state, const TActorId &source,
471-
const TIntrusivePtr<TBlobStorageGroupProxyMon> &mon, TEvBlobStorage::TEvGet *ev,
472-
ui64 cookie, NWilson::TTraceId traceId, TNodeLayoutInfoPtr&& nodeLayout,
473-
TMaybe<TGroupStat::EKind> latencyQueueKind, TInstant now,
474-
TIntrusivePtr<TStoragePoolCounters> &storagePoolCounters) {
475-
return new TBlobStorageGroupGetRequest(info, state, source, mon, ev, cookie, std::move(traceId),
476-
std::move(nodeLayout), latencyQueueKind, now, storagePoolCounters);
460+
IActor* CreateBlobStorageGroupGetRequest(TBlobStorageGroupGetParameters params) {
461+
return new TBlobStorageGroupGetRequest(params);
477462
}
478463

479464
}//NKikimr

0 commit comments

Comments
 (0)