You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by al...@apache.org on 2017/03/15 21:21:11 UTC

[10/13] mesos git commit: Added a warning if command executor gets an unknown acknowledgement.

Added a warning if command executor gets an unknown acknowledgement.

Review: https://reviews.apache.org/r/57149


Project: http://git-wip-us.apache.org/repos/asf/mesos/repo
Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/702562cb
Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/702562cb
Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/702562cb

Branch: refs/heads/master
Commit: 702562cb9cded3dc86e88f704d650a958b98396c
Parents: f042bf6
Author: Alexander Rukletsov <al...@apache.org>
Authored: Tue Feb 28 14:05:33 2017 +0100
Committer: Alexander Rukletsov <al...@apache.org>
Committed: Wed Mar 15 22:20:20 2017 +0100

----------------------------------------------------------------------
 src/launcher/executor.cpp | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/mesos/blob/702562cb/src/launcher/executor.cpp
----------------------------------------------------------------------
diff --git a/src/launcher/executor.cpp b/src/launcher/executor.cpp
index adcc50f..8b13b41 100644
--- a/src/launcher/executor.cpp
+++ b/src/launcher/executor.cpp
@@ -211,6 +211,12 @@ public:
       case Event::ACKNOWLEDGED: {
         const UUID uuid = UUID::fromBytes(event.acknowledged().uuid()).get();
 
+        if (!unacknowledgedUpdates.contains(uuid)) {
+          LOG(WARNING) << "Received acknowledgement " << uuid
+                       << " for unknown status update";
+          return;
+        }
+
         // Terminate if we receive the ACK for the terminal status update.
         // NOTE: The executor receives an ACK iff it uses the HTTP library.
         // No ACK will be received if V0ToV1Adapter is used.