diff options
-rw-r--r-- | ydb/core/blobstorage/backpressure/queue.cpp | 12 | ||||
-rw-r--r-- | ydb/core/blobstorage/backpressure/queue.h | 4 | ||||
-rw-r--r-- | ydb/core/blobstorage/backpressure/queue_backpressure_client.cpp | 6 | ||||
-rw-r--r-- | ydb/core/blobstorage/backpressure/queue_backpressure_client.h | 8 | ||||
-rw-r--r-- | ydb/core/blobstorage/dsproxy/dsproxy.h | 14 | ||||
-rw-r--r-- | ydb/core/blobstorage/dsproxy/dsproxy_monactor.cpp | 8 | ||||
-rw-r--r-- | ydb/core/blobstorage/dsproxy/dsproxy_state.cpp | 2 | ||||
-rw-r--r-- | ydb/core/blobstorage/dsproxy/group_sessions.cpp | 75 | ||||
-rw-r--r-- | ydb/core/blobstorage/dsproxy/group_sessions.h | 10 | ||||
-rw-r--r-- | ydb/core/blobstorage/storagepoolmon/storagepool_counters.h | 6 | ||||
-rw-r--r-- | ydb/core/blobstorage/ut_vdisk/lib/helpers.cpp | 2 | ||||
-rw-r--r-- | ydb/core/blobstorage/vdisk/common/vdisk_costmodel.cpp | 22 | ||||
-rw-r--r-- | ydb/core/blobstorage/vdisk/common/vdisk_costmodel.h | 5 |
13 files changed, 48 insertions, 126 deletions
diff --git a/ydb/core/blobstorage/backpressure/queue.cpp b/ydb/core/blobstorage/backpressure/queue.cpp index 0977eed6bf..f16a73bcfc 100644 --- a/ydb/core/blobstorage/backpressure/queue.cpp +++ b/ydb/core/blobstorage/backpressure/queue.cpp @@ -11,7 +11,7 @@ TBlobStorageQueue::TBlobStorageQueue(const TIntrusivePtr<::NMonitoring::TDynamic , NextMsgId(0) , CurrentSequenceId(1) , LogPrefix(logPrefix) - , CostModel(std::make_shared<const TCostModel>(2000, 100000000, 50000000, 540000, 540000, 500000, gType)) // default cost model + , CostModel(2000, 100000000, 50000000, 540000, 540000, 500000, gType) // default cost model , BSProxyCtx(bspctx) , ClientId(clientId) , BytesWaiting(0) @@ -52,8 +52,8 @@ TBlobStorageQueue::~TBlobStorageQueue() { void TBlobStorageQueue::UpdateCostModel(TInstant now, const NKikimrBlobStorage::TVDiskCostSettings& settings, const TBlobStorageGroupType& type) { TCostModel newCostModel(settings, type); - if (newCostModel != *CostModel) { - CostModel = std::make_shared<const TCostModel>(std::move(newCostModel)); + if (newCostModel != CostModel) { + CostModel = std::move(newCostModel); InvalidateCosts(); } CostSettingsUpdate = now + TDuration::Minutes(1); @@ -78,8 +78,8 @@ bool TBlobStorageQueue::SetMaxWindowSize(ui64 maxWindowSize) { } } -std::shared_ptr<const TCostModel> TBlobStorageQueue::GetCostModel() const { - return CostModel; +ui32 TBlobStorageQueue::GetMinREALHugeBlobInBytes() const { + return CostModel.MinREALHugeBlobInBytes; } void TBlobStorageQueue::SetItemQueue(TItem& item, EItemQueue newQueue) { @@ -141,7 +141,7 @@ void TBlobStorageQueue::SendToVDisk(const TActorContext& ctx, const TActorId& re // update item's cost if it is dirty if (item.DirtyCost) { - item.Cost = CostModel->CalculateCost(item.CostEssence); + item.Cost = CostModel.CalculateCost(item.CostEssence); item.DirtyCost = false; } diff --git a/ydb/core/blobstorage/backpressure/queue.h b/ydb/core/blobstorage/backpressure/queue.h index f6667aef89..c5d8387e2c 100644 --- a/ydb/core/blobstorage/backpressure/queue.h +++ b/ydb/core/blobstorage/backpressure/queue.h @@ -116,7 +116,7 @@ class TBlobStorageQueue { TString& LogPrefix; - std::shared_ptr<const TCostModel> CostModel; + TCostModel CostModel; TInstant CostSettingsUpdate; TBSProxyContextPtr BSProxyCtx; @@ -184,7 +184,7 @@ public: const TBlobStorageGroupType& type); void InvalidateCosts(); bool SetMaxWindowSize(ui64 maxWindowSize); - std::shared_ptr<const TCostModel> GetCostModel() const; + ui32 GetMinREALHugeBlobInBytes() const; void SetItemQueue(TItem& item, EItemQueue newQueue); diff --git a/ydb/core/blobstorage/backpressure/queue_backpressure_client.cpp b/ydb/core/blobstorage/backpressure/queue_backpressure_client.cpp index 0fcaab8426..9f4aa973f6 100644 --- a/ydb/core/blobstorage/backpressure/queue_backpressure_client.cpp +++ b/ydb/core/blobstorage/backpressure/queue_backpressure_client.cpp @@ -456,7 +456,7 @@ private: case EState::READY: QLOG_NOTICE_S("BSQ96", "connection lost status# " << NKikimrProto::EReplyStatus_Name(status) << " errorReason# " << errorReason << " timeout# " << timeout); - ctx.Send(BlobStorageProxy, new TEvProxyQueueState(VDiskId, QueueId, false, false, nullptr)); + ctx.Send(BlobStorageProxy, new TEvProxyQueueState(VDiskId, QueueId, false, false, 0)); Queue.DrainQueue(status, TStringBuilder() << "BS_QUEUE: " << errorReason, ctx); DrainStatus(status, ctx); DrainAssimilate(status, errorReason, ctx); @@ -563,7 +563,7 @@ private: Queue.UpdateCostModel(ctx.Now(), record.GetCostSettings(), GType); } ctx.Send(BlobStorageProxy, new TEvProxyQueueState(VDiskId, QueueId, true, ExtraBlockChecksSupport, - Queue.GetCostModel())); + Queue.GetMinREALHugeBlobInBytes())); Queue.OnConnect(); State = EState::READY; } else { @@ -799,7 +799,7 @@ private: << " VDiskId# " << VDiskId << " IsConnected# " << isConnected); ctx.Send(ev->Sender, new TEvProxyQueueState(VDiskId, QueueId, isConnected, isConnected && ExtraBlockChecksSupport, - Queue.GetCostModel())); + Queue.GetMinREALHugeBlobInBytes())); } #define QueueRequestHFunc(TEvType) \ diff --git a/ydb/core/blobstorage/backpressure/queue_backpressure_client.h b/ydb/core/blobstorage/backpressure/queue_backpressure_client.h index 4a5c5828b2..971b8e00fa 100644 --- a/ydb/core/blobstorage/backpressure/queue_backpressure_client.h +++ b/ydb/core/blobstorage/backpressure/queue_backpressure_client.h @@ -17,15 +17,15 @@ namespace NKikimr { NKikimrBlobStorage::EVDiskQueueId QueueId; bool IsConnected; bool ExtraBlockChecksSupport; - std::shared_ptr<const TCostModel> CostModel; + ui32 MinREALHugeBlobInBytes; TEvProxyQueueState(const TVDiskID &vDiskId, NKikimrBlobStorage::EVDiskQueueId queueId, bool isConnected, - bool extraBlockChecksSupport, std::shared_ptr<const TCostModel> costModel) + bool extraBlockChecksSupport, ui32 minREALHugeBlobInBytes) : VDiskId(vDiskId) , QueueId(queueId) , IsConnected(isConnected) , ExtraBlockChecksSupport(extraBlockChecksSupport) - , CostModel(std::move(costModel)) + , MinREALHugeBlobInBytes(minREALHugeBlobInBytes) {} TString ToString() const { @@ -34,7 +34,7 @@ namespace NKikimr { str << " QueueId# " << static_cast<ui32>(QueueId); str << " IsConnected# " << (IsConnected ? "true" : "false"); str << " ExtraBlockChecksSupport# " << (ExtraBlockChecksSupport ? "true" : "false"); - str << " CostModel# " << CostModel->ToString(); + str << " MinREALHugeBlobInBytes# " << MinREALHugeBlobInBytes; str << "}"; return str.Str(); } diff --git a/ydb/core/blobstorage/dsproxy/dsproxy.h b/ydb/core/blobstorage/dsproxy/dsproxy.h index 3dabf7f65d..ce7f1a2478 100644 --- a/ydb/core/blobstorage/dsproxy/dsproxy.h +++ b/ydb/core/blobstorage/dsproxy/dsproxy.h @@ -178,7 +178,6 @@ public: , LogCtx(logComponent, logAccEnabled) , Span(TWilson::BlobStorage, std::move(traceId), std::move(name)) , RestartCounter(restartCounter) - , CostModel(GroupQueues->CostModel) , Source(source) , Cookie(cookie) , LatencyQueueKind(latencyQueueKind) @@ -190,8 +189,6 @@ public: Span .Attribute("GroupId", Info->GroupID) .Attribute("RestartCounter", RestartCounter); - - Y_VERIFY(CostModel); } void Registered(TActorSystem *as, const TActorId& parentId) override { @@ -369,14 +366,7 @@ public: void SendToQueue(std::unique_ptr<T> event, ui64 cookie, bool timeStatsEnabled = false) { if constexpr (!std::is_same_v<T, TEvBlobStorage::TEvVStatus> && !std::is_same_v<T, TEvBlobStorage::TEvVAssimilate>) { event->MessageRelevanceTracker = MessageRelevanceTracker; - if constexpr (std::is_same_v<T, TEvBlobStorage::TEvVMultiPut>) { - bool internalQueue; - SentSubrequestCostNs += CostModel->GetCost(*event, &internalQueue); - } else { - SentSubrequestCostNs += CostModel->GetCost(*event); - } } - const TActorId queueId = GroupQueues->Send(*this, Info->GetTopology(), std::move(event), cookie, Span.GetTraceId(), timeStatsEnabled); ++RequestsInFlight; @@ -508,7 +498,7 @@ public: Y_VERIFY(!Dead); if (RequestHandleClass && PoolCounters) { PoolCounters->GetItem(*RequestHandleClass, RequestBytes).Register( - RequestBytes, GeneratedSubrequests, GeneratedSubrequestBytes, SentSubrequestCostNs, Timer.Passed()); + RequestBytes, GeneratedSubrequests, GeneratedSubrequestBytes, Timer.Passed()); } if (timeStats) { @@ -580,10 +570,8 @@ protected: ui32 RequestBytes = 0; ui32 GeneratedSubrequests = 0; ui32 GeneratedSubrequestBytes = 0; - ui64 SentSubrequestCostNs = 0; bool Dead = false; const ui32 RestartCounter = 0; - std::shared_ptr<const TCostModel> CostModel; private: const TActorId Source; diff --git a/ydb/core/blobstorage/dsproxy/dsproxy_monactor.cpp b/ydb/core/blobstorage/dsproxy/dsproxy_monactor.cpp index d66fb7f241..453b31506e 100644 --- a/ydb/core/blobstorage/dsproxy/dsproxy_monactor.cpp +++ b/ydb/core/blobstorage/dsproxy/dsproxy_monactor.cpp @@ -87,12 +87,8 @@ public: str << "GroupID: " << Info->GroupID << "<br/>" << "Generation: " << Info->GroupGeneration; } DIV() { - str << "CostModel: "; - if (GroupQueues->CostModel) { - str << GroupQueues->CostModel->ToString(); - } else { - str << "None"; - } + str << "MinREALHugeBlobInBytes: "; + str << GroupQueues->MinREALHugeBlobInBytes; } DIV() TABLE_CLASS("table table-bordered table-condensed") TABLEBODY() { ui32 maxFailDomain = 0; diff --git a/ydb/core/blobstorage/dsproxy/dsproxy_state.cpp b/ydb/core/blobstorage/dsproxy/dsproxy_state.cpp index c74b0c09ef..0092b7d436 100644 --- a/ydb/core/blobstorage/dsproxy/dsproxy_state.cpp +++ b/ydb/core/blobstorage/dsproxy/dsproxy_state.cpp @@ -206,7 +206,7 @@ namespace NKikimr { auto *msg = ev->Get(); Y_VERIFY(Topology); Sessions->QueueConnectUpdate(Topology->GetOrderNumber(msg->VDiskId), msg->QueueId, msg->IsConnected, - msg->ExtraBlockChecksSupport, msg->CostModel, *Topology); + msg->ExtraBlockChecksSupport, msg->MinREALHugeBlobInBytes, *Topology); MinREALHugeBlobInBytes = Sessions->GetMinREALHugeBlobInBytes(); if (msg->IsConnected && (CurrentStateFunc() == &TThis::StateEstablishingSessions || CurrentStateFunc() == &TThis::StateEstablishingSessionsTimeout)) { diff --git a/ydb/core/blobstorage/dsproxy/group_sessions.cpp b/ydb/core/blobstorage/dsproxy/group_sessions.cpp index b56ae76421..0ffe410e66 100644 --- a/ydb/core/blobstorage/dsproxy/group_sessions.cpp +++ b/ydb/core/blobstorage/dsproxy/group_sessions.cpp @@ -116,80 +116,49 @@ bool TGroupSessions::GoodToGo(const TBlobStorageGroupInfo::TTopology& topology, } void TGroupSessions::QueueConnectUpdate(ui32 orderNumber, NKikimrBlobStorage::EVDiskQueueId queueId, bool connected, - bool extraGroupChecksSupport, std::shared_ptr<const TCostModel> costModel, const TBlobStorageGroupInfo::TTopology& topology) { + bool extraGroupChecksSupport, ui32 minREALHugeBlobInBytes, const TBlobStorageGroupInfo::TTopology& topology) { const auto v = topology.GetVDiskId(orderNumber); const ui32 fdom = topology.GetFailDomainOrderNumber(v); auto& f = GroupQueues->FailDomains[fdom]; auto& vdisk = f.VDisks[v.VDisk]; auto& q = vdisk.Queues.GetQueue(queueId); - bool updated = false; - if (connected) { ConnectedQueuesMask[orderNumber] |= 1 << queueId; q.ExtraBlockChecksSupport = extraGroupChecksSupport; - Y_VERIFY(costModel); - if (!q.CostModel || *q.CostModel != *costModel) { - updated = true; - q.CostModel = costModel; - } + q.MinREALHugeBlobInBytes = minREALHugeBlobInBytes; } else { ConnectedQueuesMask[orderNumber] &= ~(1 << queueId); q.ExtraBlockChecksSupport.reset(); - if (q.CostModel) { - updated = true; - q.CostModel = nullptr; - } + q.MinREALHugeBlobInBytes = 0; } q.IsConnected = connected; - if (updated) { - auto iterate = [](auto& currentCostModel, const auto& next) { - if (next.CostModel) { - if (!currentCostModel) { - currentCostModel.emplace(*next.CostModel); - } else { - currentCostModel->PessimisticComposition(*next.CostModel); - } - } - }; - - auto update = [](std::shared_ptr<const TCostModel>& current, const std::optional<TCostModel>& recalculated) { - if (!recalculated) { - current.reset(); - } else { - if (!current || *current != *recalculated) { - current = std::make_shared<const TCostModel>(*recalculated); - } - } - }; - - // recalculate CostModel for the whole VDisk - std::optional<TCostModel> pessimistic; - vdisk.CostModel.reset(); - vdisk.Queues.ForEachQueue([&](auto& q) { iterate(pessimistic, q); }); - update(vdisk.CostModel, pessimistic); - - // do the same for the fail domain - f.CostModel.reset(); - pessimistic.reset(); - for (const auto& vdisk : f.VDisks) { - iterate(pessimistic, vdisk); + auto update = [](auto& current, const auto& next) { + if (next.MinREALHugeBlobInBytes && (!current.MinREALHugeBlobInBytes || next.MinREALHugeBlobInBytes < current.MinREALHugeBlobInBytes)) { + current.MinREALHugeBlobInBytes = next.MinREALHugeBlobInBytes; } - update(f.CostModel, pessimistic); + }; - // and for the whole group - GroupQueues->CostModel.reset(); - pessimistic.reset(); - for (const auto& fdom : GroupQueues->FailDomains) { - iterate(pessimistic, fdom); - } - update(GroupQueues->CostModel, pessimistic); + // recalculate MinREALHugeBlobInBytes for the whole VDisk + vdisk.MinREALHugeBlobInBytes = 0; + vdisk.Queues.ForEachQueue([&](auto& q) { update(vdisk, q); }); + + // do the same for the fail domain + f.MinREALHugeBlobInBytes = 0; + for (const auto& vdisk : f.VDisks) { + update(f, vdisk); + } + + // and for the whole group + GroupQueues->MinREALHugeBlobInBytes = 0; + for (const auto& fdom : GroupQueues->FailDomains) { + update(*GroupQueues, fdom); } } ui32 TGroupSessions::GetMinREALHugeBlobInBytes() const { - return GroupQueues->CostModel ? GroupQueues->CostModel->MinREALHugeBlobInBytes : 0; + return GroupQueues->MinREALHugeBlobInBytes; } ui32 TGroupSessions::GetNumUnconnectedDisks() { diff --git a/ydb/core/blobstorage/dsproxy/group_sessions.h b/ydb/core/blobstorage/dsproxy/group_sessions.h index c8ce50fca8..714159f90c 100644 --- a/ydb/core/blobstorage/dsproxy/group_sessions.h +++ b/ydb/core/blobstorage/dsproxy/group_sessions.h @@ -22,7 +22,7 @@ namespace NKikimr { TActorId ActorId; TIntrusivePtr<NBackpressure::TFlowRecord> FlowRecord; std::optional<bool> ExtraBlockChecksSupport; - std::shared_ptr<const TCostModel> CostModel = nullptr; + ui32 MinREALHugeBlobInBytes = 0; volatile bool IsConnected = false; }; TQueue PutTabletLog; @@ -133,7 +133,7 @@ namespace NKikimr { }; TQueues Queues; - std::shared_ptr<const TCostModel> CostModel; + ui32 MinREALHugeBlobInBytes = 0; TString ToString() const { return TStringBuilder() << "{Queues# " << Queues.ToString() << "}"; @@ -142,7 +142,7 @@ namespace NKikimr { struct TFailDomain { TStackVec<TVDisk, TypicalDisksInFailDomain> VDisks; - std::shared_ptr<const TCostModel> CostModel; + ui32 MinREALHugeBlobInBytes = 0; // Ill-formed because TVDisk is not assignable. TFailDomain(const TFailDomain& other) = default; @@ -162,7 +162,7 @@ namespace NKikimr { TStackVec<TFailDomain, TypicalFailDomainsInGroup> FailDomains; TStackVec<TVDisk*, TypicalDisksInGroup> DisksByOrderNumber; - std::shared_ptr<const TCostModel> CostModel; + ui32 MinREALHugeBlobInBytes = 0; TGroupQueues(const TBlobStorageGroupInfo::TTopology& topology) : FailDomains(topology.GetTotalFailDomainsNum()) @@ -246,7 +246,7 @@ namespace NKikimr { void Poison(); bool GoodToGo(const TBlobStorageGroupInfo::TTopology& topology, bool waitForAllVDisks); void QueueConnectUpdate(ui32 orderNumber, NKikimrBlobStorage::EVDiskQueueId queueId, bool connected, - bool extraBlockChecksSupport, std::shared_ptr<const TCostModel> costModel, const TBlobStorageGroupInfo::TTopology& topology); + bool extraBlockChecksSupport, ui32 minREALHugeBlobInBytes, const TBlobStorageGroupInfo::TTopology& topology); ui32 GetNumUnconnectedDisks(); ui32 GetMinREALHugeBlobInBytes() const; }; diff --git a/ydb/core/blobstorage/storagepoolmon/storagepool_counters.h b/ydb/core/blobstorage/storagepoolmon/storagepool_counters.h index 1e366243ff..0eb004ec16 100644 --- a/ydb/core/blobstorage/storagepoolmon/storagepool_counters.h +++ b/ydb/core/blobstorage/storagepoolmon/storagepool_counters.h @@ -20,14 +20,12 @@ struct TRequestMonItem { ::NMonitoring::TDynamicCounters::TCounterPtr RequestBytes; ::NMonitoring::TDynamicCounters::TCounterPtr GeneratedSubrequests; ::NMonitoring::TDynamicCounters::TCounterPtr GeneratedSubrequestBytes; - ::NMonitoring::TDynamicCounters::TCounterPtr SentSubrequestCostNs; NMonitoring::THistogramPtr ResponseTime; void Init(TIntrusivePtr<::NMonitoring::TDynamicCounters> counters, NPDisk::EDeviceType type) { RequestBytes = counters->GetCounter("requestBytes", true); GeneratedSubrequests = counters->GetCounter("generatedSubrequests", true); GeneratedSubrequestBytes = counters->GetCounter("generatedSubrequestBytes", true); - SentSubrequestCostNs = counters->GetCounter("estimatedDiskTimeConsumptionNs", true); NMonitoring::TBucketBounds bounds = GetCommonLatencyHistBounds(type); @@ -35,12 +33,10 @@ struct TRequestMonItem { NMonitoring::ExplicitHistogram(std::move(bounds))); } - void Register(ui32 requestBytes, ui32 generatedSubrequests, ui32 generatedSubrequestBytes, ui64 sentSubrequestCostNs, - double durationSeconds) { + void Register(ui32 requestBytes, ui32 generatedSubrequests, ui32 generatedSubrequestBytes, double durationSeconds) { *RequestBytes += requestBytes; *GeneratedSubrequests += generatedSubrequests; *GeneratedSubrequestBytes += generatedSubrequestBytes; - *SentSubrequestCostNs += sentSubrequestCostNs; ResponseTime->Collect(durationSeconds * 1000.0); } }; diff --git a/ydb/core/blobstorage/ut_vdisk/lib/helpers.cpp b/ydb/core/blobstorage/ut_vdisk/lib/helpers.cpp index 48ea78f3bd..884673b2ed 100644 --- a/ydb/core/blobstorage/ut_vdisk/lib/helpers.cpp +++ b/ydb/core/blobstorage/ut_vdisk/lib/helpers.cpp @@ -413,7 +413,7 @@ class TManyMultiPuts : public TActorBootstrapped<TManyMultiPuts> { void Handle(TEvProxyQueueState::TPtr& ev, const TActorContext& ctx) { if (ev->Get()->IsConnected && !Started) { // put logo blob - MinREALHugeBlobInBytes = ev->Get()->CostModel->MinREALHugeBlobInBytes; + MinREALHugeBlobInBytes = ev->Get()->MinREALHugeBlobInBytes; Y_VERIFY(MinREALHugeBlobInBytes); SendPut(ctx); Started = true; diff --git a/ydb/core/blobstorage/vdisk/common/vdisk_costmodel.cpp b/ydb/core/blobstorage/vdisk/common/vdisk_costmodel.cpp index 4a6921a34e..3acfe26ea3 100644 --- a/ydb/core/blobstorage/vdisk/common/vdisk_costmodel.cpp +++ b/ydb/core/blobstorage/vdisk/common/vdisk_costmodel.cpp @@ -153,26 +153,4 @@ namespace NKikimr { return cost; } - TString TCostModel::ToString() const { - TStringStream str; - str << "{SeekTimeUs# " << SeekTimeUs; - str << " ReadSpeedBps# " << ReadSpeedBps; - str << " WriteSpeedBps# " << WriteSpeedBps; - str << " ReadBlockSize# " << ReadBlockSize; - str << " WriteBlockSize# " << WriteBlockSize; - str << " MinREALHugeBlobInBytes# " << MinREALHugeBlobInBytes; - str << " GType# " << GType.ToString(); - str << "}"; - return str.Str(); - } - - void TCostModel::PessimisticComposition(const TCostModel& other) { - SeekTimeUs = std::max(SeekTimeUs, other.SeekTimeUs); - ReadSpeedBps = std::min(ReadSpeedBps, other.ReadSpeedBps); - WriteSpeedBps = std::min(WriteSpeedBps, other.WriteSpeedBps); - ReadBlockSize = std::min(ReadBlockSize, other.ReadBlockSize); - WriteBlockSize = std::min(WriteBlockSize, other.WriteBlockSize); - MinREALHugeBlobInBytes = std::max(MinREALHugeBlobInBytes, other.MinREALHugeBlobInBytes); - } - } // NKikimr diff --git a/ydb/core/blobstorage/vdisk/common/vdisk_costmodel.h b/ydb/core/blobstorage/vdisk/common/vdisk_costmodel.h index d072757471..eb16996c30 100644 --- a/ydb/core/blobstorage/vdisk/common/vdisk_costmodel.h +++ b/ydb/core/blobstorage/vdisk/common/vdisk_costmodel.h @@ -216,11 +216,6 @@ namespace NKikimr { ui64 MovedPatchCostBySize(ui32 blobSize) const; ui64 ReadCostBySize(ui64 size) const; ui64 ReadCost(const TEvBlobStorage::TEvVGet &ev) const; - - public: - TString ToString() const; - void PessimisticComposition(const TCostModel& other); - }; } // NKikimr |