Skip to content

Commit

Permalink
Merge pull request #1327 from seokho-son/main
Browse files Browse the repository at this point in the history
Refactor func names
  • Loading branch information
seokho-son authored Sep 6, 2023
2 parents 509491b + a920f93 commit 6805ef1
Show file tree
Hide file tree
Showing 3 changed files with 14 additions and 14 deletions.
2 changes: 1 addition & 1 deletion src/api/rest/server/mcis/manageInfo.go
Original file line number Diff line number Diff line change
Expand Up @@ -282,7 +282,7 @@ func RestGetMcisVm(c echo.Context) error {

switch option {
case "status":
result, err := mcis.CoreGetMcisVmStatus(nsId, mcisId, vmId)
result, err := mcis.GetMcisVmStatus(nsId, mcisId, vmId)
if err != nil {
common.CBLog.Error(err)
mapA := map[string]string{"message": err.Error()}
Expand Down
22 changes: 11 additions & 11 deletions src/core/mcis/manageInfo.go
Original file line number Diff line number Diff line change
Expand Up @@ -552,7 +552,7 @@ func ListMcisInfo(nsId string, option string) ([]TbMcisInfo, error) {

if option == "status" {
//get current vm status
vmStatusInfoTmp, err := GetVmStatus(nsId, mcisId, v1)
vmStatusInfoTmp, err := FetchVmStatus(nsId, mcisId, v1)
if err != nil {
common.CBLog.Error(err)
}
Expand Down Expand Up @@ -628,7 +628,7 @@ func ListVmInfo(nsId string, mcisId string, vmId string) (*TbVmInfo, error) {
vmTmp.Id = vmId

//get current vm status
vmStatusInfoTmp, err := GetVmStatus(nsId, mcisId, vmId)
vmStatusInfoTmp, err := FetchVmStatus(nsId, mcisId, vmId)
if err != nil {
common.CBLog.Error(err)
}
Expand Down Expand Up @@ -807,7 +807,7 @@ func GetMcisStatus(nsId string, mcisId string) (*McisStatusInfo, error) {
var wg sync.WaitGroup
for _, v := range vmList {
wg.Add(1)
go GetVmStatusAsync(&wg, nsId, mcisId, v, &mcisStatus)
go FetchVmStatusAsync(&wg, nsId, mcisId, v, &mcisStatus)
}
wg.Wait() //goroutine sync wg

Expand Down Expand Up @@ -1110,12 +1110,12 @@ func GetVmSpecId(nsId string, mcisId string, vmId string) string {
return content.SpecId
}

// GetVmStatusAsync is func to get VM status async
func GetVmStatusAsync(wg *sync.WaitGroup, nsId string, mcisId string, vmId string, results *McisStatusInfo) error {
// FetchVmStatusAsync is func to get VM status async
func FetchVmStatusAsync(wg *sync.WaitGroup, nsId string, mcisId string, vmId string, results *McisStatusInfo) error {
defer wg.Done() //goroutine sync done

if nsId != "" && mcisId != "" && vmId != "" {
vmStatusTmp, err := GetVmStatus(nsId, mcisId, vmId)
vmStatusTmp, err := FetchVmStatus(nsId, mcisId, vmId)
if err != nil {
common.CBLog.Error(err)
vmStatusTmp.Status = StatusFailed
Expand All @@ -1128,8 +1128,8 @@ func GetVmStatusAsync(wg *sync.WaitGroup, nsId string, mcisId string, vmId strin
return nil
}

// GetVmStatus is func to get VM status
func GetVmStatus(nsId string, mcisId string, vmId string) (TbVmStatusInfo, error) {
// FetchVmStatus is func to fetch VM status (call to CSPs)
func FetchVmStatus(nsId string, mcisId string, vmId string) (TbVmStatusInfo, error) {

// defer func() {
// if runtimeErr := recover(); runtimeErr != nil {
Expand Down Expand Up @@ -1349,8 +1349,8 @@ func GetVmStatus(nsId string, mcisId string, vmId string) (TbVmStatusInfo, error
return vmStatusTmp, nil
}

// CoreGetMcisVmStatus is func to Get McisVm Status
func CoreGetMcisVmStatus(nsId string, mcisId string, vmId string) (*TbVmStatusInfo, error) {
// GetMcisVmStatus is func to Get McisVm Status
func GetMcisVmStatus(nsId string, mcisId string, vmId string) (*TbVmStatusInfo, error) {

err := common.CheckString(nsId)
if err != nil {
Expand Down Expand Up @@ -1395,7 +1395,7 @@ func CoreGetMcisVmStatus(nsId string, mcisId string, vmId string) (*TbVmStatusIn
return nil, fmt.Errorf("Cannot find " + vmKey)
}

vmStatusResponse, err := GetVmStatus(nsId, mcisId, vmId)
vmStatusResponse, err := FetchVmStatus(nsId, mcisId, vmId)

if err != nil {
common.CBLog.Error(err)
Expand Down
4 changes: 2 additions & 2 deletions src/core/mcis/provisioning.go
Original file line number Diff line number Diff line change
Expand Up @@ -567,7 +567,7 @@ func CreateMcisVm(nsId string, mcisId string, vmInfoData *TbVmInfo) (*TbVmInfo,

wg.Wait()

vmStatus, err := GetVmStatus(nsId, mcisId, vmInfoData.Id)
vmStatus, err := FetchVmStatus(nsId, mcisId, vmInfoData.Id)
if err != nil {
return nil, fmt.Errorf("Cannot find " + common.GenMcisKey(nsId, mcisId, vmInfoData.Id))
}
Expand Down Expand Up @@ -1535,7 +1535,7 @@ func AddVmToMcis(wg *sync.WaitGroup, nsId string, mcisId string, vmInfoData *TbV
vmInfoData.TargetStatus = StatusComplete

// get and set current vm status
vmStatusInfoTmp, err := GetVmStatus(nsId, mcisId, vmInfoData.Id)
vmStatusInfoTmp, err := FetchVmStatus(nsId, mcisId, vmInfoData.Id)

if err != nil {
common.CBLog.Error(err)
Expand Down

0 comments on commit 6805ef1

Please sign in to comment.