Skip to content

Commit

Permalink
Check profile, node name to prevent duplication
Browse files Browse the repository at this point in the history
Check profile and node name before add to prevent conflict with
machine name on multinode cluster.
  • Loading branch information
daehyeok authored and Daehyeok Mun committed Jan 13, 2021
1 parent 31aa5c1 commit dda0b26
Show file tree
Hide file tree
Showing 4 changed files with 40 additions and 4 deletions.
24 changes: 24 additions & 0 deletions cmd/minikube/cmd/start.go
Original file line number Diff line number Diff line change
Expand Up @@ -178,6 +178,7 @@ func runStart(cmd *cobra.Command, args []string) {
upgradeExistingConfig(existing)
}

validateProfileName(existing)
validateSpecifiedDriver(existing)
validateKubernetesVersion(existing)

Expand Down Expand Up @@ -638,6 +639,29 @@ func hostDriver(existing *config.ClusterConfig) string {
return h.Driver.DriverName()
}

// validateProfileName makes sure that new profile name not duplicated with any of machine names in existing multi-node clusters.
func validateProfileName(existing *config.ClusterConfig) {
if existing != nil {
return
}

validPs, _, err := config.ListProfiles()
if err != nil {
exit.Message(reason.InternalListConfig, "Unable to list profiles: {{.error}}", out.V{"error": err})
}
for _, ps := range validPs {
for _, existNode := range ps.Config.Nodes {
machineName := config.MachineName(*ps.Config, existNode)
if ClusterFlagValue() == machineName {
out.WarningT("Profile name '{{.name}}' is duplicated with machine name '{{.machine}}' in profile '{{.profile}}'", out.V{"name": ClusterFlagValue(),
"machine": machineName,
"profile": ps.Name})
exit.Message(reason.Usage, "Profile name should be unique")
}
}
}
}

// validateSpecifiedDriver makes sure that if a user has passed in a driver
// it matches the existing cluster if there is one
func validateSpecifiedDriver(existing *config.ClusterConfig) {
Expand Down
2 changes: 1 addition & 1 deletion pkg/minikube/config/profile.go
Original file line number Diff line number Diff line change
Expand Up @@ -291,7 +291,7 @@ func ProfileFolderPath(profile string, miniHome ...string) string {
// MachineName returns the name of the machine, as seen by the hypervisor given the cluster and node names
func MachineName(cc ClusterConfig, n Node) string {
// For single node cluster, default to back to old naming
if len(cc.Nodes) == 1 || n.ControlPlane {
if (len(cc.Nodes) == 1 && cc.Nodes[0].Name == n.Name) || n.ControlPlane {
return cc.Name
}
return fmt.Sprintf("%s-%s", cc.Name, n.Name)
Expand Down
4 changes: 1 addition & 3 deletions pkg/minikube/machine/cluster_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -146,10 +146,8 @@ func TestStartHostExists(t *testing.T) {
mc := defaultClusterConfig
mc.Name = ih.Name

n := config.Node{Name: ih.Name}

// This should pass without calling Create because the host exists already.
h, _, err := StartHost(api, &mc, &n)
h, _, err := StartHost(api, &mc, &(mc.Nodes[0]))
if err != nil {
t.Fatalf("Error starting host: %v", err)
}
Expand Down
14 changes: 14 additions & 0 deletions pkg/minikube/node/node.go
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,20 @@ const (

// Add adds a new node config to an existing cluster.
func Add(cc *config.ClusterConfig, n config.Node, delOnFail bool) error {
validPs, _, err := config.ListProfiles()
if err != nil {
return err
}

machineName := config.MachineName(*cc, n)
for _, ps := range validPs {
for _, existNode := range ps.Config.Nodes {
if machineName == config.MachineName(*ps.Config, existNode) {
return errors.Errorf("Node %s already exists in %s profile", machineName, ps.Name)
}
}
}

if err := config.SaveNode(cc, &n); err != nil {
return errors.Wrap(err, "save node")
}
Expand Down

0 comments on commit dda0b26

Please sign in to comment.