Add namespace extended attributes to directory
(cherry picked from commit 75f9bcccbc)
			
			
This commit is contained in:
		
							parent
							
								
									df0026975d
								
							
						
					
					
						commit
						2ad4797674
					
				|  | @ -26,6 +26,7 @@ import ( | ||||||
| 
 | 
 | ||||||
| 	"github.com/golang/glog" | 	"github.com/golang/glog" | ||||||
| 	"github.com/kubernetes-incubator/external-storage/lib/controller" | 	"github.com/kubernetes-incubator/external-storage/lib/controller" | ||||||
|  | 	"github.com/pkg/xattr" | ||||||
| 	"k8s.io/api/core/v1" | 	"k8s.io/api/core/v1" | ||||||
| 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" | 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" | ||||||
| 	"k8s.io/apimachinery/pkg/util/wait" | 	"k8s.io/apimachinery/pkg/util/wait" | ||||||
|  | @ -65,6 +66,10 @@ func (p *nfsProvisioner) Provision(options controller.VolumeOptions) (*v1.Persis | ||||||
| 	if err := os.MkdirAll(fullPath, 0777); err != nil { | 	if err := os.MkdirAll(fullPath, 0777); err != nil { | ||||||
| 		return nil, errors.New("unable to create directory to provision new pv: " + err.Error()) | 		return nil, errors.New("unable to create directory to provision new pv: " + err.Error()) | ||||||
| 	} | 	} | ||||||
|  | 	if err := xattr.Set(fullPath, "namespace", []byte(pvcNamespace)); err != nil { | ||||||
|  | 		return nil, errors.New("unable to set extended attributes on directory to provision new pv: " + err.Error()) | ||||||
|  | 	} | ||||||
|  | 	os.Chmod(fullPath, 0777) | ||||||
| 
 | 
 | ||||||
| 	path := filepath.Join(p.path, pvName) | 	path := filepath.Join(p.path, pvName) | ||||||
| 
 | 
 | ||||||
|  |  | ||||||
		Loading…
	
		Reference in New Issue