aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/interconnect/load.h
diff options
context:
space:
mode:
authorAlexander Rutkovsky <alexvru@mail.ru>2022-02-10 16:47:39 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:39 +0300
commitf3646f91e0de459836a7800b9ce3e8dc57a2ab3a (patch)
tree25c1423200152570c1f8307e5b8304b9bc3840c5 /library/cpp/actors/interconnect/load.h
parentfccc62e9bfdce9be2fe7e0f23479da3a5512211a (diff)
downloadydb-f3646f91e0de459836a7800b9ce3e8dc57a2ab3a.tar.gz
Restoring authorship annotation for Alexander Rutkovsky <alexvru@mail.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/actors/interconnect/load.h')
-rw-r--r--library/cpp/actors/interconnect/load.h28
1 files changed, 14 insertions, 14 deletions
diff --git a/library/cpp/actors/interconnect/load.h b/library/cpp/actors/interconnect/load.h
index 0a01a0dc04..4e122f6e53 100644
--- a/library/cpp/actors/interconnect/load.h
+++ b/library/cpp/actors/interconnect/load.h
@@ -1,24 +1,24 @@
-#pragma once
-
+#pragma once
+
#include <library/cpp/actors/core/actor.h>
-
-namespace NInterconnect {
- // load responder -- lives on every node as a service actor
+
+namespace NInterconnect {
+ // load responder -- lives on every node as a service actor
NActors::IActor* CreateLoadResponderActor();
NActors::TActorId MakeLoadResponderActorId(ui32 node);
-
- // load actor -- generates load with specific parameters
- struct TLoadParams {
- TString Name;
- ui32 Channel;
+
+ // load actor -- generates load with specific parameters
+ struct TLoadParams {
+ TString Name;
+ ui32 Channel;
TVector<ui32> NodeHops; // node ids for the message route
ui32 SizeMin, SizeMax; // min and max size for payloads
ui32 InFlyMax; // maximum number of in fly messages
- TDuration IntervalMin, IntervalMax; // min and max intervals between sending messages
+ TDuration IntervalMin, IntervalMax; // min and max intervals between sending messages
bool SoftLoad; // is the load soft?
TDuration Duration; // test duration
- bool UseProtobufWithPayload; // store payload separately
- };
+ bool UseProtobufWithPayload; // store payload separately
+ };
NActors::IActor* CreateLoadActor(const TLoadParams& params);
-
+
}