Skip to content

Commit 4166e91

Browse files
committedFeb 15, 2021
fixup! zeromq: Fix warnings with recv()
Signed-off-by: Martin Braun <[email protected]>
1 parent e774111 commit 4166e91

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed
 

‎gr-zeromq/lib/pull_msg_source_impl.cc

+2-2
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ void pull_msg_source_impl::readloop()
9494
if (!ok) {
9595
// Should not happen, we've checked POLLIN.
9696
GR_LOG_ERROR(d_logger, "Failed to receive message.");
97-
std::this_thread::sleep_for(100ms);
97+
std::this_thread::sleep_for(100us);
9898
continue;
9999
}
100100

@@ -108,7 +108,7 @@ void pull_msg_source_impl::readloop()
108108
}
109109

110110
} else {
111-
std::this_thread::sleep_for(100ms);
111+
std::this_thread::sleep_for(100us);
112112
}
113113
}
114114
}

‎gr-zeromq/lib/req_msg_source_impl.cc

+2-2
Original file line numberDiff line numberDiff line change
@@ -113,7 +113,7 @@ void req_msg_source_impl::readloop()
113113
if (!ok) {
114114
// Should not happen, we've checked POLLIN.
115115
GR_LOG_ERROR(d_logger, "Failed to receive message.");
116-
std::this_thread::sleep_for(100ms);
116+
std::this_thread::sleep_for(100us);
117117
continue;
118118
}
119119

@@ -127,7 +127,7 @@ void req_msg_source_impl::readloop()
127127
}
128128

129129
} else {
130-
std::this_thread::sleep_for(100ms);
130+
std::this_thread::sleep_for(100us);
131131
}
132132
}
133133
}

‎gr-zeromq/lib/sub_msg_source_impl.cc

+2-2
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ void sub_msg_source_impl::readloop()
9393
if (!ok) {
9494
// Should not happen, we've checked POLLIN.
9595
GR_LOG_ERROR(d_logger, "Failed to receive message.");
96-
std::this_thread::sleep_for(100ms);
96+
std::this_thread::sleep_for(100us);
9797
continue;
9898
}
9999

@@ -106,7 +106,7 @@ void sub_msg_source_impl::readloop()
106106
GR_LOG_ERROR(d_logger, std::string("Invalid PMT message: ") + e.what());
107107
}
108108
} else {
109-
std::this_thread::sleep_for(100ms);
109+
std::this_thread::sleep_for(100us);
110110
}
111111
}
112112
}

0 commit comments

Comments
 (0)
Please sign in to comment.