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.