diff options
| author | Yuval Lifshitz <ylifshit@ibm.com> | 2024-08-15 10:00:20 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-08-15 10:00:20 +0200 |
| commit | cb8d669457b6f7f562c0189200a9be68b2ee3726 (patch) | |
| tree | 67f171f7aaf776ab3b9176cdffeff4c91430fdeb /src/cls | |
| parent | Merge pull request #59219 from yuvalif/wip-yuval-50610 (diff) | |
| parent | test/cls_2pc_queue: prevent list+remove race between consumers (diff) | |
| download | ceph-cb8d669457b6f7f562c0189200a9be68b2ee3726.tar.xz ceph-cb8d669457b6f7f562c0189200a9be68b2ee3726.zip | |
Merge pull request #58911 from yuvalif/wip-yuval-67229
test/cls_2pc_queue: prevent list+remove race between consumers
Reviewed-By: Casey Bodley <cbodley@ibm.com>
Diffstat (limited to 'src/cls')
| -rw-r--r-- | src/cls/2pc_queue/cls_2pc_queue.cc | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/cls/2pc_queue/cls_2pc_queue.cc b/src/cls/2pc_queue/cls_2pc_queue.cc index 759d360b014..6e6b6e02db5 100644 --- a/src/cls/2pc_queue/cls_2pc_queue.cc +++ b/src/cls/2pc_queue/cls_2pc_queue.cc @@ -616,10 +616,10 @@ static int cls_2pc_queue_remove_entries(cls_method_context_t hctx, bufferlist *i list_op.end_marker = rem_2pc_op.end_marker; ret = cls_2pc_queue_count_entries(hctx, list_op, head, rem_2pc_op.entries_to_remove); if (ret < 0) { - CLS_LOG(1, "ERROR: cls_2pc_queue_count_entries: returned: %d", ret); + CLS_LOG(1, "ERROR: cls_2pc_queue_remove_entries: returned: %d", ret); return ret; } - CLS_LOG(10, "INFO: cls_2pc_queue_count_entries: counted: %u", rem_2pc_op.entries_to_remove); + CLS_LOG(10, "INFO: cls_2pc_queue_remove_entries: counted: %u", rem_2pc_op.entries_to_remove); } cls_queue_remove_op rem_op; |