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:09:01 UTC

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

Author: benh
Date: Sun Jun  5 09:09:01 2011
New Revision: 1132260

URL: http://svn.apache.org/viewvc?rev=1132260&view=rev
Log:
Updated libprocess to ensure happens-before from dispatchs (when applicable).

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=1132260&r1=1132259&r2=1132260&view=diff
==============================================================================
--- incubator/mesos/trunk/third_party/libprocess/process.cpp (original)
+++ incubator/mesos/trunk/third_party/libprocess/process.cpp Sun Jun  5 09:09:01 2011
@@ -2623,9 +2623,12 @@ void Process::dispatcher(Process *proces
   }
 
   // Encode and deliver outgoing message.
-  Message *message = encode(PID(), process->pid, DISPATCH, 
+  Message *message = encode(PID(), process->pid, DISPATCH,
                             string((char *) &delegator, sizeof(delegator)));
 
-  // TODO(benh): Maintain happens before using proc_process?
-  process_manager->deliver(message);
+  if (proc_process != NULL) {
+    process_manager->deliver(message, proc_process);
+  } else {
+    process_manager->deliver(message);
+  }
 }