]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
rgw/notifications: cleanup all coroutines after sending the notification 54528/head
authorYuval Lifshitz <ylifshit@redhat.com>
Thu, 16 Nov 2023 15:47:06 +0000 (15:47 +0000)
committerYuval Lifshitz <ylifshit@redhat.com>
Sun, 19 Nov 2023 11:19:16 +0000 (11:19 +0000)
this is fixing a regression from: 6b6592f50b6b81fa13a330bcb91273ba7f25c0c9

Fixes: https://tracker.ceph.com/issues/63580
Signed-off-by: Yuval Lifshitz <ylifshit@redhat.com>
src/rgw/rgw_op.cc

index dc802b4c4528768b0dafadbfa0d5610fb6464994..3accf03e496896286155ab62f17760b53577d6c4 100644 (file)
@@ -7283,7 +7283,6 @@ void RGWDeleteMultiObj::handle_individual_object(const rgw_obj_key& o, optional_
     op_ret = 0;
   }
 
-  send_partial_response(o, del_op->result.delete_marker, del_op->result.version_id, op_ret, formatter_flush_cond);
 
   // send request to notification manager
   int ret = res->publish_commit(this, obj_size, ceph::real_clock::now(), etag, version_id);
@@ -7291,6 +7290,8 @@ void RGWDeleteMultiObj::handle_individual_object(const rgw_obj_key& o, optional_
     ldpp_dout(this, 1) << "ERROR: publishing notification failed, with error: " << ret << dendl;
     // too late to rollback operation, hence op_ret is not set here
   }
+  
+  send_partial_response(o, del_op->result.delete_marker, del_op->result.version_id, op_ret, formatter_flush_cond);
 }
 
 void RGWDeleteMultiObj::execute(optional_yield y)