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

Remove selected IP from backup-volfile-servers list to avoid warning in mount logs.

Browse Source
This commit is contained in:
nagexiucai 2019-06-17 16:36:53 +08:00
parent 8f4cc7d81f
commit 63cb1d65ca
1 changed files with 18 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
pkg/volume/glusterfs/glusterfs.go
View File

@ -371,8 +371,18 @@ func (b *glusterfsMounter) setUpAtInternal(dir string) error {
} }
} }
//Add backup-volfile-servers and auto_unmount options. if (len(addrlist) > 0) && (addrlist[0] != "") {
ip := addrlist[rand.Intn(len(addrlist))]
// Add backup-volfile-servers and auto_unmount options.
// When ip is also in backup-volfile-servers, there will be a warning:
// "gf_remember_backup_volfile_server] 0-glusterfs: failed to set volfile server: File exists".
addr.Delete(ip)
backups := addr.List()
// Avoid an invalid empty backup-volfile-servers option.
if len(backups) > 0 {
options = append(options, "backup-volfile-servers="+dstrings.Join(addrlist[:], ":")) options = append(options, "backup-volfile-servers="+dstrings.Join(addrlist[:], ":"))
}
options = append(options, "auto_unmount") options = append(options, "auto_unmount")
mountOptions := volutil.JoinMountOptions(b.mountOptions, options) mountOptions := volutil.JoinMountOptions(b.mountOptions, options)
@ -381,8 +391,6 @@ func (b *glusterfsMounter) setUpAtInternal(dir string) error {
// will fetch all the servers mentioned in the backup-volfile-servers list. // will fetch all the servers mentioned in the backup-volfile-servers list.
// Refer to backup-volfile-servers @ http://docs.gluster.org/en/latest/Administrator%20Guide/Setting%20Up%20Clients/ // Refer to backup-volfile-servers @ http://docs.gluster.org/en/latest/Administrator%20Guide/Setting%20Up%20Clients/
if (len(addrlist) > 0) && (addrlist[0] != "") {
ip := addrlist[rand.Intn(len(addrlist))]
errs = b.mounter.Mount(ip+":"+b.path, dir, "glusterfs", mountOptions) errs = b.mounter.Mount(ip+":"+b.path, dir, "glusterfs", mountOptions)
if errs == nil { if errs == nil {
klog.Infof("successfully mounted directory %s", dir) klog.Infof("successfully mounted directory %s", dir)