kubernetes
/
kops
mirror of https://github.com/kubernetes/kops.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

mockec2: more missing locking

This commit is contained in:
Justin Santa Barbara 2018-03-20 19:20:39 -04:00
parent 717eb4f6c5
commit c8a8d72534
3 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
cloudmock/aws/mockec2/dhcpoptions.go
View File

@ -27,6 +27,9 @@ import (
)
func (m *MockEC2) DescribeDhcpOptions(request *ec2.DescribeDhcpOptionsInput) (*ec2.DescribeDhcpOptionsOutput, error) {
m.mutex.Lock()
defer m.mutex.Unlock()
glog.Infof("DescribeDhcpOptions: %v", request)
if request.DryRun != nil {

6
cloudmock/aws/mockec2/tags.go
View File

@ -41,6 +41,9 @@ func (m *MockEC2) CreateTagsWithContext(aws.Context, *ec2.CreateTagsInput, ...re
}
func (m *MockEC2) CreateTags(request *ec2.CreateTagsInput) (*ec2.CreateTagsOutput, error) {
m.mutex.Lock()
defer m.mutex.Unlock()
glog.Infof("CreateTags %v", request)
for _, v := range request.Resources {
@ -156,6 +159,9 @@ func (m *MockEC2) getTags(resourceType string, resourceId string) []*ec2.Tag {
}
func (m *MockEC2) DescribeTags(request *ec2.DescribeTagsInput) (*ec2.DescribeTagsOutput, error) {
m.mutex.Lock()
defer m.mutex.Unlock()
glog.Infof("DescribeTags %v", request)
var tags []*ec2.TagDescription

3
cloudmock/aws/mockec2/volumes.go
View File

@ -125,6 +125,9 @@ func (m *MockEC2) DescribeVolumesWithContext(aws.Context, *ec2.DescribeVolumesIn
return nil, nil
}
func (m *MockEC2) DescribeVolumes(request *ec2.DescribeVolumesInput) (*ec2.DescribeVolumesOutput, error) {
m.mutex.Lock()
defer m.mutex.Unlock()
glog.Infof("DescribeVolumes: %v", request)
if request.VolumeIds != nil {