From 94238a86d9d7f2e6485bcf40d1fd1f8ce6b27d8c Mon Sep 17 00:00:00 2001 From: zhucan Date: Wed, 19 Jun 2019 15:00:07 +0800 Subject: [PATCH] Leader election lock name should include driver name --- cmd/csi-snapshotter/main.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/cmd/csi-snapshotter/main.go b/cmd/csi-snapshotter/main.go index 880320c0..5f68fb33 100644 --- a/cmd/csi-snapshotter/main.go +++ b/cmd/csi-snapshotter/main.go @@ -73,8 +73,8 @@ var ( ) var ( - version = "unknown" - leaderElectionLockName = "external-snapshotter-leader-election" + version = "unknown" + prefix = "external-snapshotter-leader" ) func main() { @@ -214,7 +214,8 @@ func main() { if !*leaderElection { run(context.TODO()) } else { - le := leaderelection.NewLeaderElection(kubeClient, leaderElectionLockName, run) + lockName := fmt.Sprintf("%s-%s", prefix, strings.Replace(*snapshotterName, "/", "-", -1)) + le := leaderelection.NewLeaderElection(kubeClient, lockName, run) if *leaderElectionNamespace != "" { le.WithNamespace(*leaderElectionNamespace) }