summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--gr-zeromq/lib/pull_msg_source_impl.cc4
-rw-r--r--gr-zeromq/lib/req_msg_source_impl.cc4
-rw-r--r--gr-zeromq/lib/sub_msg_source_impl.cc4
3 files changed, 6 insertions, 6 deletions
diff --git a/gr-zeromq/lib/pull_msg_source_impl.cc b/gr-zeromq/lib/pull_msg_source_impl.cc
index 220a908565..1bf4e7532e 100644
--- a/gr-zeromq/lib/pull_msg_source_impl.cc
+++ b/gr-zeromq/lib/pull_msg_source_impl.cc
@@ -94,7 +94,7 @@ void pull_msg_source_impl::readloop()
if (!ok) {
// Should not happen, we've checked POLLIN.
GR_LOG_ERROR(d_logger, "Failed to receive message.");
- std::this_thread::sleep_for(100ms);
+ std::this_thread::sleep_for(100us);
continue;
}
@@ -108,7 +108,7 @@ void pull_msg_source_impl::readloop()
}
} else {
- std::this_thread::sleep_for(100ms);
+ std::this_thread::sleep_for(100us);
}
}
}
diff --git a/gr-zeromq/lib/req_msg_source_impl.cc b/gr-zeromq/lib/req_msg_source_impl.cc
index 2bd6435e22..15950489cf 100644
--- a/gr-zeromq/lib/req_msg_source_impl.cc
+++ b/gr-zeromq/lib/req_msg_source_impl.cc
@@ -113,7 +113,7 @@ void req_msg_source_impl::readloop()
if (!ok) {
// Should not happen, we've checked POLLIN.
GR_LOG_ERROR(d_logger, "Failed to receive message.");
- std::this_thread::sleep_for(100ms);
+ std::this_thread::sleep_for(100us);
continue;
}
@@ -127,7 +127,7 @@ void req_msg_source_impl::readloop()
}
} else {
- std::this_thread::sleep_for(100ms);
+ std::this_thread::sleep_for(100us);
}
}
}
diff --git a/gr-zeromq/lib/sub_msg_source_impl.cc b/gr-zeromq/lib/sub_msg_source_impl.cc
index b65179107f..edef82a21f 100644
--- a/gr-zeromq/lib/sub_msg_source_impl.cc
+++ b/gr-zeromq/lib/sub_msg_source_impl.cc
@@ -93,7 +93,7 @@ void sub_msg_source_impl::readloop()
if (!ok) {
// Should not happen, we've checked POLLIN.
GR_LOG_ERROR(d_logger, "Failed to receive message.");
- std::this_thread::sleep_for(100ms);
+ std::this_thread::sleep_for(100us);
continue;
}
@@ -106,7 +106,7 @@ void sub_msg_source_impl::readloop()
GR_LOG_ERROR(d_logger, std::string("Invalid PMT message: ") + e.what());
}
} else {
- std::this_thread::sleep_for(100ms);
+ std::this_thread::sleep_for(100us);
}
}
}