diff options
author | xenoxeno <xeno@ydb.tech> | 2023-11-03 19:11:04 +0300 |
---|---|---|
committer | xenoxeno <xeno@ydb.tech> | 2023-11-03 19:37:43 +0300 |
commit | 0b4d17fbe9cbbf725384822e981e2de570a6a280 (patch) | |
tree | ad71c95bbff129b5d152fc4359b093644e7657e5 | |
parent | 180b27d7fa265c9b35f3ba63516dec24d848e839 (diff) | |
download | ydb-0b4d17fbe9cbbf725384822e981e2de570a6a280.tar.gz |
make move semantics more clear KIKIMR-19973
-rw-r--r-- | ydb/core/blobstorage/vdisk/scrub/scrub_actor.cpp | 2 | ||||
-rw-r--r-- | ydb/core/cms/cms_ut_common.cpp | 2 | ||||
-rw-r--r-- | ydb/core/tablet/tablet_resolver.cpp | 2 | ||||
-rw-r--r-- | ydb/core/tx/columnshard/blob_cache.cpp | 2 | ||||
-rw-r--r-- | ydb/core/tx/columnshard/columnshard_impl.h | 2 | ||||
-rw-r--r-- | ydb/core/tx/tx_proxy/read_table_impl.cpp | 8 | ||||
-rw-r--r-- | ydb/core/util/single_thread_ic_mock.cpp | 2 | ||||
-rw-r--r-- | ydb/core/util/testactorsys.h | 2 |
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; } } |