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