diff mbox

the messenger to send osd write ack|ondisk

Message ID Pine.LNX.4.64.1109062058240.7748@cobra.newdream.net (mailing list archive)
State New, archived
Headers show

Commit Message

Sage Weil Sept. 7, 2011, 4 a.m. UTC
Ah, nice catch.  This fixes it:

Pushing to master.

Thanks!
sage

--
To unsubscribe from this list: send the line "unsubscribe ceph-devel" in
the body of a message to majordomo@vger.kernel.org
More majordomo info at  http://vger.kernel.org/majordomo-info.html

Comments

Sage Weil Sept. 7, 2011, 5:15 a.m. UTC | #1
On Tue, 6 Sep 2011, Sage Weil wrote:
> Ah, nice catch.  This fixes it:
> 
> diff --git a/src/osd/ReplicatedPG.cc b/src/osd/ReplicatedPG.cc
> index 73b42ac..48ee6bb 100644
> --- a/src/osd/ReplicatedPG.cc
> +++ b/src/osd/ReplicatedPG.cc
> @@ -2817,7 +2817,7 @@ void ReplicatedPG::eval_repop(RepGather *repop)
>           reply = new MOSDOpReply(op, 0, osd->osdmap->get_epoch(), 0);
>         reply->add_flags(CEPH_OSD_FLAG_ACK);
>         dout(10) << " sending ack on " << *repop << " " << reply << dendl;
> -       osd->cluster_messenger->send_message(reply, op->get_connection());
> +       osd->client_messenger->send_message(reply, op->get_connection());
>         repop->sent_ack = true;
>        }
> 
> Pushing to master.

Er, looks like Greg already pushed this fix on Sunday!

sage
--
To unsubscribe from this list: send the line "unsubscribe ceph-devel" in
the body of a message to majordomo@vger.kernel.org
More majordomo info at  http://vger.kernel.org/majordomo-info.html
diff mbox

Patch

diff --git a/src/osd/ReplicatedPG.cc b/src/osd/ReplicatedPG.cc
index 73b42ac..48ee6bb 100644
--- a/src/osd/ReplicatedPG.cc
+++ b/src/osd/ReplicatedPG.cc
@@ -2817,7 +2817,7 @@  void ReplicatedPG::eval_repop(RepGather *repop)
          reply = new MOSDOpReply(op, 0, osd->osdmap->get_epoch(), 0);
        reply->add_flags(CEPH_OSD_FLAG_ACK);
        dout(10) << " sending ack on " << *repop << " " << reply << dendl;
-       osd->cluster_messenger->send_message(reply, op->get_connection());
+       osd->client_messenger->send_message(reply, op->get_connection());
        repop->sent_ack = true;
       }