mirror of
https://github.com/ceph/ceph-csi.git
synced 2024-11-18 04:10:22 +00:00
cleanup: return error type in NodeServer.processEncryptedDevice()
Signed-off-by: Niels de Vos <ndevos@redhat.com>
This commit is contained in:
parent
8019e4d1bc
commit
d6fb8f302d
@ -796,14 +796,14 @@ func (ns *NodeServer) processEncryptedDevice(ctx context.Context, volOptions *rb
|
|||||||
var existingFormat string
|
var existingFormat string
|
||||||
existingFormat, err = diskMounter.GetDiskFormat(devicePath)
|
existingFormat, err = diskMounter.GetDiskFormat(devicePath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return "", fmt.Errorf("failed to get disk format for path %s, error: %v", devicePath, err)
|
return "", fmt.Errorf("failed to get disk format for path %s: %w", devicePath, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
switch existingFormat {
|
switch existingFormat {
|
||||||
case "":
|
case "":
|
||||||
err = encryptDevice(ctx, volOptions, devicePath)
|
err = encryptDevice(ctx, volOptions, devicePath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return "", fmt.Errorf("failed to encrypt rbd image %s: %v", imageSpec, err)
|
return "", fmt.Errorf("failed to encrypt rbd image %s: %w", imageSpec, err)
|
||||||
}
|
}
|
||||||
case "crypt":
|
case "crypt":
|
||||||
util.WarningLog(ctx, "rbd image %s is encrypted, but encryption state was not updated",
|
util.WarningLog(ctx, "rbd image %s is encrypted, but encryption state was not updated",
|
||||||
|
Loading…
Reference in New Issue
Block a user