Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
maximyurchuk committed Jul 16, 2024
1 parent dbccf20 commit 103f6ef
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions ydb/core/tx/tx_proxy/datareq.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -281,14 +281,14 @@ class TDataReq : public TActor<TDataReq> {

struct TEvPrivate {
enum EEv {
TEvProxyDataReqOngoingTransactionsWatchdog = EventSpaceBegin(TEvents::ES_PRIVATE),
EvProxyDataReqOngoingTransactionsWatchdog = EventSpaceBegin(TEvents::ES_PRIVATE),
EvReattachToShard,
EvEnd
};

static_assert(EvEnd < EventSpaceEnd(TEvents::ES_PRIVATE), "expect EvEnd < EventSpaceEnd(TEvents::ES_PRIVATE)");

struct TTEvProxyDataReqOngoingTransactionsWatchdog : public TEventLocal<TTEvProxyDataReqOngoingTransactionsWatchdog, TEvProxyDataReqOngoingTransactionsWatchdog> {};
struct TEvProxyDataReqOngoingTransactionsWatchdog : public TEventLocal<TEvProxyDataReqOngoingTransactionsWatchdog, EvProxyDataReqOngoingTransactionsWatchdog> {};

struct TEvReattachToShard : public TEventLocal<TEvReattachToShard, EvReattachToShard> {
const ui64 TabletId;
Expand Down Expand Up @@ -503,7 +503,7 @@ class TDataReq : public TActor<TDataReq> {
HFuncTraced(TEvTxProxySchemeCache::TEvResolveKeySetResult, Handle);
HFuncTraced(TEvents::TEvUndelivered, HandleUndeliveredResolve); // we must wait for resolve completion
CFunc(TEvents::TSystem::Wakeup, HandleExecTimeoutResolve); // we must wait for resolve completion to keep key description
CFunc(TEvPrivate::TEvProxyDataReqOngoingTransactionsWatchdog, HandleWatchdog);
CFunc(TEvPrivate::EvProxyDataReqOngoingTransactionsWatchdog, HandleWatchdog);
}
}

Expand All @@ -514,7 +514,7 @@ class TDataReq : public TActor<TDataReq> {
HFuncTraced(TEvTxProcessing::TEvStreamIsDead, Handle);
HFuncTraced(TEvents::TEvUndelivered, Handle);
CFunc(TEvents::TSystem::Wakeup, HandleExecTimeout);
CFunc(TEvPrivate::TEvProxyDataReqOngoingTransactionsWatchdog, HandleWatchdog);
CFunc(TEvPrivate::EvProxyDataReqOngoingTransactionsWatchdog, HandleWatchdog);
}
}

Expand Down Expand Up @@ -544,7 +544,7 @@ class TDataReq : public TActor<TDataReq> {
HFuncTraced(TEvPrivate::TEvReattachToShard, Handle);
HFuncTraced(TEvents::TEvUndelivered, Handle);
CFunc(TEvents::TSystem::Wakeup, HandleExecTimeout);
CFunc(TEvPrivate::TEvProxyDataReqOngoingTransactionsWatchdog, HandleWatchdog);
CFunc(TEvPrivate::EvProxyDataReqOngoingTransactionsWatchdog, HandleWatchdog);
}
}

Expand Down Expand Up @@ -577,7 +577,7 @@ class TDataReq : public TActor<TDataReq> {
HFuncTraced(TEvPrivate::TEvReattachToShard, Handle);
HFuncTraced(TEvents::TEvUndelivered, Handle);
CFunc(TEvents::TSystem::Wakeup, HandleExecTimeout);
CFunc(TEvPrivate::TEvProxyDataReqOngoingTransactionsWatchdog, HandleWatchdog);
CFunc(TEvPrivate::EvProxyDataReqOngoingTransactionsWatchdog, HandleWatchdog);
}
}
};
Expand Down

0 comments on commit 103f6ef

Please sign in to comment.