Skip to content

Commit 7201cbb

Browse files
committed
Issue #22 - add -v to NFS portion of driver, source formatting
1 parent 3330bad commit 7201cbb

File tree

4 files changed

+22
-15
lines changed

4 files changed

+22
-15
lines changed

netshare/drivers/cifs.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -76,12 +76,12 @@ func (s cifsDriver) Path(r volume.Request) volume.Response {
7676

7777
func (s cifsDriver) Get(r volume.Request) volume.Response {
7878
log.Debugf("Get for %s is at %s", r.Name, mountpoint(s.root, r.Name))
79-
return volume.Response{ Volume: &volume.Volume{Name: r.Name, Mountpoint: mountpoint(s.root, r.Name)}}
79+
return volume.Response{Volume: &volume.Volume{Name: r.Name, Mountpoint: mountpoint(s.root, r.Name)}}
8080
}
8181

8282
func (s cifsDriver) List(r volume.Request) volume.Response {
8383
log.Debugf("List Volumes")
84-
return volume.Response{ Volumes: s.mountm.GetVolumes(s.root) }
84+
return volume.Response{Volumes: s.mountm.GetVolumes(s.root)}
8585
}
8686

8787
func (s cifsDriver) Mount(r volume.Request) volume.Response {

netshare/drivers/efs.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -71,12 +71,12 @@ func (e efsDriver) Path(r volume.Request) volume.Response {
7171

7272
func (s efsDriver) Get(r volume.Request) volume.Response {
7373
log.Debugf("Get for %s is at %s", r.Name, mountpoint(s.root, r.Name))
74-
return volume.Response{ Volume: &volume.Volume{Name: r.Name, Mountpoint: mountpoint(s.root, r.Name)}}
74+
return volume.Response{Volume: &volume.Volume{Name: r.Name, Mountpoint: mountpoint(s.root, r.Name)}}
7575
}
7676

7777
func (s efsDriver) List(r volume.Request) volume.Response {
7878
log.Debugf("List Volumes")
79-
return volume.Response{ Volumes: s.mountm.GetVolumes(s.root) }
79+
return volume.Response{Volumes: s.mountm.GetVolumes(s.root)}
8080
}
8181

8282
func (e efsDriver) Mount(r volume.Request) volume.Response {
@@ -162,4 +162,4 @@ func (e efsDriver) mountVolume(source, dest string) error {
162162
cmd := fmt.Sprintf("mount -t nfs4 %s %s", source, dest)
163163
log.Debugf("exec: %s\n", cmd)
164164
return run(cmd)
165-
}
165+
}

netshare/drivers/mounts.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
package drivers
2+
23
import "github.com/docker/go-plugins-helpers/volume"
34

45
type mount struct {

netshare/drivers/nfs.go

Lines changed: 16 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ import (
1010
)
1111

1212
const (
13-
NfsOptions = "nfsopts"
13+
NfsOptions = "nfsopts"
1414
DefaultNfsV3 = "port=2049,nolock,proto=tcp"
1515
)
1616

@@ -19,14 +19,13 @@ type nfsDriver struct {
1919
version int
2020
mountm *mountManager
2121
m *sync.Mutex
22-
opts map[string]string
22+
opts map[string]string
2323
}
2424

2525
var (
2626
EmptyMap = map[string]string{}
2727
)
2828

29-
3029
func NewNFSDriver(root string, version int, options string) nfsDriver {
3130
d := nfsDriver{
3231
root: root,
@@ -63,12 +62,12 @@ func (n nfsDriver) Path(r volume.Request) volume.Response {
6362

6463
func (s nfsDriver) Get(r volume.Request) volume.Response {
6564
log.Debugf("Get for %s is at %s", r.Name, mountpoint(s.root, r.Name))
66-
return volume.Response{ Volume: &volume.Volume{Name: r.Name, Mountpoint: mountpoint(s.root, r.Name)}}
65+
return volume.Response{Volume: &volume.Volume{Name: r.Name, Mountpoint: mountpoint(s.root, r.Name)}}
6766
}
6867

6968
func (s nfsDriver) List(r volume.Request) volume.Response {
7069
log.Debugf("List Volumes")
71-
return volume.Response{ Volumes: s.mountm.GetVolumes(s.root) }
70+
return volume.Response{Volumes: s.mountm.GetVolumes(s.root)}
7271
}
7372

7473
func (n nfsDriver) Mount(r volume.Request) volume.Response {
@@ -140,31 +139,38 @@ func (n nfsDriver) mountVolume(source, dest string, version int) error {
140139
if val, ok := options[NfsOptions]; ok {
141140
opts = val
142141
}
142+
143+
mountCmd := "mount"
144+
145+
if log.GetLevel() == log.DebugLevel {
146+
mountCmd = mountCmd + " -v"
147+
}
148+
143149
switch version {
144150
case 3:
145151
log.Debugf("Mounting with NFSv3 - src: %s, dest: %s", source, dest)
146152
if len(opts) < 1 {
147153
opts = DefaultNfsV3
148154
}
149-
cmd = fmt.Sprintf("mount -o %s %s %s", opts, source, dest)
155+
cmd = fmt.Sprintf("%s -o %s %s %s", mountCmd, opts, source, dest)
150156
default:
151157
log.Debugf("Mounting with NFSv4 - src: %s, dest: %s", source, dest)
152158
if len(opts) > 0 {
153-
cmd = fmt.Sprintf("mount -t nfs4 -o %s %s %s", opts, source, dest)
159+
cmd = fmt.Sprintf("%s -t nfs4 -o %s %s %s", mountCmd, opts, source, dest)
154160
} else {
155-
cmd = fmt.Sprintf("mount -t nfs4 %s %s", source, dest)
161+
cmd = fmt.Sprintf("%s -t nfs4 %s %s", mountCmd, source, dest)
156162
}
157163
}
158164
log.Debugf("exec: %s\n", cmd)
159165
return run(cmd)
160166
}
161167

162168
func (n nfsDriver) mountOptions(src map[string]string) map[string]string {
163-
if (len(n.opts) == 0 && len(src) == 0) {
169+
if len(n.opts) == 0 && len(src) == 0 {
164170
return EmptyMap
165171
}
166172

167-
dst := map[string]string {}
173+
dst := map[string]string{}
168174
for k, v := range n.opts {
169175
dst[k] = v
170176
}

0 commit comments

Comments
 (0)