[mesos] 01/02: Made starting and stopping on CSI plugin containers more verbose.

[bb...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

bbannier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/mesos.git

commit a7d960a91d6bb213cb9b8e5054ee0741436d6aee
Author: Benjamin Bannier <be...@mesosphere.io>
AuthorDate: Thu Jan 24 10:04:51 2019 +0100

    Made starting and stopping on CSI plugin containers more verbose.
    
    This patch adds some additional logging so it becomes easier to follow
    the lifecycle of CSI plugins. The container daemon already logged some
    related information, but didn't directly call out that it was working
    with CSI plugin containers.
    
    Review: https://reviews.apache.org/r/69606/
---
 src/resource_provider/storage/provider.cpp | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/src/resource_provider/storage/provider.cpp b/src/resource_provider/storage/provider.cpp
index a064166..6f0c062 100644
--- a/src/resource_provider/storage/provider.cpp
+++ b/src/resource_provider/storage/provider.cpp
@@ -2017,6 +2017,11 @@ Future<csi::v0::Client> StorageLocalResourceProviderProcess::getService(
       config->resources(),
       containerInfo,
       std::function<Future<Nothing>()>(defer(self(), [=]() -> Future<Nothing> {
+        LOG(INFO)
+          << "CSI plugin container '" << containerId << "' started for plugin"
+          << " type '" << info.storage().plugin().type() << "' and "
+          << " name '" << info.storage().plugin().name() << "'";
+
         CHECK(services.at(containerId)->associate(connect(endpointPath)));
         return services.at(containerId)->future()
           .then([] { return Nothing(); });
@@ -2027,6 +2032,11 @@ Future<csi::v0::Client> StorageLocalResourceProviderProcess::getService(
         services.at(containerId)->discard();
         services.at(containerId).reset(new Promise<csi::v0::Client>());
 
+        LOG(INFO)
+          << "CSI plugin container '" << containerId << "' stopped for plugin"
+          << " type '" << info.storage().plugin().type() << "' and "
+          << " name '" << info.storage().plugin().name() << "'";
+
         if (os::exists(endpointPath)) {
           Try<Nothing> rm = os::rm(endpointPath);
           if (rm.isError()) {