You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by be...@apache.org on 2012/09/19 07:47:42 UTC

svn commit: r1387452 - /incubator/mesos/trunk/third_party/libprocess/src/process.cpp

Author: benh
Date: Wed Sep 19 05:47:42 2012
New Revision: 1387452

URL: http://svn.apache.org/viewvc?rev=1387452&view=rev
Log:
Changed libprocess to always have at least 4 processing threads.

Modified:
    incubator/mesos/trunk/third_party/libprocess/src/process.cpp

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=1387452&r1=1387451&r2=1387452&view=diff
==============================================================================
--- incubator/mesos/trunk/third_party/libprocess/src/process.cpp (original)
+++ incubator/mesos/trunk/third_party/libprocess/src/process.cpp Wed Sep 19 05:47:42 2012
@@ -86,7 +86,6 @@ using std::deque;
 using std::find;
 using std::list;
 using std::map;
-using std::max;
 using std::ostream;
 using std::pair;
 using std::queue;
@@ -1236,7 +1235,7 @@ void initialize(const string& delegate)
   socket_manager = new SocketManager();
 
   // Setup processing threads.
-  long cpus = sysconf(_SC_NPROCESSORS_ONLN);
+  long cpus = std::max(4L, sysconf(_SC_NPROCESSORS_ONLN));
 
   for (int i = 0; i < cpus; i++) {
     pthread_t thread; // For now, not saving handles on our threads.