Skip to content

Commit ef65208

Browse files
committed
Fix use of mount path for efs driver
1 parent 22f77f6 commit ef65208

File tree

1 file changed

+6
-9
lines changed

1 file changed

+6
-9
lines changed

netshare/drivers/efs.go

Lines changed: 6 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -106,30 +106,27 @@ func (e efsDriver) fixSource(r volume.Request) string {
106106
}
107107

108108
v := strings.Split(name, "/")
109+
uri := v[0]
109110
if e.resolve {
110-
uri := fmt.Sprintf(EfsTemplateURI, e.availzone, v[0], e.region)
111+
uri = fmt.Sprintf(EfsTemplateURI, e.availzone, v[0], e.region)
111112
if i, ok := e.dnscache[uri]; ok {
112-
return mountSuffix(i)
113+
uri = i
113114
}
114115

115116
log.Debugf("Attempting to resolve: %s", uri)
116117
if ip, err := e.resolver.Lookup(uri); err == nil {
117118
log.Debugf("Resolved Addresses: %s", ip)
118119
e.dnscache[uri] = ip
119-
return mountSuffix(ip)
120+
uri = ip
120121
} else {
121122
log.Errorf("Error during resolve: %s", err.Error())
122-
return mountSuffix(uri)
123+
uri = uri
123124
}
124125
}
125-
v[0] = v[0] + ":"
126+
v[0] = uri + ":"
126127
return strings.Join(v, "/")
127128
}
128129

129-
func mountSuffix(uri string) string {
130-
return uri + ":/"
131-
}
132-
133130
func (e efsDriver) mountVolume(source, dest string) error {
134131
cmd := fmt.Sprintf("mount -t nfs4 %s %s", source, dest)
135132
log.Debugf("exec: %s\n", cmd)

0 commit comments

Comments
 (0)