 +            return 'root'
 +
 +def get_ceph_group():
++    global CEPH_PREF_GROUP
++
 +    if CEPH_PREF_GROUP != None:
 +        try:
 +            grp.getgrnam(CEPH_PREF_GROUP)

 
 ###### lock ########
 
@@ -841,12 +845,34 @@
     return osd_id
 
 def get_ceph_user():

 
 def path_set_context(path):
     # restore selinux context to default policy values
@@ -1947,7 +1977,7 @@
             '--osd-uuid', fsid,
             '--keyring', os.path.join(path, 'keyring'),
             '--setuser', get_ceph_user(),
