From 62ed4e5f80bfc376c3ffc99c434062cfa8f67eb9 Mon Sep 17 00:00:00 2001 From: Alexey Rybalchenko Date: Thu, 13 Aug 2020 11:53:40 +0200 Subject: [PATCH] Avoid unconditional call to now() when allocating message --- fairmq/shmem/Message.h | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/fairmq/shmem/Message.h b/fairmq/shmem/Message.h index d6b1fd15..6de8ff0c 100644 --- a/fairmq/shmem/Message.h +++ b/fairmq/shmem/Message.h @@ -244,7 +244,7 @@ class Message final : public fair::mq::Message bool InitializeChunk(const size_t size, size_t alignment = 0) { - tools::RateLimiter rateLimiter(20); + // tools::RateLimiter rateLimiter(20); while (fMeta.fHandle < 0) { try { @@ -265,7 +265,8 @@ class Message final : public fair::mq::Message if (fManager.ThrowingOnBadAlloc()) { throw MessageBadAlloc(tools::ToString("shmem: could not create a message of size ", size, ", alignment: ", (alignment != 0) ? std::to_string(alignment) : "default", ", free memory: ", fManager.Segment().get_free_memory())); } - rateLimiter.maybe_sleep(); + // rateLimiter.maybe_sleep(); + std::this_thread::sleep_for(std::chrono::milliseconds(50)); if (fManager.Interrupted()) { return false; } else {