opensource/cloudpods
3
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-09-24 16:03:43 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1205 in YUNIONIO/onecloud from ~QUXUAN/onecloud:hotfix/qx-openstack-host to release/2.5.0

Browse Source 
* commit '42589ad68ff78a6bbb6ef59fc1e2135ec9c43229':
  尽可能的同步openstack host信息
This commit is contained in:
邱剑
2019-03-11 17:20:10 +08:00
parent eb82534279 42589ad68f
commit 07193fe9d9
2 changed files with 11 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/util/openstack/host.go
+2 -2
View File
@@ -32,7 +32,7 @@ type SResource struct {
type SHost struct {
zone *SZone
CpuInfo CpuInfo
CpuInfo string
CurrentWorkload int
Status string
@@ -165,7 +165,7 @@ func (host *SHost) GetNodeCount() int8 {
}
func (host *SHost) GetCpuDesc() string {
return jsonutils.Marshal(host.CpuInfo).String()
return host.CpuInfo
}
func (host *SHost) GetCpuMhz() int {
pkg/util/openstack/zone.go
+9 -17
View File
@@ -7,7 +7,6 @@ import (
"yunion.io/x/jsonutils"
"yunion.io/x/log"
"yunion.io/x/onecloud/pkg/cloudcommon/version"
"yunion.io/x/onecloud/pkg/cloudprovider"
"yunion.io/x/onecloud/pkg/compute/models"
)
@@ -144,15 +143,12 @@ type SOsHost struct {
}
func (zone *SZone) GetIHosts() ([]cloudprovider.ICloudHost, error) {
// 2.28 Hypervisor CPU字段是字符串，会解析失败
ihosts := []cloudprovider.ICloudHost{}
hosts := []SHost{}
_, maxVersion, err := zone.region.GetVersion("compute")
if err == nil && version.GE(maxVersion, HYPERVISORS_VERSION) {
_, resp, err := zone.region.Get("compute", "/os-hypervisors/detail", maxVersion, nil)
if err != nil {
return nil, err
}
// 尽可能的优先使用 os-hypervisor, 里面的信息更全些, 实在不行再使用 os-host
_, resp, err := zone.region.Get("compute", "/os-hypervisors/detail", "", nil)
if err == nil {
if err := resp.Unmarshal(&hosts, "hypervisors"); err != nil {
return nil, err
}
@@ -167,8 +163,7 @@ func (zone *SZone) GetIHosts() ([]cloudprovider.ICloudHost, error) {
}
return ihosts, nil
}
_, resp, err := zone.region.Get("compute", "/os-hosts", "", nil)
_, resp, err = zone.region.Get("compute", "/os-hosts", "", nil)
if err != nil {
return nil, err
}
@@ -188,18 +183,15 @@ func (zone *SZone) GetIHosts() ([]cloudprovider.ICloudHost, error) {
}
func (zone *SZone) GetIHostById(id string) (cloudprovider.ICloudHost, error) {
_, maxVersion, err := zone.region.GetVersion("compute")
host := &SHost{zone: zone}
if err == nil && version.GE(maxVersion, HYPERVISORS_VERSION) {
_, resp, err := zone.region.Get("compute", "/os-hypervisors/"+id, maxVersion, nil)
if err != nil {
return nil, err
}
_, resp, err := zone.region.Get("compute", "/os-hypervisors/"+id, "", nil)
if err == nil {
return host, resp.Unmarshal(&host, "hypervisor")
}
host.HostName = id
host.Resource = []map[string]SResource{}
_, resp, err := zone.region.Get("compute", "/os-hosts/"+id, maxVersion, nil)
_, resp, err = zone.region.Get("compute", "/os-hosts/"+id, "", nil)
if err != nil {
return nil, err
}