diff options
author | Alexander Rutkovsky <alexvru@mail.ru> | 2022-02-10 16:47:39 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:39 +0300 |
commit | f3646f91e0de459836a7800b9ce3e8dc57a2ab3a (patch) | |
tree | 25c1423200152570c1f8307e5b8304b9bc3840c5 /library/cpp/actors/interconnect/load.h | |
parent | fccc62e9bfdce9be2fe7e0f23479da3a5512211a (diff) | |
download | ydb-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.h | 28 |
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); - + } |