Skip to content

Commit 4efd471

Browse files
serbel324serbel324
authored
Wrap ctor arguments in structs (#7631)
1 parent eda17f9 commit 4efd471

18 files changed

+744
-545
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 & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -264,18 +264,12 @@ class TBlobStorageGroupAssimilateRequest : public TBlobStorageGroupRequestActor
264264
return ERequestType::Assimilate;
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-
NKikimrServices::TActivity::BS_GROUP_ASSIMILATE)
275-
, SkipBlocksUpTo(ev->SkipBlocksUpTo)
276-
, SkipBarriersUpTo(ev->SkipBarriersUpTo)
277-
, SkipBlobsUpTo(ev->SkipBlobsUpTo)
278-
, 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())
279273
, Result(new TEvBlobStorage::TEvAssimilateResult(NKikimrProto::OK, {}))
280274
{
281275
Heap.reserve(PerVDiskInfo.size());
@@ -465,11 +459,8 @@ class TBlobStorageGroupAssimilateRequest : public TBlobStorageGroupRequestActor
465459
}
466460
};
467461

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

475466
} // NKikimr

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

Lines changed: 9 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -132,20 +132,13 @@ class TBlobStorageGroupBlockRequest : public TBlobStorageGroupRequestActor {
132132
return ERequestType::Block;
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-
NKikimrServices::TActivity::BS_GROUP_BLOCK)
144-
, TabletId(ev->TabletId)
145-
, Generation(ev->Generation)
146-
, Deadline(ev->Deadline)
147-
, IssuerGuid(ev->IssuerGuid)
148-
, 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)
149142
, QuorumTracker(Info.Get())
150143
{}
151144

@@ -176,11 +169,8 @@ class TBlobStorageGroupBlockRequest : public TBlobStorageGroupRequestActor {
176169
}
177170
};
178171

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

186176
} // NKikimr

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

Lines changed: 17 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -140,28 +140,22 @@ class TBlobStorageGroupCollectGarbageRequest : public TBlobStorageGroupRequestAc
140140
return ERequestType::CollectGarbage;
141141
}
142142

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

167161
void Bootstrap() override {
@@ -205,12 +199,8 @@ class TBlobStorageGroupCollectGarbageRequest : public TBlobStorageGroupRequestAc
205199
}
206200
};
207201

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);
202+
IActor* CreateBlobStorageGroupCollectGarbageRequest(TBlobStorageGroupCollectGarbageParameters params) {
203+
return new TBlobStorageGroupCollectGarbageRequest(params);
214204
}
215205

216206
} // NKikimr

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

Lines changed: 12 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -869,25 +869,18 @@ class TBlobStorageGroupDiscoverRequest : public TBlobStorageGroupRequestActor {
869869
return ERequestType::Discover;
870870
}
871871

872-
TBlobStorageGroupDiscoverRequest(const TIntrusivePtr<TBlobStorageGroupInfo> &info,
873-
const TIntrusivePtr<TGroupQueues> &state, const TActorId &source,
874-
const TIntrusivePtr<TBlobStorageGroupProxyMon> mon, TEvBlobStorage::TEvDiscover *ev,
875-
ui64 cookie, NWilson::TTraceId traceId, TInstant now,
876-
TIntrusivePtr<TStoragePoolCounters> &storagePoolCounters)
877-
: TBlobStorageGroupRequestActor(info, state, mon, source, cookie,
878-
NKikimrServices::BS_PROXY_DISCOVER, true, {}, now, storagePoolCounters, ev->RestartCounter,
879-
std::move(traceId), "DSProxy.Discover", ev, std::move(ev->ExecutionRelay),
880-
NKikimrServices::TActivity::BS_GROUP_DISCOVER)
881-
, TabletId(ev->TabletId)
882-
, MinGeneration(ev->MinGeneration)
883-
, ReadBody(ev->ReadBody)
884-
, DiscoverBlockedGeneration(ev->DiscoverBlockedGeneration)
885-
, Deadline(ev->Deadline)
886-
, StartTime(now)
872+
TBlobStorageGroupDiscoverRequest(TBlobStorageGroupDiscoverParameters& params)
873+
: TBlobStorageGroupRequestActor(params)
874+
, TabletId(params.Common.Event->TabletId)
875+
, MinGeneration(params.Common.Event->MinGeneration)
876+
, ReadBody(params.Common.Event->ReadBody)
877+
, DiscoverBlockedGeneration(params.Common.Event->DiscoverBlockedGeneration)
878+
, Deadline(params.Common.Event->Deadline)
879+
, StartTime(params.Common.Now)
887880
, GroupResponseTracker(Info)
888881
, IsGetBlockDone(!DiscoverBlockedGeneration)
889-
, ForceBlockedGeneration(ev->ForceBlockedGeneration)
890-
, FromLeader(ev->FromLeader)
882+
, ForceBlockedGeneration(params.Common.Event->ForceBlockedGeneration)
883+
, FromLeader(params.Common.Event->FromLeader)
891884
{}
892885

893886
void Bootstrap() override {
@@ -965,13 +958,8 @@ class TBlobStorageGroupDiscoverRequest : public TBlobStorageGroupRequestActor {
965958
}
966959
};
967960

968-
IActor* CreateBlobStorageGroupDiscoverRequest(const TIntrusivePtr<TBlobStorageGroupInfo> &info,
969-
const TIntrusivePtr<TGroupQueues> &state, const TActorId &source,
970-
const TIntrusivePtr<TBlobStorageGroupProxyMon> &mon, TEvBlobStorage::TEvDiscover *ev,
971-
ui64 cookie, NWilson::TTraceId traceId, TInstant now,
972-
TIntrusivePtr<TStoragePoolCounters> &storagePoolCounters) {
973-
return new TBlobStorageGroupDiscoverRequest(info, state, source, mon, ev, cookie, std::move(traceId), now,
974-
storagePoolCounters);
961+
IActor* CreateBlobStorageGroupDiscoverRequest(TBlobStorageGroupDiscoverParameters params) {
962+
return new TBlobStorageGroupDiscoverRequest(params);
975963
}
976964

977965
}//NKikimr

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

Lines changed: 12 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -457,23 +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-
NKikimrServices::TActivity::BS_GROUP_DISCOVER)
469-
, TabletId(ev->TabletId)
470-
, MinGeneration(ev->MinGeneration)
471-
, StartTime(now)
472-
, Deadline(ev->Deadline)
473-
, ReadBody(ev->ReadBody)
474-
, DiscoverBlockedGeneration(ev->DiscoverBlockedGeneration)
475-
, ForceBlockedGeneration(ev->ForceBlockedGeneration)
476-
, 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)
477470
, GetBlockTracker(Info.Get())
478471
{}
479472

@@ -736,13 +729,8 @@ class TBlobStorageGroupMirror3dcDiscoverRequest : public TBlobStorageGroupReques
736729
}
737730
};
738731

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

748736
}//NKikimr

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

Lines changed: 12 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -27,23 +27,16 @@ class TBlobStorageGroupMirror3of4DiscoverRequest : public TBlobStorageGroupReque
2727
return ERequestType::Discover;
2828
}
2929

30-
TBlobStorageGroupMirror3of4DiscoverRequest(TIntrusivePtr<TBlobStorageGroupInfo> info,
31-
TIntrusivePtr<TGroupQueues> state, const TActorId& source,
32-
TIntrusivePtr<TBlobStorageGroupProxyMon> mon, TEvBlobStorage::TEvDiscover *ev,
33-
ui64 cookie, NWilson::TTraceId traceId, TInstant now,
34-
TIntrusivePtr<TStoragePoolCounters> &storagePoolCounters)
35-
: TBlobStorageGroupRequestActor(std::move(info), std::move(state), std::move(mon), source, cookie,
36-
NKikimrServices::BS_PROXY_DISCOVER, false, {}, now, storagePoolCounters, ev->RestartCounter,
37-
std::move(traceId), "DSProxy.Discover", ev, std::move(ev->ExecutionRelay),
38-
NKikimrServices::TActivity::BS_GROUP_DISCOVER)
39-
, TabletId(ev->TabletId)
40-
, MinGeneration(ev->MinGeneration)
41-
, StartTime(now)
42-
, Deadline(ev->Deadline)
43-
, ReadBody(ev->ReadBody)
44-
, DiscoverBlockedGeneration(ev->DiscoverBlockedGeneration)
45-
, ForceBlockedGeneration(ev->ForceBlockedGeneration)
46-
, FromLeader(ev->FromLeader)
30+
TBlobStorageGroupMirror3of4DiscoverRequest(TBlobStorageGroupDiscoverParameters& params)
31+
: TBlobStorageGroupRequestActor(params)
32+
, TabletId(params.Common.Event->TabletId)
33+
, MinGeneration(params.Common.Event->MinGeneration)
34+
, StartTime(params.Common.Now)
35+
, Deadline(params.Common.Event->Deadline)
36+
, ReadBody(params.Common.Event->ReadBody)
37+
, DiscoverBlockedGeneration(params.Common.Event->DiscoverBlockedGeneration)
38+
, ForceBlockedGeneration(params.Common.Event->ForceBlockedGeneration)
39+
, FromLeader(params.Common.Event->FromLeader)
4740
{
4841
for (size_t i = 0; i < DiskState.size(); ++i) {
4942
TDiskState& disk = DiskState[i];
@@ -363,13 +356,8 @@ class TBlobStorageGroupMirror3of4DiscoverRequest : public TBlobStorageGroupReque
363356
}
364357
};
365358

366-
IActor* CreateBlobStorageGroupMirror3of4DiscoverRequest(const TIntrusivePtr<TBlobStorageGroupInfo> &info,
367-
const TIntrusivePtr<TGroupQueues> &state, const TActorId &source,
368-
const TIntrusivePtr<TBlobStorageGroupProxyMon> &mon, TEvBlobStorage::TEvDiscover *ev,
369-
ui64 cookie, NWilson::TTraceId traceId, TInstant now,
370-
TIntrusivePtr<TStoragePoolCounters> &storagePoolCounters) {
371-
return new TBlobStorageGroupMirror3of4DiscoverRequest(info, state, source, mon, ev, cookie, std::move(traceId), now,
372-
storagePoolCounters);
359+
IActor* CreateBlobStorageGroupMirror3of4DiscoverRequest(TBlobStorageGroupDiscoverParameters params) {
360+
return new TBlobStorageGroupMirror3of4DiscoverRequest(params);
373361
}
374362

375363
}//NKikimr

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

Lines changed: 13 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -395,28 +395,23 @@ class TBlobStorageGroupGetRequest : public TBlobStorageGroupRequestActor {
395395
return ERequestType::Get;
396396
}
397397

398-
TBlobStorageGroupGetRequest(const TIntrusivePtr<TBlobStorageGroupInfo> &info,
399-
const TIntrusivePtr<TGroupQueues> &state, const TActorId &source,
400-
const TIntrusivePtr<TBlobStorageGroupProxyMon> &mon, TEvBlobStorage::TEvGet *ev, ui64 cookie,
401-
NWilson::TTraceId&& traceId, TNodeLayoutInfoPtr&& nodeLayout, TMaybe<TGroupStat::EKind> latencyQueueKind,
402-
TInstant now, TIntrusivePtr<TStoragePoolCounters> &storagePoolCounters)
403-
: TBlobStorageGroupRequestActor(info, state, mon, source, cookie,
404-
NKikimrServices::BS_PROXY_GET, ev->IsVerboseNoDataEnabled || ev->CollectDebugInfo,
405-
latencyQueueKind, now, storagePoolCounters, ev->RestartCounter, std::move(traceId), "DSProxy.Get", ev,
406-
std::move(ev->ExecutionRelay), NKikimrServices::TActivity::BS_PROXY_GET_ACTOR)
407-
, GetImpl(info, state, ev, std::move(nodeLayout), LogCtx.RequestPrefix)
408-
, Orbit(std::move(ev->Orbit))
409-
, Deadline(ev->Deadline)
410-
, StartTime(now)
398+
TBlobStorageGroupGetRequest(TBlobStorageGroupGetParameters& params)
399+
: TBlobStorageGroupRequestActor(params)
400+
, GetImpl(Info, GroupQueues, params.Common.Event, std::move(params.NodeLayout),
401+
LogCtx.RequestPrefix)
402+
, Orbit(std::move(params.Common.Event->Orbit))
403+
, Deadline(params.Common.Event->Deadline)
404+
, StartTime(params.Common.Now)
411405
, StartTimePut(StartTime)
412-
, GroupSize(info->Type.BlobSubgroupSize())
406+
, GroupSize(Info->Type.BlobSubgroupSize())
413407
, ReportedBytes(0)
414408
{
415409
ReportBytes(sizeof(*this));
416-
MaxSaneRequests = ev->QuerySize * info->Type.TotalPartCount() * (1 + info->Type.Handoff()) * 3;
410+
MaxSaneRequests = params.Common.Event->QuerySize * Info->Type.TotalPartCount() *
411+
(1 + Info->Type.Handoff()) * 3;
417412

418413
RequestBytes = GetImpl.CountRequestBytes();
419-
RequestHandleClass = HandleClassToHandleClass(ev->GetHandleClass);
414+
RequestHandleClass = HandleClassToHandleClass(params.Common.Event->GetHandleClass);
420415
if (Orbit.HasShuttles()) {
421416
RootCauseTrack.IsOn = true;
422417
}
@@ -468,14 +463,8 @@ class TBlobStorageGroupGetRequest : public TBlobStorageGroupRequestActor {
468463
}
469464
};
470465

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

481470
}//NKikimr

0 commit comments

Comments
 (0)