Skip to content

Commit

Permalink
fix test build
Browse files Browse the repository at this point in the history
  • Loading branch information
swalrus1 committed Dec 9, 2024
1 parent 9660271 commit 6e6a34d
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 1 deletion.
3 changes: 2 additions & 1 deletion ydb/core/tx/columnshard/engines/ut/ut_logs_engine.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -443,7 +443,8 @@ class TTestMetadataAccessorsSubscriber: public NOlap::IDataAccessorRequestsSubsc
TColumnEngineForLogs& Engine;

virtual void DoOnRequestsFinished(TDataAccessorsResult&& result) override {
Processor->ApplyResult(std::move(result), Engine);
Processor->ApplyResult(
NOlap::NResourceBroker::NSubscribe::TResourceContainer<NOlap::TDataAccessorsResult>::BuildForTest(std::move(result)), Engine);
}

public:
Expand Down
8 changes: 8 additions & 0 deletions ydb/core/tx/columnshard/resource_subscriber/container.h
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,10 @@ class TResourceContainer: private TMoveOnly {
std::optional<T> Value;
std::shared_ptr<NResourceBroker::NSubscribe::TResourcesGuard> ResourcesGuard;

TResourceContainer(T&& value)
: Value(std::move(value)) {
}

public:
const T& GetValue() const {
AFL_VERIFY(Value);
Expand Down Expand Up @@ -49,5 +53,9 @@ class TResourceContainer: private TMoveOnly {
AFL_VERIFY(!ResourcesGuard);
}
}

static TResourceContainer BuildForTest(T&& value) {
return TResourceContainer(std::move(value));
}
};
} // namespace NKikimr::NOlap::NResourceBroker::NSubscribe

0 comments on commit 6e6a34d

Please sign in to comment.