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 2011/06/05 11:20:18 UTC
svn commit: r1132290 -
/incubator/mesos/trunk/third_party/libprocess/process.cpp
Author: benh
Date: Sun Jun 5 09:20:17 2011
New Revision: 1132290
URL: http://svn.apache.org/viewvc?rev=1132290&view=rev
Log:
Bug fix in libprocess relating to 'pause'.
Modified:
incubator/mesos/trunk/third_party/libprocess/process.cpp
Modified: incubator/mesos/trunk/third_party/libprocess/process.cpp
URL: http://svn.apache.org/viewvc/incubator/mesos/trunk/third_party/libprocess/process.cpp?rev=1132290&r1=1132289&r2=1132290&view=diff
==============================================================================
--- incubator/mesos/trunk/third_party/libprocess/process.cpp (original)
+++ incubator/mesos/trunk/third_party/libprocess/process.cpp Sun Jun 5 09:20:17 2011
@@ -2955,6 +2955,7 @@ const std::string& ProcessBase::body() c
void ProcessBase::pause(double secs)
{
if (pthread_self() == proc_thread) {
+ process_manager->pause(this, secs);
} else {
sleep(secs);
}
@@ -3164,6 +3165,8 @@ namespace internal {
void dispatcher(const UPID& pid, function<void(ProcessBase*)>* delegator)
{
+ initialize();
+
if (proc_process != NULL) {
process_manager->deliver(pid, delegator, proc_process);
} else {