mirror of
https://github.com/ceph/ceph-csi.git
synced 2024-12-18 02:50:30 +00:00
fscrypt: fsync encrypted dir after setting policy [workaround]
Revert once our google/fscrypt dependency is upgraded to a version that includes https://github.com/google/fscrypt/pull/359 gets accepted Signed-off-by: Marcel Lauhoff <marcel.lauhoff@suse.com>
This commit is contained in:
parent
33c33a8b49
commit
4e38bdac10
@ -111,6 +111,20 @@ func createKeyFuncFromVolumeEncryption(
|
|||||||
return keyFunc, nil
|
return keyFunc, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// fsyncEncryptedDirectory calls sync on dirPath. It is intended to
|
||||||
|
// work around the fscrypt library not syncing the directory it sets a
|
||||||
|
// policy on.
|
||||||
|
// TODO Remove when the fscrypt dependency has https://github.com/google/fscrypt/pull/359
|
||||||
|
func fsyncEncryptedDirectory(dirPath string) error {
|
||||||
|
dir, err := os.Open(dirPath)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
defer dir.Close()
|
||||||
|
|
||||||
|
return dir.Sync()
|
||||||
|
}
|
||||||
|
|
||||||
// unlockExisting tries to unlock an already set up fscrypt directory using keys from Ceph CSI.
|
// unlockExisting tries to unlock an already set up fscrypt directory using keys from Ceph CSI.
|
||||||
func unlockExisting(
|
func unlockExisting(
|
||||||
ctx context.Context,
|
ctx context.Context,
|
||||||
@ -225,6 +239,12 @@ func initializeAndUnlock(
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if err = fsyncEncryptedDirectory(encryptedPath); err != nil {
|
||||||
|
log.ErrorLog(ctx, "fscrypt: fsync encrypted dir - to flush kernel policy to disk failed %v", err)
|
||||||
|
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user