diff options
author | danlark <[email protected]> | 2022-02-10 16:46:10 +0300 |
---|---|---|
committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:46:10 +0300 |
commit | baa58daefa91fde4b4769facdbd2903763b9c6a8 (patch) | |
tree | 1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /library/cpp/actors/interconnect/load.cpp | |
parent | 3426a9bc7f169ae9da54cef557ad2a33f6e8eee0 (diff) |
Restoring authorship annotation for <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/actors/interconnect/load.cpp')
-rw-r--r-- | library/cpp/actors/interconnect/load.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/library/cpp/actors/interconnect/load.cpp b/library/cpp/actors/interconnect/load.cpp index 6ec989f2415..2a8443da71f 100644 --- a/library/cpp/actors/interconnect/load.cpp +++ b/library/cpp/actors/interconnect/load.cpp @@ -186,7 +186,7 @@ namespace NInterconnect { } void GenerateMessages(const TActorContext& ctx) { - while (InFly.size() < Params.InFlyMax && ctx.Now() >= NextMessageTimestamp) { + while (InFly.size() < Params.InFlyMax && ctx.Now() >= NextMessageTimestamp) { // generate payload const ui32 size = Params.SizeMin + RandomNumber(Params.SizeMax - Params.SizeMin + 1); @@ -360,7 +360,7 @@ namespace NInterconnect { std::sort(v.begin(), v.end()); for (double q : {0.5, 0.9, 0.99, 0.999, 0.9999, 1.0}) { const size_t pos = q * (v.size() - 1); - msg << Sprintf(" %.4f# %s", q, v[pos].ToString().data()); + msg << Sprintf(" %.4f# %s", q, v[pos].ToString().data()); } msg << "}"; } else { @@ -373,7 +373,7 @@ namespace NInterconnect { msg << " final"; } - LOG_NOTICE(ctx, NActorsServices::INTERCONNECT_SPEED_TEST, "%s", msg.Str().data()); + LOG_NOTICE(ctx, NActorsServices::INTERCONNECT_SPEED_TEST, "%s", msg.Str().data()); if (schedule) { SchedulePublishResults(ctx); |