diff --git a/pkg/compute/guestdrivers/esxi.go b/pkg/compute/guestdrivers/esxi.go index 909dc84c96..4ab8dc4fd1 100644 --- a/pkg/compute/guestdrivers/esxi.go +++ b/pkg/compute/guestdrivers/esxi.go @@ -481,3 +481,42 @@ func (self *SESXiGuestDriver) RequestLiveMigrate(ctx context.Context, guest *mod }) return nil } + +func (self *SESXiGuestDriver) RequestSyncstatusOnHost(ctx context.Context, guest *models.SGuest, host *models.SHost, userCred mcclient.TokenCredential) (jsonutils.JSONObject, error) { + ihost, err := host.GetIHost() + if err != nil { + return nil, err + } + ivm, err := ihost.GetIVMById(guest.GetExternalId()) + if err != nil && errors.Cause(err) != errors.ErrNotFound { + return nil, err + } + // VM may be migrated by Vcenter, try to find VM from whole datacenter. + if err != nil { + ehost := ihost.(*esxi.SHost) + dc, err := ehost.GetDatacenter() + if err != nil { + return nil, errors.Wrapf(err, "ehost.GetDatacenter") + } + vm, err := dc.FetchVMById(guest.GetExternalId()) + if err != nil { + log.Errorf("fail to find ivm by id %q in dc %q: %v", guest.GetExternalId(), dc.GetName(), err) + return nil, err + } + ihost = vm.GetIHost() + host = models.HostManager.FetchHostByExtId(ihost.GetGlobalId()) + if host == nil { + return nil, errors.Wrapf(errors.ErrNotFound, "find ivm %q in ihost %q which is not existed here", guest.GetExternalId(), ihost.GetGlobalId()) + } + ivm = vm + } + err = guest.SyncAllWithCloudVM(ctx, userCred, host, ivm) + if err != nil { + return nil, err + } + + status := GetCloudVMStatus(ivm) + body := jsonutils.NewDict() + body.Add(jsonutils.NewString(status), "status") + return body, nil +} diff --git a/pkg/compute/models/hosts.go b/pkg/compute/models/hosts.go index 4250ade053..1a9ad048fe 100644 --- a/pkg/compute/models/hosts.go +++ b/pkg/compute/models/hosts.go @@ -5467,3 +5467,15 @@ func (manager *SHostManager) ListItemExportKeys(ctx context.Context, } return q, nil } + +func (manager *SHostManager) FetchHostByExtId(extid string) *SHost { + host := SHost{} + host.SetModelManager(manager, &host) + err := manager.Query().Equals("external_id", extid).First(&host) + if err != nil { + log.Errorf("fetchHostByExtId fail %s", err) + return nil + } else { + return &host + } +}