Skip to content

Commit 8fca2df

Browse files
authored
Fix verify in TSharingTransactionOperator::DoParse (#9158)
1 parent f60d553 commit 8fca2df

File tree

1 file changed

+25
-25
lines changed

1 file changed

+25
-25
lines changed

ydb/core/tx/columnshard/columnshard__init.cpp

Lines changed: 25 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -113,6 +113,31 @@ bool TTxInit::ReadEverything(TTransactionContext& txc, const TActorContext& ctx)
113113
Self->InsertTable.swap(localInsertTable);
114114
}
115115

116+
{
117+
ACFL_DEBUG("step", "TTablesManager::Load_Start");
118+
TTablesManager tManagerLocal(Self->StoragesManager, Self->TabletID());
119+
{
120+
TMemoryProfileGuard g("TTxInit/TTablesManager");
121+
if (!tManagerLocal.InitFromDB(db)) {
122+
ACFL_ERROR("step", "TTablesManager::InitFromDB_Fails");
123+
return false;
124+
}
125+
}
126+
{
127+
TMemoryProfileGuard g("TTxInit/LoadIndex");
128+
if (!tManagerLocal.LoadIndex(dbTable)) {
129+
ACFL_ERROR("step", "TTablesManager::LoadIndex_Fails");
130+
return false;
131+
}
132+
}
133+
Self->TablesManager = std::move(tManagerLocal);
134+
135+
Self->Counters.GetTabletCounters()->SetCounter(COUNTER_TABLES, Self->TablesManager.GetTables().size());
136+
Self->Counters.GetTabletCounters()->SetCounter(COUNTER_TABLE_PRESETS, Self->TablesManager.GetSchemaPresets().size());
137+
Self->Counters.GetTabletCounters()->SetCounter(COUNTER_TABLE_TTLS, Self->TablesManager.GetTtl().PathsCount());
138+
ACFL_DEBUG("step", "TTablesManager::Load_Finish");
139+
}
140+
116141
{
117142
ACFL_DEBUG("step", "TTxController::Load_Start");
118143
TMemoryProfileGuard g("TTxInit/TTxController");
@@ -147,31 +172,6 @@ bool TTxInit::ReadEverything(TTransactionContext& txc, const TActorContext& ctx)
147172
ACFL_DEBUG("step", "TStoragesManager::Load_Finish");
148173
}
149174

150-
{
151-
ACFL_DEBUG("step", "TTablesManager::Load_Start");
152-
TTablesManager tManagerLocal(Self->StoragesManager, Self->TabletID());
153-
{
154-
TMemoryProfileGuard g("TTxInit/TTablesManager");
155-
if (!tManagerLocal.InitFromDB(db)) {
156-
ACFL_ERROR("step", "TTablesManager::InitFromDB_Fails");
157-
return false;
158-
}
159-
}
160-
{
161-
TMemoryProfileGuard g("TTxInit/LoadIndex");
162-
if (!tManagerLocal.LoadIndex(dbTable)) {
163-
ACFL_ERROR("step", "TTablesManager::LoadIndex_Fails");
164-
return false;
165-
}
166-
}
167-
Self->TablesManager = std::move(tManagerLocal);
168-
169-
Self->Counters.GetTabletCounters()->SetCounter(COUNTER_TABLES, Self->TablesManager.GetTables().size());
170-
Self->Counters.GetTabletCounters()->SetCounter(COUNTER_TABLE_PRESETS, Self->TablesManager.GetSchemaPresets().size());
171-
Self->Counters.GetTabletCounters()->SetCounter(COUNTER_TABLE_TTLS, Self->TablesManager.GetTtl().PathsCount());
172-
ACFL_DEBUG("step", "TTablesManager::Load_Finish");
173-
}
174-
175175
{
176176
TMemoryProfileGuard g("TTxInit/LongTxWrites");
177177
auto rowset = db.Table<Schema::LongTxWrites>().Select();

0 commit comments

Comments
 (0)