diff options
| author | Samuel Just <sam.just@inktank.com> | 2013-09-24 12:33:37 -0700 |
|---|---|---|
| committer | Samuel Just <sam.just@inktank.com> | 2013-09-24 12:33:37 -0700 |
| commit | a2512073f62784e3011cf07b835291d316b76b17 (patch) | |
| tree | b6717d1fe8a62c89292c7c05c35d4fb3eb656a41 | |
| parent | 857e20227190845ac1c2d2977f7ee97249b189cb (diff) | |
| download | ceph-a2512073f62784e3011cf07b835291d316b76b17.tar.gz | |
ReplicatedPG: assert build_push_op succeeds on primary
Signed-off-by: Samuel Just <sam.just@inktank.com>
| -rw-r--r-- | src/osd/ReplicatedPG.cc | 14 |
1 files changed, 8 insertions, 6 deletions
diff --git a/src/osd/ReplicatedPG.cc b/src/osd/ReplicatedPG.cc index c831af45a84..7a4ffa897f9 100644 --- a/src/osd/ReplicatedPG.cc +++ b/src/osd/ReplicatedPG.cc @@ -6172,11 +6172,12 @@ void ReplicatedBackend::prep_push( pi.recovery_progress.omap_complete = 0; ObjectRecoveryProgress new_progress; - build_push_op(pi.recovery_info, - pi.recovery_progress, - &new_progress, - pop, - &(pi.stat)); + int r = build_push_op(pi.recovery_info, + pi.recovery_progress, + &new_progress, + pop, + &(pi.stat)); + assert(r == 0); pi.recovery_progress = new_progress; } @@ -6702,10 +6703,11 @@ bool ReplicatedBackend::handle_push_reply(int peer, PushReplyOp &op, PushOp *rep << pi->recovery_progress.data_recovered_to << " of " << pi->recovery_info.copy_subset << dendl; ObjectRecoveryProgress new_progress; - build_push_op( + int r = build_push_op( pi->recovery_info, pi->recovery_progress, &new_progress, reply, &(pi->stat)); + assert(r == 0); pi->recovery_progress = new_progress; return true; } else { |