Lines Matching refs:con
111 ceph_con_send(&monc->con, monc->m_auth); in __send_prepared_auth_request()
124 ceph_con_close(&monc->con); in __close_session()
185 ceph_con_open(&monc->con, CEPH_ENTITY_TYPE_MON, monc->cur_mon, in __open_session()
192 ceph_con_keepalive(&monc->con); in __open_session()
206 monc->cur_mon, ceph_pr_addr(&monc->con.peer_addr.in_addr)); in reopen_session()
295 ceph_con_send(&monc->con, ceph_msg_get(msg)); in __send_subscribe()
560 ceph_con_send(&monc->con, ceph_msg_get(req->request)); in send_generic_request()
621 static struct ceph_msg *get_generic_reply(struct ceph_connection *con, in get_generic_reply() argument
625 struct ceph_mon_client *monc = con->private; in get_generic_reply()
943 ceph_con_send(&monc->con, ceph_msg_get(req->request)); in __resend_generic_request()
964 if (ceph_con_keepalive_expired(&monc->con, in delayed_work()
972 ceph_con_keepalive(&monc->con); in delayed_work()
978 !(monc->con.peer_features & CEPH_FEATURE_MON_STATEFUL_SUB)) { in delayed_work()
1067 ceph_con_init(&monc->con, monc, &mon_con_ops, in ceph_monc_init()
1172 ceph_pr_addr(&monc->con.peer_addr.in_addr)); in handle_auth_reply()
1210 static void dispatch(struct ceph_connection *con, struct ceph_msg *msg) in dispatch() argument
1212 struct ceph_mon_client *monc = con->private; in dispatch()
1262 static struct ceph_msg *mon_alloc_msg(struct ceph_connection *con, in mon_alloc_msg() argument
1266 struct ceph_mon_client *monc = con->private; in mon_alloc_msg()
1279 return get_generic_reply(con, hdr, skip); in mon_alloc_msg()
1285 return get_generic_reply(con, hdr, skip); in mon_alloc_msg()
1309 (unsigned int)con->peer_name.type, in mon_alloc_msg()
1310 le64_to_cpu(con->peer_name.num)); in mon_alloc_msg()
1322 static void mon_fault(struct ceph_connection *con) in mon_fault() argument
1324 struct ceph_mon_client *monc = con->private; in mon_fault()
1345 static struct ceph_connection *con_get(struct ceph_connection *con) in con_get() argument
1347 return con; in con_get()
1350 static void con_put(struct ceph_connection *con) in con_put() argument