aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorxenoxeno <xeno@ydb.tech>2023-11-03 19:11:04 +0300
committerxenoxeno <xeno@ydb.tech>2023-11-03 19:37:43 +0300
commit0b4d17fbe9cbbf725384822e981e2de570a6a280 (patch)
treead71c95bbff129b5d152fc4359b093644e7657e5
parent180b27d7fa265c9b35f3ba63516dec24d848e839 (diff)
downloadydb-0b4d17fbe9cbbf725384822e981e2de570a6a280.tar.gz
make move semantics more clear KIKIMR-19973
-rw-r--r--ydb/core/blobstorage/vdisk/scrub/scrub_actor.cpp2
-rw-r--r--ydb/core/cms/cms_ut_common.cpp2
-rw-r--r--ydb/core/tablet/tablet_resolver.cpp2
-rw-r--r--ydb/core/tx/columnshard/blob_cache.cpp2
-rw-r--r--ydb/core/tx/columnshard/columnshard_impl.h2
-rw-r--r--ydb/core/tx/tx_proxy/read_table_impl.cpp8
-rw-r--r--ydb/core/util/single_thread_ic_mock.cpp2
-rw-r--r--ydb/core/util/testactorsys.h2
8 files changed, 11 insertions, 11 deletions
diff --git a/ydb/core/blobstorage/vdisk/scrub/scrub_actor.cpp b/ydb/core/blobstorage/vdisk/scrub/scrub_actor.cpp
index 6c21771c89..661208e908 100644
--- a/ydb/core/blobstorage/vdisk/scrub/scrub_actor.cpp
+++ b/ydb/core/blobstorage/vdisk/scrub/scrub_actor.cpp
@@ -52,7 +52,7 @@ namespace NKikimr {
}
void TScrubCoroImpl::ForwardToBlobRecoveryActor(TAutoPtr<IEventHandle> ev) {
- Send(IEventHandle::Forward(ev, BlobRecoveryActorId));
+ Send(IEventHandle::Forward(std::move(ev), BlobRecoveryActorId));
}
void TScrubCoroImpl::Run() {
diff --git a/ydb/core/cms/cms_ut_common.cpp b/ydb/core/cms/cms_ut_common.cpp
index 77df3691e5..cb7dfec9b9 100644
--- a/ydb/core/cms/cms_ut_common.cpp
+++ b/ydb/core/cms/cms_ut_common.cpp
@@ -551,7 +551,7 @@ TCmsTestEnv::TCmsTestEnv(const TTestEnvOpts &options)
|| event->GetTypeRewrite() == TEvConfigsDispatcher::EvGetConfigRequest) {
auto fakeId = NNodeWhiteboard::MakeNodeWhiteboardServiceId(event->Recipient.NodeId());
if (event->Recipient != fakeId)
- event = IEventHandle::Forward(event, fakeId);
+ event = IEventHandle::Forward(std::move(event), fakeId);
}
return TTestActorRuntime::EEventAction::PROCESS;
diff --git a/ydb/core/tablet/tablet_resolver.cpp b/ydb/core/tablet/tablet_resolver.cpp
index 5af056baa8..f1f55121d1 100644
--- a/ydb/core/tablet/tablet_resolver.cpp
+++ b/ydb/core/tablet/tablet_resolver.cpp
@@ -313,7 +313,7 @@ class TTabletResolver : public TActorBootstrapped<TTabletResolver> {
if (endpoint.first) {
ctx.Send(sender, new TEvTabletResolver::TEvForwardResult(msg->TabletID, endpoint.second, endpoint.first, LastCacheEpoch));
if (!!msg->Ev) {
- ctx.ExecutorThread.Send(IEventHandle::Forward(msg->Ev, msg->SelectActor(endpoint.second, endpoint.first)));
+ ctx.ExecutorThread.Send(IEventHandle::Forward(std::move(msg->Ev), msg->SelectActor(endpoint.second, endpoint.first)));
}
return true;
} else {
diff --git a/ydb/core/tx/columnshard/blob_cache.cpp b/ydb/core/tx/columnshard/blob_cache.cpp
index 5985812cd4..feaf8bb283 100644
--- a/ydb/core/tx/columnshard/blob_cache.cpp
+++ b/ydb/core/tx/columnshard/blob_cache.cpp
@@ -208,7 +208,7 @@ private:
default:
LOG_S_WARN("Unhandled event type: " << ev->GetTypeRewrite()
<< " event: " << ev->ToString());
- Send(IEventHandle::ForwardOnNondelivery(ev, TEvents::TEvUndelivered::ReasonActorUnknown));
+ Send(IEventHandle::ForwardOnNondelivery(std::move(ev), TEvents::TEvUndelivered::ReasonActorUnknown));
break;
};
}
diff --git a/ydb/core/tx/columnshard/columnshard_impl.h b/ydb/core/tx/columnshard/columnshard_impl.h
index 0bd6d4abef..68dfb97945 100644
--- a/ydb/core/tx/columnshard/columnshard_impl.h
+++ b/ydb/core/tx/columnshard/columnshard_impl.h
@@ -239,7 +239,7 @@ protected:
LOG_S_WARN("TColumnShard.StateBroken at " << TabletID()
<< " unhandled event type: " << ev->GetTypeRewrite()
<< " event: " << ev->ToString());
- Send(IEventHandle::ForwardOnNondelivery(ev, TEvents::TEvUndelivered::ReasonActorUnknown));
+ Send(IEventHandle::ForwardOnNondelivery(std::move(ev), TEvents::TEvUndelivered::ReasonActorUnknown));
break;
}
}
diff --git a/ydb/core/tx/tx_proxy/read_table_impl.cpp b/ydb/core/tx/tx_proxy/read_table_impl.cpp
index 6b85d9801a..569154524b 100644
--- a/ydb/core/tx/tx_proxy/read_table_impl.cpp
+++ b/ydb/core/tx/tx_proxy/read_table_impl.cpp
@@ -1601,7 +1601,7 @@ private:
TXLOG_T("Ignore propose result from ShardId# " << shardId << " TxId# " << msg->GetTxId()
<< " in State# " << state.State << " ReadTxId# " << state.ReadTxId);
// Pretend we don't exist if sender tracks delivery
- ctx.Send(IEventHandle::ForwardOnNondelivery(ev, TEvents::TEvUndelivered::ReasonActorUnknown));
+ ctx.Send(IEventHandle::ForwardOnNondelivery(std::move(ev), TEvents::TEvUndelivered::ReasonActorUnknown));
return;
}
@@ -1994,7 +1994,7 @@ private:
if (state.State != EShardState::ReadTableStreaming || state.ReadTxId != record.GetTxId()) {
// Ignore outdated messages and pretend we don't exist
TXLOG_T("Ignoring outdated TEvStreamQuotaRequest from ShardId# " << shardId);
- ctx.Send(IEventHandle::ForwardOnNondelivery(ev, TEvents::TEvUndelivered::ReasonActorUnknown));
+ ctx.Send(IEventHandle::ForwardOnNondelivery(std::move(ev), TEvents::TEvUndelivered::ReasonActorUnknown));
return;
}
@@ -2045,7 +2045,7 @@ private:
if (state.State != EShardState::ReadTableStreaming || state.ReadTxId != record.GetTxId()) {
// Ignore outdated messages and pretend we don't exist
TXLOG_T("Ignoring outdated TEvStreamQuotaRelease from ShardId# " << shardId);
- ctx.Send(IEventHandle::ForwardOnNondelivery(ev, TEvents::TEvUndelivered::ReasonActorUnknown));
+ ctx.Send(IEventHandle::ForwardOnNondelivery(std::move(ev), TEvents::TEvUndelivered::ReasonActorUnknown));
return;
}
@@ -2711,7 +2711,7 @@ private:
HFunc(TEvTxProxySchemeCache::TEvResolveKeySetResult, HandleZombieDie);
default:
// For all other events we play dead as if we didn't exist
- Send(IEventHandle::ForwardOnNondelivery(ev, TEvents::TEvUndelivered::ReasonActorUnknown));
+ Send(IEventHandle::ForwardOnNondelivery(std::move(ev), TEvents::TEvUndelivered::ReasonActorUnknown));
break;
}
}
diff --git a/ydb/core/util/single_thread_ic_mock.cpp b/ydb/core/util/single_thread_ic_mock.cpp
index 5ced8a853c..d2dd1382e0 100644
--- a/ydb/core/util/single_thread_ic_mock.cpp
+++ b/ydb/core/util/single_thread_ic_mock.cpp
@@ -177,7 +177,7 @@ public:
if (ev->GetTypeRewrite() == TEvents::TSystem::Poison) {
TActor::PassAway();
} else {
- TActivationContext::Send(IEventHandle::ForwardOnNondelivery(ev, TEvents::TEvUndelivered::ReasonActorUnknown));
+ TActivationContext::Send(IEventHandle::ForwardOnNondelivery(std::move(ev), TEvents::TEvUndelivered::ReasonActorUnknown));
}
}
diff --git a/ydb/core/util/testactorsys.h b/ydb/core/util/testactorsys.h
index 7c29b1ac3c..a6be3756a6 100644
--- a/ydb/core/util/testactorsys.h
+++ b/ydb/core/util/testactorsys.h
@@ -408,7 +408,7 @@ public:
Schedule(Clock, ev, nullptr, nodeId);
return true;
} else {
- Send(IEventHandle::ForwardOnNondelivery(ev, TEvents::TEvUndelivered::ReasonActorUnknown), nodeId);
+ Send(IEventHandle::ForwardOnNondelivery(std::move(ev), TEvents::TEvUndelivered::ReasonActorUnknown), nodeId);
return false;
}
}