mirrors/ceph-csi
1
0
Fork 0
mirror of https://github.com/ceph/ceph-csi.git synced 2024-11-17 20:00:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

cleanup: use errors.As() in journal.Connection methods

Browse Source 
See-also: https://github.com/golang/go/wiki/ErrorValueFAQ#how-should-i-change-my-error-handling-code-to-work-with-the-new-features
Signed-off-by: Niels de Vos <ndevos@redhat.com>
This commit is contained in:
Niels de Vos 2020-06-25 10:35:19 +02:00 committed by mergify[bot]
parent ad04e0d8c4
commit 91ade42a32
1 changed files with 22 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
internal/journal/voljournal.go
View File

@ -281,13 +281,14 @@ func (conn *Connection) CheckReservation(ctx context.Context,
values, err := getOMapValues(
ctx, conn, journalPool, cj.namespace, cj.csiDirectory,
cj.commonPrefix, fetchKeys)
switch err.(type) {
case nil:
case util.ErrKeyNotFound, util.ErrPoolNotFound:
// pool or omap (oid) was not present
// stop processing but without an error for no reservation exists
return nil, nil
default:
if err != nil {
var eknf util.ErrKeyNotFound
var epnf util.ErrPoolNotFound
if errors.As(err, &eknf) || errors.As(err, &epnf) {
// pool or omap (oid) was not present
// stop processing but without an error for no reservation exists
return nil, nil
}
return nil, err
}
objUUIDAndPool, found := values[cj.csiNameKeyPrefix+reqName]
@ -315,7 +316,8 @@ func (conn *Connection) CheckReservation(ctx context.Context,
savedImagePool, err = util.GetPoolName(conn.monitors, conn.cr, savedImagePoolID)
if err != nil {
if _, ok := err.(util.ErrPoolNotFound); ok {
var epnf util.ErrPoolNotFound
if errors.As(err, &epnf) {
err = conn.UndoReservation(ctx, journalPool, "", "", reqName)
}
return nil, err
@ -327,7 +329,8 @@ func (conn *Connection) CheckReservation(ctx context.Context,
if err != nil {
// error should specifically be not found, for image to be absent, any other error
// is not conclusive, and we should not proceed
if _, ok := err.(util.ErrKeyNotFound); ok {
var eknf util.ErrKeyNotFound
if errors.As(err, &eknf) {
err = conn.UndoReservation(ctx, journalPool, savedImagePool,
cj.GetNameForUUID(namePrefix, objUUID, snapSource), reqName)
}
@ -409,7 +412,8 @@ func (conn *Connection) UndoReservation(ctx context.Context,
err := util.RemoveObject(ctx, conn.monitors, conn.cr, volJournalPool, cj.namespace, cj.cephUUIDDirectoryPrefix+imageUUID)
if err != nil {
if _, ok := err.(util.ErrObjectNotFound); !ok {
var eonf util.ErrObjectNotFound
if !errors.As(err, &eonf) {
klog.Errorf(util.Log(ctx, "failed removing oMap %s (%s)"), cj.cephUUIDDirectoryPrefix+imageUUID, err)
return err
}
@ -441,7 +445,8 @@ func reserveOMapName(ctx context.Context, monitors string, cr *util.Credentials,
err := util.CreateObject(ctx, monitors, cr, pool, namespace, oMapNamePrefix+iterUUID)
if err != nil {
if _, ok := err.(util.ErrObjectExists); ok {
var eoe util.ErrObjectExists
if errors.As(err, &eoe) {
attempt++
// try again with a different uuid, for maxAttempts tries
klog.V(4).Infof(util.Log(ctx, "uuid (%s) conflict detected, retrying (attempt %d of %d)"),
@ -608,12 +613,13 @@ func (conn *Connection) GetImageAttributes(ctx context.Context, pool, objectUUID
values, err := getOMapValues(
ctx, conn, pool, cj.namespace, cj.cephUUIDDirectoryPrefix+objectUUID,
cj.commonPrefix, fetchKeys)
switch err.(type) {
case nil:
case util.ErrPoolNotFound, util.ErrKeyNotFound:
if err != nil {
var eknf util.ErrKeyNotFound
var epnf util.ErrPoolNotFound
if !errors.As(err, &eknf) && !errors.As(err, &epnf) {
return nil, err
}
klog.Warningf(util.Log(ctx, "unable to read omap keys: pool or key missing: %v"), err)
default:
return nil, err
}
var found bool