m->set_dispatch_stamp(ceph_clock_now(cct));
for (list<Dispatcher*>::iterator p = dispatchers.begin();
p != dispatchers.end();
- p++)
+ ++p) {
if ((*p)->ms_dispatch(m))
return;
+ }
lsubdout(cct, ms, 0) << "ms_deliver_dispatch: unhandled message " << m << " " << *m << " from "
<< m->get_source_inst() << dendl;
assert(!cct->_conf->ms_die_on_unhandled_msg);
void ms_deliver_handle_connect(Connection *con) {
for (list<Dispatcher*>::iterator p = dispatchers.begin();
p != dispatchers.end();
- p++)
+ ++p)
(*p)->ms_handle_connect(con);
}
void ms_deliver_handle_accept(Connection *con) {
for (list<Dispatcher*>::iterator p = dispatchers.begin();
p != dispatchers.end();
- p++)
+ ++p)
(*p)->ms_handle_accept(con);
}
void ms_deliver_handle_reset(Connection *con) {
for (list<Dispatcher*>::iterator p = dispatchers.begin();
p != dispatchers.end();
- p++)
+ ++p) {
if ((*p)->ms_handle_reset(con))
return;
+ }
}
/**
* Notify each Dispatcher of a Connection which has been "forgotten" about
void ms_deliver_handle_remote_reset(Connection *con) {
for (list<Dispatcher*>::iterator p = dispatchers.begin();
p != dispatchers.end();
- p++)
+ ++p)
(*p)->ms_handle_remote_reset(con);
}
/**
AuthAuthorizer *a = 0;
for (list<Dispatcher*>::iterator p = dispatchers.begin();
p != dispatchers.end();
- p++)
+ ++p) {
if ((*p)->ms_get_authorizer(peer_type, &a, force_new))
return a;
+ }
return NULL;
}
/**
bool& isvalid, CryptoKey& session_key) {
for (list<Dispatcher*>::iterator p = dispatchers.begin();
p != dispatchers.end();
- p++)
+ ++p) {
if ((*p)->ms_verify_authorizer(con, peer_type, protocol, authorizer, authorizer_reply, isvalid, session_key))
return true;
+ }
return false;
}
/**