This is an automated email from the ASF dual-hosted git repository.
grag pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/mesos.git
commit 68b481085fb82b475e108b9aa39935a8d7729983
Author: Greg Mann <g...@mesosphere.io>
AuthorDate: Thu Aug 20 19:26:48 2020 -0700
Fixed a bug in CSI volume manager initialization.
Previously, the volume managers would assume that they could
make CONTROLLER_SERVICE calls during plugin initialization,
regardless of whether or not the plugin provides that service.
Review: https://reviews.apache.org/r/72726/
---
src/csi/v0_volume_manager.cpp | 2 +-
src/csi/v1_volume_manager.cpp | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/csi/v0_volume_manager.cpp b/src/csi/v0_volume_manager.cpp
index 42a23ba..8ba6100 100644
--- a/src/csi/v0_volume_manager.cpp
+++ b/src/csi/v0_volume_manager.cpp
@@ -648,7 +648,7 @@ Future<Nothing> VolumeManagerProcess::prepareServices()
vector<Future<GetPluginInfoResponse>> futures;
foreach (const Service& service, services) {
futures.push_back(call(
- CONTROLLER_SERVICE, &Client::getPluginInfo, GetPluginInfoRequest())
+ service, &Client::getPluginInfo, GetPluginInfoRequest())
.onReady([service](const GetPluginInfoResponse& response) {
LOG(INFO) << service << " loaded: " << stringify(response);
}));
diff --git a/src/csi/v1_volume_manager.cpp b/src/csi/v1_volume_manager.cpp
index c05265c..1a1b97c 100644
--- a/src/csi/v1_volume_manager.cpp
+++ b/src/csi/v1_volume_manager.cpp
@@ -669,7 +669,7 @@ Future<Nothing> VolumeManagerProcess::prepareServices()
vector<Future<GetPluginInfoResponse>> futures;
foreach (const Service& service, services) {
futures.push_back(call(
- CONTROLLER_SERVICE, &Client::getPluginInfo, GetPluginInfoRequest())
+ service, &Client::getPluginInfo, GetPluginInfoRequest())
.onReady([service](const GetPluginInfoResponse& response) {
LOG(INFO) << service << " loaded: " << stringify(response);
}));
