|
5 | 5 |
|
6 | 6 | #include <ydb/core/base/subdomain.h>
|
7 | 7 |
|
8 |
| -// #define LOG_I(stream) LOG_INFO_S (context.Ctx, NKikimrServices::FLAT_TX_SCHEMESHARD, "[" << context.SS->TabletID() << "] " << stream) |
9 |
| -// #define LOG_N(stream) LOG_NOTICE_S(context.Ctx, NKikimrServices::FLAT_TX_SCHEMESHARD, "[" << context.SS->TabletID() << "] " << stream) |
10 |
| - |
11 | 8 | namespace {
|
12 | 9 |
|
13 | 10 | using namespace NKikimr;
|
@@ -39,9 +36,9 @@ class TPropose: public TSubOperationState {
|
39 | 36 | Y_ABORT_UNLESS(txState);
|
40 | 37 | Y_ABORT_UNLESS(txState->TxType == TTxState::TxCreateExternalDataSource);
|
41 | 38 |
|
42 |
| - const auto pathId = txState->TargetPathId; |
43 |
| - const auto path = TPath::Init(pathId, context.SS); |
44 |
| - const auto pathPtr = context.SS->PathsById.at(pathId); |
| 39 | + const auto pathId = txState->TargetPathId; |
| 40 | + const auto path = TPath::Init(pathId, context.SS); |
| 41 | + const TPathElement::TPtr pathPtr = context.SS->PathsById.at(pathId); |
45 | 42 |
|
46 | 43 | context.SS->TabletCounters->Simple()[COUNTER_EXTERNAL_DATA_SOURCE_COUNT].Add(1);
|
47 | 44 |
|
@@ -76,23 +73,23 @@ class TCreateExternalDataSource : public TSubOperation {
|
76 | 73 |
|
77 | 74 | TTxState::ETxState NextState(TTxState::ETxState state) const override {
|
78 | 75 | switch (state) {
|
79 |
| - case TTxState::Waiting: |
80 |
| - case TTxState::Propose: |
81 |
| - return TTxState::Done; |
82 |
| - default: |
83 |
| - return TTxState::Invalid; |
| 76 | + case TTxState::Waiting: |
| 77 | + case TTxState::Propose: |
| 78 | + return TTxState::Done; |
| 79 | + default: |
| 80 | + return TTxState::Invalid; |
84 | 81 | }
|
85 | 82 | }
|
86 | 83 |
|
87 | 84 | TSubOperationState::TPtr SelectStateFunc(TTxState::ETxState state) override {
|
88 | 85 | switch (state) {
|
89 |
| - case TTxState::Waiting: |
90 |
| - case TTxState::Propose: |
91 |
| - return MakeHolder<TPropose>(OperationId); |
92 |
| - case TTxState::Done: |
93 |
| - return MakeHolder<TDone>(OperationId); |
94 |
| - default: |
95 |
| - return nullptr; |
| 86 | + case TTxState::Waiting: |
| 87 | + case TTxState::Propose: |
| 88 | + return MakeHolder<TPropose>(OperationId); |
| 89 | + case TTxState::Done: |
| 90 | + return MakeHolder<TDone>(OperationId); |
| 91 | + default: |
| 92 | + return nullptr; |
96 | 93 | }
|
97 | 94 | }
|
98 | 95 |
|
|
0 commit comments