Add support for static uid/gid from storage class for dir-mode provisioning

and fix obvious typo while checking gid in ap-mode.

Author: mpatlasov

pkg/driver/provisioner_ap.go

@@ -132,7 +132,7 @@ func (a AccessPointProvisioner) Provision(ctx context.Context, req *csi.CreateVo
 			if err != nil {
 				return nil, status.Errorf(codes.InvalidArgument, "Failed to parse invalid %v: %v", Gid, err)
 			}
-			if uid < 0 {
+			if gid < 0 {
 				return nil, status.Errorf(codes.InvalidArgument, "%v must be greater or equal than 0", Gid)
 			}
 		}

pkg/driver/provisioner_dir.go

@@ -2,6 +2,7 @@ package driver
 
 import (
 	"context"
+	"math"
 	"os"
 	"path"
 	"strconv"
@@ -78,10 +79,38 @@ func (d DirectoryProvisioner) Provision(ctx context.Context, req *csi.CreateVolu
 		}
 	}
 
-	klog.V(5).Infof("Provisioning directory with permissions %s", perms)
+	var uid int64
+	if value, ok := volumeParams[Uid]; ok {
+		uid, err = strconv.ParseInt(value, 10, 64)
+		if err != nil {
+			return nil, status.Errorf(codes.InvalidArgument, "Failed to parse invalid %v: %v", Uid, err)
+		}
+		if uid < 0 {
+			return nil, status.Errorf(codes.InvalidArgument, "%v must be greater or equal than 0", Uid)
+		}
+		if uid > math.MaxInt {
+			return nil, status.Errorf(codes.InvalidArgument, "%v must be lesser than math.MaxInt", Uid)
+		}
+	}
+
+	var gid int64
+	if value, ok := volumeParams[Gid]; ok {
+		gid, err = strconv.ParseInt(value, 10, 64)
+		if err != nil {
+			return nil, status.Errorf(codes.InvalidArgument, "Failed to parse invalid %v: %v", Gid, err)
+		}
+		if gid < 0 {
+			return nil, status.Errorf(codes.InvalidArgument, "%v must be greater or equal than 0", Gid)
+		}
+		if gid > math.MaxInt {
+			return nil, status.Errorf(codes.InvalidArgument, "%v must be lesser than math.MaxInt", Gid)
+		}
+	}
+
+	klog.V(5).Infof("Provisioning directory with permissions %s, uid %d, gid %d", perms, uid, gid)
 
 	provisionedDirectory := path.Join(target, provisionedPath)
-	err = d.osClient.MkDirAllWithPermsNoOwnership(provisionedDirectory, perms)
+	err = d.osClient.MkDirAllWithPerms(provisionedDirectory, perms, int(uid), int(gid))
 	if err != nil {
 		return nil, status.Errorf(codes.Internal, "Could not provision directory: %v", err)
 	}