Skip to content

Commit 4eedc60

Browse files
authored
Move spacewatcher to CS mailbox (#18799)
2 parents f4f3e42 + c806fce commit 4eedc60

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

ydb/core/tx/columnshard/columnshard.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -119,6 +119,7 @@ void TColumnShard::OnActivateExecutor(const TActorContext& ctx) {
119119

120120
AFL_INFO(NKikimrServices::TX_COLUMNSHARD)("event", "initialize_shard")("step", "initialize_tiring_finished");
121121
auto& icb = *AppData(ctx)->Icb;
122+
SpaceWatcherId = RegisterWithSameMailbox(SpaceWatcher);
122123
Limits.RegisterControls(icb);
123124
Settings.RegisterControls(icb);
124125
ResourceSubscribeActor = ctx.Register(new NOlap::NResourceBroker::NSubscribe::TActor(TabletID(), SelfId()));

ydb/core/tx/columnshard/columnshard_impl.cpp

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,6 @@ TColumnShard::TColumnShard(TTabletStorageInfo* info, const TActorId& tablet)
9898
, SysLocks(this) {
9999
AFL_VERIFY(TabletActivityImpl->Inc() == 1);
100100
SpaceWatcher = new TSpaceWatcher(this);
101-
SpaceWatcherId = TActorContext::AsActorContext().Register(SpaceWatcher);
102101
}
103102

104103
void TColumnShard::OnDetach(const TActorContext& ctx) {
@@ -1438,7 +1437,7 @@ class TTxAskPortionChunks: public TTransactionBase<TColumnShard> {
14381437

14391438
bool Execute(TTransactionContext& txc, const TActorContext& /*ctx*/) override {
14401439
NIceDb::TNiceDb db(txc.DB);
1441-
1440+
14421441
TBlobGroupSelector selector(Self->Info());
14431442
bool reask = false;
14441443
NActors::TLogContextGuard lGuard = NActors::TLogContextBuilder::Build()("event", "TTxAskPortionChunks::Execute");

0 commit comments

Comments
 (0)