aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAleksei Borzenkov <snaury@gmail.com>2022-06-24 15:32:32 +0300
committerAleksei Borzenkov <snaury@gmail.com>2022-06-24 15:32:32 +0300
commit87d89a758766acfdcb00000c1db4af6cd89d95c1 (patch)
tree82210ce58c7e7aca65db69b2b832db0dd4121b3e
parentbd27be4437e22260a6ecd24043c8eb2c76700ce1 (diff)
downloadydb-87d89a758766acfdcb00000c1db4af6cd89d95c1.tar.gz
Remove unused code, KIKIMR-15189
ref:880d2c4cf3abe8cb591bf2a2d70e7bfa9621f5b0
-rw-r--r--ydb/core/tablet_flat/test/tool/perf/do_writes.h51
-rw-r--r--ydb/core/tx/datashard/datashard__undelivered.cpp65
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