}
rejoin_scour_survivor_replicas(from, ack);
- mds->send_message(ack, get_connection());
+ mds->send_message(ack, weak->get_connection());
} else {
// done?
assert(rejoin_gather.count(from));
+void MDS::send_message(Message *m, Connection *c) {
+ messenger->send_message(m, c);
+}
void MDS::send_message_mds(Message *m, int mds)
void send_message_client(Message *m, client_t client);
void send_message_client(Message *m, entity_inst_t clientinst);
-
- void send_message(Message *m, Connection *c) {
- messenger->send_message(m, c);
- }
+ void send_message(Message *m, Connection *c);
// start up, shutdown
int init();