manager: set patched flag properly

components/dm/spec/topology_dm.go

@@ -112,6 +112,7 @@ type MasterSpec struct {
 	Host     string `yaml:"host"`
 	SSHPort  int    `yaml:"ssh_port,omitempty" validate:"ssh_port:editable"`
 	Imported bool   `yaml:"imported,omitempty"`
+	Patched  bool   `yaml:"patched,omitempty"`
 	// Use Name to get the name with a default value if it's empty.
 	Name            string                 `yaml:"name,omitempty"`
 	Port            int                    `yaml:"port,omitempty" default:"8261"`
@@ -173,6 +174,7 @@ type WorkerSpec struct {
 	Host     string `yaml:"host"`
 	SSHPort  int    `yaml:"ssh_port,omitempty" validate:"ssh_port:editable"`
 	Imported bool   `yaml:"imported,omitempty"`
+	Patched  bool   `yaml:"patched,omitempty"`
 	// Use Name to get the name with a default value if it's empty.
 	Name            string                 `yaml:"name,omitempty"`
 	Port            int                    `yaml:"port,omitempty" default:"8262"`

pkg/cluster/manager/patch.go

@@ -91,6 +91,19 @@ func (m *Manager) Patch(name string, packagePath string, opt operator.Options, o
 		}
 	}
 
+	// mark instance as patched in meta
+	topo.IterInstance(func(ins spec.Instance) {
+		for _, pachedIns := range insts {
+			if ins.ID() == pachedIns.ID() {
+				ins.SetPatched(true)
+				break
+			}
+		}
+	})
+	if err := m.specManager.SaveMeta(name, metadata); err != nil {
+		return perrs.Trace(err)
+	}
+
 	return nil
 }
 

pkg/cluster/spec/instance.go

@@ -92,6 +92,7 @@ type Instance interface {
 	OS() string // only linux supported now
 	Arch() string
 	IsPatched() bool
+	SetPatched(bool)
 }
 
 // PortStarted wait until a port is being listened
@@ -369,6 +370,15 @@ func (i *BaseInstance) IsPatched() bool {
 	return v.Bool()
 }
 
+// SetPatched implements the Instance interface
+func (i *BaseInstance) SetPatched(p bool) {
+	v := reflect.Indirect(reflect.ValueOf(i.InstanceSpec)).FieldByName("Patched")
+	if !v.CanSet() {
+		return
+	}
+	v.SetBool(p)
+}
+
 // PrepareStart checks instance requirements before starting
 func (i *BaseInstance) PrepareStart(tlsCfg *tls.Config) error {
 	return nil