diff options
author | Aleksei Borzenkov <snaury@gmail.com> | 2022-06-24 15:32:32 +0300 |
---|---|---|
committer | Aleksei Borzenkov <snaury@gmail.com> | 2022-06-24 15:32:32 +0300 |
commit | 87d89a758766acfdcb00000c1db4af6cd89d95c1 (patch) | |
tree | 82210ce58c7e7aca65db69b2b832db0dd4121b3e | |
parent | bd27be4437e22260a6ecd24043c8eb2c76700ce1 (diff) | |
download | ydb-87d89a758766acfdcb00000c1db4af6cd89d95c1.tar.gz |
Remove unused code, KIKIMR-15189
ref:880d2c4cf3abe8cb591bf2a2d70e7bfa9621f5b0
-rw-r--r-- | ydb/core/tablet_flat/test/tool/perf/do_writes.h | 51 | ||||
-rw-r--r-- | ydb/core/tx/datashard/datashard__undelivered.cpp | 65 |
2 files changed, 0 insertions, 116 deletions
diff --git a/ydb/core/tablet_flat/test/tool/perf/do_writes.h b/ydb/core/tablet_flat/test/tool/perf/do_writes.h deleted file mode 100644 index 3e94106b240..00000000000 --- a/ydb/core/tablet_flat/test/tool/perf/do_writes.h +++ /dev/null @@ -1,51 +0,0 @@ -#pragma once - -#include "util.h" -#include "meter.h" - -#include <ydb/core/tablet_flat/flat_mem_warm.h> -#include <ydb/core/tablet_flat/flat_row_state.h> -#include <ydb/core/tablet_flat/flat_row_scheme.h> -#include <ydb/core/tablet_flat/test/libs/rows/layout.h> - -namespace NKikimr { -namespace NTable { - - class TPerfMemUp { - public: - void DoUpdate(bool insert) - { - NTest::TLayoutCook lay; - - lay - .Col(0, 0, NScheme::NTypeIds::Uint64) - .Col(0, 1, NScheme::NTypeIds::Double) - .Key({ 0 }); - - TMemTable table(lay.RowScheme(), 0); - - TVector<TRawTypeValue> key; - TVector<TUpdateOp> ops; - - ui64 keyUi64 = 42; - key.emplace_back(&keyUi64, sizeof(keyUi64), NScheme::NTypeIds::Uin> - - double dblVal = 2015.1027; - ops.emplace_back(1, ECellOp::Set, TRawTypeValue(&dblVal, sizeof(dblVa> - - NTest::TMeter meter(TDuration::Seconds(10)); - - for (;meter.More();) { - keyUi64 = meter.Count(); - if (!insert) - keyUi64 %= 0x010000; - - table.Update(ERowOp::Upsert, key, ops); - } - - Cout << "rps " << meter.Report() << Endl; - } - }; - -} -} diff --git a/ydb/core/tx/datashard/datashard__undelivered.cpp b/ydb/core/tx/datashard/datashard__undelivered.cpp deleted file mode 100644 index 0cee328d022..00000000000 --- a/ydb/core/tx/datashard/datashard__undelivered.cpp +++ /dev/null @@ -1,65 +0,0 @@ -#include "datashard_impl.h" - -namespace NKikimr { -namespace NDataShard { - -using namespace NTabletFlatExecutor; - -class TDataShard::TTxDisconnected : public NTabletFlatExecutor::TTransactionBase<TDataShard> { -public: - TTxDisconnected(TDataShard *self, TEvInterconnect::TEvNodeDisconnected::TPtr ev) - : TBase(self) - , Event(std::move(ev)) - {} - - TTxType GetTxType() const override - { - return TXTYPE_DISCONNECTED; - } - - bool Execute(TTransactionContext &/*txc*/, const TActorContext &ctx) - { - ui32 nodeId = Event->Get()->NodeId; - Self->Pipeline.ProcessDisconnected(nodeId); - - LOG_DEBUG_S(ctx, NKikimrServices::TX_DATASHARD, - "TTxDisconnected, shard: " << Self->TabletID() << ", node: " << nodeId); - - Self->PlanQueue.Progress(ctx); - return true; - } - - void Complete(const TActorContext &/*ctx*/) override { - } - -private: - TEvInterconnect::TEvNodeDisconnected::TPtr Event; -}; - -void TDataShard::Handle(TEvents::TEvUndelivered::TPtr &ev, - const TActorContext &ctx) -{ - ui64 txId = ev->Cookie; - auto op = Pipeline.FindOp(ev->Cookie); - if (op) { - op->AddInputEvent(ev.Release()); - Pipeline.AddCandidateOp(op); - PlanQueue.Progress(ctx); - } -} - -void TDataShard::Handle(TEvInterconnect::TEvNodeDisconnected::TPtr &ev, - const TActorContext &ctx) -{ - ui32 nodeId = ev->Get()->NodeId; - - LOG_NOTICE_S(ctx, NKikimrServices::TX_DATASHARD, - "Shard " << TabletID() << " disconnected from node " << nodeId); - - Pipeline.ProcessDisconnected(nodeId); - PlanQueue.Progress(ctx); -} - - -} // namesapce NDataShard -} // namespace NKikimr |