summaryrefslogtreecommitdiffstats
path: root/ydb/core/tablet/tablet_pipe_client.cpp
diff options
context:
space:
mode:
authorAlexander Rutkovsky <[email protected]>2022-02-10 16:47:40 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:47:40 +0300
commit667a4ee7da2e004784b9c3cfab824a81e96f4d66 (patch)
treec0748b5dcbade83af788c0abfa89c0383d6b779c /ydb/core/tablet/tablet_pipe_client.cpp
parentf3646f91e0de459836a7800b9ce3e8dc57a2ab3a (diff)
Restoring authorship annotation for Alexander Rutkovsky <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'ydb/core/tablet/tablet_pipe_client.cpp')
-rw-r--r--ydb/core/tablet/tablet_pipe_client.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/ydb/core/tablet/tablet_pipe_client.cpp b/ydb/core/tablet/tablet_pipe_client.cpp
index 43fdd0142ae..2fa35af9a0e 100644
--- a/ydb/core/tablet/tablet_pipe_client.cpp
+++ b/ydb/core/tablet/tablet_pipe_client.cpp
@@ -28,8 +28,8 @@ namespace NTabletPipe {
class TClient : public TActorBootstrapped<TClient> {
public:
- static constexpr NKikimrServices::TActivity::EType ActorActivityType() {
- return NKikimrServices::TActivity::TABLET_PIPE_CLIENT;
+ static constexpr NKikimrServices::TActivity::EType ActorActivityType() {
+ return NKikimrServices::TActivity::TABLET_PIPE_CLIENT;
}
TClient(const TActorId& owner, ui64 tabletId, const TClientConfig& config)
@@ -706,7 +706,7 @@ namespace NTabletPipe {
}
void SendData(TActorId self, TActorId clientId, ui32 eventType, TIntrusivePtr<TEventSerializedData> buffer, ui64 cookie) {
- auto ev = new IEventHandle(eventType, 0, clientId, self, buffer, cookie);
+ auto ev = new IEventHandle(eventType, 0, clientId, self, buffer, cookie);
ev->Rewrite(TEvTabletPipe::EvSend, clientId);
TActivationContext::Send(ev);
}
@@ -718,7 +718,7 @@ namespace NTabletPipe {
}
void SendData(const TActorContext& ctx, const TActorId& clientId, ui32 eventType, TIntrusivePtr<TEventSerializedData> buffer, ui64 cookie) {
- auto ev = new IEventHandle(eventType, 0, clientId, ctx.SelfID, buffer, cookie);
+ auto ev = new IEventHandle(eventType, 0, clientId, ctx.SelfID, buffer, cookie);
ev->Rewrite(TEvTabletPipe::EvSend, clientId);
ctx.ExecutorThread.Send(ev);
}