github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-21 02:41:25 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #93846 from knight42/fix/TestEnsureBackendPoolDeletedConcurrently

Browse Source 
fix(azure): set default value of VmssVirtualMachinesCacheTTLInSeconds when initializing scaleSet
This commit is contained in:
Kubernetes Prow Robot 2020-08-10 21:12:17 -07:00 committed by GitHub
commit 04362870ad
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
staging/src/k8s.io/legacy-cloud-providers/azure/azure_vmss.go
View File

@ -83,13 +83,16 @@ type scaleSet struct {
// newScaleSet creates a new scaleSet. // newScaleSet creates a new scaleSet.
func newScaleSet(az *Cloud) (VMSet, error) { func newScaleSet(az *Cloud) (VMSet, error) {
var err error if az.Config.VmssVirtualMachinesCacheTTLInSeconds == 0 {
az.Config.VmssVirtualMachinesCacheTTLInSeconds = vmssVirtualMachinesCacheTTLDefaultInSeconds
}
ss := &scaleSet{ ss := &scaleSet{
Cloud: az, Cloud: az,
availabilitySet: newAvailabilitySet(az), availabilitySet: newAvailabilitySet(az),
vmssVMCache: &sync.Map{}, vmssVMCache: &sync.Map{},
} }
var err error
if !ss.DisableAvailabilitySetNodes { if !ss.DisableAvailabilitySetNodes {
ss.availabilitySetNodesCache, err = ss.newAvailabilitySetNodesCache() ss.availabilitySetNodesCache, err = ss.newAvailabilitySetNodesCache()
if err != nil { if err != nil {

3
staging/src/k8s.io/legacy-cloud-providers/azure/azure_vmss_cache.go
View File

@ -154,9 +154,6 @@ func (ss *scaleSet) gcVMSSVMCache() error {
// newVMSSVirtualMachinesCache instanciates a new VMs cache for VMs belonging to the provided VMSS. // newVMSSVirtualMachinesCache instanciates a new VMs cache for VMs belonging to the provided VMSS.
func (ss *scaleSet) newVMSSVirtualMachinesCache(resourceGroupName, vmssName, cacheKey string) (*azcache.TimedCache, error) { func (ss *scaleSet) newVMSSVirtualMachinesCache(resourceGroupName, vmssName, cacheKey string) (*azcache.TimedCache, error) {
if ss.Config.VmssVirtualMachinesCacheTTLInSeconds == 0 {
ss.Config.VmssVirtualMachinesCacheTTLInSeconds = vmssVirtualMachinesCacheTTLDefaultInSeconds
}
vmssVirtualMachinesCacheTTL := time.Duration(ss.Config.VmssVirtualMachinesCacheTTLInSeconds) * time.Second vmssVirtualMachinesCacheTTL := time.Duration(ss.Config.VmssVirtualMachinesCacheTTLInSeconds) * time.Second
getter := func(key string) (interface{}, error) { getter := func(key string) (interface{}, error) {