void ms_handle_fast_connect(Connection *con) {
lock.Lock();
- lderr(g_ceph_context) << __func__ << con << dendl;
+ lderr(g_ceph_context) << __func__ << " " << con << dendl;
Session *s = static_cast<Session*>(con->get_priv());
if (!s) {
s = new Session(con);
}
bool ms_handle_reset(Connection *con) {
Mutex::Locker l(lock);
- lderr(g_ceph_context) << __func__ << con << dendl;
+ lderr(g_ceph_context) << __func__ << " " << con << dendl;
Session *s = static_cast<Session*>(con->get_priv());
if (s) {
s->con.reset(NULL); // break con <-> session ref cycle
}
void ms_handle_remote_reset(Connection *con) {
Mutex::Locker l(lock);
- lderr(g_ceph_context) << __func__ << con << dendl;
+ lderr(g_ceph_context) << __func__ << " " << con << dendl;
Session *s = static_cast<Session*>(con->get_priv());
if (s) {
s->con.reset(NULL); // break con <-> session ref cycle
}
void ms_handle_fast_connect(Connection *con) {
- lderr(g_ceph_context) << __func__ << con << dendl;
+ lderr(g_ceph_context) << __func__ << " " << con << dendl;
Mutex::Locker l(lock);
conns.insert(con);
}
return true;
}
bool ms_handle_reset(Connection *con) {
- lderr(g_ceph_context) << __func__ << con << dendl;
+ lderr(g_ceph_context) << __func__ << " " << con << dendl;
Mutex::Locker l(lock);
conns.erase(con);
usleep(rand() % 500);
void ms_handle_remote_reset(Connection *con) {
Mutex::Locker l(lock);
conns.erase(con);
- lderr(g_ceph_context) << __func__ << con << dendl;
+ lderr(g_ceph_context) << __func__ << " " << con << dendl;
}
void ms_fast_dispatch(Message *m) {
assert(0);