Lines Matching defs:con
182 ceph_con_send(&monc->con, monc->m_auth);
195 ceph_con_close(&monc->con);
256 ceph_con_open(&monc->con, CEPH_ENTITY_TYPE_MON, monc->cur_mon,
265 ceph_con_keepalive(&monc->con);
283 monc->cur_mon, ceph_pr_addr(&monc->con.peer_addr));
379 ceph_con_send(&monc->con, ceph_msg_get(msg));
645 ceph_con_send(&monc->con, ceph_msg_get(req->request));
706 static struct ceph_msg *get_generic_reply(struct ceph_connection *con,
710 struct ceph_mon_client *monc = con->private;
1074 ceph_con_send(&monc->con, ceph_msg_get(req->request));
1095 if (ceph_con_keepalive_expired(&monc->con,
1103 ceph_con_keepalive(&monc->con);
1109 !(monc->con.peer_features & CEPH_FEATURE_MON_STATEFUL_SUB)) {
1202 ceph_con_init(&monc->con, monc, &mon_con_ops,
1244 * - any work that references our embedded con is finished.
1299 ceph_pr_addr(&monc->con.peer_addr));
1350 static int mon_get_auth_request(struct ceph_connection *con,
1354 struct ceph_mon_client *monc = con->private;
1369 static int mon_handle_auth_reply_more(struct ceph_connection *con,
1374 struct ceph_mon_client *monc = con->private;
1390 static int mon_handle_auth_done(struct ceph_connection *con,
1395 struct ceph_mon_client *monc = con->private;
1413 static int mon_handle_auth_bad_method(struct ceph_connection *con,
1418 struct ceph_mon_client *monc = con->private;
1435 static void mon_dispatch(struct ceph_connection *con, struct ceph_msg *msg)
1437 struct ceph_mon_client *monc = con->private;
1484 static struct ceph_msg *mon_alloc_msg(struct ceph_connection *con,
1488 struct ceph_mon_client *monc = con->private;
1501 return get_generic_reply(con, hdr, skip);
1507 return get_generic_reply(con, hdr, skip);
1531 (unsigned int)con->peer_name.type,
1532 le64_to_cpu(con->peer_name.num));
1544 static void mon_fault(struct ceph_connection *con)
1546 struct ceph_mon_client *monc = con->private;
1567 static struct ceph_connection *mon_get_con(struct ceph_connection *con)
1569 return con;
1572 static void mon_put_con(struct ceph_connection *con)