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;
   }