summaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/interconnect/load.cpp
diff options
context:
space:
mode:
authordanlark <[email protected]>2022-02-10 16:46:10 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:46:10 +0300
commitbaa58daefa91fde4b4769facdbd2903763b9c6a8 (patch)
tree1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /library/cpp/actors/interconnect/load.cpp
parent3426a9bc7f169ae9da54cef557ad2a33f6e8eee0 (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.cpp6
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);