Lines Matching refs:con
182 ceph_con_send(&monc->con, monc->m_auth); in __send_prepared_auth_request()
195 ceph_con_close(&monc->con); in __close_session()
256 ceph_con_open(&monc->con, CEPH_ENTITY_TYPE_MON, monc->cur_mon, in __open_session()
265 ceph_con_keepalive(&monc->con); in __open_session()
283 monc->cur_mon, ceph_pr_addr(&monc->con.peer_addr)); in reopen_session()
379 ceph_con_send(&monc->con, ceph_msg_get(msg)); in __send_subscribe()
645 ceph_con_send(&monc->con, ceph_msg_get(req->request)); in send_generic_request()
706 static struct ceph_msg *get_generic_reply(struct ceph_connection *con, in get_generic_reply() argument
710 struct ceph_mon_client *monc = con->private; in get_generic_reply()
1074 ceph_con_send(&monc->con, ceph_msg_get(req->request)); in __resend_generic_request()
1101 if (ceph_con_keepalive_expired(&monc->con, in delayed_work()
1109 ceph_con_keepalive(&monc->con); in delayed_work()
1115 !(monc->con.peer_features & CEPH_FEATURE_MON_STATEFUL_SUB)) { in delayed_work()
1210 ceph_con_init(&monc->con, monc, &mon_con_ops, in ceph_monc_init()
1309 ceph_pr_addr(&monc->con.peer_addr)); in finish_auth()
1360 static int mon_get_auth_request(struct ceph_connection *con, in mon_get_auth_request() argument
1364 struct ceph_mon_client *monc = con->private; in mon_get_auth_request()
1379 static int mon_handle_auth_reply_more(struct ceph_connection *con, in mon_handle_auth_reply_more() argument
1384 struct ceph_mon_client *monc = con->private; in mon_handle_auth_reply_more()
1400 static int mon_handle_auth_done(struct ceph_connection *con, in mon_handle_auth_done() argument
1405 struct ceph_mon_client *monc = con->private; in mon_handle_auth_done()
1423 static int mon_handle_auth_bad_method(struct ceph_connection *con, in mon_handle_auth_bad_method() argument
1428 struct ceph_mon_client *monc = con->private; in mon_handle_auth_bad_method()
1445 static void mon_dispatch(struct ceph_connection *con, struct ceph_msg *msg) in mon_dispatch() argument
1447 struct ceph_mon_client *monc = con->private; in mon_dispatch()
1494 static struct ceph_msg *mon_alloc_msg(struct ceph_connection *con, in mon_alloc_msg() argument
1498 struct ceph_mon_client *monc = con->private; in mon_alloc_msg()
1511 return get_generic_reply(con, hdr, skip); in mon_alloc_msg()
1517 return get_generic_reply(con, hdr, skip); in mon_alloc_msg()
1541 (unsigned int)con->peer_name.type, in mon_alloc_msg()
1542 le64_to_cpu(con->peer_name.num)); in mon_alloc_msg()
1554 static void mon_fault(struct ceph_connection *con) in mon_fault() argument
1556 struct ceph_mon_client *monc = con->private; in mon_fault()
1577 static struct ceph_connection *mon_get_con(struct ceph_connection *con) in mon_get_con() argument
1579 return con; in mon_get_con()
1582 static void mon_put_con(struct ceph_connection *con) in mon_put_con() argument