You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by bm...@apache.org on 2013/04/15 02:35:31 UTC
svn commit: r1467842 - in /incubator/mesos/trunk/third_party/libprocess:
configure.ac src/process.cpp src/tests/process_tests.cpp
Author: bmahler
Date: Mon Apr 15 00:35:31 2013
New Revision: 1467842
URL: http://svn.apache.org/r1467842
Log:
Replaced usleep() calls in libprocess with os::sleep().
From: Jiang Yan Xu <ya...@jxu.me>
Review: https://reviews.apache.org/r/10241
Modified:
incubator/mesos/trunk/third_party/libprocess/configure.ac
incubator/mesos/trunk/third_party/libprocess/src/process.cpp
incubator/mesos/trunk/third_party/libprocess/src/tests/process_tests.cpp
Modified: incubator/mesos/trunk/third_party/libprocess/configure.ac
URL: http://svn.apache.org/viewvc/incubator/mesos/trunk/third_party/libprocess/configure.ac?rev=1467842&r1=1467841&r2=1467842&view=diff
==============================================================================
--- incubator/mesos/trunk/third_party/libprocess/configure.ac (original)
+++ incubator/mesos/trunk/third_party/libprocess/configure.ac Mon Apr 15 00:35:31 2013
@@ -101,4 +101,13 @@ fi
AM_CONDITIONAL([HAS_GPERFTOOLS], [test "x$gperftools" = "xyes"])
+# Added for clock_gettime() call in stout/stopwatch.hpp.
+case "${target_os}" in
+ linux*)
+ LIBS="$LIBS -lrt"
+ ;;
+ *)
+ ;;
+esac
+
AC_OUTPUT
Modified: incubator/mesos/trunk/third_party/libprocess/src/process.cpp
URL: http://svn.apache.org/viewvc/incubator/mesos/trunk/third_party/libprocess/src/process.cpp?rev=1467842&r1=1467841&r2=1467842&view=diff
==============================================================================
--- incubator/mesos/trunk/third_party/libprocess/src/process.cpp (original)
+++ incubator/mesos/trunk/third_party/libprocess/src/process.cpp Mon Apr 15 00:35:31 2013
@@ -2729,7 +2729,7 @@ void ProcessManager::settle()
{
bool done = true;
do {
- usleep(10000);
+ os::sleep(Milliseconds(10));
done = true;
// Hopefully this is the only place we acquire both these locks.
synchronized (runq) {
Modified: incubator/mesos/trunk/third_party/libprocess/src/tests/process_tests.cpp
URL: http://svn.apache.org/viewvc/incubator/mesos/trunk/third_party/libprocess/src/tests/process_tests.cpp?rev=1467842&r1=1467841&r2=1467842&view=diff
==============================================================================
--- incubator/mesos/trunk/third_party/libprocess/src/tests/process_tests.cpp (original)
+++ incubator/mesos/trunk/third_party/libprocess/src/tests/process_tests.cpp Mon Apr 15 00:35:31 2013
@@ -892,14 +892,14 @@ public:
virtual void initialize()
{
- usleep(10000);
+ os::sleep(Milliseconds(10));
delay(Seconds(0), self(), &SettleProcess::afterDelay);
}
void afterDelay()
{
dispatch(self(), &SettleProcess::afterDispatch);
- usleep(10000);
+ os::sleep(Milliseconds(10));
TimeoutProcess timeoutProcess;
spawn(timeoutProcess);
terminate(timeoutProcess);
@@ -908,7 +908,7 @@ public:
void afterDispatch()
{
- usleep(10000);
+ os::sleep(Milliseconds(10));
calledDispatch = true;
}