aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/core
diff options
context:
space:
mode:
authorienkovich <ienkovich@yandex-team.ru>2022-02-10 16:47:50 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:50 +0300
commit0a579de32b745908473b2cea7c5cd5540bc801f0 (patch)
treec0748b5dcbade83af788c0abfa89c0383d6b779c /library/cpp/actors/core
parent5bd76e73fa8dd777999be2668ff56928cc3dbecb (diff)
downloadydb-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.h6
-rw-r--r--library/cpp/actors/core/interconnect.h100
-rw-r--r--library/cpp/actors/core/log_settings.h4
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);