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 2014/08/05 00:09:41 UTC

[20/43] git commit: Made Docker::ps/rm default arguments match CLI defaults.

Made Docker::ps/rm default arguments match CLI defaults.


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

Branch: refs/heads/master
Commit: a54dda8a49d49265255580241a80edb68b4d76f4
Parents: 38e4752
Author: Benjamin Hindman <be...@gmail.com>
Authored: Sun Jun 29 17:57:28 2014 -0700
Committer: Benjamin Hindman <be...@gmail.com>
Committed: Mon Aug 4 15:08:16 2014 -0700

----------------------------------------------------------------------
 src/docker/docker.hpp                    | 4 ++--
 src/slave/containerizer/docker.cpp       | 9 +++++----
 src/tests/docker_containerizer_tests.cpp | 2 +-
 3 files changed, 8 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/mesos/blob/a54dda8a/src/docker/docker.hpp
----------------------------------------------------------------------
diff --git a/src/docker/docker.hpp b/src/docker/docker.hpp
index 6643036..2957e92 100644
--- a/src/docker/docker.hpp
+++ b/src/docker/docker.hpp
@@ -71,7 +71,7 @@ public:
   // Performs 'docker rm (-f) CONTAINER'.
   process::Future<Option<int> > rm(
       const std::string& container,
-      const bool force = true) const;
+      const bool force = false) const;
 
   // Performs 'docker inspect CONTAINER'.
   process::Future<Container> inspect(
@@ -79,7 +79,7 @@ public:
 
   // Performs 'docker ps (-a)'.
   process::Future<std::list<Container> > ps(
-      const bool all = true) const;
+      const bool all = false) const;
 
   process::Future<std::string> info() const;
 

http://git-wip-us.apache.org/repos/asf/mesos/blob/a54dda8a/src/slave/containerizer/docker.cpp
----------------------------------------------------------------------
diff --git a/src/slave/containerizer/docker.cpp b/src/slave/containerizer/docker.cpp
index 24255e6..5026082 100644
--- a/src/slave/containerizer/docker.cpp
+++ b/src/slave/containerizer/docker.cpp
@@ -409,8 +409,9 @@ Future<Nothing> DockerContainerizerProcess::recover(
     }
   }
 
-  // Get the list of Docker containers in order to Remove any orphans.
-  return docker.ps()
+  // Get the list of all Docker containers (running and exited) in
+  // order to remove any orphans.
+  return docker.ps(true)
     .then(defer(self(), &Self::_recover, lambda::_1));
 }
 
@@ -437,7 +438,7 @@ Future<Nothing> DockerContainerizerProcess::_recover(
     if (!statuses.keys().contains(id.get())) {
       // TODO(benh): Retry 'docker rm -f' if it failed but the container
       // still exists (asynchronously).
-      docker.rm(container.id());
+      docker.rm(container.id(), true);
     }
   }
 
@@ -705,7 +706,7 @@ void DockerContainerizerProcess::destroy(
 
   // TODO(benh): Retry 'docker rm -f' if it failed but the container
   // still exists (asynchronously).
-  docker.rm(DOCKER_NAME_PREFIX + stringify(containerId))
+  docker.rm(DOCKER_NAME_PREFIX + stringify(containerId), true)
     .onAny(defer(self(), &Self::_destroy, containerId, killed, lambda::_1));
 }
 

http://git-wip-us.apache.org/repos/asf/mesos/blob/a54dda8a/src/tests/docker_containerizer_tests.cpp
----------------------------------------------------------------------
diff --git a/src/tests/docker_containerizer_tests.cpp b/src/tests/docker_containerizer_tests.cpp
index b716de4..274eee7 100644
--- a/src/tests/docker_containerizer_tests.cpp
+++ b/src/tests/docker_containerizer_tests.cpp
@@ -147,7 +147,7 @@ TEST_F(DockerContainerizerTest, DOCKER_Launch)
   AWAIT_READY_FOR(statusRunning, Seconds(60));
   EXPECT_EQ(TASK_RUNNING, statusRunning.get().state());
 
-  Future<list<Docker::Container> > containers = docker.ps();
+  Future<list<Docker::Container> > containers = docker.ps(true);
 
   AWAIT_READY(containers);