Previously the decoded PaxosServiceMessage would attempt to follow an
uninitialized Connection* and segfault the system.
client = m->get_source_inst();
client_caps = m->get_session()->caps;
}
+ MForward(PaxosServiceMessage *m, MonCaps caps) :
+ Message(MSG_FORWARD), msg(m), client_caps(caps) {
+ client = m->get_source_inst();
+ }
~MForward() {
delete msg;
PaxosServiceMessage *req = (PaxosServiceMessage *)decode_message(q);
dout(10) << " resend to mon" << mon << " tid " << rr->tid << " " << *req << dendl;
- MForward *forward = new MForward(req);
+ MForward *forward = new MForward(req, rr->session->caps);
forward->set_priority(req->get_priority());
messenger->send_message(forward, monmap->get_inst(mon));
}