diff options
author | ienkovich <ienkovich@yandex-team.ru> | 2022-02-10 16:47:50 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:50 +0300 |
commit | 0a579de32b745908473b2cea7c5cd5540bc801f0 (patch) | |
tree | c0748b5dcbade83af788c0abfa89c0383d6b779c /library/cpp/actors/core | |
parent | 5bd76e73fa8dd777999be2668ff56928cc3dbecb (diff) | |
download | ydb-0a579de32b745908473b2cea7c5cd5540bc801f0.tar.gz |
Restoring authorship annotation for <ienkovich@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/actors/core')
-rw-r--r-- | library/cpp/actors/core/hfunc.h | 6 | ||||
-rw-r--r-- | library/cpp/actors/core/interconnect.h | 100 | ||||
-rw-r--r-- | library/cpp/actors/core/log_settings.h | 4 |
3 files changed, 55 insertions, 55 deletions
diff --git a/library/cpp/actors/core/hfunc.h b/library/cpp/actors/core/hfunc.h index 618c641fff..26f3c65013 100644 --- a/library/cpp/actors/core/hfunc.h +++ b/library/cpp/actors/core/hfunc.h @@ -64,9 +64,9 @@ HandleFunc(ctx); \ break; -#define cFunc(TEventType, HandleFunc) \ - case TEventType: \ - HandleFunc(); \ +#define cFunc(TEventType, HandleFunc) \ + case TEventType: \ + HandleFunc(); \ break; #define FFunc(TEventType, HandleFunc) \ diff --git a/library/cpp/actors/core/interconnect.h b/library/cpp/actors/core/interconnect.h index 662b22fdfc..679a4b8cc6 100644 --- a/library/cpp/actors/core/interconnect.h +++ b/library/cpp/actors/core/interconnect.h @@ -128,9 +128,9 @@ namespace NActors { EvRegisterNodeResult, EvListNodes, EvNodesInfo, - EvDisconnect, - EvGetNode, - EvNodeInfo, + EvDisconnect, + EvGetNode, + EvNodeInfo, EvClosePeerSocket, EvCloseInputSession, EvPoisonSession, @@ -146,7 +146,7 @@ namespace NActors { static_assert(EvEnd < EventSpaceEnd(TEvents::ES_INTERCONNECT), "expect EvEnd < EventSpaceEnd(TEvents::ES_INTERCONNECT)"); struct TEvResolveNode; - struct TEvNodeAddress; + struct TEvNodeAddress; struct TEvConnectNode: public TEventBase<TEvConnectNode, EvConnectNode> { DEFINE_SIMPLE_LOCAL_EVENT(TEvConnectNode, "TEvInterconnect::TEvConnectNode") @@ -178,38 +178,38 @@ namespace NActors { struct TEvListNodes: public TEventLocal<TEvListNodes, EvListNodes> { }; - struct TNodeInfo { - ui32 NodeId; - TString Address; - TString Host; - TString ResolveHost; - ui16 Port; + struct TNodeInfo { + ui32 NodeId; + TString Address; + TString Host; + TString ResolveHost; + ui16 Port; TNodeLocation Location; TNodeInfo() = default; TNodeInfo(const TNodeInfo&) = default; TNodeInfo& operator =(const TNodeInfo&) = default; - TNodeInfo(ui32 nodeId, - const TString& address, - const TString& host, - const TString& resolveHost, - ui16 port, + TNodeInfo(ui32 nodeId, + const TString& address, + const TString& host, + const TString& resolveHost, + ui16 port, const TNodeLocation& location) - : NodeId(nodeId) - , Address(address) - , Host(host) - , ResolveHost(resolveHost) - , Port(port) - , Location(location) - { - } - - operator ui32() const { - return NodeId; - } - }; - - struct TEvNodesInfo: public TEventLocal<TEvNodesInfo, EvNodesInfo> { + : NodeId(nodeId) + , Address(address) + , Host(host) + , ResolveHost(resolveHost) + , Port(port) + , Location(location) + { + } + + operator ui32() const { + return NodeId; + } + }; + + struct TEvNodesInfo: public TEventLocal<TEvNodesInfo, EvNodesInfo> { TVector<TNodeInfo> Nodes; const TNodeInfo* GetNodeInfo(ui32 nodeId) const { @@ -220,29 +220,29 @@ namespace NActors { return nullptr; } }; - - struct TEvDisconnect; - - struct TEvGetNode: public TEventLocal<TEvGetNode, EvGetNode> { - ui32 NodeId; + + struct TEvDisconnect; + + struct TEvGetNode: public TEventLocal<TEvGetNode, EvGetNode> { + ui32 NodeId; TInstant Deadline; - + TEvGetNode(ui32 nodeId, TInstant deadline = TInstant::Max()) - : NodeId(nodeId) + : NodeId(nodeId) , Deadline(deadline) - { - } - }; - - struct TEvNodeInfo: public TEventLocal<TEvNodeInfo, EvNodeInfo> { - TEvNodeInfo(ui32 nodeId) - : NodeId(nodeId) - { - } - - ui32 NodeId; - THolder<TNodeInfo> Node; - }; + { + } + }; + + struct TEvNodeInfo: public TEventLocal<TEvNodeInfo, EvNodeInfo> { + TEvNodeInfo(ui32 nodeId) + : NodeId(nodeId) + { + } + + ui32 NodeId; + THolder<TNodeInfo> Node; + }; struct TEvClosePeerSocket : TEventLocal<TEvClosePeerSocket, EvClosePeerSocket> {}; diff --git a/library/cpp/actors/core/log_settings.h b/library/cpp/actors/core/log_settings.h index 4e2b45ae48..7fe4504edd 100644 --- a/library/cpp/actors/core/log_settings.h +++ b/library/cpp/actors/core/log_settings.h @@ -118,8 +118,8 @@ namespace NActors { return func(static_cast<T>(c)); } ); - } - + } + inline bool Satisfies(EPriority priority, EComponent component, ui64 sampleBy = 0) const { // by using Mask we don't get outside of array boundaries TComponentSettings settings = GetComponentSettings(component); |