Lines Matching defs:con
117 ceph_con_send(&monc->con, monc->m_auth);
130 ceph_con_close(&monc->con);
191 ceph_con_open(&monc->con, CEPH_ENTITY_TYPE_MON, monc->cur_mon,
198 ceph_con_keepalive(&monc->con);
212 monc->cur_mon, ceph_pr_addr(&monc->con.peer_addr));
308 ceph_con_send(&monc->con, ceph_msg_get(msg));
574 ceph_con_send(&monc->con, ceph_msg_get(req->request));
635 static struct ceph_msg *get_generic_reply(struct ceph_connection *con,
639 struct ceph_mon_client *monc = con->private;
1003 ceph_con_send(&monc->con, ceph_msg_get(req->request));
1030 if (ceph_con_keepalive_expired(&monc->con,
1038 ceph_con_keepalive(&monc->con);
1044 !(monc->con.peer_features & CEPH_FEATURE_MON_STATEFUL_SUB)) {
1135 ceph_con_init(&monc->con, monc, &mon_con_ops,
1179 * - any work that references our embedded con is finished.
1242 ceph_pr_addr(&monc->con.peer_addr));
1280 static void dispatch(struct ceph_connection *con, struct ceph_msg *msg)
1282 struct ceph_mon_client *monc = con->private;
1329 static struct ceph_msg *mon_alloc_msg(struct ceph_connection *con,
1333 struct ceph_mon_client *monc = con->private;
1346 return get_generic_reply(con, hdr, skip);
1352 return get_generic_reply(con, hdr, skip);
1376 (unsigned int)con->peer_name.type,
1377 le64_to_cpu(con->peer_name.num));
1389 static void mon_fault(struct ceph_connection *con)
1391 struct ceph_mon_client *monc = con->private;
1412 static struct ceph_connection *con_get(struct ceph_connection *con)
1414 return con;
1417 static void con_put(struct ceph_connection *con)