github/kubernetes
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Refactor downward API volume to use AtomicWriter

Browse Source
This commit is contained in:
Paul Morie
2016-04-21 17:09:02 -04:00
parent c6157a2356
commit 272066321c
2 changed files with 19 additions and 177 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/volume/downwardapi/downwardapi_test.go
View File

@@ -33,6 +33,8 @@ import (
volumetest "k8s.io/kubernetes/pkg/volume/testing"
)
const downwardAPIDir = "..data"
func formatMap(m map[string]string) (fmtstr string) {
for key, value := range m {
fmtstr += fmt.Sprintf("%v=%q\n", key, value)
@@ -407,7 +409,7 @@ func TestWriteTwiceNoUpdate(t *testing.T) {
// get the link of the link
var currentTarget string
if currentTarget, err = os.Readlink(path.Join(volumePath, downwardAPIDir)); err != nil {
t.Errorf(".current should be a link... %s\n", err.Error())
t.Errorf(".data should be a link... %s\n", err.Error())
}
err = mounter.SetUp(nil) // now re-run Setup
@@ -418,7 +420,7 @@ func TestWriteTwiceNoUpdate(t *testing.T) {
// get the link of the link
var currentTarget2 string
if currentTarget2, err = os.Readlink(path.Join(volumePath, downwardAPIDir)); err != nil {
t.Errorf(".current should be a link... %s\n", err.Error())
t.Errorf(".data should be a link... %s\n", err.Error())
}
if currentTarget2 != currentTarget {