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

fix(region): vpc create with tags

Browse Source
This commit is contained in:
ioito
2021-12-23 19:39:41 +08:00
parent c1824f028e
commit 00affbc8d7
1 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/compute/models/vpcs.go
+12 -12
View File
@@ -882,25 +882,25 @@ func (manager *SVpcManager) ValidateCreateData(
func (self *SVpc) PostCreate(ctx context.Context, userCred mcclient.TokenCredential, ownerId mcclient.IIdentityProvider, query jsonutils.JSONObject, data jsonutils.JSONObject) {
input := api.VpcCreateInput{}
err := data.Unmarshal(&input)
if err != nil {
log.Errorf("input unmarshal error %s", err)
} else {
pendingUsage := &SInfrasQuota{Vpc: 1}
keys := GetVpcQuotaKeysFromCreateInput(ownerId, input)
pendingUsage.SetKeys(keys)
quotas.CancelPendingUsage(ctx, userCred, pendingUsage, pendingUsage, true)
}
data.Unmarshal(&input)
pendingUsage := &SInfrasQuota{Vpc: 1}
keys := GetVpcQuotaKeysFromCreateInput(ownerId, input)
pendingUsage.SetKeys(keys)
quotas.CancelPendingUsage(ctx, userCred, pendingUsage, pendingUsage, true)
defer func() {
self.SEnabledStatusInfrasResourceBase.PostCreate(ctx, userCred, ownerId, query, data)
}()
if len(self.ManagerId) == 0 {
return
}
task, err := taskman.TaskManager.NewTask(ctx, "VpcCreateTask", self, userCred, nil, "", "", nil)
if err != nil {
log.Errorf("VpcCreateTask newTask error %s", err)
} else {
task.ScheduleRun(nil)
self.SetStatus(userCred, api.VPC_STATUS_FAILED, errors.Wrapf(err, "NewTask").Error())
return
}
task.ScheduleRun(nil)
}
func (self *SVpc) GetIRegion() (cloudprovider.ICloudRegion, error) {