object/ceph: allow delete when ceph cluster is full (#4131)

juicedata · Nov 1, 2023 · 7f73821 · 7f73821
1 parent 35dac2c
commit 7f73821
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/object/ceph.go b/pkg/object/ceph.go
@@ -63,7 +63,11 @@ func (c *ceph) newContext() (*rados.IOContext, error) {
 	case ctx := <-c.free:
 		return ctx, nil
 	default:
-		return c.conn.OpenIOContext(c.name)
+		ctx, err := c.conn.OpenIOContext(c.name)
+		if err == nil {
+			_ = ctx.SetPoolFullTry()
+		}
+		return ctx, err
 	}
 }